Changeset: 6953bd6a94a6 for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=6953bd6a94a6
Modified Files:
        clients/Tests/MAL-signatures.stable.out
        clients/Tests/MAL-signatures.stable.out.int128
        clients/Tests/exports.stable.out
Branch: wlcrNov2019
Log Message:

Accept signatures


diffs (186 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
@@ -12063,9 +12063,10 @@ stdout of test 'MAL-signatures` in direc
 [ "wlc",       "drop_user",    "pattern wlc.drop_user(sname:str, 
action:int):void ",   "WLCgeneric;",  "Catalog operation drop_user"   ]
 [ "wlc",       "drop_user",    "pattern wlc.drop_user(sname:str, auth:str, 
action:int):void ", "WLCgeneric;",  "Catalog operation drop_user"   ]
 [ "wlc",       "drop_view",    "pattern wlc.drop_view(sname:str, name:str, 
action:int, ifexists:int):void ",   "WLCgeneric;",  "Catalog operation 
drop_view"   ]
-[ "wlc",       "getmasterbeat",        "pattern 
wlc.getmasterbeat(duration:int):str ", "WLCgetmasterbeat;",    "Maximal delay 
for transaction log flushing"    ]
-[ "wlc",       "getmasterclock",       "pattern wlc.getmasterclock():str ",    
"WLCgetmasterclock;",   "Timestamp of last update transaction"  ]
-[ "wlc",       "getmastertick",        "pattern wlc.getmastertick():lng ",     
"WLCgetmastertick;",    "Transaction identifier of the last committed 
transaction"      ]
+[ "wlc",       "flush",        "pattern wlc.flush():void ",    "WLCflush;",    
"Flush current log buffer"      ]
+[ "wlc",       "getbeat",      "pattern wlc.getbeat(duration:int):str ",       
"WLCgetbeat;",  "Maximal delay for transaction log flushing"    ]
+[ "wlc",       "getclock",     "pattern wlc.getclock():str ",  "WLCgetclock;", 
"Timestamp of last update transaction"  ]
+[ "wlc",       "gettick",      "pattern wlc.gettick():lng ",   "WLCgettick;",  
"Transaction identifier of the last committed transaction"      ]
 [ "wlc",       "grant",        "pattern wlc.grant(sname:str, tbl:str, 
grantee:str, privs:int, cname:str, gr:int, grantor:int):void ",  "WLCgeneric;", 
 "Catalog operation grant"       ]
 [ "wlc",       "grant_function",       "pattern wlc.grant_function(sname:str, 
fcnid:int, grantee:str, privs:int, grant:int, grantor:int):void ",       
"WLCgeneric;",  "Catalog operation grant_function"      ]
 [ "wlc",       "grant_roles",  "pattern wlc.grant_roles(sname:str, auth:str, 
grantor:int, admin:int):void ",   "WLCgeneric;",  "Catalog operation 
grant_roles" ]
@@ -12082,14 +12083,15 @@ stdout of test 'MAL-signatures` in direc
 [ "wlc",       "revoke_roles", "pattern wlc.revoke_roles(sname:str, auth:str, 
grantor:int, admin:int):void ",  "WLCgeneric;",  "Catalog operation 
revoke_roles"        ]
 [ "wlc",       "rollback",     "pattern wlc.rollback():void ", 
"WLCcommitCmd;",        "Rollback the workload-capture-replay record"   ]
 [ "wlc",       "rollback",     "pattern wlc.rollback():void ", 
"WLCrollbackCmd;",      "Mark the end of the work unit" ]
-[ "wlc",       "setmasterbeat",        "pattern 
wlc.setmasterbeat(duration:int):void ",        "WLCsetmasterbeat;",    "Maximal 
delay for transaction log flushing"    ]
-[ "wlc",       "stopmaster",   "pattern wlc.stopmaster():void ",       
"WLCstopmaster;",       "Stop capturing the logs"       ]
+[ "wlc",       "setbeat",      "pattern wlc.setbeat(duration:int):void ",      
"WLCsetbeat;",  "Maximal delay for transaction log flushing"    ]
+[ "wlc",       "stop", "pattern wlc.stop():void ",     "WLCstop;",     "Stop 
capturing the logs"       ]
 [ "wlc",       "transaction",  "unsafe pattern wlc.transaction():void ",       
"WLCgeneric;",  "Start an autocommit transaction"       ]
 [ "wlc",       "transaction_begin",    "pattern 
wlc.transaction_begin(chain:int, name:str):void ",     "WLCgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
 [ "wlc",       "transaction_commit",   "pattern 
wlc.transaction_commit(chain:int, name:str):void ",    "WLCgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
 [ "wlc",       "transaction_release",  "pattern 
wlc.transaction_release(chain:int, name:str):void ",   "WLCgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
 [ "wlc",       "transaction_rollback", "pattern 
wlc.transaction_rollback(chain:int, name:str):void ",  "WLCgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
 [ "wlc",       "update",       "pattern wlc.update(sname:str, tname:str, 
cname:str, tid:any, val:any):int ",   "WLCupdate;",   "Keep the update in the 
workload-capture-replay list"   ]
+[ "wlr",       "accept",       "pattern wlr.accept():void ",   "WLRaccept;",   
"Accept failing transaction"    ]
 [ "wlr",       "action",       "pattern wlr.action(q:str):void ",      
"WLRaction;",   "A query producing updates"     ]
 [ "wlr",       "alter_add_range_partition",    "pattern 
wlr.alter_add_range_partition(sname:str, mtnme:str, psnme:str, ptnme:str, 
min:str, max:str, nills:int, update:int):void ",     "WLRgeneric;",  "Catalog 
operation alter_add_range_partition"   ]
 [ "wlr",       "alter_add_table",      "pattern wlr.alter_add_table(sname:str, 
mtnme:str, psnme:str, ptnme:str, action:int):void ",    "WLRgeneric;",  
"Catalog operation alter_add_table"     ]
@@ -12128,28 +12130,28 @@ stdout of test 'MAL-signatures` in direc
 [ "wlr",       "drop_user",    "pattern wlr.drop_user(sname:str, 
action:int):void ",   "WLRgeneric;",  "Catalog operation drop_user"   ]
 [ "wlr",       "drop_user",    "pattern wlr.drop_user(sname:str, auth:str, 
action:int):void ", "WLRgeneric;",  "Catalog operation drop_user"   ]
 [ "wlr",       "drop_view",    "pattern wlr.drop_view(sname:str, name:str, 
action:int, ifexists:int):void ",   "WLRgeneric;",  "Catalog operation 
drop_view"   ]
-[ "wlr",       "getreplicaclock",      "pattern wlr.getreplicaclock():str ",   
"WLRgetreplicaclock;",  "Timestamp of last replicated transaction."     ]
-[ "wlr",       "getreplicatick",       "pattern wlr.getreplicatick():lng ",    
"WLRgetreplicatick;",   "Transaction identifier of the last replicated 
transaction."    ]
+[ "wlr",       "getclock",     "pattern wlr.getclock():str ",  "WLRgetclock;", 
"Timestamp of last replicated transaction."     ]
+[ "wlr",       "gettick",      "pattern wlr.gettick():lng ",   "WLRgettick;",  
"Transaction identifier of the last replicated transaction."    ]
 [ "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",       "master",       "pattern wlr.master(dbname:str):void ", 
"WLRmaster;",   "Initialize the replicator thread"      ]
 [ "wlr",       "rename_column",        "pattern wlr.rename_column(sname:str, 
tname:str, cname:str, newnme:str):void ", "WLRgeneric;",  "Catalog operation 
rename_column"       ]
 [ "wlr",       "rename_schema",        "pattern wlr.rename_schema(sname:str, 
newnme:str):void ",       "WLRgeneric;",  "Catalog operation rename_schema"     
  ]
 [ "wlr",       "rename_table", "pattern wlr.rename_table(osname:str, 
nsname:str, otname:str, ntname:str):void ",       "WLRgeneric;",  "Catalog 
operation rename_table"        ]
 [ "wlr",       "rename_user",  "pattern wlr.rename_user(sname:str, newnme:str, 
action:int):void ",     "WLRgeneric;",  "Catalog operation rename_user" ]
-[ "wlr",       "replicate",    "pattern wlr.replicate():void ",        
"WLRreplicate;",        "Roll the snapshot forward to an up-to-date clone"      
]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str):void ",      
"WLRreplicate;",        "Roll the snapshot forward to an up-to-date clone"      
]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, id:bte):void 
",      "WLRreplicate;",        "Roll the snapshot forward to a specific 
transaction id"        ]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, id:int):void 
",      "WLRreplicate;",        "Roll the snapshot forward to a specific 
transaction id"        ]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, id:lng):void 
",      "WLRreplicate;",        "Roll the snapshot forward to a specific 
transaction id"        ]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, id:sht):void 
",      "WLRreplicate;",        "Roll the snapshot forward to a specific 
transaction id"        ]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, 
ts:timestamp):void ",        "WLRreplicate;",        "Roll the snapshot forward 
to the time TS"      ]
+[ "wlr",       "replicate",    "pattern wlr.replicate():void ",        
"WLRreplicate;",        "Continue to keep the replica in sink"  ]
+[ "wlr",       "replicate",    "pattern wlr.replicate(id:bte):void ",  
"WLRreplicate;",        "Roll the snapshot forward to a specific transaction 
id"        ]
+[ "wlr",       "replicate",    "pattern wlr.replicate(id:int):void ",  
"WLRreplicate;",        "Roll the snapshot forward to a specific transaction 
id"        ]
+[ "wlr",       "replicate",    "pattern wlr.replicate(id:lng):void ",  
"WLRreplicate;",        "Roll the snapshot forward to a specific transaction 
id"        ]
+[ "wlr",       "replicate",    "pattern wlr.replicate(id:sht):void ",  
"WLRreplicate;",        "Roll the snapshot forward to a specific transaction 
id"        ]
 [ "wlr",       "replicate",    "pattern wlr.replicate(ts:timestamp):void ",    
"WLRreplicate;",        "Roll the snapshot forward to an up-to-date clone"      
]
 [ "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"        ]
 [ "wlr",       "rollback",     "pattern wlr.rollback():void ", "WLRrollback;", 
"Mark the end of the work unit" ]
-[ "wlr",       "setreplicabeat",       "pattern 
wlr.setreplicabeat(dur:int):void ",    "WLRsetreplicabeat;",   "Threshold (in 
seconds) for re-running queries" ]
+[ "wlr",       "setbeat",      "pattern wlr.setbeat(dur:int):void ",   
"WLRsetbeat;",  "Threshold (in seconds) for re-running queries" ]
+[ "wlr",       "stop", "pattern wlr.stop():void ",     "WLRstop;",     "Stop 
the replicator thread"    ]
 [ "wlr",       "transaction",  "unsafe pattern wlr.transaction():void ",       
"WLRgeneric;",  "Start an autocommit transaction"       ]
 [ "wlr",       "transaction",  "pattern wlr.transaction(tid:lng, started:str, 
user:str):void ",        "WLRtransaction;",      "Mark the beginning of the 
work unit which can be a compound transaction"       ]
 [ "wlr",       "transaction_begin",    "pattern 
wlr.transaction_begin(chain:int, name:str):void ",     "WLRgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
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
@@ -16483,9 +16483,10 @@ stdout of test 'MAL-signatures` in direc
 [ "wlc",       "drop_user",    "pattern wlc.drop_user(sname:str, 
action:int):void ",   "WLCgeneric;",  "Catalog operation drop_user"   ]
 [ "wlc",       "drop_user",    "pattern wlc.drop_user(sname:str, auth:str, 
action:int):void ", "WLCgeneric;",  "Catalog operation drop_user"   ]
 [ "wlc",       "drop_view",    "pattern wlc.drop_view(sname:str, name:str, 
action:int, ifexists:int):void ",   "WLCgeneric;",  "Catalog operation 
drop_view"   ]
-[ "wlc",       "getmasterbeat",        "pattern 
wlc.getmasterbeat(duration:int):str ", "WLCgetmasterbeat;",    "Maximal delay 
for transaction log flushing"    ]
-[ "wlc",       "getmasterclock",       "pattern wlc.getmasterclock():str ",    
"WLCgetmasterclock;",   "Timestamp of last update transaction"  ]
-[ "wlc",       "getmastertick",        "pattern wlc.getmastertick():lng ",     
"WLCgetmastertick;",    "Transaction identifier of the last committed 
transaction"      ]
+[ "wlc",       "flush",        "pattern wlc.flush():void ",    "WLCflush;",    
"Flush current log buffer"      ]
+[ "wlc",       "getbeat",      "pattern wlc.getbeat(duration:int):str ",       
"WLCgetbeat;",  "Maximal delay for transaction log flushing"    ]
+[ "wlc",       "getclock",     "pattern wlc.getclock():str ",  "WLCgetclock;", 
"Timestamp of last update transaction"  ]
+[ "wlc",       "gettick",      "pattern wlc.gettick():lng ",   "WLCgettick;",  
"Transaction identifier of the last committed transaction"      ]
 [ "wlc",       "grant",        "pattern wlc.grant(sname:str, tbl:str, 
grantee:str, privs:int, cname:str, gr:int, grantor:int):void ",  "WLCgeneric;", 
 "Catalog operation grant"       ]
 [ "wlc",       "grant_function",       "pattern wlc.grant_function(sname:str, 
fcnid:int, grantee:str, privs:int, grant:int, grantor:int):void ",       
"WLCgeneric;",  "Catalog operation grant_function"      ]
 [ "wlc",       "grant_roles",  "pattern wlc.grant_roles(sname:str, auth:str, 
grantor:int, admin:int):void ",   "WLCgeneric;",  "Catalog operation 
grant_roles" ]
@@ -16502,14 +16503,15 @@ stdout of test 'MAL-signatures` in direc
 [ "wlc",       "revoke_roles", "pattern wlc.revoke_roles(sname:str, auth:str, 
grantor:int, admin:int):void ",  "WLCgeneric;",  "Catalog operation 
revoke_roles"        ]
 [ "wlc",       "rollback",     "pattern wlc.rollback():void ", 
"WLCcommitCmd;",        "Rollback the workload-capture-replay record"   ]
 [ "wlc",       "rollback",     "pattern wlc.rollback():void ", 
"WLCrollbackCmd;",      "Mark the end of the work unit" ]
-[ "wlc",       "setmasterbeat",        "pattern 
wlc.setmasterbeat(duration:int):void ",        "WLCsetmasterbeat;",    "Maximal 
delay for transaction log flushing"    ]
-[ "wlc",       "stopmaster",   "pattern wlc.stopmaster():void ",       
"WLCstopmaster;",       "Stop capturing the logs"       ]
+[ "wlc",       "setbeat",      "pattern wlc.setbeat(duration:int):void ",      
"WLCsetbeat;",  "Maximal delay for transaction log flushing"    ]
+[ "wlc",       "stop", "pattern wlc.stop():void ",     "WLCstop;",     "Stop 
capturing the logs"       ]
 [ "wlc",       "transaction",  "unsafe pattern wlc.transaction():void ",       
"WLCgeneric;",  "Start an autocommit transaction"       ]
 [ "wlc",       "transaction_begin",    "pattern 
wlc.transaction_begin(chain:int, name:str):void ",     "WLCgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
 [ "wlc",       "transaction_commit",   "pattern 
wlc.transaction_commit(chain:int, name:str):void ",    "WLCgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
 [ "wlc",       "transaction_release",  "pattern 
wlc.transaction_release(chain:int, name:str):void ",   "WLCgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
 [ "wlc",       "transaction_rollback", "pattern 
wlc.transaction_rollback(chain:int, name:str):void ",  "WLCgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
 [ "wlc",       "update",       "pattern wlc.update(sname:str, tname:str, 
cname:str, tid:any, val:any):int ",   "WLCupdate;",   "Keep the update in the 
workload-capture-replay list"   ]
+[ "wlr",       "accept",       "pattern wlr.accept():void ",   "WLRaccept;",   
"Accept failing transaction"    ]
 [ "wlr",       "action",       "pattern wlr.action(q:str):void ",      
"WLRaction;",   "A query producing updates"     ]
 [ "wlr",       "alter_add_range_partition",    "pattern 
wlr.alter_add_range_partition(sname:str, mtnme:str, psnme:str, ptnme:str, 
min:str, max:str, nills:int, update:int):void ",     "WLRgeneric;",  "Catalog 
operation alter_add_range_partition"   ]
 [ "wlr",       "alter_add_table",      "pattern wlr.alter_add_table(sname:str, 
mtnme:str, psnme:str, ptnme:str, action:int):void ",    "WLRgeneric;",  
"Catalog operation alter_add_table"     ]
@@ -16548,28 +16550,28 @@ stdout of test 'MAL-signatures` in direc
 [ "wlr",       "drop_user",    "pattern wlr.drop_user(sname:str, 
action:int):void ",   "WLRgeneric;",  "Catalog operation drop_user"   ]
 [ "wlr",       "drop_user",    "pattern wlr.drop_user(sname:str, auth:str, 
action:int):void ", "WLRgeneric;",  "Catalog operation drop_user"   ]
 [ "wlr",       "drop_view",    "pattern wlr.drop_view(sname:str, name:str, 
action:int, ifexists:int):void ",   "WLRgeneric;",  "Catalog operation 
drop_view"   ]
-[ "wlr",       "getreplicaclock",      "pattern wlr.getreplicaclock():str ",   
"WLRgetreplicaclock;",  "Timestamp of last replicated transaction."     ]
-[ "wlr",       "getreplicatick",       "pattern wlr.getreplicatick():lng ",    
"WLRgetreplicatick;",   "Transaction identifier of the last replicated 
transaction."    ]
+[ "wlr",       "getclock",     "pattern wlr.getclock():str ",  "WLRgetclock;", 
"Timestamp of last replicated transaction."     ]
+[ "wlr",       "gettick",      "pattern wlr.gettick():lng ",   "WLRgettick;",  
"Transaction identifier of the last replicated transaction."    ]
 [ "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",       "master",       "pattern wlr.master(dbname:str):void ", 
"WLRmaster;",   "Initialize the replicator thread"      ]
 [ "wlr",       "rename_column",        "pattern wlr.rename_column(sname:str, 
tname:str, cname:str, newnme:str):void ", "WLRgeneric;",  "Catalog operation 
rename_column"       ]
 [ "wlr",       "rename_schema",        "pattern wlr.rename_schema(sname:str, 
newnme:str):void ",       "WLRgeneric;",  "Catalog operation rename_schema"     
  ]
 [ "wlr",       "rename_table", "pattern wlr.rename_table(osname:str, 
nsname:str, otname:str, ntname:str):void ",       "WLRgeneric;",  "Catalog 
operation rename_table"        ]
 [ "wlr",       "rename_user",  "pattern wlr.rename_user(sname:str, newnme:str, 
action:int):void ",     "WLRgeneric;",  "Catalog operation rename_user" ]
-[ "wlr",       "replicate",    "pattern wlr.replicate():void ",        
"WLRreplicate;",        "Roll the snapshot forward to an up-to-date clone"      
]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str):void ",      
"WLRreplicate;",        "Roll the snapshot forward to an up-to-date clone"      
]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, id:bte):void 
",      "WLRreplicate;",        "Roll the snapshot forward to a specific 
transaction id"        ]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, id:int):void 
",      "WLRreplicate;",        "Roll the snapshot forward to a specific 
transaction id"        ]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, id:lng):void 
",      "WLRreplicate;",        "Roll the snapshot forward to a specific 
transaction id"        ]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, id:sht):void 
",      "WLRreplicate;",        "Roll the snapshot forward to a specific 
transaction id"        ]
-[ "wlr",       "replicate",    "pattern wlr.replicate(dbname:str, 
ts:timestamp):void ",        "WLRreplicate;",        "Roll the snapshot forward 
to the time TS"      ]
+[ "wlr",       "replicate",    "pattern wlr.replicate():void ",        
"WLRreplicate;",        "Continue to keep the replica in sink"  ]
+[ "wlr",       "replicate",    "pattern wlr.replicate(id:bte):void ",  
"WLRreplicate;",        "Roll the snapshot forward to a specific transaction 
id"        ]
+[ "wlr",       "replicate",    "pattern wlr.replicate(id:int):void ",  
"WLRreplicate;",        "Roll the snapshot forward to a specific transaction 
id"        ]
+[ "wlr",       "replicate",    "pattern wlr.replicate(id:lng):void ",  
"WLRreplicate;",        "Roll the snapshot forward to a specific transaction 
id"        ]
+[ "wlr",       "replicate",    "pattern wlr.replicate(id:sht):void ",  
"WLRreplicate;",        "Roll the snapshot forward to a specific transaction 
id"        ]
 [ "wlr",       "replicate",    "pattern wlr.replicate(ts:timestamp):void ",    
"WLRreplicate;",        "Roll the snapshot forward to an up-to-date clone"      
]
 [ "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"        ]
 [ "wlr",       "rollback",     "pattern wlr.rollback():void ", "WLRrollback;", 
"Mark the end of the work unit" ]
-[ "wlr",       "setreplicabeat",       "pattern 
wlr.setreplicabeat(dur:int):void ",    "WLRsetreplicabeat;",   "Threshold (in 
seconds) for re-running queries" ]
+[ "wlr",       "setbeat",      "pattern wlr.setbeat(dur:int):void ",   
"WLRsetbeat;",  "Threshold (in seconds) for re-running queries" ]
+[ "wlr",       "stop", "pattern wlr.stop():void ",     "WLRstop;",     "Stop 
the replicator thread"    ]
 [ "wlr",       "transaction",  "unsafe pattern wlr.transaction():void ",       
"WLRgeneric;",  "Start an autocommit transaction"       ]
 [ "wlr",       "transaction",  "pattern wlr.transaction(tid:lng, started:str, 
user:str):void ",        "WLRtransaction;",      "Mark the beginning of the 
work unit which can be a compound transaction"       ]
 [ "wlr",       "transaction_begin",    "pattern 
wlr.transaction_begin(chain:int, name:str):void ",     "WLRgeneric;",  "A 
transaction statement (type can be commit,release,rollback or start)"        ]
diff --git a/clients/Tests/exports.stable.out b/clients/Tests/exports.stable.out
--- a/clients/Tests/exports.stable.out
+++ b/clients/Tests/exports.stable.out
@@ -1919,11 +1919,12 @@ str WLCcommit(int clientid);
 str WLCcommitCmd(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 str WLCdelete(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 str WLCfinish(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
+str WLCflush(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 str WLCgeneric(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 str WLCgetConfig(void);
-str WLCgetmasterbeat(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
-str WLCgetmasterclock(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
-str WLCgetmastertick(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
+str WLCgetbeat(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
+str WLCgetclock(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
+str WLCgettick(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 str WLCinit(void);
 str WLCinitCmd(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 str WLCmaster(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
@@ -1932,8 +1933,8 @@ str WLCreadConfig(FILE *fd);
 void WLCreset(void);
 str WLCrollback(int clientid);
 str WLCrollbackCmd(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
-str WLCsetmasterbeat(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
-str WLCstopmaster(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
+str WLCsetbeat(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
+str WLCstop(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 str WLCtransaction(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 str WLCupdate(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
 int WLCused(void);
@@ -2667,6 +2668,7 @@ char wlc_dir[FILENAME_MAX];
 lng wlc_id;
 MT_Lock wlc_lock;
 int wlc_state;
+lng wlc_tag;
 char wlc_write[26];
 str wlrRef;
 str zero_or_oneRef;
_______________________________________________
checkin-list mailing list
[email protected]
https://www.monetdb.org/mailman/listinfo/checkin-list

Reply via email to