hch
2025-10-14 193a90f580f5ff6870d906e37821f27d350dc08f
1
2
3
4
5
6
7
8
9
10
11
12
13
œÔíhc@seddlZddlmZddlmZdd    d„ƒYZdd
d„ƒYZdad„ZdS( iÿÿÿÿN(ttime(tmylogtMergeServerProxyClientcBs;eZdZd„Zd„Zd„Zd„Zd„ZRS(icCsF||_||_||_||_tƒ|_t|_d|_dS(Ni(    t    sessionIDt
clientGUIDt    groupNametclientIPRt*_MergeServerProxyClient__lastHeartbeatTicktTruetisValidt._MergeServerProxyClient__lastSendHeartbeatTick(tselfRRRR((s&.\\ServersRoute\MergeProxyClientMgr.pyt__init__ s                     cCstƒ|_dS(N(RR(R ((s&.\\ServersRoute\MergeProxyClientMgr.pytrefreshHeartbeatscCs+tƒ}||j|jdkr'tStS(Ni(RRtHeartbeatIntervalRtFalse(R tnow((s&.\\ServersRoute\MergeProxyClientMgr.pytcheckHeartbeats    cCsG|js tStƒ}|j|kr)tS||j|jkrCtStS(N(R
RRRR(R R((s&.\\ServersRoute\MergeProxyClientMgr.pytshouldSendHeartbeat!s        cCstƒ|_dS(N(RR
(R ((s&.\\ServersRoute\MergeProxyClientMgr.pytrefreshSendHeartbeatTick-s(t__name__t
__module__RR R RRR(((s&.\\ServersRoute\MergeProxyClientMgr.pyR
s                   tMergeServerProxyClientMgrcBsYeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
RS(    cCsi|_i|_i|_dS(N(t*_MergeServerProxyClientMgr__sessionIDIndext+_MergeServerProxyClientMgr__clientGUIDIndext1_MergeServerProxyClientMgr__operatorServerIDIndex(R ((s&.\\ServersRoute\MergeProxyClientMgr.pyR 2s        cCs|jj|ƒS(N(Rtget(R tguid((s&.\\ServersRoute\MergeProxyClientMgr.pytfindClientByGUID7scCs|S(N((R R((s&.\\ServersRoute\MergeProxyClientMgr.pytgetCompoundKey:sc
Cs´||jkrdS|jj|ƒ}|j}|j}|j}|jj|dƒ|jj|j|ƒdƒt    j
d||||t |jƒt |jƒt |jƒfƒdS(Ns)merge: delClient %s %s %s %s ... %s-%s-%s( RtpopRRRRtNoneRRRtinfotlen(R RtclientRRR((s&.\\ServersRoute\MergeProxyClientMgr.pyt    delClient=s              cCsC||j|j<||j|j<|j|jƒ}||j|<dS(N(RRRRRRR(R R"t compoundKey((s&.\\ServersRoute\MergeProxyClientMgr.pyt    addClientLsc
Cs3|j|ƒ}|rDtjd|ƒtjd|||fƒdS|jj|ƒr…tjd|ƒtjd|||fƒdS|jj|j|ƒƒrÌtjd|ƒtjd||fƒdSt    ||||ƒ}|j
|ƒtjd||||t |jƒt |j ƒt |jƒfƒdS(Ns'###error merge: addClient clientGUID %ssmerge clientGUID %s, %s, %ss&###error merge: addClient sessionID %ssmerge sessionID %s, %s, %ss&###error merge: addClient groupName %ssmerge groupName %s, %ss.merge: addClient %s %s %s %s login... %s-%s-%s( RRR tPegasusCollectorProxyt ErrorReportRthas_keyRRRR%R!R(R RRRRR"((s&.\\ServersRoute\MergeProxyClientMgr.pyt updateClientRs(   cCs|j|ƒ}|jj|ƒS(N(RRR(R RR$((s&.\\ServersRoute\MergeProxyClientMgr.pytfindClientByCompoundKeykscCs|jj|ƒS(N(RR(R R((s&.\\ServersRoute\MergeProxyClientMgr.pytfindClientBySessionIDoscCs |jjƒS(N(Rtvalues(R ((s&.\\ServersRoute\MergeProxyClientMgr.pyt getClientListrs( RRR RRR#R%R)R*R+R-(((s&.\\ServersRoute\MergeProxyClientMgr.pyR1s                                cCststƒantS(N(t__gMergeProxyClientMgrR(((s&.\\ServersRoute\MergeProxyClientMgr.pytgetMergeProxyClientMgrws (((    R&RtCommonRRRRR.R/(((s&.\\ServersRoute\MergeProxyClientMgr.pyt<module>s 'D