ó
|
:[c @ s¡ d d l Z d d l m Z d d l Z d d l Z d d l m Z d d l Z d d l Z d e f d YZ
|
d d
|
d YZ d a d Z d Z d S( iÿÿÿÿN( t ProjectRobot( t Threadt AIThreadc B s# e Z d Z d Z d Z RS( c C sT t j | d d d | | | _ g | _ d | _ d | _ d | _ d | _ d S( Ns AIThreadPy_%si i ( R t __init__t Nonet robotMgrt AIListt lastTimet badRobotCntt ProcessFindTJGTimet lastLoginTime( t selfR t index( ( s .\\RobotMgr.pyR s c
|
C s& t j d | j xt r!yºt j } | j r2| | j | j k r2| | _ | j j } | j j j
|
} g } xx t t | D]d } | j } | d | k rÆ d G| d GHq n | j j | } | j | | d k r Pq q Wx6 | D]+ } | sq n | j s | j q q Wn xs t | j j D]\ } | | j j k rgPn y | j j | } Wn Pn X| sqHn | j j qHW| j s½| | _ n t j d x¨ t | j j D] } | j j | } | s&d GH| j j | | j d 7_ Pn | j ràd GHt j d | j | j j | | j d 7_ PqàqàWt j } | | j d k rÙd
|
| j j | j j f GH| | _ | j rÙd | j GHqÙn Wq t k
|
r } t j d t | t j d t! j" q Xq Wd S( Ns thread %s starti s ÕýÔڵǼÖÐ------i
|
g{®Gáz?s ====ûÓлúÆ÷ÈËs ++++++±»´Ý»Ùs GetNeedDestroy __peer:0x%08X i s ÍÑ»ú¹ÒÍæ¼ÒÊýÁ¿: %s - %ss ²Î¿¼-ÀúÊ·Òì³£ÍÑ»ú¹Ò´ÎÊý£º%ss AIThread: %s(# t loggingt infot getNamet Truet timeR
|
R R t GetRobotAccIDListt dbRobott GetTokenListt xranget lent popt AddRobott appendt IsConnectedt ReCreateRobott GetRobotCountt GetRobott GetAIMgrt ProcessAIt sleept RemoveR t GetNeedDestroyt debugt GetPeerValueR t GetLoginOKRobotCountt Exceptiont errort strt tracebackt print_exc(
|
R t nowTimet logoningListt tokenListt robotListt it tokenInfot robotR t e( ( s .\\RobotMgr.pyt runThread st ! c C s | j } | d S( N( R3 ( R t runM( ( s .\\RobotMgr.pyt runp s ( t __name__t
|
__module__R R3 R5 ( ( ( s .\\RobotMgr.pyR s St RobotMgrc B sk e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z d
|
Z RS( c C sS | | _ d | _ g | _ g | _ | | _ i | _ t | d } | j d S( Ni ( t _RobotMgr__asioMgrt _RobotMgr__robotNumt _RobotMgr__robotst _RobotMgr__robotAccIDsR t TeamMgrR t start( R t asioMgrR t th( ( s .\\RobotMgr.pyR y s c C s> g | _ x+ | j D] } | j j | j d q W| j S( Ni ( R< R; R t GetRobotConfig( R R1 ( ( s .\\RobotMgr.pyR s c C s: t j d | f t | j | } | j j | | S( Ns Create Robot index:%s.....( R R# R R9 R; R ( R R0 R1 ( ( s .\\RobotMgr.pyR s c C s t | j S( N( R R; ( R ( ( s .\\RobotMgr.pyR s c C s7 d } x* | j D] } | j r | d 7} q q W| S( Ni i ( R; R ( R t nR1 ( ( s .\\RobotMgr.pyt GetConnectedRobotCount s
|
c C sM d } x@ | j D]5 } | j r/ | d 7} q t j d | j q W| S( Ni i s !!!not login :0x%08X( R; t GetIsLoginOKR R# R$ ( R RB R1 ( ( s .\\RobotMgr.pyR% ¤ s c C s | j | S( N( R; ( R R ( ( s .\\RobotMgr.pyR » s c C s | j j | d S( N( R; t remove( R R1 ( ( s .\\RobotMgr.pyR! À s c C sP | j j } t j d | | j | | j k rL | j | n d S( Ns DisconnectServer for %s( t GetPlayerInfot GetAccIDR R# t DestroyRobotR; R! ( R R1 t accID( ( s .\\RobotMgr.pyt DisconnectServerÄ s
|
|
c C s. t j d | | j | } | s* t Sd S( Ns StartAI for %d( R R# R t False( R R R1 ( ( s .\\RobotMgr.pyt StartAIÎ s c C s. t j d | | j | } | s* t Sd S( Ns StopAI for %d( R R# R RK ( R R R1 ( ( s .\\RobotMgr.pyt StopAIÚ s ( R6 R7 R R R R RC R% R R! RJ RL RM ( ( ( s .\\RobotMgr.pyR8 w s
|
|
c C s t s t | | a n d S( N( t __gRobotMgrR8 ( R? R ( ( s .\\RobotMgr.pyt CreateRobotMgr s c C s t S( N( RN ( ( ( s .\\RobotMgr.pyt GetRobotMgr s ( ( R t ProjectBinding.ProjectRobotR t& ConfigurationReader.RobotsConfigReadert ConfigurationReadert# ConfigurationReader.ConfigIniReadert threadingR R) R R R8 R RN RO RP ( ( ( s .\\RobotMgr.pyt <module> s g
|
