ó
|
í³Ôdc @ sz d d l Z d d l Z d d l m Z d e f d YZ d e j f d YZ d Z e d k rv e n d S( iÿÿÿÿN( t errort PoolObjc B s# e Z d Z d Z d Z RS( c C s t | _ d S( N( t Falset Alloc( t self( ( s! .\\ServersRoute\Common\ObjPool.pyt __init__ s c C s | | _ d S( N( R ( R t isAlloc( ( s! .\\ServersRoute\Common\ObjPool.pyt
|
setIsAlloc s c C s | j S( N( R ( R ( ( s! .\\ServersRoute\Common\ObjPool.pyR s ( t __name__t
|
__module__R R R ( ( ( s! .\\ServersRoute\Common\ObjPool.pyR s t ObjPoolc B sJ e Z d Z e d Z d Z d Z d Z d Z d Z RS( c K s< t j j | y d d l } Wn t k
|
r? d d l } n X| d | _ | j d p_ g | _ t | d d | _ | d | _
|
d | _ t | j t sÙ t j d t j d | j t f } t j | d S| j | _ g t | j D] } t | j | j ^ qø | _ g | _ | j j | j d S( Niÿÿÿÿt classnamet argst initSizei t increaseSizeR s %s must be subclass of %s( t SingletonR t threadingt ImportErrort dummy_threadingt _ObjPool__objClsNamet gett _ObjPool__objArgst maxt _ObjPool__initSizet _ObjPool__increaseSizet _ObjPool__allocCntt
|
issubclassR R t formatMsgt
|
ERROR_NO_7t mylogt Lockt _ObjPool__emptyObjsLockt xranget applyt _ObjPool__emptyObjst _ObjPool__objPoolt extend( R t kwargsR t msgt i( ( s! .\\ServersRoute\Common\ObjPool.pyR s$ % 4 c C s | j j t | j d k rF | s9 | j j d S| j n t | j d k rl | j j d S| j j d } | j rÊ t j
|
d t j d t | } t j | | j j d S| j t | j d 7_ | j j t j d t | | S( Ni R s unclean obj id = %s found!i s object id = %s( R t acquiret lenR" t releaset Nonet _ObjPool__extend_listt popR R R t
|
ERROR_NO_8t idR R t TrueR t debug( R t autoIncreaset emptyObjR& ( ( s! .\\ServersRoute\Common\ObjPool.pyt alloc4 s( " c C s | j j | j sY t j d t j d t | } t j | | j j d S| j t
|
| j j | | j d 8_ | j j t j d t | d S( NR s Invild obj id = %s found!i s object id = %s( R R( R R R t
|
ERROR_NO_9R/ R R* R R R" t appendR R1 ( R t objR& ( ( s! .\\ServersRoute\Common\ObjPool.pyt freeJ s " c C s t | j S( N( R) R# ( R ( ( s! .\\ServersRoute\Common\ObjPool.pyt countW s c C s! | | j k r d S| j | S( N( R9 R+ R# ( R t index( ( s! .\\ServersRoute\Common\ObjPool.pyt atZ s c C s | j S( N( R ( R ( ( s! .\\ServersRoute\Common\ObjPool.pyt getAllocCnt_ s c C si t j d | j g t | j D] } t | j | j ^ q$ } | j j | | j j | d S( Ns increase size = %s(
|
R t infoR R R! R R R" R$ R# ( R R' t
|
extendList( ( s! .\\ServersRoute\Common\ObjPool.pyt __extend_listb s 1(
|
R R R R0 R4 R8 R9 R; R< R, ( ( ( s! .\\ServersRoute\Common\ObjPool.pyR
|
s c C s d d l m } d d l } | j d t d | j d d d d } d t | GHt d | j d d d d
|
} d t | GHd S( Niÿÿÿÿ( t
|
MMORPGPacks ObjPool.logR R i
|
R i s id(pool1) = %si s id(pool2) = %s( t ProtocolR@ R t InitMyLogR
|
t MMORPGPacketR/ ( R@ R t pool1t pool2( ( s! .\\ServersRoute\Common\ObjPool.pyt testh s t __main__( R R t DBCommonR t objectR R
|
RF R ( ( ( s! .\\ServersRoute\Common\ObjPool.pyt <module>
|
s
|
P
|
