5932 诛仙神技

cehua_hzl

2019-01-22 d6e9237b7de1a1ac685e440f894fb54522db3185

1
2
3
4
5
6
7
8
9
10
11
12
ó 
lÆ{Pc@sdd
lm
Z

ddlZddlmZ
ddlmZ
de
jf
d„ƒYZdejf
d„ƒYZ    dad    „ZdS(
iÿÿÿÿ(
tAsyncoreServerN(
t    Singleton(
tSingletonObjectt MongoDBServercBs2eZ
ded
„Zd„Zd„Zd„ZRS(iÿÿÿÿcCs#tj
j|d
|
ƒ
||_dS(NR(RtAsynCoreServert__init__t_MongoDBServer__notifyPrepare(tselftMaxClientCntt notifyPrepare((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyRs

cCs"tj|
||||j
ƒ}|S(
s½ÓÊÕÁ¬½Óʼþ֪ͨ(tMongoDBServerClientR(RtsocktaddrtonClientDisconnectt    recvQueuetclient((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pytonAcceptClients
c    Csˆtj
ƒjƒ}|j|
ƒ

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

|j|ƒ

dS(
N(RtgetPackPooltalloctsetSessionIDtgetPackHeadt    sessionIDt    poolIndexttypet
dstSvrTypet
srcSvrTypet    setBuffertpushSend(    RtsendViaSessionIDRRRRRtbuftsendPack((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pytpackSendBySessionID&s

 





 
cCs|jj
|
ƒ
S(
N(t    clientMgrtgetClientSessionIDByIndex(Rtindex((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyR!7s
(t__name__t
__module__tTrueRRRR!(((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyRs
        tMongoDBServerMgrc
BsbeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
d    „ZRS(
c

Cs i|_dS(
N(
t_MongoDBServerMgr__ServersDict(
R((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyRIsc
Cs(x!|jj
ƒD]}
|
jƒ
qWdS(
N(R'tvaluestprocessSendQueue(Rt
v((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pytprocessAllSendQueueMs

cCs'|jj
|
ƒ
rtS||j|
<tS(
N(R'thas_keytFalseR%(RtNametServer((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyt    AddServerQs
 
cCs|jj
|
dƒS(
N(R'tgettNone(RR.((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyt    GetServerYs
c
Cs(x!|jj
ƒD]}
|
jƒ
qWdS(
N(R'R(tstop(RtoServer((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyR4cs

cCs/|j|
j
ƒƒ
}|r+|j|
ƒ

ndS(
N(tFindServerByClientSessionIDtgetSessionIDR(RtpackR5((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyRos

c

Cs i|_dS(
N(
R'(
R((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pytClearuscCs&|j|
ƒ
}|r"|j
|ƒ
Sd
S(Niÿÿÿÿ(R3R!(RtnameR"tserver((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pytgetClientSessionIDByNameys


 
cCs1x*|jj
ƒD]}|j|
ƒ
r|SqWdS(
N(R'R(tFindClientBySessionIDR2(RRR;((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyR6s



c    Cs;|j|
ƒ
}|r7|j
|
||||||ƒ
ndS(
N(R6R(    RRRRRRRRR;((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyR…s


(R#R$RR+R0R3R4RR9R<R6R(((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyR&Gs                
                    c
Cstr
tSt
ƒatS(
N(t__MongoDBServerMgrR&(((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pytgetServerMgrŒs

    
( tNetCoreRR
tCommonR
tDBCommonRRRR&R2R>R?(((s2.\server\db\PyMongoDataServer\Net\MongoDBServer.pyt<module>s


7C