ó
|
Ö4hc @ s[ d d l m Z m Z m Z m Z m Z m Z m Z m Z m Z m
|
Z
|
d d l m Z m Z d d l m Z d d l m Z d d l m Z e d d \ Z Z Z Z Z Z Z Z Z Z Z Z Z! Z" Z# d e f d YZ$ d
|
e j f d YZ% d e% f d YZ& d e j f d YZ' d Z( d Z) d Z* e+ d k rWe* n d S( iÿÿÿÿ(
|
t c_intt Structuret c_ushortt c_ubytet memsett addressoft memmovet sizeoft create_string_buffert string_at( t mylogt ObjPool( t b2a_hex( t IPack( t errori i t tagMMORPGPackHeadc B s e Z d Z d Z d e f d e f d e f d e f d e f g Z d Z d Z d Z
|
d
|
d
|
d Z d Z d Z d Z RS( s ·â°üÍ·Àài t sessionIDt poolIndext typet
|
dstSvrTypet
|
srcSvrTypec C s t j | | j d S( N( R t __init__t clear( t self( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR 1 s c C s& t t | t | t | d S( N( R R R ( R t anotherHead( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt assign5 s c C s t t | d | j d S( Ni ( R R t getLength( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR 8 s i c C sÑ | | k s? t j d t j d | t f } t j | d St | | | j k r t j d t j d t | | | j } t j | d S| j t t | | | | j | j S( NR s error pos = %d len = %diÿÿÿÿs len = %d while %d expected!(
|
R t formatMsgt ERROR_NO_10t lenR
|
R t ERROR_NO_11R R R ( R t buft post lengtht msg( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt readData; s " 1
|
c C s
|
t t S( N( R R ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR H s c C s t t | | j S( N( R R R ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt getBufferK s c C s& d | j | j | j | j | j f S( Ns //MMORPG·â°üÍ·//tagMMORPGPackHead:
|
sessionID:0x%x,
|
poolIndex:0x%x,
|
type:0x%x,
|
dstSvrType:0x%x,
|
srcSvrType:0x%x
|
( R R R R R ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt outputStringN s ( t __name__t
|
__module__t __doc__t _pack_R R R t _fields_R R R R# R R$ R% ( ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR ( s t MMORPGPacketc B s e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z d
|
Z d Z d Z d Z RS( s ·â°üÀàc C s) t j j | t | _ d | _ d S( Nt ( R R R t _MMORPGPacket__packHeadt _MMORPGPacket__buf( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR _ s c C s | j j | j d S( N( R- R ( R t anotherPack( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt
|
assignHeade s c C s0 | j | t j j | | | j | _ d S( N( R0 R R R. ( R t other( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR h s c C s | j S( N( R- ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt getPackHeadm s c C s
|
| j j S( N( R- R ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt getDstSvrTypep s c C s | | j _ d S( N( R- R ( R R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt setSrcSvrTypes s c C s, | j j d | _ d | _ d | _ d S( NR, iÿÿÿÿ( R- R R. t _MMORPGPacket__recvFromSocketIDt _MMORPGPacket__sendViaSocketID( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR v s c C sr t | } | | j j k r% d S| j j | d | } d | k rM d S| | d k ra | S| | | _ | S( Niÿÿÿÿi ( R R- R R# R. ( R R t bufLent readLen( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR# | s c C s | j j | j S( N( R- R$ R. ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt getPackData s c C s | | _ d S( N( R. ( R R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt setBuffer s c C s | j S( N( R. ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR$ s c C s t | j S( N( R R. ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR s c C s | j j t | j S( N( R- R% R R. ( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR% s ( R& R' R( R R0 R R2 R3 R4 R R# R9 R: R$ R R% ( ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR+ ] s t MMORPGPacket_Stackc B s e Z d Z d Z RS( s" ¶ÑÕ»Éϵķâ°üÀ࣬·ÀÖ¹Îó·Å»Ø·â°ü³ØÖÐc C s t S( N( t False( R ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt IsAlloc s ( R& R' R( R= ( ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR; s t MMORPGPacketPoolc B s e Z d Z d Z RS( s ·â°ü³ØÀà,Ḭ̈߳²È«c C s& t j j | d t d | d | d S( Nt classnamet initSizet increaseSize( R R R+ ( R t maxSizet incSize( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR s ( R& R' R( R ( ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyR> s c C sh t d d } t j d t | t d d } t j d t | d } d } g } t j d | | f x t | D] } xP t | D]B } | j } | j | t j d t | | j f q Wt j d | j t j d | j q Wt j d
|
| d } xo | D]g } | | k rAPn | d 7} | j
|
| t j d t | | j f t j d | j q+Wt j d | xZ t | D]L } | j } t j d t | | j f t j d | j q´Wt } t j d | j | j }
|
t j d |
|
j | }
|
t j d |
|
j d S( Ni
|
i s id(packPool1) = %ss id(packPool2) = %si s ·ÖÅä%sÅú£¬Ã¿Åú%s¸ös pack %s isAlloc = %ss pool1 cnt = %ss pool1 allocCnt = %ss ÊÍ·ÅÒ»Åú%s¸öi s ÔÙ·ÖÅäÒ»Åú%s¸ös packStack.isAlloc() = %ss packHeap.isAlloc() = %ss" after copy packHeap.isAlloc() = %s( R> R
|
t infot idt xranget alloct appendt isAlloct countt getAllocCntt freeR; ( t packPool1t packPool2t allocCntt
|
allocTimest
|
allocPackst jt it packt freeCntt packStackt packHeap( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt test_MMORPGPacketPool¡ sF '
|
# # c C sø t } t j d | j d | _ d | _ d | _ d | _ d | _ t j d | j t j d t | j
|
t } t j d | j | j | j
|
d | j t j d | j t j d
|
t | j
|
d S( Ns head = %si
ui i i i s head.bindata = %ss
|
head1 = %si s head1.bindata = %s( R R
|
RD R% R R R R R R R$ R# R ( t headt head1( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt test_tagMMORPGPackHeadË s c C s t j d t d S( Ns test_MMORPGHead.log( R
|
t InitMyLogRX ( ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt testÝ s t __main__N(, t ctypesR R R R R R R R R R t CommonR
|
R t binasciiR t NetCoreR t DBCommonR t ranget stMint stDatat stCenterGatet stGamet stLogint stRoutet stMapt stGatet stInterfacet stDbSaveServert stCreateRoleServert stGMToolt stMergeClientt stNoSenset stMaxR R+ R; R> RX R[ R] R& ( ( ( s& .\\ServersRoute\Protocol\MMORPGPack.pyt <module>
|
s F<5: *
|
