6025 【配置】【1.5.100】开服8-14天累冲修改

cehua-HWJ35

2019-01-23 06171f3a8fac3aae373837b680d8c6bc249fe401

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
ó 
F/\c@sÒdd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
dd
lZddlm    Z    m
Z

dd
lZdd
lZdd
l Z dd
lZedƒ
Zdejf
d„ƒYZdd
d    „ƒYZd
S(iÿÿÿÿN(
tmylog(
tPacketDispatcher(tCommonDefinetStatsConfig.DBConfigtAsynServerClientc
BsYeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
RS(    cCswtj
j||
ƒ
ttjƒƒ
|_||_tjƒ|_    |j
|j    _
||_||_d
|_ t|_dS(Nt(tasyncoret
dispatchert__init__tstrtuuidtuuid4t    sessionIDtaddrR
t!_AsynServerClient__packDispatchertOnGetPackett_AsynServerClient__onCloset_AsynServerClient__recvQueuetsendBuftTruet_AsynServerClient__active(tselftsockR tOnCloset    recvQueue((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyRs


    


    
        
cCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(Rtwarning(Rtbuf((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyR$sc
Cs#
|js dSy«|j
tjƒ
}
t|
ƒ
d
k
rB|jƒ
dStjsitj    ƒj
t|
ƒ
7_
ntjr§tj dt|
ƒ
tj|
ƒ
|jjƒfƒ

n|jj|
ƒ

Wndtk
r

}
tjd|jjƒ|fƒ

tjd|jjƒtjƒfƒ

|jƒ
dSXdS(Nis*recv len = %s data = %s from socketID = %sssocketID = %s error = %sssocketID = %s %s(RtrecvRtMAX_RECVtlentclosetDBConfigtMultiThreadingRtGetStatt    RecvBytest
DUMPPACKETRtdebugtbinasciitb2a_hextsockettfilenoRtonRecvOrginPackett    ExceptionRt    tracebackt
format_exc(RtrecvBuftwhy((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pythandle_read+s"
    





    
    
5

 
&


c

Cst|j
ƒ
d
kS(Ni(RR(
R((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pytwritableEs
c
Cs¤
|jst
|jƒ
d
k
r#dStjri
xq
t
|jƒ
re
y»|j|jƒ
}
|
d
k
ržtjd|jj    ƒt
j|jƒ
fƒ

tj dƒ

w/ntjƒrÔtjd|
t
j|j|
 ƒ
fƒ

n|j|
|_tjd|jƒ

Wq/tjk
ra

}
tjd|jj    ƒ|fƒ

tjd|jj    ƒtjƒfƒ

|jƒ
q/Xq/Wn7|j|jƒ
}
|j|
|_tjƒj|
7_dS(NissocketID = %s send %s failed!g¸…ëQ¸ž?slen = %s data = %s send!sleft data = %sssocketID = %s error = %s!ssocketID = %s %s(RRRRR tsendRRR'R(R%R&ttimetsleepRtIsDebugR$terrorR+R,thandle_closeRR!t    SendBytes(RtsentR.((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyt __processSendHs*


    




,
 


*



 
&


c


Cstj
s|jƒ
ndS(
N(RR t_AsynServerClient__processSend(
R((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pythandle_write`s
    
c

CsW|js dSt
|_tjd
|jjƒƒ

|jrI|j|ƒ

n|jƒ
dS(NssockID = %s closed!(RtFalseRtinfoR'R(RR(
R((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyR6es
    

    

    

cCsy|jj
|
ƒ
}|j|7_t|jƒ
tjkrktjd
t|jƒ
tj|jj    ƒfƒ

n|j
ƒ
dS(Ns;send buf (len = %s) > (MAX_PACK_LEN = %s) via socketID = %s(RtpackDataRRRtMAX_PACK_LENRR5R'R(R:(RRtpackBuf((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pytpushSend|s




2c

Cs(tj
d
|jjƒƒ

|jƒ
dS(NsDisconnect socketID = %s(RR=R'R(R6(
R((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyt
disconnect„s

(t__name__t
__module__RRR/R0R:R;R6RARB(((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyRs
                                tAsynServerClientMgrc
BsGeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„ZRS(c

Cs i|_dS(
N(
t sessionIDDict(
R((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyR‰scCsT|
s
dSt|
t
ƒsdStjd
|
jjƒ|
jfƒ

|
|j|
j<dS(NssocketID = %s sessionID = %s(t
isinstanceRRR$R'R(RRF(Rtclient((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyt    addClients




#
cCsB|jj
|
jƒ
r&|j|
j=tStjd
|
jƒ

tSdS(Nsdel sessionID = %s failed!(RFthas_keyRRRRR<(RRH((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyt    delClient•s


 

c

Cs t|j
ƒ
S(
N(RRF(
R((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pytgetClientCnts
cCs|jj
|
ƒ
S(
N(RFtget(RR((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyt    getClient s
cCs0|jj
ƒ}|
t|ƒ
kr%d
S||
jS(Niÿÿÿÿ(RFtvaluesRR(Rtindext
clientList((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pytgetClientSessionIDByIndex£s



c


Cs |jj
ƒS(
N(RFRO(
R((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyt getClientList©s
(    RCRDRRIRKRLRNRRRS(((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyREˆs
                        ((RR'R+tCommonRtProtocolR
R%tDBCommonRRtQueuetinspectR
R2t
__import__RRRRE(((sU.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsynServerClient.pyt<module>
s










q