16 卡牌服务端（删除部分无用代码GY_GM_xxx.py）

hxp

54 分钟以前 ce8d11938d9444fde6a89774cfcb12ac0a7b1a58

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
38
39
40
41
42
43
ó 
=-hc@s 
dd
lm
Z

ddlZddlmZ
ddlZddlmZ
ddlmZ
ddl    m
Z
mZmZm Z mZmZmZ
ddlmZ
ddlmZmZ
ddlZed    ƒ
ZddlZyddlZWnek
r



ddlZn
Xd
e
f
d„ƒYZdS(iÿÿÿÿ(
tThreadN(
tsleep(
tmylog(
tCommFunc(tSingletonObjecttCommonDefinet    FuncGradetGlobalFunctionsterrort
SpeedGradetStat(
t MongoDBServer(tSendPackProtocolt
MMORPGPacksConfig.DBConfigtCtrlDBc
BséeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
d    „Zd
„Zd„Z d„Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(cCs

tj
|d
|
ƒ


g|_x9td|ƒD](}d}|jj|tjƒgƒ

q,W||_d|_d|_    d|_
d|_t|_ tj|
ƒ
|_tj|
ƒ
|_ddg|_tjƒ|_t|_d|_t|_d|_d|_dS(Ntnameit((Rt__init__tpriorityQueueListtxrangetappendtQueuet ctrlDBManagertNonet _CtrlDB__hostt _CtrlDB__portt_CtrlDB__dbNamet_CtrlDB__reconnectCnttFalset_CtrlDB__elegantExitRtFuncGradeManagertfuncGradeManagerR    t SpeedGradeMgrtspeedGradeManagertStatet    threadingtLockt
StateMutextQueueSizeExceedThresholdtBlockCntt    Connectedt
connectiontdb(tselft
threadNametpriorityQueueSizeRt
itqueueProcessRequestType((s&.\\ServersRoute\LogicProcess\CtrlDB.pyRs*
    


 
    
    
    
    
    
    



    
        
    
cCsd
d
g|_dS(Ni(
R"(R+tRequest((s&.\\ServersRoute\LogicProcess\CtrlDB.pyt
clearState6s
cCs|
tj
ƒg|_dS(
N(ttimeitt default_timerR"(R+tcurrentProcessingRequest((s&.\\ServersRoute\LogicProcess\CtrlDB.pytupdateState9s
c
CsH|jd
}
|jd}|
s$dSt
jƒ}d|
||||fS(Nii
s
-s)Type = %s, process time = %s secs, %s, %s(R"R2R3(R+tstatetstartProcessTicktcurrentTime((s&.\\ServersRoute\LogicProcess\CtrlDB.pytgetState<s
 
 


c


Cs|jS(
N(
R(
R+((s&.\\ServersRoute\LogicProcess\CtrlDB.pytGetFuncGradeManagerEs
c


Cs|jS(
N(
R!(
R+((s&.\\ServersRoute\LogicProcess\CtrlDB.pytGetSpeedGradeMgrHs
cCs|jj
|
ƒ
S(
N(RtGetFuncGrade(R+tfuncName((s&.\\ServersRoute\LogicProcess\CtrlDB.pyR<Ks
cCs|jj
|
ƒ
S(
N(R!t GetSpeedGrade(R+R((s&.\\ServersRoute\LogicProcess\CtrlDB.pyR>Ns
c

Cs t|j
ƒ
S(
N(tlenR(
R+((s&.\\ServersRoute\LogicProcess\CtrlDB.pytgetPrioorityQueueCntQs
cCs|j|
d
j
ƒS(Ni
(Rtqsize(R+tindex((s&.\\ServersRoute\LogicProcess\CtrlDB.pytgetPriorityQueueSizeTs
cCsEtj
ƒjƒ}tj|jƒ_|j|
ƒ

|jj    |ƒ

dS(
N(
RtgetPackPooltallocRtatInnertgetPackHeadttypet    setBufferRt dbRequestPush(R+tbuftsendPack((s&.\\ServersRoute\LogicProcess\CtrlDB.pyt sendDBRequestWs


 
c    Cs®tj
d
|
|||||fƒ

tjƒjƒ}|j|
ƒ

||jƒ_||jƒ_||jƒ_    ||jƒ_
||jƒ_|j|ƒ

|j j|ƒ

dS(NsksendViaSessiondID = %s, sessionID = %s, poolIndex = %s, type = %s, dstSvrType = %s,         srcSvrType = %s(RtdebugRRDREtsetSessionIDRGt    sessionIDt    poolIndexRHt
dstSvrTypet
srcSvrTypeRIRtdbAnswerPush(    R+tsendViaSessiondIDRPRQRHRRRSRKRL((s&.\\ServersRoute\LogicProcess\CtrlDB.pytpackSend]s


 





 
cCs5tj
ƒj|
jƒƒ
}|r1|j|
ƒ

ndS(
N(RtgetServerMgrtFindServerByClientSessionIDtgetSessionIDtpushSend(R+tpacktoServer((s&.\\ServersRoute\LogicProcess\CtrlDB.pyRZks

cCsHxAtd
t
|jƒ
ƒD]'}|j|d
}|
|krtSqWtS(Ni(RR?RtTrueR(R+trequestTypeR.trequestTypeList((s&.\\ServersRoute\LogicProcess\CtrlDB.pyt
canProcessqs




cCs|
|_||_
dS(
N(RR(R+thosttport((s&.\\ServersRoute\LogicProcess\CtrlDB.pyt    setServerys
    
cCs|
|_||_
||_dS(
N(Rt_CtrlDB__dbUsert_CtrlDB__dbPwd(R+tdbNametusertpwd((s&.\\ServersRoute\LogicProcess\CtrlDB.pytsetDataBase}s
    
    
cCs
d
}tj
|
jƒ|ƒ\}}d}xGtd
t|jƒ
ƒD]-}|j|d
}||krC|}PqCqCW|d
ks•|t|jƒ
krÂtjdtjd|ƒ}t    j|ƒ

t
St    jd||fƒ

|jd|ƒ
j ƒ
|j|dj|
ƒ

tS(NiiÿÿÿÿRspriorityLV = %s not found!spack type = %s add to queue %ssrequestPush_%si
(RtReadBYTEt    getBufferRR?RRt    formatMsgtERROR_NO_42RRRNR>tRefreshtputR](R+R[tposR^t
priorityLVR.R_tmsg((s&.\\ServersRoute\LogicProcess\CtrlDB.pytrequestPushŒs 








!

 




c
Cstj
r
d
}
xÅtd
t|jƒ
ƒD]«}|j|djƒtjkr¦|jsÓ|jd7_t    |_t
jd|jƒ||j|djƒfƒ

qÓq(|j|djƒtj kr(|
d7}
q(q(W|jr
|
t|jƒ
kr
t|_t
jd|jƒƒ

q
nxãtd
t|jƒ
ƒD]É}y|j|djƒ}Wntjk
rn



q4
n
X|r4
d
}tj|jƒ|ƒ\}}|jd|ƒ
jƒ
tjƒ}|j|ƒ

t
jd||jƒfƒ

tjƒj|ƒ

|Sq4
WdS(Nii
s!!!*** %s queue %s size = %ss$!!!*** %s queue resume low balanced!s requestPop_%ss)pop pack from queue(priorityLV = %s) = %s( tDBConfigtStartProfileRR?RRAtProfileQueueThresholdMaxR&R'R]RtwarningtgetNametProfileQueueThresholdMinRt
get_nowaitRtEmptyRRjRkR>RnR tMMORPGPacket_StacktassignRNtoutputStringRRDtfreeR(R+tlowBalanceQueueCntR.R[RpR^tret((s&.\\ServersRoute\LogicProcess\CtrlDB.pyt__requestPopžs8    


 
    

    
7
 


    









 


c
    Csx    try-|j
sÄtjd
|j|jfƒ

tj|j|jdtƒ
|_    |j    |j
|_t|_
tjd|j|jfƒ

tj |j|jd|j    ƒ
s±dS|j|jƒ

n|jƒ}
|
dkràPntjƒjd7_d}d}|
jƒdkr_
d}tj|
jƒ|ƒ\}}|j|ƒ

tjr_
tjƒ}q_
n|j|j|
ƒ}|rÙ
tjrÉ
|rÉ
tjƒ|}|tj dkrÉ
tj!d||fƒ

qÉ
n|j"|ƒ

ntj#d    t$|
jƒdƒ
ƒ

|rwnt%j&d
t%j'd|
j(ƒƒ}tj%|ƒ

Wqtj)j*k
rÒ


|j+d7_+tjd|j|j|j+fƒ

|j+tj,krÉt%j&d t%j-d|j|jfƒ}tj.|ƒ

dSt}q


t%j&d
t%j/dt0j1ƒƒ}tj%|ƒ

qXqWdS(Ns!!!!!!!!!!!connect %s:%stauto_start_requests!!!!!!!!!!!connect %s:%s ok!R)i
ig@@s.!!!---request type = %s process time = %s secssend process request type = %dRsfailed to process pack = %ss"try reconnecting %s:%s cnt = %s...tfatalsreconnect %s:%s failed!s%s(2R]R(RtinfoRRtpymongot
ConnectionRR)RR*RtLoginMongoDBRdRet onConnectedOKt_CtrlDB__requestPopRR
tGetStattDBProcessCountt    getLengthRRjRkR5RtRuR2R3trequestLogicProcesstProfileThresholdRwR1RNtordRRltERROR_NO_43R~terrorst AutoReconnectRtmaxReconnectCnttERROR_NO_44R„tERROR_NO_45t    tracebackt
format_exc(    R+R[R^tprocessStartTickRptresulttprocessTimeRrt
bConnected((s&.\\ServersRoute\LogicProcess\CtrlDB.pyt__requestProcessÀs\    

    

!

    
!







     




!

"


#

(
 

    
"
c


Cs|jƒ
dS(
N(
t_CtrlDB__requestProcess(
R+((s&.\\ServersRoute\LogicProcess\CtrlDB.pytrunþscCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(RRw(R+R*R[((s&.\\ServersRoute\LogicProcess\CtrlDB.pyRŽ
sc
Csd
S(s×ÓÀàʵÏÖN((R+R*((s&.\\ServersRoute\LogicProcess\CtrlDB.pyR‰
sc

Cs:t|_
tj|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(RRRtstartRR…Rxtident(
R+((s&.\\ServersRoute\LogicProcess\CtrlDB.pyR 

s
    
 
c

CsXtj
d
|jƒƒ

t|_x|jƒr<tdƒ

q#Wtj
d|jƒƒ

dS(NsStoping thread %s...gš™™™™™¹?sThread %s stop OK!(RR…RxR]RtisAliveR
(
R+((s&.\\ServersRoute\LogicProcess\CtrlDB.pytstop
s


    

cCs„tj
ƒ}||_d
|_|jƒ|}|j|
jƒ|
jƒj|
jƒj    |
jƒj
|
jƒj|
jƒj|ƒ
dS(Ni
( RttagDBToGameServerHeadtTypetSuccesst    GetBufferRVRYRGRPRQRHRSRR(R+trecvPackRHtdataRLtsendBuf((s&.\\ServersRoute\LogicProcess\CtrlDB.pytsendGameServerString
s

    
    




(t__name__t
__module__RR1R5R9R:R;R<R>R@RCRMRVRZR`RcRiRsRŠRžRŸRŽR‰R R£R«(((s&.\\ServersRoute\LogicProcess\CtrlDB.pyRs2
                                                                            "    >                    (R#RRttimeR
R†tCommonRRtDBCommonRRRRRR    R
tNetRtProtocolRR R—t
__import__RtR2tImportErrortdummy_threadingR(((s&.\\ServersRoute\LogicProcess\CtrlDB.pyt<module>s 





4