Merge branch '1.5.200' of http://192.168.0.87:10010/r/snxx_server into 1.5.200

xdh

2019-02-21 92eee67f85cbd29feb1287ae5a15ad0c787e95cb

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
ó 
¡/\c@sÿdd
lZdd
l
Z
dd
lZddlmZ
dd
lZddlmZ
dd
lZddl    m
Z

ddlmZ
dd
l Z ddlmZ
edƒ
Zde
f
d    „ƒYZd
e
jf
d„ƒYZd„Zd „Zedkrûeƒ
nd
S(iÿÿÿÿN(
tmylog(
tsleep(
tThread(
tSingletonObject(
tCommonDefinesConfig.DBConfigtSendPackDispatchThreadc
Bs#eZ
d„Zd
„Zd„ZRS(cCs tj
|d
dƒ


|
|_dS(NtnameR(Rt__init__t'_SendPackDispatchThread__asyncoreServer(tselftasyncoreServer((s.\\AsyncoreServer.pyRs

c

Cs4|jj
ƒ
tjr0tjd
|jƒƒ

ndS(Nsend of thread %s!(RtprocessSendQueuetDBConfigtMultiThreadingRtinfotgetName(
R    ((s.\\AsyncoreServer.pytruns
 
    
c

Cs1tj
|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(RtstartRRRtident(
R    ((s.\\AsyncoreServer.pyR!s
 
(t__name__t
__module__RRR(((s.\\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(R    RR!((s.\\AsyncoreServer.pyR's


    



    
c


Cs |jj
ƒS(
N(RtgetClientCnt(
R    ((s.\\AsyncoreServer.pytGetClientCnt4s
cCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(Rtwarning(R    tsocktaddrtonClientDisconnectt    recvQueue((s.\\AsyncoreServer.pytonAcceptClient7scCs|jj
|
ƒ
S(
N(Rt    getClient(R    t    sessionID((s.\\AsyncoreServer.pytFindClientBySessionID?s
c


Cs |jj
ƒS(
N(Rtqsize(
R    ((s.\\AsyncoreServer.pyt sendQueueSizeBs
cCs|jj
|
ƒ

dS(
N(Rtput(R    tpack((s.\\AsyncoreServer.pytpushSendEs
c


Cs |jj
ƒS(
s#recv queue item cnt,but no reliable(RR-(
R    ((s.\\AsyncoreServer.pytrecvQueueCntLsc
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(Rt
get_nowaitRtEmptytNone(R    R0((s.\\AsyncoreServer.pytrecvQueuePopNoWaitPs




c

Cs|jj
ƒ}
|
S(
N(Rtget(R    trecvPack((s.\\AsyncoreServer.pytrecvQueuePopXs
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#tfilenotcloseRR)t#_AsynCoreServer__onClientDisconnectRRt    addClient(R    R%R&twhytclient((s.\\AsyncoreServer.pyt handle_accept]s





$
#




c

Cstj
d
|jƒ

dS(Ns    %s close!(RRR(
R    ((s.\\AsyncoreServer.pythandle_closeos
cCsJ|jj
|
ƒ
sFtjd
|jjtjƒdd|
jfƒ

ndS(Ns&%s.%s del client failed!sessionID = %sii(    Rt    delClientRtdebugt    __class__RtinspecttstackR+(R    RE((s.\\AsyncoreServer.pyt__onClientDisconnectrs

#
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(R RR3RR4R5RR R
tgetSessionIDRt getClientListRRItoutputStringR1tgetPackDataR*RJRRKRLRtgetPackPooltfree(R    R0t
clientListREtserverClient((s.\\AsyncoreServer.pyRws.







    



 




#


cCs*tj
d
|
ƒ

t|_|jj|
ƒ
S(s?¸²¸Ç¸¸ÀàµÄͬÃû·½·¨£¬¸¸ÀàÔÚNTϵͳÏ£¬ÏÞÖÆÁËÁ¬½Ó¶ÓÁеÄ×î´óÊýÁ¿Îª5sServer start with backlog = %s(RRItTruet    acceptingR;tlisten(R    tconnectionQueueSize((s.\\AsyncoreServer.pyRX•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...(RVR RR RRt create_socketR;tAF_INETtSOCK_STREAMRRRtbindRX(R    tportRYtbindAddr((s.\\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!(
R RRRRR RtjointisAliveR
(
R    ((s.\\AsyncoreServer.pytstop©s
    

 
    
    



(RRRR#R)R,R.R1R2R6R9RFRGRBRRXRRc(((s.\\AsyncoreServer.pyR%s                                                      c
Cs9tj
ƒr5d
dl}
tjd|
j|ƒ
ƒ

ndS(Niÿÿÿÿsbuf = %s(RtIsDebugtbinasciiRRItb2a_hex(tbufRe((s.\\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    InitMyLogRRRht    OnGetPackRRVRtloopRR5R
R;R<R>R?t    ExceptionR=(tServert
e((s.\\AsyncoreServer.pyttest¹s



    


    



 



t__main__(R;RRtCommonRR>ttimeR
Rt    threadingRtDBCommonRRKRt
__import__RRRRRhRpR(((s.\\AsyncoreServer.pyt<module>
s"










