Revert "12345 技能测试1"

hxp

2025-08-20 d0a3a9fc96782d1ae4fd0b110681de7c9ab089f5

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
ó 
6hc@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„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-.\\ServersRoute\LogicProcess\CtrlDBManager.pyRs


    


c
Cs"x|jD]}
|
j
ƒ
q
WdS(
N(Rtrun(RtdbProcesser((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pytrunAlls

c
Cstx-tr/|j
ƒ}
|
r+|j|
ƒ

qPqW|jƒ
x3tro|jƒ}|rktjƒj|ƒ

q=Pq=WdS(
N(tTruetdbRequestPoptpackDispatchRtdbAnswerPopRtgetServerMgrtpushSend(Rtrequesttanswer((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyR!s
    



    

c


Cs |jj
ƒS(
N(Rtqsize(
R((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pytdbRequestQueueCnt4s
cCs|jj
|
ƒ

dS(
N(Rtput(Rtpack((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyt dbRequestPush7sc
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(Rt
get_nowaitR tEmptytNone(RR((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyR;s




c


Cs |jj
ƒS(
N(RR(
R((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pytdbAnswerQueueCntCs
cCs|jj
|
ƒ

dS(
N(RR (RR!((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pytdbAnswerPushFs
c
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(RR#R R$R%(RR((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyRIs





c

Cs t|j
ƒ
S(
N(tlenR(
R((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pytgetCtrlDBCntPs
cCsy|j|
SWn


dSXdS(
N(RR%(Rtindex((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyt    getCtrlDBSs



cCs.x'|jD]}|j
ƒ|
kr
|Sq
WdS(
N(RtgetName(RtNamet    curCtrlDB((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pytgetCtrlDBByNameXs


cCs|jj
|
ƒ

dS(
N(Rtappend(RtctrlDB((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyt    addCtrlDB]s
cCsLxEt|j
ƒ
D]4\}}|jƒ|
jƒkr|
|j
|<qqWdS(
N(t    enumerateRR,(Rt    newCtrlDBt
iR.((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyt replaceCtrlDB`s



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
canProcesstdebugR,trequestPushRtERROR_NO_48(RR!tmsgtbuftreadPosttypeR((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyRfs&


 


(
 






 

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

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(    RtstartRRRRtinfoR,tident(RtdbProcessThread((s-.\\ServersRoute\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!(    RRHR,RRtisAliveR
Rtstop(RRJ((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pytstopAll…s


    





c
CsZd
}
x1|jD]&}|
|j
ƒjƒ7}
|
d7}
qWtjtjƒdd|
ƒ
dS(Nts 
t    FuncGrades FuncGrade.txt(RtGetFuncGradeManagertGetFmtGradeInfoRtDumpDataRt
getAppPath(RtdumpInfoR1((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyt DumpFuncGrade’s





c
CsZd
}
x1|jD]&}|
|j
ƒjƒ7}
|
d7}
qWtjtjƒdd|
ƒ
dS(NROs 
RPsSpeedGrade.txt(RtGetSpeedGradeMgrRRRRSRRT(RRUR1((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pytDumpSpeedGrade™s





(t__name__t
__module__RRRRR"RR&R'RR)R+R/R2R6RRKRNRVRX(((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyR    s&
                                                                         c
Cstst
ƒantS(
N(t _ctrlDBManagrR    (((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyt
getCtrlMgr¢s

(R t    threadingRttimeR
tCommonRRRtNetRtDBCommonRRRt
__import__tDBConfigR    R%R[R\(((s-.\\ServersRoute\LogicProcess\CtrlDBManager.pyt<module>s





‹