Skip to content

Commit a3b8298

Browse files
authored
Update wdb.q (#663)
* Update wdb.q Added sync flushing to wdb in case of eodwaittime = 0 * Made changes to sync reloadend based off feedback
1 parent 6f36c3d commit a3b8298

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

code/processes/wdb.q

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -240,7 +240,8 @@ handler:{
240240
/- notify the gateway that we are done
241241
flushend:{
242242
if[not @[value;`.wdb.reloadcomplete;0b];
243-
@[{neg[x]"";neg[x][]};;()] each key reloadsummary;
243+
if[eodwaittime>0;
244+
@[{neg[x]"";neg[x][]};;()] each key reloadsummary];
244245
informgateway(`reloadend;`);
245246
.lg.o[`sort;"end of day sort is now complete"];
246247
reloadcomplete::1b];
@@ -256,8 +257,9 @@ doreload:{[pt]
256257
/-inform gateway of reload start
257258
informgateway(`reloadstart;`);
258259
getprocs[;pt] each reloadorder;
259-
if[eodwaittime>0;
260+
$[eodwaittime>0;
260261
.timer.one[timeouttime::.proc.cp[]+eodwaittime;(value;".wdb.flushend[]");"release all hdbs and rdbs as timer has expired";0b];
262+
.wdb.flushend[]
261263
];
262264
};
263265

0 commit comments

Comments
 (0)