ó
|
¬¼,Pc @ sF d Z d d l m Z m Z d d d YZ d d d YZ d S(
|
s#
|
Created on 2012-7-3
|
|
@author: xcc
|
iÿÿÿÿ( t SSCommonFunct SSCommonLogt tagMMORPGPackHeadc B s, e Z d Z d Z d Z d Z RS( c C s1 d | _ d | _ d | _ d | _ d | _ d S( Ni ( t SessionIDt PoolIndext Typet DestServerTypet SrcServerType( t self( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt __init__ s
|
c C sç t | } | d k r/ t j j d d S| d } | | k r\ t j j d d St j | | \ | _ } t j | | \ | _ } t j | | \ | _
|
} t j | | \ | _ } t j | | \ | _ } | S( Ni s tagMMORPGPackHead bufLen = 0iÿÿÿÿi s" tagMMORPGPackHead bufLen < packLen( t lenR t GetLogt debugR t ReadDWORDR t ReadWORDR t ReadBYTER R R ( R t buft post bufLent packLen( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt ReadData s
|
c C s d S( Ni ( ( R ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt GetLength( s c C ss d } t j | | j } t j | | j } t j | | j } t j | | j } t j | | j } | S( Nt ( R t
|
WriteDWORDR t WriteWORDR t WriteBYTER R R ( R R ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt GetPackData+ s ( t __name__t
|
__module__R R R R ( ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyR s t CSSPackParsec B s> e Z d Z d Z d Z d Z d Z d Z RS( c C s: d | _ d | _ d | _ d | _ d | _ d | _ d S( Ni i iÿÌ R i ( t _CSSPackParse__PackHeadLent _CSSPackParse__PackSignLent _CSSPackParse__PackHeadt _CSSPackParse__BuffPackt Nonet SSPackDispatchert _CSSPackParse__Count( R ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyR 6 s c C s@ | d k s t | d r3 t j j d d S| | _ d S( Nt OnRecvPacketsM (SSPackDispatcher == None) or (not hasattr(SSPackDispatcher, "OnRecvPacket"))( R" t hasattrR R t warningR# ( R R# ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt BindSSPackDispatcher> s c
|
C s t | } | d k r/ t j j d d S| j | j } | | k rb t j j d d Sd } t j | | \ } } | | j k rª t j j d | d St j
|
| | \ } } | | | k ré t j j d d St } | j | | d k rd S| j } t j | | | | | \ } } | j r| j d 7_ | j j | | | t j j d | j n t j j d | S(
|
Ni s bufLen == 0s bufLen < packLens ·â°üÍ·´íÎ󣬽ÓÊÕµ½µÄ·â°üÍ·=%xiÿÿÿÿs readLen + pos > bufLeni s RecvCount = %ds self.OnSSPackDispatcher == None( R
|
R R R' R R R R R R R R R R t
|
ReadStringR# R$ R% (
|
R R t statusRespondClientR R R t packHeadt readLent MMORPGPackHeadLent curPack( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt __GetPackE s8 # c C s¼ | j | | _ x¥ t | j r· | j | j | } | d k rq t | j d k r | j d | _ q q n | d k r¤ t j j d t j | j Pn | j | | _ q Wd S( Niÿÿÿÿi i s% ·â°ü²»ÍêÕû£¬µÈ´ýºóÐø·â°ü, ·â°üÊý¾Ý:%s( R! R
|
t _CSSPackParse__GetPackR R t infoR t b2a_hex( R R R* R ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt OnRecvOrignPackk s c C s d | _ d S( NR ( R! ( R ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt Clear} s c C s[ d } t j | | j } t j | t | | j } | | j 7} | | 7} | S( NR ( R R R R R
|
R R ( R t MMORPGPackHeadR t headBuf( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt PackData s "
|
( R R R R( R0 R3 R4 R7 ( ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyR 5 s & N( ( ( t __doc__t SSCommonR R R R ( ( ( s: .\server\db\PyMongoDataServer\SSPackProcess\SSPackParse.pyt <module> s &
|
