ó
|
¬¼,Pc @ sC d d l m Z d d l Z d d l m Z d d d YZ d S( iÿÿÿÿ( t mylogN( t CommonDefinet IPacketDispatcherc B sG e Z d Z d Z d Z d Z d Z d Z d Z d Z
|
RS( iÿÿÿÿiþÿÿÿc C s d | _ d S( Nt ( t _IPacketDispatcher__remainBuf( t self( ( s; .\server\db\PyMongoDataServer\Protocol\IPacketDispatcher.pyt __init__ s c C s t j d d S( Ns
|
unhandled!( R t warning( R t buf( ( s; .\server\db\PyMongoDataServer\Protocol\IPacketDispatcher.pyt readSinglePacket s c C sò | j | } d | _ t j r< t j d t j | n d } x© | t | k rí | j | | } | | j k r d | _ t j
|
d | Pn | | j k rà | | | _ t j rÜ t j d t j | j n Pn | | } qE Wd S( NR s totalBuf = %si s Òì³£%s read!s %s remained!waiting...( R R t
|
DUMPPACKETR t debugt binasciit b2a_hext lenR t READ_PACKET_ERR_0t errort READ_PACKET_ERR_SHORTBUF( R R t totalBuft readLent bytesRead( ( s; .\server\db\PyMongoDataServer\Protocol\IPacketDispatcher.pyt onRecvOrginPacket s" c C s t j d d S( Ns
|
unhandled!( R R ( R R ( ( s; .\server\db\PyMongoDataServer\Protocol\IPacketDispatcher.pyt packData9 s c C s d | _ d S( NR ( R ( R ( ( s; .\server\db\PyMongoDataServer\Protocol\IPacketDispatcher.pyt clear< s N( t __name__t
|
__module__R R t Nonet OnGetPacketR R R R R ( ( ( s; .\server\db\PyMongoDataServer\Protocol\IPacketDispatcher.pyR s ( ( t CommonR R t DBCommonR R ( ( ( s; .\server\db\PyMongoDataServer\Protocol\IPacketDispatcher.pyt <module> s
|
