Changeset: c44892ed7ec5 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=c44892ed7ec5
Added Files:
sql/test/wlcr/Tests/wlc70.py
sql/test/wlcr/Tests/wlc70.stable.err
sql/test/wlcr/Tests/wlc70.stable.out
sql/test/wlcr/Tests/wlc80.py
sql/test/wlcr/Tests/wlc80.stable.err
sql/test/wlcr/Tests/wlc80.stable.out
sql/test/wlcr/Tests/wlr70.py
sql/test/wlcr/Tests/wlr70.stable.err
sql/test/wlcr/Tests/wlr70.stable.out
sql/test/wlcr/Tests/wlr80.py
sql/test/wlcr/Tests/wlr80.stable.err
sql/test/wlcr/Tests/wlr80.stable.out
Modified Files:
clients/Tests/MAL-signatures.stable.out
clients/Tests/MAL-signatures.stable.out.int128
clients/Tests/SQL-dump.stable.out
clients/Tests/SQL-dump.stable.out.int128
clients/Tests/exports.stable.out
monetdb5/modules/mal/wlcr.c
sql/backends/monet5/sql_wlcr.c
sql/backends/monet5/sql_wlcr.h
sql/backends/monet5/sql_wlcr.mal
sql/scripts/60_wlcr.sql
sql/test/wlcr/Tests/All
sql/test/wlcr/Tests/wlc60.py
sql/test/wlcr/Tests/wlc60.stable.err
sql/test/wlcr/Tests/wlc60.stable.out
sql/test/wlcr/Tests/wlr60.py
Branch: wlcr
Log Message:
Add state control over the log reader
The replica reconstruction can be interrupted
using the function pausereplicate() and
followed by resumereplicate()
The state persists and applies to all clients.
diffs (truncated from 1180 to 300 lines):
diff --git a/clients/Tests/MAL-signatures.stable.out
b/clients/Tests/MAL-signatures.stable.out
--- a/clients/Tests/MAL-signatures.stable.out
+++ b/clients/Tests/MAL-signatures.stable.out
@@ -8739,13 +8739,17 @@ Ready.
[ "wlcr", "logthreshold", "pattern wlcr.logthreshold(limit:int):void ",
"WLClogthreshold;", "Activate the workload-capture-replay. Only queries
surpassing the threshold (in milliseconds) are kept." ]
[ "wlcr", "master", "pattern wlcr.master():void ", "WLCmaster;",
"Activate the workload-capture-replay" ]
[ "wlcr", "master", "pattern wlcr.master(flag:int):void ",
"WLCmaster;", "Activate the workload-capture-replay in a particular
mode.\nStart/Pause/Resume/Stop = 0/1/2/3" ]
+[ "wlcr", "master", "pattern wlcr.master(path:str):void ",
"WLCmaster;", "Activate the workload-capture-replay. Use a different location
for the logs." ]
+[ "wlcr", "pausemaster", "pattern wlcr.pausemaster():void ",
"WLCpausemaster;", "Suspend capturing the logs" ]
[ "wlcr", "query", "pattern wlcr.query(q:str):void ",
"WLCquery;", "Keep the queries for replay." ]
[ "wlcr", "rename_user", "pattern wlcr.rename_user(sname:str,
newnme:str, action:int):void ", "WLCgeneric;", "Catalog operation
rename_user" ]
+[ "wlcr", "resumemaster", "pattern wlcr.resumemaster():void ",
"WLCresumemaster;", "Resume capturing the logs" ]
[ "wlcr", "revoke", "pattern wlcr.revoke(sname:str, tbl:str,
grantee:str, privs:int, cname:str, grant:int, grantor:int):void ",
"WLCgeneric;", "Catalog operation revoke" ]
[ "wlcr", "revoke_function", "pattern
wlcr.revoke_function(sname:str, fcnid:int, grantee:str, privs:int, grant:int,
grantor:int):void ", "WLCgeneric;", "Catalog operation revoke_function"
]
[ "wlcr", "revoke_roles", "pattern wlcr.revoke_roles(sname:str, auth:str,
grantor:int, admin:int):void ", "WLCgeneric;", "Catalog operation
revoke_roles" ]
[ "wlcr", "rollback", "pattern wlcr.rollback():void ",
"WLCcommitCmd;", "Rollback the workload-capture-replay record" ]
[ "wlcr", "rollback", "pattern wlcr.rollback():void ",
"WLCfinish;", "Mark the end of the work unit" ]
+[ "wlcr", "stopmaster", "pattern wlcr.stopmaster():void ",
"WLCstopmaster;", "Stop capturing the logs" ]
[ "wlcr", "transaction", "pattern wlcr.transaction():void ",
"WLCgeneric;", "Start an autocommit transaction" ]
[ "wlcr", "transaction_begin", "pattern
wlcr.transaction_begin(chain:int, name:str):void ", "WLCgeneric;", "A
transaction statement (type can be commit,release,rollback or start)" ]
[ "wlcr", "transaction_commit", "pattern
wlcr.transaction_commit(chain:int, name:str):void ", "WLCgeneric;", "A
transaction statement (type can be commit,release,rollback or start)" ]
@@ -8792,10 +8796,12 @@ Ready.
[ "wlr", "grant", "pattern wlr.grant(sname:str, tbl:str,
grantee:str, privs:int, cname:str, gr:int, grantor:int):void ", "WLRgeneric;",
"Catalog operation grant" ]
[ "wlr", "grant_function", "pattern wlr.grant_function(sname:str,
fcnid:int, grantee:str, privs:int, grant:int, grantor:int):void ",
"WLRgeneric;", "Catalog operation grant_function" ]
[ "wlr", "grant_roles", "pattern wlr.grant_roles(sname:str, auth:str,
grantor:int, admin:int):void ", "WLRgeneric;", "Catalog operation
grant_roles" ]
+[ "wlr", "pausereplicate", "pattern wlr.pausereplicate():void ",
"WLRpausereplicate;", "Suspend replica synchronisation" ]
[ "wlr", "query", "pattern wlr.query(q:str):void ",
"WLRquery;", "The actual query applied" ]
[ "wlr", "rename_user", "pattern wlr.rename_user(sname:str, newnme:str,
action:int):void ", "WLRgeneric;", "Catalog operation rename_user" ]
[ "wlr", "replaythreshold", "pattern
wlr.replaythreshold(dur:int):void ", "WLRreplaythreshold;", "Threshold (in
milliseconds) for re-running queries" ]
[ "wlr", "replicate", "pattern wlr.replicate(dbname:str):void ",
"WLRreplicate;", "Roll the snapshot forward to an up-to-date clone"
]
+[ "wlr", "resumereplicate", "pattern wlr.resumereplicate():void ",
"WLRresumereplicate;", "Resume replica synchronisation" ]
[ "wlr", "revoke", "pattern wlr.revoke(sname:str, tbl:str,
grantee:str, privs:int, cname:str, grant:int, grantor:int):void ",
"WLRgeneric;", "Catalog operation revoke" ]
[ "wlr", "revoke_function", "pattern wlr.revoke_function(sname:str,
fcnid:int, grantee:str, privs:int, grant:int, grantor:int):void ",
"WLRgeneric;", "Catalog operation revoke_function" ]
[ "wlr", "revoke_roles", "pattern wlr.revoke_roles(sname:str, auth:str,
grantor:int, admin:int):void ", "WLRgeneric;", "Catalog operation
revoke_roles" ]
diff --git a/clients/Tests/MAL-signatures.stable.out.int128
b/clients/Tests/MAL-signatures.stable.out.int128
--- a/clients/Tests/MAL-signatures.stable.out.int128
+++ b/clients/Tests/MAL-signatures.stable.out.int128
@@ -11104,13 +11104,17 @@ Ready.
[ "wlcr", "logthreshold", "pattern wlcr.logthreshold(limit:int):void ",
"WLClogthreshold;", "Activate the workload-capture-replay. Only queries
surpassing the threshold (in milliseconds) are kept." ]
[ "wlcr", "master", "pattern wlcr.master():void ", "WLCmaster;",
"Activate the workload-capture-replay" ]
[ "wlcr", "master", "pattern wlcr.master(flag:int):void ",
"WLCmaster;", "Activate the workload-capture-replay in a particular
mode.\nStart/Pause/Resume/Stop = 0/1/2/3" ]
+[ "wlcr", "master", "pattern wlcr.master(path:str):void ",
"WLCmaster;", "Activate the workload-capture-replay. Use a different location
for the logs." ]
+[ "wlcr", "pausemaster", "pattern wlcr.pausemaster():void ",
"WLCpausemaster;", "Suspend capturing the logs" ]
[ "wlcr", "query", "pattern wlcr.query(q:str):void ",
"WLCquery;", "Keep the queries for replay." ]
[ "wlcr", "rename_user", "pattern wlcr.rename_user(sname:str,
newnme:str, action:int):void ", "WLCgeneric;", "Catalog operation
rename_user" ]
+[ "wlcr", "resumemaster", "pattern wlcr.resumemaster():void ",
"WLCresumemaster;", "Resume capturing the logs" ]
[ "wlcr", "revoke", "pattern wlcr.revoke(sname:str, tbl:str,
grantee:str, privs:int, cname:str, grant:int, grantor:int):void ",
"WLCgeneric;", "Catalog operation revoke" ]
[ "wlcr", "revoke_function", "pattern
wlcr.revoke_function(sname:str, fcnid:int, grantee:str, privs:int, grant:int,
grantor:int):void ", "WLCgeneric;", "Catalog operation revoke_function"
]
[ "wlcr", "revoke_roles", "pattern wlcr.revoke_roles(sname:str, auth:str,
grantor:int, admin:int):void ", "WLCgeneric;", "Catalog operation
revoke_roles" ]
[ "wlcr", "rollback", "pattern wlcr.rollback():void ",
"WLCcommitCmd;", "Rollback the workload-capture-replay record" ]
[ "wlcr", "rollback", "pattern wlcr.rollback():void ",
"WLCfinish;", "Mark the end of the work unit" ]
+[ "wlcr", "stopmaster", "pattern wlcr.stopmaster():void ",
"WLCstopmaster;", "Stop capturing the logs" ]
[ "wlcr", "transaction", "pattern wlcr.transaction():void ",
"WLCgeneric;", "Start an autocommit transaction" ]
[ "wlcr", "transaction_begin", "pattern
wlcr.transaction_begin(chain:int, name:str):void ", "WLCgeneric;", "A
transaction statement (type can be commit,release,rollback or start)" ]
[ "wlcr", "transaction_commit", "pattern
wlcr.transaction_commit(chain:int, name:str):void ", "WLCgeneric;", "A
transaction statement (type can be commit,release,rollback or start)" ]
@@ -11157,10 +11161,12 @@ Ready.
[ "wlr", "grant", "pattern wlr.grant(sname:str, tbl:str,
grantee:str, privs:int, cname:str, gr:int, grantor:int):void ", "WLRgeneric;",
"Catalog operation grant" ]
[ "wlr", "grant_function", "pattern wlr.grant_function(sname:str,
fcnid:int, grantee:str, privs:int, grant:int, grantor:int):void ",
"WLRgeneric;", "Catalog operation grant_function" ]
[ "wlr", "grant_roles", "pattern wlr.grant_roles(sname:str, auth:str,
grantor:int, admin:int):void ", "WLRgeneric;", "Catalog operation
grant_roles" ]
+[ "wlr", "pausereplicate", "pattern wlr.pausereplicate():void ",
"WLRpausereplicate;", "Suspend replica synchronisation" ]
[ "wlr", "query", "pattern wlr.query(q:str):void ",
"WLRquery;", "The actual query applied" ]
[ "wlr", "rename_user", "pattern wlr.rename_user(sname:str, newnme:str,
action:int):void ", "WLRgeneric;", "Catalog operation rename_user" ]
[ "wlr", "replaythreshold", "pattern
wlr.replaythreshold(dur:int):void ", "WLRreplaythreshold;", "Threshold (in
milliseconds) for re-running queries" ]
[ "wlr", "replicate", "pattern wlr.replicate(dbname:str):void ",
"WLRreplicate;", "Roll the snapshot forward to an up-to-date clone"
]
+[ "wlr", "resumereplicate", "pattern wlr.resumereplicate():void ",
"WLRresumereplicate;", "Resume replica synchronisation" ]
[ "wlr", "revoke", "pattern wlr.revoke(sname:str, tbl:str,
grantee:str, privs:int, cname:str, grant:int, grantor:int):void ",
"WLRgeneric;", "Catalog operation revoke" ]
[ "wlr", "revoke_function", "pattern wlr.revoke_function(sname:str,
fcnid:int, grantee:str, privs:int, grant:int, grantor:int):void ",
"WLRgeneric;", "Catalog operation revoke_function" ]
[ "wlr", "revoke_roles", "pattern wlr.revoke_roles(sname:str, auth:str,
grantor:int, admin:int):void ", "WLRgeneric;", "Catalog operation
revoke_roles" ]
diff --git a/clients/Tests/SQL-dump.stable.out
b/clients/Tests/SQL-dump.stable.out
--- a/clients/Tests/SQL-dump.stable.out
+++ b/clients/Tests/SQL-dump.stable.out
@@ -233,6 +233,7 @@ Ready.
\dSf sys."optimizers"
\dSf sys."password_hash"
\dSf sys."pause"
+\dSf sys."pausemaster"
\dSf sys."quantile"
\dSf sys."querycache"
\dSf sys."querylog"
@@ -247,6 +248,7 @@ Ready.
\dSf sys."replaythreshold"
\dSf sys."replicate"
\dSf sys."resume"
+\dSf sys."resumemaster"
\dSf sys."reuse"
\dSf sys."reverse"
\dSf sys."right_shift"
@@ -355,6 +357,7 @@ Ready.
\dSf sys."stddev_pop"
\dSf sys."stddev_samp"
\dSf sys."stop"
+\dSf sys."stopmaster"
\dSf sys."storage"
\dSf sys."storagemodel"
\dSf sys."storagemodelinit"
@@ -624,6 +627,7 @@ SYSTEM FUNCTION sys.or
SYSTEM FUNCTION sys.password_hash
SYSTEM FUNCTION sys.patindex
SYSTEM FUNCTION sys.pause
+SYSTEM FUNCTION sys.pausemaster
SYSTEM FUNCTION sys.pi
SYSTEM FUNCTION sys.power
SYSTEM FUNCTION sys.prod
@@ -647,6 +651,7 @@ SYSTEM FUNCTION sys.replaythreshold
SYSTEM FUNCTION sys.replicate
SYSTEM FUNCTION sys.restart
SYSTEM FUNCTION sys.resume
+SYSTEM FUNCTION sys.resumemaster
SYSTEM FUNCTION sys.reuse
SYSTEM FUNCTION sys.reverse
SYSTEM FUNCTION sys.right
@@ -780,6 +785,7 @@ SYSTEM FUNCTION sys.st_z
SYSTEM FUNCTION sys.stddev_pop
SYSTEM FUNCTION sys.stddev_samp
SYSTEM FUNCTION sys.stop
+SYSTEM FUNCTION sys.stopmaster
SYSTEM FUNCTION sys.storage
SYSTEM FUNCTION sys.storagemodel
SYSTEM FUNCTION sys.storagemodelinit
@@ -989,6 +995,7 @@ create procedure logthreshold(duration i
create function sys.malfunctions() returns table("module" string, "function"
string, "signature" string, "address" string, "comment" string) external name
"manual"."functions";
create function "masklen" (p inet) returns int external name inet."masklen";
create procedure master() external name wlcr.master;
+create procedure master(path string) external name wlcr.master;
create procedure master(role integer) external name wlcr.master;
create function mbr(geom geometry) returns mbr external name geom."mbr";
create function sys.md5(v string) returns string external name clients.md5sum;
@@ -1017,6 +1024,7 @@ create function sys.optimizers () return
create function sys.password_hash (username string) returns string external
name sql.password;
create procedure sys.pause(tag int) external name sql.sysmon_pause;
create procedure sys.pause(tag bigint) external name sql.sysmon_pause;
+create procedure pausemaster() external name wlcr.pausemaster;
create aggregate quantile(val tinyint, q double) returns tinyint external name
"aggr"."quantile";
create aggregate quantile(val smallint, q double) returns smallint external
name "aggr"."quantile";
create aggregate quantile(val integer, q double) returns integer external name
"aggr"."quantile";
@@ -1042,6 +1050,7 @@ create procedure replaythreshold(duratio
create procedure replicate(dbname string) external name wlr.replicate;
create procedure sys.resume(tag int) external name sql.sysmon_resume;
create procedure sys.resume(tag bigint) external name sql.sysmon_resume;
+create procedure resumemaster() external name wlcr.resumemaster;
create procedure reuse(sys string, tab string) external name sql.reuse;
create function reverse(src string) returns string external name udf.reverse;
create function "right_shift"(i1 inet, i2 inet) returns boolean external name
inet.">>";
@@ -1194,6 +1203,7 @@ create aggregate stddev_samp(val time) r
create aggregate stddev_samp(val timestamp) returns double external name
"aggr"."stdev";
create procedure sys.stop(tag int) external name sql.sysmon_stop;
create procedure sys.stop(tag bigint) external name sql.sysmon_stop;
+create procedure stopmaster() external name wlcr.stopmaster;
create function sys."storage"() returns table ("schema" string, "table"
string, "column" string, "type" string, "mode" string, location string, "count"
bigint, typewidth int, columnsize bigint, heapsize bigint, hashes bigint, phash
boolean, "imprints" bigint, sorted boolean, revsorted boolean, "unique"
boolean, orderidx bigint) external name sql."storage";
create function sys."storage"(sname string) returns table ("schema" string,
"table" string, "column" string, "type" string, "mode" string, location string,
"count" bigint, typewidth int, columnsize bigint, heapsize bigint, hashes
bigint, phash boolean, "imprints" bigint, sorted boolean, revsorted boolean,
"unique" boolean, orderidx bigint) external name sql."storage";
create function sys."storage"(sname string, tname string) returns table
("schema" string, "table" string, "column" string, "type" string, "mode"
string, location string, "count" bigint, typewidth int, columnsize bigint,
heapsize bigint, hashes bigint, phash boolean, "imprints" bigint, sorted
boolean, revsorted boolean, "unique" boolean, orderidx bigint) external name
sql."storage";
@@ -2153,6 +2163,7 @@ drop function pcre_replace(string, strin
[ "sys", "malfunctions", "create function sys.malfunctions() returns
table(\"module\" string, \"function\" string, \"signature\" string, \"address\"
string, \"comment\" string) external name \"manual\".\"functions\";",
"manual", 1, 5, false, false, false ]
[ "sys", "masklen", "create function \"masklen\" (p inet) returns
int external name inet.\"masklen\";", "inet", 1, 1, false,
false, false ]
[ "sys", "master", "create procedure master() external name
wlcr.master;", "wlcr", 1, 2, true, false, false ]
+[ "sys", "master", "create procedure master(path string) external
name wlcr.master;", "wlcr", 1, 2, true, false, false ]
[ "sys", "master", "create procedure master(role integer) external
name wlcr.master;", "wlcr", 1, 2, true, false, false ]
[ "sys", "max", "max", "aggr", 0, 3, false, false, false
]
[ "sys", "mbr", "create function mbr(geom geometry) returns mbr
external name geom.\"mbr\";", "geom", 1, 1, false, false, false
]
@@ -2254,6 +2265,7 @@ drop function pcre_replace(string, strin
[ "sys", "patindex", "patindex", "pcre", 0, 1, false,
false, false ]
[ "sys", "pause", "create procedure sys.pause(tag bigint)
external name sql.sysmon_pause;", "sql", 1, 2, true, false,
false ]
[ "sys", "pause", "create procedure sys.pause(tag int) external
name sql.sysmon_pause;", "sql", 1, 2, true, false, false ]
+[ "sys", "pausemaster", "create procedure pausemaster() external name
wlcr.pausemaster;", "wlcr", 1, 2, true, false, false ]
[ "sys", "pcre_replace", "create function pcre_replace(origin string,
pat string, repl string, flags string) returns string external name
pcre.replace;", "pcre", 1, 1, false, false, false ]
[ "sys", "pi", "pi", "mmath", 0, 1, false, false,
false ]
[ "sys", "power", "pow", "mmath", 0, 1, false,
false, false ]
@@ -2306,6 +2318,7 @@ drop function pcre_replace(string, strin
[ "sys", "restart", "restart", "sql", 0, 1, false,
false, false ]
[ "sys", "resume", "create procedure sys.resume(tag bigint)
external name sql.sysmon_resume;", "sql", 1, 2, true, false,
false ]
[ "sys", "resume", "create procedure sys.resume(tag int) external
name sql.sysmon_resume;", "sql", 1, 2, true, false, false
]
+[ "sys", "resumemaster", "create procedure resumemaster() external name
wlcr.resumemaster;", "wlcr", 1, 2, true, false, false ]
[ "sys", "reuse", "create procedure reuse(sys string, tab string)
external name sql.reuse;", "sql", 1, 2, true, false, false
]
[ "sys", "reverse", "create function reverse(src string) returns
string external name udf.reverse;", "udf", 1, 1, false,
false, false ]
[ "sys", "right", "stringright", "str", 0, 1, false,
false, false ]
@@ -3252,6 +3265,7 @@ drop function pcre_replace(string, strin
[ "sys", "stddev_samp", "create aggregate stddev_samp(val tinyint)
returns double external name \"aggr\".\"stdev\";", "aggr", 1, 3,
false, false, false ]
[ "sys", "stop", "create procedure sys.stop(tag bigint) external name
sql.sysmon_stop;", "sql", 1, 2, true, false, false ]
[ "sys", "stop", "create procedure sys.stop(tag int) external name
sql.sysmon_stop;", "sql", 1, 2, true, false, false ]
+[ "sys", "stopmaster", "create procedure stopmaster() external name
wlcr.stopmaster;", "wlcr", 1, 2, true, false, false ]
[ "sys", "storage", "create function sys.\"storage\"() returns
table (\"schema\" string, \"table\" string, \"column\" string, \"type\" string,
\"mode\" string, location string, \"count\" bigint, typewidth int, columnsize
bigint, heapsize bigint, hashes bigint, phash boolean, \"imprints\" bigint,
sorted boolean, revsorted boolean, \"unique\" boolean, orderidx bigint)
external name sql.\"storage\";", "sql", 1, 5, false, false,
false ]
[ "sys", "storage", "create function sys.\"storage\"(sname string)
returns table (\"schema\" string, \"table\" string, \"column\" string, \"type\"
string, \"mode\" string, location string, \"count\" bigint, typewidth int,
columnsize bigint, heapsize bigint, hashes bigint, phash boolean, \"imprints\"
bigint, sorted boolean, revsorted boolean, \"unique\" boolean, orderidx bigint)
external name sql.\"storage\";", "sql", 1, 5, false, false,
false ]
[ "sys", "storage", "create function sys.\"storage\"(sname string,
tname string) returns table (\"schema\" string, \"table\" string, \"column\"
string, \"type\" string, \"mode\" string, location string, \"count\" bigint,
typewidth int, columnsize bigint, heapsize bigint, hashes bigint, phash
boolean, \"imprints\" bigint, sorted boolean, revsorted boolean, \"unique\"
boolean, orderidx bigint) external name sql.\"storage\";", "sql", 1, 5,
false, false, false ]
@@ -3711,6 +3725,7 @@ drop function pcre_replace(string, strin
[ "sys", "masklen", "p", "inet", 0, 0, 1, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "master", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "master", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
+[ "sys", "master", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "max", "arg", "any", 0, 0, 1, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "mbr", "geom", "geometry", 0, 0, 1, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "mbr_above", "arg_1", "geometry", 0, 0,
1, "arg_2", "geometry", 0, 0, 1, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL ]
@@ -3811,6 +3826,7 @@ drop function pcre_replace(string, strin
[ "sys", "patindex", "arg_1", "varchar", 0, 0,
1, "arg_2", "varchar", 0, 0, 1, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL ]
[ "sys", "pause", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "pause", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
+[ "sys", "pausemaster", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "pcre_replace", "origin", "clob", 0, 0, 1,
"pat", "clob", 0, 0, 1, "repl", "clob", 0, 0, 1,
"flags", "clob", 0, 0, 1, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL ]
[ "sys", "pi", NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "power", "arg_1", "double", 53, 0,
1, "arg_2", "double", 53, 0, 1, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL ]
@@ -3863,6 +3879,7 @@ drop function pcre_replace(string, strin
[ "sys", "restart", "arg_1", "varchar", 0, 0,
1, "arg_2", "varchar", 0, 0, 1, "arg_3",
"bigint", 64, 0, 1, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL ]
[ "sys", "resume", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "resume", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
+[ "sys", "resumemaster", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "reuse", "tab", "clob", 0, 0, 1, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "reverse", "src", "clob", 0, 0, 1, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "right", "arg_1", "char", 0, 0, 1,
"arg_2", "int", 32, 0, 1, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL ]
@@ -4809,6 +4826,7 @@ drop function pcre_replace(string, strin
[ "sys", "stddev_samp", "val", "tinyint", 8, 0, 1,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL
]
[ "sys", "stop", NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "stop", NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
+[ "sys", "stopmaster", NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL ]
[ "sys", "storage", "table", "clob", 0, 0, 0,
"column", "clob", 0, 0, 0, "type", "clob", 0, 0,
0, "mode", "clob", 0, 0, 0, "location", "clob", 0,
0, 0, "count", "bigint", 64, 0, 0,
"typewidth", "int", 32, 0, 0, "columnsize", "bigint",
64, 0, 0, "heapsize", "bigint", 64, 0, 0,
"hashes", "bigint", 64, 0, 0, "phash",
"boolean", 1, 0, 0, "imprints", "bigint", 64,
0, 0, "sorted", "boolean", 1, 0, 0,
"revsorted", "boolean", 1, 0, 0, "unique",
"boolean", 1, 0, 0 ]
[ "sys", "storage", "table", "clob", 0, 0, 0,
"column", "clob", 0, 0, 0, "type", "clob", 0, 0,
0, "mode", "clob", 0, 0, 0, "location", "clob", 0,
0, 0, "count", "bigint", 64, 0, 0,
"typewidth", "int", 32, 0, 0, "columnsize", "bigint",
64, 0, 0, "heapsize", "bigint", 64, 0, 0,
"hashes", "bigint", 64, 0, 0, "phash",
"boolean", 1, 0, 0, "imprints", "bigint", 64,
0, 0, "sorted", "boolean", 1, 0, 0,
"revsorted", "boolean", 1, 0, 0, "unique",
"boolean", 1, 0, 0 ]
[ "sys", "storage", "table", "clob", 0, 0, 0,
"column", "clob", 0, 0, 0, "type", "clob", 0, 0,
0, "mode", "clob", 0, 0, 0, "location", "clob", 0,
0, 0, "count", "bigint", 64, 0, 0,
"typewidth", "int", 32, 0, 0, "columnsize", "bigint",
64, 0, 0, "heapsize", "bigint", 64, 0, 0,
"hashes", "bigint", 64, 0, 0, "phash",
"boolean", 1, 0, 0, "imprints", "bigint", 64,
0, 0, "sorted", "boolean", 1, 0, 0,
"revsorted", "boolean", 1, 0, 0, "unique",
"boolean", 1, 0, 0 ]
@@ -6129,6 +6147,7 @@ drop function pcre_replace(string, strin
[ "masklen" ]
[ "master" ]
[ "master" ]
+[ "master" ]
[ "max" ]
[ "mbr" ]
[ "mbr_above" ]
@@ -6231,6 +6250,7 @@ drop function pcre_replace(string, strin
[ "patindex" ]
[ "pause" ]
[ "pause" ]
+[ "pausemaster" ]
[ "pi" ]
[ "power" ]
[ "power" ]
@@ -6282,6 +6302,7 @@ drop function pcre_replace(string, strin
[ "restart" ]
[ "resume" ]
[ "resume" ]
+[ "resumemaster" ]
[ "reuse" ]
[ "reverse" ]
[ "reverse_qual" ]
@@ -7239,6 +7260,7 @@ drop function pcre_replace(string, strin
[ "stop" ]
[ "stop" ]
[ "stop" ]
+[ "stopmaster" ]
[ "storage" ]
[ "storage" ]
[ "storage" ]
diff --git a/clients/Tests/SQL-dump.stable.out.int128
b/clients/Tests/SQL-dump.stable.out.int128
--- a/clients/Tests/SQL-dump.stable.out.int128
+++ b/clients/Tests/SQL-dump.stable.out.int128
@@ -229,6 +229,7 @@ Ready.
\dSf sys."optimizers"
\dSf sys."password_hash"
\dSf sys."pause"
+\dSf sys."pausemaster"
\dSf sys."quantile"
\dSf sys."querycache"
\dSf sys."querylog"
@@ -243,6 +244,7 @@ Ready.
\dSf sys."replaythreshold"
\dSf sys."replicate"
\dSf sys."resume"
+\dSf sys."resumemaster"
\dSf sys."reuse"
\dSf sys."reverse"
\dSf sys."right_shift"
@@ -351,6 +353,7 @@ Ready.
\dSf sys."stddev_pop"
\dSf sys."stddev_samp"
\dSf sys."stop"
+\dSf sys."stopmaster"
\dSf sys."storage"
\dSf sys."storagemodel"
\dSf sys."storagemodelinit"
@@ -620,6 +623,7 @@ SYSTEM FUNCTION sys.or
SYSTEM FUNCTION sys.password_hash
SYSTEM FUNCTION sys.patindex
SYSTEM FUNCTION sys.pause
+SYSTEM FUNCTION sys.pausemaster
SYSTEM FUNCTION sys.pi
SYSTEM FUNCTION sys.power
SYSTEM FUNCTION sys.prod
@@ -643,6 +647,7 @@ SYSTEM FUNCTION sys.replaythreshold
SYSTEM FUNCTION sys.replicate
SYSTEM FUNCTION sys.restart
SYSTEM FUNCTION sys.resume
+SYSTEM FUNCTION sys.resumemaster
SYSTEM FUNCTION sys.reuse
SYSTEM FUNCTION sys.reverse
SYSTEM FUNCTION sys.right
@@ -776,6 +781,7 @@ SYSTEM FUNCTION sys.st_z
SYSTEM FUNCTION sys.stddev_pop
SYSTEM FUNCTION sys.stddev_samp
SYSTEM FUNCTION sys.stop
+SYSTEM FUNCTION sys.stopmaster
SYSTEM FUNCTION sys.storage
SYSTEM FUNCTION sys.storagemodel
SYSTEM FUNCTION sys.storagemodelinit
@@ -989,6 +995,7 @@ create procedure logthreshold(duration i
create function sys.malfunctions() returns table("module" string, "function"
string, "signature" string, "address" string, "comment" string) external name
"manual"."functions";
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
https://www.monetdb.org/mailman/listinfo/checkin-list
