0312 GM命令修复

hch

3 天以前 94a2808b4e2a2ce3b9f6ade33bc52757797cdfa7

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
ó 
‡lic@s*
dd
lm
Z

ddlZddlmZ
ddlmZmZmZm    Z    
ddl
mZmZ
ddl mZmZmZmZ
edƒ
ZddlmZ
ddlZdd    lmZmZ
ddlZddlZddlZdd
lmZ
ddlZej ƒa!de
f
d„ƒYZ"dS( iÿÿÿÿ(
tThreadN(
tsleep(tCommonDefineterrortStattSingletonObject(tCommFunctmylog(t
MMORPGPacktRecvPackProtocoltSendPackProtocoltMergeServerRecvProtocolsConfig.DBConfig(
t MongoDBServer(tProjSpecialProcesstGMToolCommandMgr(
t ServersConfigtLogicProcessThreadc
Bs}eZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
d    „Zd
„Zd„Z d„ZRS( cCsYtj
|d
dƒ


|
|_tjtjtjtjf|_t    j    ƒ|_
t|_dS(NtnameR( Rt__init__t_LogicProcessThread__serverRtlsdDataServerPreparedAsktgstGMToolCommandtgstGMToolCommandResulttgstCrossServerToServerPackt'_LogicProcessThread__processRequestTypetQueuet!_LogicProcessThread__requestQueuetFalset _LogicProcessThread__elegantExit(tselft    serverObj((s.\\LogicProcessThread.pyRs

    



cCsl|
jƒj
tjkr1|
jƒd
kr1tSnd}tj|
jƒ|ƒ\}}||j    krht
StS(Ni
i(tgetPackHeadttypeRtatInnert    getLengthRRtReadBYTEt    getBufferRtTrue(RtpacktposR ((s.\\LogicProcessThread.pyt
canProcess's




cCs|jj
|
ƒ

dS(
N(Rtput(RR&((s.\\LogicProcessThread.pytrequestPush6s
c
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(Rt
get_nowaitRtEmptytNone(RR&((s.\\LogicProcessThread.pytrequestPopNoWait9s





cCsv
d
}tj
|
jƒ|ƒ\}}|tjkrÄtjdƒ

tjƒ}tj    |_
|jj|
j ƒ|
jƒj|
jƒj|
jƒj|
jƒj|
jƒj|jƒƒ
tjdƒ

tS|tjkrþtjdƒ

|j|
ƒ

tjdƒ

tS|tjkr8
tjdƒ

|j|
ƒ

tjdƒ

tS|tjkrr
tjdƒ

|j|
ƒ

tjd    ƒ

tStS(
NisReturn data server prepared!sReturn data server prepared!!!s#onInnerServerPack gstGMToolCommand!s'onInnerServerPack gstGMToolCommand! Ends)onInnerServerPack gstGMToolCommandResult!s-onInnerServerPack gstGMToolCommandResult! Ends3onInnerServerPack gstCrossServerToServerPack start!s1onInnerServerPack gstCrossServerToServerPack end!(RR#R$RRRtdebugR
ttagDataServerInitOKtdgDataServerPrepareOKtTypeRtpackSendBySessionIDtgetSessionIDRt    sessionIDt    poolIndexR t
srcSvrTypet
dstSvrTypet    GetBufferR%RtOnGMToolCommandRtOnGMToolCommandResultRtOnCrossServerToServerPackR(RR&R'R tsendPack((s.\\LogicProcessThread.pytonInnerServerPack@s4



 

*
1
 


 
 
 


 
 
 


 
 
 
c

Cs:t|_
tj|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start...(RRRtstartRtinfotgetNametident(
R((s.\\LogicProcessThread.pyR?^s
    
 
c

CsXtj
d
|jƒƒ

t|_x|jƒr<tdƒ

q#Wtj
d|jƒƒ

dS(NsStopping thread %s...gš™™™™™¹?sThread %s stop ok!(RR@RAR%RtisAliveR
(
R((s.\\LogicProcessThread.pytstopcs


    


c
Cs,
x%
tr'
y•|j
ƒ}
|
dkr(Pntjƒjd
7_|
jƒj}|tj    kr†|j
|
ƒ
r†tjƒj |
ƒ

wq†ntjd|
jƒƒ

Wqtk
rë
}
tjdtjd|tjƒfƒ}tj|ƒ

qq


tjdtjdtjƒƒ}tj|ƒ

qqXqWdS(Ni
spack %s not processed!Rs"Exception %s caught!traceback = %ss'Unknown exception caught!traceback = %s(R%R.R-RtGetStattLogicProcessCountRR RR!R>RtgetPackPooltfreeRtwarningtoutputStringt    ExceptionRt    formatMsgtERROR_NO_28t    tracebackt
format_exc(RR&tpackTypet
etmsg((s.\\LogicProcessThread.pytrunjs(
    







    


(
 


"
 
cCsÎtj
ƒ}|j|
jƒƒ

tj|j|jƒ}tj    |kr”t
|tj    ƒ
|_t|jƒ
|_|j |jƒƒ

|jtj    ƒ

nt|ƒ
d
krªdS|j|
||ƒ
tjdƒ

dS(NiR<(RttagLPStringDatatReadDataR$RtFilterServerListt
ServerListtDirTypetDBConfigt    GroupNametstrtlent    ServerLent sendMapStringR9tpopt!_LogicProcessThread__SendMergeMsgRR/(RR&trecvPacktserverGroupDic((s.\\LogicProcessThread.pyR<„s





 c    
Csí
tj
r{tjr{tjƒ}|s)dSt|ƒ
|_t|jƒ
|_|
j    |j
ƒƒ

|j|
ƒ

tj d
ƒ

dStjƒjdƒ
}|sšdSd|kr»tj|jƒ
}nx
|jƒD]
\}}t|ƒ
|_t|jƒ
|_|tjkr
|j|j
ƒƒ

qÈntjƒj|ƒ
}|sU
tj d||fƒ

qÈnt|ƒ
|_t|jƒ
|_|
j    |j
ƒƒ

|j|j|
jƒj|
jƒjtj|
jƒj |
jƒj!|
j"ƒƒ
qÈWtj dƒ

dS(Nsforward to serversroute HubtMerget    AllServersÏò×Ó·þ%s·¢ËÍÏûϢʧ°Ü %s sforward to serversroute Child(#RYtIsMsgFowardHubtMsgFowardHubIPtServerRouteClienttGetServersRouteChildR[RWR\R]t    setBufferR9tSendPackRR/RtgetServerMgrt    GetServerRtGetAllServerRXt    iteritemsRZR^tMergeProxyClientMgrtgetMergeProxyClientMgrtfindClientByCompoundKeyR3R5RR6RR!R7R8R$(    RR&RaRbtserverRouteClientRt    groupNamet
serverListtclient((s.\\LogicProcessThread.pyt__SendMergeMsg sJ





 
 


















 
cCsÔ
tj
ƒjd
ƒ
}|dkr%dS|jƒdk
r`tjdtjdƒ}tj    |ƒ

dSt
jƒr›ddl}tj d|j|
jƒƒ
ƒ

n|
jƒ}tjƒ}|j|
jƒƒ

tj|j|ƒtkrådStj|j|jƒ}tj|kr—
yOt|tjƒ
|_t|jƒ
|_ |
j!|j"ƒƒ

t#j$|
|ƒ
Wq—



tjdtj%dt&j'ƒƒ}tj|ƒ

q—
Xn|j(tjƒ

t|ƒ
dkr½
dS|j)|
||ƒ
dS(NtGMTooliRsILogicProcessThread::OnGMToolCommand Recv Cmd, but no Client in GMToolPortiÿÿÿÿsbuf = %ssMLogicProcessThread::OnGMToolCommand Catch a unexpetcted exception, error = %s(*RRkRlR-tGetClientCntRRLtERROR_NO_173RtDeployErrorRtIsDebugtbinasciiR/tb2a_hexR$R4R    ttagGMCommandRUt
g_GMCMDMgrtAddPairtOrderIdRRRVRWRXRYRZR[R\R]RiR9R R:tERROR_NO_172RNROR_R`(RR&tGmToolServerRRR|R5RaRb((s.\\LogicProcessThread.pyR:Øs:



 


#









"


cCs
tj
ƒ}|j|
jƒƒ

ytj|ƒ
}Wn6


tjd
tjdt    j
ƒƒ}tj|ƒ

n
Xtj |jƒ
}d}d}tjd|||fƒ

|dkrÀtjdƒ

dStjƒ}|j|||tjtjtj|jƒƒ
tjdƒ

dS(    NRsSLogicProcessThread::OnGMToolCommandResult Catch a unexpetcted exception, error = %siiÿÿÿÿsMSendToGMToolCommandResult sendViaSessionID = %s,SessionID = %d,PoolIndex = %dts7SendToGMToolCommandResult Fail, No Client in GMToolPortsSendToGMToolCommandResult Done(R
ttagGMCommandResultRUR$R R;RRLR‚RNRORRtPopPairRR@RIRRkR3RR!RtstGMTooltstCenterGateR9(RR&RjRRtsendViaSessionIDt    SessionIDt    PoolIndext    ServerMgr((s.\\LogicProcessThread.pyR;
s(



"




 



 
cCsVtj
ƒ}|jd
dƒ}d}d}|j|||tjtjtj|
ƒ
dS(NtRouteServeriiÿÿÿÿ(    RRktgetClientSessionIDByNameR3RtatWorldLogicRtstRouteRˆ(RtbufRŒR‰RŠR‹((s.\\LogicProcessThread.pyR^(
s






(t__name__t
__module__RR(R*R.R>R?RDRSR<R`R:R;R^(((s.\\LogicProcessThread.pyRs
                                        8    -    #(#t    threadingRRttimeR
tDBCommonRRRRtCommonRRtProtocolRR    R
Rt
__import__RYtNetRRNtGMToolLogicProcessR RRotjsontcPickletConfigRRgt GetGMOrderMgrRR(((s.\\LogicProcessThread.pyt<module>s 


"

"