ó
|
¬¼,Pc @ sU d d l Z d d l m Z m Z d d l m Z m Z d e j f d YZ d S( iÿÿÿÿN( t CommFunct mylog( t CommonDefinet errort PacketDispatcherc B s> e Z d Z d Z d Z d Z d Z d Z d Z RS( iÿÌ i i c C s t j j | d S( N( t IPacketDispatchert __init__( t self( ( s: .\server\db\PyMongoDataServer\Protocol\PacketDispatcher.pyR s c C s | j | j S( N( t _PacketDispatcher__packHeadLent _PacketDispatcher__packLenSize( R ( ( s: .\server\db\PyMongoDataServer\Protocol\PacketDispatcher.pyt __getPacketHeadLen s c C s d } t | d k r, t j d | j St | | j k rb t j d t | | j St j | | \ } } | | j k s¹ t
|
j d t
|
j d | } t j
|
| | j St j | | \ } } | | j } | t j k r)t
|
j d t
|
j d | t j f } t j
|
| | j S| t | k r_t j d t | | f | j S| j r
| j | | j | ! n | | 7} | S( Ni s len(buf) <= 0s buf len = %d not enough!R s PackSign Error curPackSign = %ss PackTotalLen = %s > %ss' buf len = %d expect len = %d waiting...( t lenR t warningt READ_PACKET_ERR_0t# _PacketDispatcher__getPacketHeadLent debugt READ_PACKET_ERR_SHORTBUFR t ReadWORDt _PacketDispatcher__packHeadR t formatMsgt ERROR_NO_136t ReadDWORDR t MAX_PACK_LENt ERROR_NO_137t OnGetPacket( R t buft post PackSignt msgt PackLent PackTotalLen( ( s: .\server\db\PyMongoDataServer\Protocol\PacketDispatcher.pyt readSinglePacket s2 %
|
c C sR d } t j | | j } t j | t | } t j | t | | } | S( Nt ( R t WriteWORDR t
|
WriteDWORDR t WriteString( R R t packBuf( ( s: .\server\db\PyMongoDataServer\Protocol\PacketDispatcher.pyt packData: s
|
( t __name__t
|
__module__R R R R R R R% ( ( ( s: .\server\db\PyMongoDataServer\Protocol\PacketDispatcher.pyR s !( R t CommonR R t DBCommonR R R ( ( ( s: .\server\db\PyMongoDataServer\Protocol\PacketDispatcher.pyt <module> s
|
