Skip to content

Commit e62d73e

Browse files
720-fixes-for-kdb-x (#721)
1 parent 1731fce commit e62d73e

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

code/common/checkinputs.q

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -219,8 +219,8 @@ checkjoin:{[dict;parameter]:checktype[107h;dict;parameter];};
219219

220220
checkpostback:{[dict;parameter]
221221
if[()~dict parameter;:dict];
222-
if[not `sync in key dict;'`$.schema.errors[`asyncpostback;`errormessage]]
223-
if[not dict`sync;'`$.schema.errors[`asyncpostback;`errormessage]]
222+
if[not `sync in key dict;'`$.schema.errors[`asyncpostback;`errormessage]];
223+
if[not dict`sync;'`$.schema.errors[`asyncpostback;`errormessage]];
224224
:checkpostprocessing[dict;parameter]};
225225

226226
checktimeout:{[dict;parameter]

code/processes/gateway.q

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -112,10 +112,10 @@ results:(enlist 0Nj)!enlist(0Ni;(enlist `)!enlist(0Ni;(::);0b))
112112
servers:([serverid:`u#`int$()]handle:`int$(); servertype:`symbol$(); inuse:`boolean$();active:`boolean$();querycount:`int$();lastquery:`timestamp$();usage:`timespan$();attributes:();disconnecttime:`timestamp$())
113113
addserverattr:{[handle;servertype;attributes] `.gw.servers upsert (nextserverid[];handle;servertype;0b;1b;0i;0Np;0D;attributes;0Np)}
114114
addserver:addserverattr[;;()!()]
115-
setserverstate:{[serverh;use]
116-
$[use;
117-
update inuse:use,lastquery:.proc.cp[],querycount+1i from `.gw.servers where handle in serverh;
118-
update inuse:use,usage:usage+.proc.cp[] - lastquery from `.gw.servers where handle in serverh]}
115+
setserverstate:{[serverh;usestate]
116+
$[usestate;
117+
update inuse:usestate,lastquery:.proc.cp[],querycount+1i from `.gw.servers where handle in serverh;
118+
update inuse:usestate,usage:usage+.proc.cp[] - lastquery from `.gw.servers where handle in serverh]}
119119
setderegserverids:{[serverh]
120120
if[@[value;`.finspace.enabled;0b] and @[value;`.finspace.dereginprog;0b];
121121
svrIDs:exec serverid from .gw.servers where not null handle, handle in serverh;

0 commit comments

Comments
 (0)