ó
|
hc @ s{ d d l m Z d d l Z d d l m Z d d l m Z m Z m Z d d l m
|
Z
|
m Z d e j f d YZ d S( iÿÿÿÿ( t mylogN( t AsynServerClient( t SingletonObjectt CommonDefinet error( t SendPackProtocolt
|
MMORPGPackt MongoDBServerClientc B s, e Z d Z d Z d Z d Z RS( c C s) t j j | | | | | | | _ d S( N( R t __init__t _MongoDBServerClient__recvQueue( t selft sockt addrt OnCloset recvQueuet notifyPrepare( ( s* .\\ServersRoute\Net\MongoDBServerClient.pyR s c C sá t j r& t j d t j | n t j j } d | j | k r t
|
j d t
|
j d } t j
|
| t j j | d S| j | j t j d | j j | j j | t j d | j j d S( s »ñµÃ²ð½âºóµÄ·â°üs buf = %siÿÿÿÿR s error in pack.readDataNs before put:recv queue cnt = %ss after put:recv queue cnt = %s( R t
|
DUMPPACKETR t debugt binasciit b2a_hexR t getPackPoolt alloct readDataR t formatMsgt ERROR_NO_135t freet setSessionIDt sessionIDR t qsizet put( R
|
t buft packt msg( ( s* .\\ServersRoute\Net\MongoDBServerClient.pyt OnGetPacket s c C sÞ t j } t j | _ t j j } | j | j j
|
d | j _ d | j _ t j | j _ t j | j _ t j | j _ | j | j | j | j t j j | t j d d S( Ni s Send OK!( R t tagDataServerInitOKR t dgDataServerPrepareOKt TypeR R R t setSendViaSocketIDt sockett filenot getPackHeadR t poolIndext atInnert typeR t stRoutet
|
dstSvrTypet stCenterGatet
|
srcSvrTypet setBuffert GetBuffert pushSendt getPackDataR R t info( R
|
t packDBInitOKt sendPack( ( s* .\\ServersRoute\Net\MongoDBServerClient.pyt notifyRouteServerDBPrepareOK' s c C sV t j } | j | | j j t j k r? | j d St j j | | d S( N(
|
R t MMORPGPacket_StackR R( R+ R t atDisconnectt
|
disconnectR R2 ( R
|
R R ( ( s* .\\ServersRoute\Net\MongoDBServerClient.pyR2 8 s
|
( t __name__t
|
__module__R R! R7 R2 ( ( ( s* .\\ServersRoute\Net\MongoDBServerClient.pyR s ( t CommonR R t NetCoreR t DBCommonR R R t ProtocolR R R ( ( ( s* .\\ServersRoute\Net\MongoDBServerClient.pyt <module> s
|
|
