ó
|
Ôí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 RS( c C s) t j j | | | | | | | _ d S( N( R t __init__t _MongoDBServerClient__recvQueue( t selft sockt addrt OnCloset recvQueue( ( 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 sV t j } | j | | j j t j k r? | j d St j j | | d S( N(
|
R t MMORPGPacket_StackR t getPackHeadt typeR t atDisconnectt
|
disconnectR t pushSend( R
|
R R ( ( s* .\\ServersRoute\Net\MongoDBServerClient.pyR& 6 s
|
( t __name__t
|
__module__R R R& ( ( ( 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
|
|
