We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6f36c3d commit a3b8298Copy full SHA for a3b8298
1 file changed
code/processes/wdb.q
@@ -240,7 +240,8 @@ handler:{
240
/- notify the gateway that we are done
241
flushend:{
242
if[not @[value;`.wdb.reloadcomplete;0b];
243
- @[{neg[x]"";neg[x][]};;()] each key reloadsummary;
+ if[eodwaittime>0;
244
+ @[{neg[x]"";neg[x][]};;()] each key reloadsummary];
245
informgateway(`reloadend;`);
246
.lg.o[`sort;"end of day sort is now complete"];
247
reloadcomplete::1b];
@@ -256,8 +257,9 @@ doreload:{[pt]
256
257
/-inform gateway of reload start
258
informgateway(`reloadstart;`);
259
getprocs[;pt] each reloadorder;
- if[eodwaittime>0;
260
+ $[eodwaittime>0;
261
.timer.one[timeouttime::.proc.cp[]+eodwaittime;(value;".wdb.flushend[]");"release all hdbs and rdbs as timer has expired";0b];
262
+ .wdb.flushend[]
263
];
264
};
265
0 commit comments