cehua_ZWJ
2018-12-24 d95a2df0070d5a17f08a992a473bcba7a6dbc003
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
hÐ\c@sIddlmZddd„ƒYZdd    d„ƒYZdad„ZdS(
iÿÿÿÿ(ttimetMergeServerProxyClientcBs;eZdZd„Zd„Zd„Zd„Zd„ZRS(icCs:||_||_||_d|_t|_d|_dS(Ni(t    sessionIDt
clientGUIDtgroupIDt*_MergeServerProxyClient__lastHeartbeatTicktTruetisValidt._MergeServerProxyClient__lastSendHeartbeatTick(tselfRRR((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pyt__init__ s                     cCstƒ|_dS(N(RR(R    ((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytrefreshHeartbeatscCs+tƒ}||j|jdkr'tStS(Ni(RRtHeartbeatIntervalRtFalse(R    tnow((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytcheckHeartbeats    cCs4|js tStƒ}||j|jkr0tStS(N(RRRR R (R    R((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytshouldSendHeartbeat s         cCstƒ|_dS(N(RR(R    ((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytrefreshSendHeartbeatTick(s(t__name__t
__module__R R
R RRR(((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pyR
s     
            tMergeServerProxyClientMgrcBsPeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z    RS(cCsi|_i|_i|_dS(N(t*_MergeServerProxyClientMgr__sessionIDIndext+_MergeServerProxyClientMgr__clientGUIDIndext1_MergeServerProxyClientMgr__operatorServerIDIndex(R    ((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pyR
-s        cCs|jj|ƒS(N(Rtget(R    tguid((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytfindClientByGUID2scCs|S(N((R    R((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytgetCompoundKey5scCsC||j|j<||j|j<|j|jƒ}||j|<dS(N(RRRRRRR(R    tclientt compoundKey((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pyt    addClient8scCsÙ|j|ƒ}|s8t|||ƒ}|j|ƒdS|j}|j|jƒ}||_||_t|_|j|ƒ}|jj    |ƒrœ|j|=n||j|<|j
j    |ƒrÈ|j
|=n||j
|<dS(N( RRRRRRRRRthas_keyR(R    RRRRt oldSessionIDt
compoudKeytnewCompoundKey((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pyt updateClient>s"                    cCs|j|ƒ}|jj|ƒS(N(RRR(R    RR((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytfindClientByCompoundKeyUscCs|jj|ƒS(N(RR(R    R((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytfindClientBySessionIDYscCs |jjƒS(N(Rtvalues(R    ((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pyt getClientList\s(
RRR
RRRR#R$R%R'(((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pyR,s                            cCststƒantS(N(t__gMergeProxyClientMgrR(((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pytgetMergeProxyClientMgras N(((RRRtNoneR(R)(((sL.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\MergeProxyClientMgr.pyt<module>s"3