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
36
37
38
39
40
41
42
43
44
45
ó 
(«Qc@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„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((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyRs*
    


 
    
    
    
    
    
    



    
        
    
cCsHtj
r5|jjƒ
d
d
g|_|jjƒ
nd
d
g|_dS(Ni(tDBConfigtMultiThreadingR%tacquireR"trelease(R+tRequest((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyt
clearState6s
    
 

cCsTtj
r;|jjƒ
|
tjƒg|_|jjƒ
n|
tjƒg|_dS(
N(R0R1R%R2ttimeitt default_timerR"R3(R+tcurrentProcessingRequest((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytupdateState?s

    
 

c
Csˆtj
r@|jjƒ
|jd
}
|jd}|jjƒ
n|jd
}
|jd}|
sddStjƒ}d|
||||fS(Nii
s
-s)Type = %s, process time = %s secs, %s, %s(R0R1R%R2R"R3R6R7(R+tstatetstartProcessTicktcurrentTime((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytgetStateGs
    
 
 
 
 
 


c


Cs|jS(
N(
R(
R+((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytGetFuncGradeManagerVs
c


Cs|jS(
N(
R!(
R+((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytGetSpeedGradeMgrYs
cCs|jj
|
ƒ
S(
N(RtGetFuncGrade(R+tfuncName((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyR@\s
cCs|jj
|
ƒ
S(
N(R!t GetSpeedGrade(R+R((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyRB_s
c

Cs t|j
ƒ
S(
N(tlenR(
R+((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytgetPrioorityQueueCntbs
cCs|j|
d
j
ƒS(Ni
(Rtqsize(R+tindex((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytgetPriorityQueueSizees
cCsEtj
ƒjƒ}tj|jƒ_|j|
ƒ

|jj    |ƒ

dS(
N(
RtgetPackPooltallocRtatInnertgetPackHeadttypet    setBufferRt dbRequestPush(R+tbuftsendPack((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyt sendDBRequesths


 
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(RtdebugRRHRItsetSessionIDRKt    sessionIDt    poolIndexRLt
dstSvrTypet
srcSvrTypeRMRtdbAnswerPush(    R+tsendViaSessiondIDRTRURLRVRWRORP((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytpackSendns


 





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

ndS(
N(RtgetServerMgrtFindServerByClientSessionIDtgetSessionIDtpushSend(R+tpacktoServer((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyR^|s

cCsHxAtd
t
|jƒ
ƒD]'}|j|d
}|
|krtSqWtS(Ni(RRCRtTrueR(R+trequestTypeR.trequestTypeList((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyt
canProcess‚s




cCs|
|_||_
dS(
N(RR(R+thosttport((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyt    setServerŠs
    
cCs|
|_||_
||_dS(
N(Rt_CtrlDB__dbUsert_CtrlDB__dbPwd(R+tdbNametusertpwd((s4.\server\db\PyMongoDataServer\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    getBufferRRCRRt    formatMsgtERROR_NO_42RRRRRBtRefreshtputRa(R+R_tposRbt
priorityLVR.Rctmsg((s4.\server\db\PyMongoDataServer\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( R0tStartProfileRRCRREtProfileQueueThresholdMaxR&R'RaRtwarningtgetNametProfileQueueThresholdMinRt
get_nowaitRtEmptyRRnRoRBRrR tMMORPGPacket_StacktassignRRtoutputStringRRHtfreeR(R+tlowBalanceQueueCntR.R_RtRbtret((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyt__requestPop¯s8    


 
    

    
7
 


    









 


c
    Cs5x.tr0yR|j
s´tjd
|j|jfƒ

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

tj |j|jd|j    ƒ
s´dSn|jƒ}
tjrõ|
dkr
|jrâPntdƒ

wq
n%|
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ƒ
ƒ

|r+wnt'j(dt'j)d|
j*ƒƒ}tj'|ƒ

Wqtj+j,k
r÷


|j-d7_-tjd |j|j|j-fƒ

|j-tj.krît'j(dt'j/d|j|jfƒ}tj0|ƒ

dSt}q


t'j(dt'j1dt2j3ƒƒ}tj'|ƒ

qXqWdS(Ns!!!!!!!!!!!connect %s:%stauto_start_requests!!!!!!!!!!!connect %s:%s ok!R)gš™™™™™¹?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(4RaR(RtinfoRRtpymongot
ConnectionRR)RR*RtLoginMongoDBRhRit_CtrlDB__requestPopR0R1RRR
R
tGetStattDBProcessCountt    getLengthRRnRoR9RxR6R7trequestLogicProcesstProfileThresholdRzR5RRtordRRptERROR_NO_43Rterrorst AutoReconnectRtmaxReconnectCnttERROR_NO_44R‡tERROR_NO_45t    tracebackt
format_exc(    R+R_RbtprocessStartTickRttresulttprocessTimeRvt
bConnected((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyt__requestProcessÑsf    

    

!

    
!

    

    



    






     




!

"


#

(
 

    
"
c

Cs1|jƒ
t
jr-tjd
|jƒƒ

ndS(NsThread %s exit!(t_CtrlDB__requestProcessR0R1RRˆR{(
R+((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytrun
s

    
cCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(RRz(R+R*R_((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyR
sc

Cs:t|_
tj|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(RRRtstartRRˆR{tident(
R+((s4.\server\db\PyMongoDataServer\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ˆR{RaRtisAliveR
(
R+((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytstop"
s


    

cCs„tj
ƒ}||_d
|_|jƒ|}|j|
jƒ|
jƒj|
jƒj    |
jƒj
|
jƒj|
jƒj|ƒ
dS(Ni
( RttagDBToGameServerHeadtTypetSuccesst    GetBufferRZR]RKRTRURLRWRV(R+trecvPackRLtdataRPtsendBuf((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pytsendGameServerString*
s

    
    




(t__name__t
__module__RR5R9R=R>R?R@RBRDRGRQRZR^RdRgRmRwRŒR R¡RR¢R¥R­(((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyRs0
                                                                            "    B                (R#RRttimeR
R‰tCommonRRtDBCommonRRRRRR    R
tNetRtProtocolRR R™t
__import__R0R6tImportErrortdummy_threadingR(((s4.\server\db\PyMongoDataServer\LogicProcess\CtrlDB.pyt<module>s 





4