hwj35
5 天以前 b8cda3b926e4503224568fc5afefdf73d403911d
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.\\MergeProxyClientMgr.pyt__init__ s                     cCstƒ|_dS(N(RR(R ((s.\\MergeProxyClientMgr.pytrefreshHeartbeatscCs+tƒ}||j|jdkr'tStS(Ni(RRtHeartbeatIntervalRtFalse(R tnow((s.\\MergeProxyClientMgr.pytcheckHeartbeats    cCsG|js tStƒ}|j|kr)tS||j|jkrCtStS(N(R
RRRR(R R((s.\\MergeProxyClientMgr.pytshouldSendHeartbeat!s        cCstƒ|_dS(N(RR
(R ((s.\\MergeProxyClientMgr.pytrefreshSendHeartbeatTick-s(t__name__t
__module__RR R RRR(((s.\\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.\\MergeProxyClientMgr.pyR 2s        cCs|jj|ƒS(N(Rtget(R tguid((s.\\MergeProxyClientMgr.pytfindClientByGUID7scCs|S(N((R R((s.\\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.\\MergeProxyClientMgr.pyt    delClient=s              cCsC||j|j<||j|j<|j|jƒ}||j|<dS(N(RRRRRRR(R R"t compoundKey((s.\\MergeProxyClientMgr.pyt    addClientLsc
Cs3|j|ƒ}|rDtjd|ƒtjd|||fƒtS|jj|ƒr…tjd|ƒtjd|||fƒtS|jj|j    |ƒƒrÌtjd|ƒtjd||fƒtSt
||||ƒ}|j |ƒtjd||||t |jƒt |j ƒt |jƒfƒtS(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 ErrorReportRRthas_keyRRRR%R!RR(R RRRRR"((s.\\MergeProxyClientMgr.pyt updateClientRs(   cCs|j|ƒ}|jj|ƒS(N(RRR(R RR$((s.\\MergeProxyClientMgr.pytfindClientByCompoundKeykscCs|jj|ƒS(N(RR(R R((s.\\MergeProxyClientMgr.pytfindClientBySessionIDoscCs |jjƒS(N(Rtvalues(R ((s.\\MergeProxyClientMgr.pyt getClientListrs( RRR RRR#R%R)R*R+R-(((s.\\MergeProxyClientMgr.pyR1s                                cCststƒantS(N(t__gMergeProxyClientMgrR(((s.\\MergeProxyClientMgr.pytgetMergeProxyClientMgrws (((    R&RtCommonRRRRR.R/(((s.\\MergeProxyClientMgr.pyt<module>s 'D