1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
IxÙfc@seddlZddlmZddlmZdd    d„ƒYZdd
d„ƒYZdad„ZdS( iÿÿÿÿN(ttime(tmylogtMergeServerProxyClientcBs;eZdZd„Zd„Zd„Zd„Zd„ZRS(icCsC||_||_||_||_d|_t|_d|_dS(Ni(t    sessionIDt
clientGUIDtgroupIDtclientIPt*_MergeServerProxyClient__lastHeartbeatTicktTruetisValidt._MergeServerProxyClient__lastSendHeartbeatTick(tselfRRRR((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pyt__init__ s                        cCstƒ|_dS(N(RR(R ((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytrefreshHeartbeatscCs+tƒ}||j|jdkr'tStS(Ni(RRtHeartbeatIntervalRtFalse(R tnow((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytcheckHeartbeats    cCsG|js tStƒ}|j|kr)tS||j|jkrCtStS(N(R
RRRR(R R((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytshouldSendHeartbeat s        cCstƒ|_dS(N(RR
(R ((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytrefreshSendHeartbeatTick,s(t__name__t
__module__RR R RRR(((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\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 ((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pyR 1s        cCs|jj|ƒS(N(Rtget(R tguid((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytfindClientByGUID6scCs|S(N((R R((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytgetCompoundKey9sc
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((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pyt    delClient<s              cCsC||j|j<||j|j<|j|jƒ}||j|<dS(N(RRRRRRR(R R"t compoundKey((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pyt    addClientKsc
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(    s 2024-9-2 ÐÂÔöÁËsessionID¶Ï¿ªÁ´½Óʱͬ²½ delClient
                                Ô­ÏÈsession¶Ï¿ªÊ±£¬Ã»ÓÐɾ³ýÏà¹ØÁª×Ó·þ£¬¿ÉÄܵ¼Ö»ñÈ¡µ½Ò»¸öÒѾ­¶Ï¿ªµÄ²»´æÔÚclient
            OnMergeMsgToClientList °´groupIDÁбí¹ã²¥Ö¸¶¨×Ó·þ·¶Î§ÐÅϢʱ»á¶àÓàÉêÇëÁ˲»´æÔÚ·þÎñÆ÷µÄ·¢ËÍpack£¬µ¼Ö²»ÊͷŶÔÏó³Ø
            
                                Ð޸ĺó£¬Ôö¼ÓÁË delClient Í¬²½É¾³ý¶ÔÓ¦clientÏà¹Ø¶ÔÏó¹ÜÀí£¬¼´Á´½ÓʱÀíÂÛÉÏÒ»¶¨ÊÇÒ»¸öеĠclient£¬Í¬¸ö»ú×Ó¶ÏÏßÖØÁ¬Í¬ÑùÊÓΪеÄclient
                                ¿ÉÄÜ´æÔÚÒÔÏÂÇé¿ö£¬¾ùÊÓΪÒì³£Çé¿ö£¬»á½øÐл㱨Óʼþ¾¯¸æÌáÐÑ
            1. Öظ´µÄclientGUIDÁ´½Ó£¬¼´ÔÚÔ­clientGUIDÒѾ­´æÔÚµÄÇé¿ö£¬ÓÐÖØ¸´µÄclientGUIDÁ´½Ó£¬¿ÉÄÜÊÇÔËά¿½±´Ð»ú×ÓguidûÓÐÖØÐÂÉú³ÉµÄÔ­Òò
            2. Öظ´µÄgroupID£¬Ô­ÒòͬÉÏ£¬¿ÉÄÜgroupIDûÓÐÐÞ¸Ä
            3. Öظ´µÄsessionID
        s'###error merge: addClient clientGUID %ssmerge clientGUID %s, %s, %sNs&###error merge: addClient sessionID %ssmerge sessionID %s, %s, %ss$###error merge: addClient groupID %ssmerge groupID %s, %ss.merge: addClient %s %s %s %s login... %s-%s-%s( RRR tPegasusCollectorProxyt ErrorReportRthas_keyRRRR%R!R(R RRRRR"((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pyt updateClientQs(    cCs|j|ƒ}|jj|ƒS(N(RRR(R RR$((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytfindClientByCompoundKeytscCs|jj|ƒS(N(RR(R R((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytfindClientBySessionIDxscCs |jjƒS(N(Rtvalues(R ((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pyt getClientList{s( RRR RRR#R%R)R*R+R-(((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pyR0s                        #        cCststƒantS(N(t__gMergeProxyClientMgrR(((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pytgetMergeProxyClientMgr€s (((    R&RtCommonRRRRR.R/(((sX.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\MergeProxyClientMgr.pyt<module>s &N