xdh
2019-02-21 92eee67f85cbd29feb1287ae5a15ad0c787e95cb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
(«Qc@smddlZddlZddlmZddlZddlmZddlZdejfd„ƒYZ    dS(iÿÿÿÿN(t CommonDefine(tPacketDispatchertAsyncoreClientcBsYeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
RS(    cCsV|jtjtjƒ}tjj||ƒtjƒ|_|j    |j_
d|_ dS(Nt( t create_sockettsockettAF_INETt SOCK_STREAMtasyncoret
dispatchert__init__Rt_AsyncoreClient__packDispatchert    onGetPackt OnGetPackett_AsyncoreClient__sendBuf(tselftsock((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyR
s
cCstjdƒdS(s×ÓÀàʵÏÖs
unhandled!N(tmylogtwarning(Rtbuf((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyR scCstjd|jƒdS(Nsconnect %s ok!(Rtinfotaddr(R((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pythandle_connectscCs¹yx|jtjƒ}t|ƒdkr5|jƒdStjrgtjdt|ƒtj    |ƒfƒn|j
j |ƒWn:t k
r´}tj d|j|jfƒ|jƒnXdS(Nisrecv len = %s data = %ssget a exception: %s: %s
(trecvRtMAX_RECVtlentcloset
DUMPPACKETRtdebugtbinasciitb2a_hexR tonRecvOrginPackett    ExceptionRterrnotstrerrort
disconnect(RRte((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyt handle_read s
    )cCs|jƒdS(N(t_AsyncoreClient__processSend(R((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyt handle_write2scCs"tjd|jƒ|jƒdS(Ns    sock = %s(RRRR(R((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyt handel_close5scCs[|j|7_t|jƒtjkrMtjdt|jƒtjfƒn|jƒdS(Ns)send buf (len = %s) > (MAX_PACK_LEN = %s)(RRRt MAX_PACK_LENRRR&(RR((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pytpushSend9s&cCs"tjd|jƒ|jƒdS(Ns    sock = %s(RRRR(R((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyR#?scCs&|j|jƒ}|j||_dS(N(tsendR(Rtsent((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyt __processSendCs( t__name__t
__module__R
R RR%R'R(R*R#R&(((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyRs                                (
RRtDBCommonRRtProtocolRRR    R(((s7.\server\db\PyMongoDataServer\NetCore\AsyncoreClient.pyt<module>
s