Merge branch 'master' of http://192.168.0.87:10010/r/snxx_server

cehua_hzl

2018-08-22 af4a1f8d277bdb9e5bbd7e388bdc0c8ea901b380

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
ó 
žQPc@sIdd
lmZ
ddd„ƒYZ
dd    d„ƒYZdad„ZdS(
iÿÿÿÿ(
ttimetMergeServerProxyClientc
Bs;eZ
dZd
„Zd„Zd„Zd„Zd„ZRS(icCsC|
|_||_
||_||_d
|_t|_d
|_dS(Ni(t    sessionIDt
clientGUIDtoperatortserverIDt*_MergeServerProxyClient__lastHeartbeatTicktTruetisValidt._MergeServerProxyClient__lastSendHeartbeatTick(tselfRRRR((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt__init__s
    
    
    
        
    c

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

c
Cs4|js t
Stƒ}
|
|j|jkr0t
StS(
N(R    RRR R(R
R((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pytshouldSendHeartbeat!s
    

    


c

Cstƒ|_
dS(
N(RR    (
R
((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pytrefreshSendHeartbeatTick)s
(t__name__t
__module__R RRRRR(((s4.\server\db\PyMongoDataServer\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
((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pyR.s
    
    
cCs|jj
|
ƒ
S(
N(Rtget(R
tguid((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pytfindClientByGUID3s
cCsd
|
|fS(Ns[%s-%s]((R
RR((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pytgetCompoundKey6s
cCsI|
|j|
j
<|
|j|
j<|j|
j|
jƒ}|
|j|<dS(
N(RRRRRRRR(R
tclienttcompoundKey((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt    addClient9s



c    Csî|j|ƒ
}|s;t
|
|||ƒ}|j|ƒ

dS|j}|j|j|jƒ}|
|_||_||_t|_|j||ƒ}|j    j
|ƒ
r±|j    |=n||j    |
<|jj
|ƒ
rÝ|j|=n||j|<dS(
N(RR
RRRRRRRRthas_keyR(    R
RRRRRtoldSessionIDt
compoudKeytnewCompoundKey((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pytupdateClient?s$



 
    
    
    
    
    

 
 
 
cCs"|j|
|ƒ}|j
j|ƒ
S(
N(RRR(R
RRR((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pytfindClientByCompoundKeyWs

cCs|jj
|
ƒ
S(
N(RR(R
R((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pytfindClientBySessionID[s
c


Cs |jj
ƒS(
N(Rtvalues(
R
((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt getClientList^s
(
RRRRRRR$R%R&R((((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pyR-s
                            c
Cstst
ƒantS(
N(t__gMergeProxyClientMgrR(((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pytgetMergeProxyClientMgrcs

N(((RR
RtNoneR)R*(((s4.\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt<module>s#4