5721 跨服BOSS配置

cehua_ZWJ

2019-01-15 ce599d688dda9a3c0c1106ef4a0bcbda0144f13b

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
ó 
"Û!\c@sIdd
lmZ
ddd„ƒYZ
dd    d„ƒYZdad„ZdS(
iÿÿÿÿ(
ttimetMergeServerProxyClientc
Bs;eZ
dZd
„Zd„Zd„Zd„Zd„ZRS(icCs:|
|_||_
||_d
|_t|_d
|_dS(Ni(t    sessionIDt
clientGUIDtgroupIDt*_MergeServerProxyClient__lastHeartbeatTicktTruetisValidt._MergeServerProxyClient__lastSendHeartbeatTick(tselfRRR((s.\MergeProxyClientMgr.pyt__init__s
    
    
        
    c

Cstƒ|_
dS(
N(RR(
R    ((s.\MergeProxyClientMgr.pytrefreshHeartbeats
c
Cs+tƒ}
|
|j
|jd
kr'tStS(Ni(RRtHeartbeatIntervalRtFalse(R    tnow((s.\MergeProxyClientMgr.pytcheckHeartbeats
    

c
CsG|js t
Stƒ}
|j|
kr)t
S|
|j|jkrCt
StS(
N(RRRRR (R    R((s.\MergeProxyClientMgr.pytshouldSendHeartbeat s
    

    


c

Cstƒ|_
dS(
N(RR(
R    ((s.\MergeProxyClientMgr.pytrefreshSendHeartbeatTick,s
(t__name__t
__module__RR
RRRR(((s.\MergeProxyClientMgr.pyR

s

    
            tMergeServerProxyClientMgrc
BsPeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z    RS(c

Csi|_i|_
i|_dS(
N(t*_MergeServerProxyClientMgr__sessionIDIndext+_MergeServerProxyClientMgr__clientGUIDIndext1_MergeServerProxyClientMgr__operatorServerIDIndex(
R    ((s.\MergeProxyClientMgr.pyR
1s
    
    
cCs|jj
|
ƒ
S(
N(Rtget(R    tguid((s.\MergeProxyClientMgr.pytfindClientByGUID6s
c
Cs|
S(
N((R    R((s.\MergeProxyClientMgr.pytgetCompoundKey9s
cCsC|
|j|
j
<|
|j|
j<|j|
jƒ
}|
|j|<dS(
N(RRRRRRR(R    tclienttcompoundKey((s.\MergeProxyClientMgr.pyt    addClient<s



cCsÙ|j|ƒ
}|s8t
|
||ƒ}|j|ƒ

dS|j}|j|jƒ
}|
|_||_t|_|j|ƒ
}|jj    |ƒ
rœ|j|=n||j|
<|j
j    |ƒ
rÈ|j
|=n||j
|<dS(
N(RR
RRRRRRRthas_keyR(R    RRRRtoldSessionIDt
compoudKeytnewCompoundKey((s.\MergeProxyClientMgr.pytupdateClientBs"



 
    
    
    
    

 
 
 
cCs|j|
ƒ
}|j
j|ƒ
S(
N(RRR(R    RR((s.\MergeProxyClientMgr.pytfindClientByCompoundKeyYs

cCs|jj
|
ƒ
S(
N(RR(R    R((s.\MergeProxyClientMgr.pytfindClientBySessionID]s
c


Cs |jj
ƒS(
N(Rtvalues(
R    ((s.\MergeProxyClientMgr.pyt getClientList`s
(
RRR
RRRR#R$R%R'(((s.\MergeProxyClientMgr.pyR0s
                            c
Cstst
ƒantS(
N(t__gMergeProxyClientMgrR(((s.\MergeProxyClientMgr.pytgetMergeProxyClientMgres

N(((RR
RtNoneR(R)(((s.\MergeProxyClientMgr.pyt<module>s&3