3469 开服红包优化

cehua_hzl

2018-09-11 d01e814a46cb4c0446b4a8609a7eef176415bbda

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
ó 
lÆ{Pc@s¯dd
lZddl
mZ
ddlmZ
ddlmZmZmZ
ddl    m
Z

ddlmZm Z mZ
edƒ
Zdejefd    „ƒYZd
ad
„Zd
S(iÿÿÿÿN(
tThread(
tsleep(tCommFunct    Singletontmylog(
t MongoDBServer(t
DataDumpertGlobalFunctionsterrorsConfig.DBConfigt CtrlDBManagerc
BsªeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
d    „Zd
„Zd„Z d„Zd „Zd„Zd„Zd„Zd„ZRS(c

CsWtjj
|ƒ

tj
|d
dƒ


g|_tjƒ|_tjƒ|_t|_dS(NtnameR    (    Rt__init__Rt#_CtrlDBManager__ctrlDBPriorityQueuetQueuet"_CtrlDBManager__dbRequestPackQueuet!_CtrlDBManager__dbAnswerPackQueuetFalset_CtrlDBManager__elegantExit(
tself((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyRs


    


c
Cs"x|jD]}
|
j
ƒ
q
WdS(
N(Rtrun(RtdbProcesser((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytrunAlls

c
CsÔxªtr¬x-tr8|j
ƒ}
|
r4|j|
ƒ

qPqWtjsO|jƒ
nx3tr„|jƒ}|r€tjƒj    |ƒ

qRPqRWtjs’dS|j
rŸPntd
ƒ

qWtjrÐtj d|jƒƒ

ndS(Ngš™™™™™¹?sThread %s exit!(tTruetdbRequestPoptpackDispatchtDBConfigtMultiThreadingRtdbAnswerPopRtgetServerMgrtpushSendRR
RtinfotgetName(Rtrequesttanswer((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyR!s(
    
    


    
     


    
    


    
c


Cs |jj
ƒS(
N(Rtqsize(
R((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytdbRequestQueueCnt=s
cCs|jj
|
ƒ

dS(
N(Rtput(Rtpack((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyt dbRequestPush@sc
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(Rt
get_nowaitR tEmptytNone(RR ((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyRDs




c


Cs |jj
ƒS(
N(RR"(
R((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytdbAnswerQueueCntLs
cCs|jj
|
ƒ

dS(
N(RR$(RR%((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytdbAnswerPushOs
c
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(RR'R R(R)(RR!((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyRRs





c

Cs t|j
ƒ
S(
N(tlenR(
R((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytgetCtrlDBCntYs
cCsy|j|
SWn


dSXdS(
N(RR)(Rtindex((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyt    getCtrlDB\s



cCs.x'|jD]}|j
ƒ|
kr
|Sq
WdS(
N(RR(RtNamet    curCtrlDB((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytgetCtrlDBByNameas


cCs|jj
|
ƒ

dS(
N(Rtappend(RtctrlDB((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyt    addCtrlDBfs
cCs4
|
dkr5t
jd
t
jdƒ}tj
|ƒ

tS|
jƒdkr€t
jd
t
jd|
jƒj    ƒƒ}tj
|ƒ

tS|
j
ƒ}d}tj||ƒ\}}xN|j D]C}|j|ƒ
r´tjd||jƒfƒ

|j|
ƒ

tSq´Wt
jd
t
jd||
j    ƒfƒ}tj
|ƒ

tS(NRspack is Nonei
s#pack.getLength() < 1 pack head = %sisDispatch type = %s to %ss%type = %d   request %s not processed!(R)Rt    formatMsgtERROR_NO_46RRt    getLengthtERROR_NO_47tgetPackHeadtoutputStringt    getBufferRtReadBYTERt
canProcesstdebugRtrequestPushRtERROR_NO_48(RR%tmsgtbuftreadPosttypeR((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyRis&


 


(
 






 

(
 c
CsXx|jD]}
|
j
ƒ
q
Wt|_tj
|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(    RtstartRRRRRRtident(RtdbProcessThread((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytstartAll‰s


    
 
c
Cs„yXtj
d
|jƒƒ

t|_x|jƒr?tdƒ

q&Wtj
d|jƒƒ

Wn


n
Xx|jD]}
|
jƒ
qlWdS(NsStopping thread %s...gš™™™™™¹?sThread %s stop ok!(    RRRRRtisAliveR
Rtstop(RRH((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytstopAll‘s


    





c
CsZd
}
x1|jD]&}|
|j
ƒjƒ7}
|
d7}
qWtjtjƒdd|
ƒ
dS(Nts 
t    FuncGrades FuncGrade.txt(RtGetFuncGradeManagertGetFmtGradeInfoRtDumpDataRt
getAppPath(RtdumpInfoR4((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyt DumpFuncGradežs





c
CsZd
}
x1|jD]&}|
|j
ƒjƒ7}
|
d7}
qWtjtjƒdd|
ƒ
dS(NRMs 
RNsSpeedGrade.txt(RtGetSpeedGradeMgrRPRRQRRR(RRSR4((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pytDumpSpeedGrade¥s





(t__name__t
__module__RRRR#R&RR*R+RR-R/R2R5RRIRLRTRV(((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyR    s$
                                                                      c
Cstst
ƒantS(
N(t _ctrlDBManagrR    (((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyt
getCtrlMgr®s

(R t    threadingRttimeR
tCommonRRRtNetRtDBCommonRRRt
__import__RR    R)RYRZ(((s;.\server\db\PyMongoDataServer\LogicProcess\CtrlDBManager.pyt<module>s





—