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

cehua_wcy

2018-12-22 c1f9d909b0b722a5dd31727d6a13729f3790e90a

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
32
33
34
35
36
37
ó 
µ\c@sïdd
lZdd
l
Z
dd
lZddlmZ
dd
lZddlmZ
dd
lZddl    m
Z

ddlmZ
dd
l Z edƒ
Zde
f
d„ƒYZd    e
jf
d
„ƒYZd„Zd„Zed krëeƒ
nd
S(iÿÿÿÿN(
tmylog(
tsleep(
tThread(
tSingletonObjectsConfig.DBConfigtSendPackDispatchThreadc
Bs#eZ
d„Zd
„Zd„ZRS(cCs tj
|d
dƒ


|
|_dS(NtnameR(Rt__init__t'_SendPackDispatchThread__asyncoreServer(tselftasyncoreServer((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRs

c

Cs4|jj
ƒ
tjr0tjd
|jƒƒ

ndS(Nsend of thread %s!(RtprocessSendQueuetDBConfigtMultiThreadingRtinfotgetName(
R((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytruns
 
    
c

Cs1tj
|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(RtstartRR Rtident(
R((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyR s
 
(t__name__t
__module__RRR(((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRs
        tAsynCoreServercBsžeZ
dd
„
Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z    d    „Z
d
„Zd„Zd„Z d „Zd„Zdd„
Zd„ZRS(iÿÿÿÿcCsktj
j|ƒ

t|ƒ
|_|
|_tjƒ|_t    j    ƒ|_
t    j    ƒ|_t|_ ||_dS(
N(tasyncoret
dispatcherRRt'_AsynCoreServer__sendPackDispatchThreadRtAsynServerClienttAsynServerClientMgrt    clientMgrtQueuet_AsynCoreServer__recvQueuet    sendQueuetFalset_AsynCoreServer__activetMaxClientCnt(RRR ((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyR&s


    



    
c


Cs |jj
ƒS(
N(RtgetClientCnt(
R((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytGetClientCnt3s
cCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(Rtwarning(RtsocktaddrtonClientDisconnectt    recvQueue((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytonAcceptClient6scCs|jj
|
ƒ
S(
N(Rt    getClient(Rt    sessionID((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytFindClientBySessionID>s
c


Cs |jj
ƒS(
N(Rtqsize(
R((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyt sendQueueSizeAs
cCs|jj
|
ƒ

dS(
N(Rtput(Rtpack((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytpushSendDs
c


Cs |jj
ƒS(
s#recv queue item cnt,but no reliable(RR,(
R((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytrecvQueueCntKsc
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(Rt
get_nowaitRtEmptytNone(RR/((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytrecvQueuePopNoWaitOs




c

Cs|jj
ƒ}
|
S(
N(Rtget(RtrecvPack((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytrecvQueuePopWs
c
Csúy|jƒ\}
}Wn=t
jk
rU
}
tjt|ƒ
ƒ

tjtjƒƒ

dSX|jd
kr«|j    ƒ|jkr«tjd|j||
j
ƒfƒ

|
jƒ
dStjd||
j
ƒfƒ

|j |
||j|jƒ}|jj|ƒ

dS(Niÿÿÿÿs:ClientCnt > %d ,close new Client(addr = %s, SocketID = %s)s)connect accepted!addr = %s, SocketID = %s(taccepttsocketterrorRR#tunicodet    tracebackt
format_excR R"tfilenotcloseR R(t#_AsynCoreServer__onClientDisconnectRRt    addClient(RR$R%twhytclient((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyt handle_accept\s





$
#




c

Cstj
d
|jƒ

dS(Ns    %s close!(RR R(
R((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pythandle_closens
cCsJ|jj
|
ƒ
sFtjd
|jjtjƒdd|
jfƒ

ndS(Ns&%s.%s del client failed!sessionID = %sii(    Rt    delClientRtdebugt    __class__RtinspecttstackR*(RRD((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyt__onClientDisconnectqs

#
c
CsX
xQ
|jrS
y|j
jƒ}
Wntjk
r;


d}
n
X|
dkretjratd
ƒ

qqePn|
j    ƒdkrÃ|j
jƒ}x4|D],}tj |
jƒƒ

|j|
jƒƒ

qWqn|j
j|
j    ƒƒ
}|dkr*
tj d|jjtjƒdd|
j    ƒ|
jƒfƒ

qn|j|
jƒƒ

tjƒj|
ƒ

qWdS(Ngü©ñÒMbP?is#%s.%s sessionID = %s ignore pack %si(RRR2RR3R4RRR
tgetSessionIDRt getClientListRRHtoutputStringR0tgetPackDataR)RIRRJRKRtgetPackPooltfree(RR/t
clientListRDtserverClient((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyR
vs.







    



 




#


cCs*tj
d
|
ƒ

t|_|jj|
ƒ
S(s?¸²¸Ç¸¸ÀàµÄͬÃû·½·¨£¬¸¸ÀàÔÚNTϵͳÏ£¬ÏÞÖÆÁËÁ¬½Ó¶ÓÁеÄ×î´óÊýÁ¿Îª5sServer start with backlog = %s(RRHtTruet    acceptingR:tlisten(RtconnectionQueueSize((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRW”s
    
icCs‰t|_
tjr"|jjƒ
n|jtjtj    ƒ
d
|
f}t
jd|j|
fƒ

|j |ƒ

t
jdƒ

|j|ƒ

dS(Nts%s starting at port = %s...sbind ok!start listenning...(RURRRRRt create_socketR:tAF_INETtSOCK_STREAMRR RtbindRW(RtportRXtbindAddr((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRšs    
    




 
 
c

Csp|js dSt
jd
ƒ

t|_tjr_|jjdƒ

x |jjƒr[t    dƒ

q?Wnt
jdƒ

dS(NsStoping server...igš™™™™™¹?sStop server OK!(
RRR RRRRtjointisAliveR
(
R((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytstop¨s
    

 
    
    



(RRRR"R(R+R-R0R1R5R8RERFRAR
RWRRb(((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyR$s                                                      c
Cs*d
dl}
t
jd|
j|ƒ
ƒ

dS(Niÿÿÿÿsbuf = %s(tbinasciiRRHtb2a_hex(tbufRc((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytOnGetMMORPGPacket³s

cCsÔyatj
d
tƒ

tdƒ
}t|_|jƒ
x*tr_tj    dt
ddƒ
tdƒ

q6WWnlt jk
r—


tjdƒ

tjtjƒƒ

n9tk
rÏ
}

tjt|
ƒ
ƒ

tjtjƒƒ

n
XdS(Ns%s.logtDBServergð?i
gš™™™™™¹?s socket error!(Rt    InitMyLogRRRft    OnGetPackRRURtloopRR4R
R:R;R=R>t    ExceptionR<(tServert
e((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyttest·s



    


    



 



t__main__(R:RRtCommonRR=ttimeR
Rt    threadingRtDBCommonRRJt
__import__RRRRRfRnR(((sS.\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyt<module>
s 









