ó
|
µ \c @ s d d l Z d d l Z d d l m Z m Z d d l m Z d d l Z d d l Z d d l Z d d l
|
Z
|
d d l m Z m Z m Z m Z m Z d d l m Z d d l m Z m Z m Z m Z d d l Z d d l m Z m Z m Z m Z m Z m Z d d l Z d d l! m" Z" m# Z# d d l$ Z$ d d l% Z% d d l m& Z& m' Z' d d
|
l( m) Z) d d l* m+ Z+ d d l m, Z, d d l- Z- d d l. Z. d d l/ Z/ d d l0 m1 Z1 d d l2 Z2 d d l( m3 Z3 e4 d Z5 d Z6 d Z7 d f d YZ8 e9 a: d Z; y d d l< Z< Wn e= k
|
r;d d l> Z< n Xd Z? d Z@ d ZA d ZB d ZC d ZD d ZE eF d k reD n d S( iÿÿÿÿN( t kbhitt getch( t sleep( t mylogt ConsoleCtrlt Timert ConsolePrintMgrt CommFunc( t MongoDBServer( t CtrlDBManagert LogCtrlDBt SysCtrlDBt
|
UserCtrlDB( t CommonDefinet GlobalFunctionst SingletonObjectt VersionNoDefinet EnvCheckt Stat( t RecvPackProtocolt
|
MMORPGPack( t errort GlobalVarDefine( t EventShellProxy( t CheckAndUpdateIndex( t FileLog( t Commands( t EventReports Config.DBConfigi i t LaunchControlMgrc B sP e Z e Z d Z e Z d Z d Z d Z d Z
|
d Z d Z RS( c C s4 t j j t j d } t j j | | _ d S( Ns _LaunchServerDLL.pyd( t ost patht joinR t
|
getAppPatht existst m_hasPyd( t selft pydPath( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt __init__@ s c C sA | j s d Sd d l } | j d k r: | j | _ n | j S( Niÿÿÿÿ( R" t Nonet LaunchServerDLLt m_lcDllInstancet IPY_LaunchControl( R# R' ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt GetInstanceD s c C sG | j s t S| j r t S| j rC | j j t | _ t Sd S( N( R" t Falset m_isLaunchControlInitOkt TrueR* t InitializeEx( R# ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt InitL s c C s# | j r | j j n d S( N( t IsInitOKR* t Deinitialize( R# ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt DeInitX s c C s | j s t S| j S( N( R" R+ R, ( R# ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyR0 \ s c C s | j s d S| j j | j j } | t k rQ d GHt j d S| t k r
| j j r
d GHt j d Sn d S( Ns" CallStop--------------------------s! CanExit--------------------------(
|
R0 R* t ProcessLogict GetStatet ssClosingR t CallStopt ssClosedt IsCanExitt CallExit( R# t state( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt ProcessLaunchControl` s
|
|
N( t __name__t
|
__module__R+ R" R& R( R, R% R* R/ R2 R0 R; ( ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyR ; s c C s t d k r t a n t S( N( t g_LaunchControlMgrR& R ( ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt GetLaunchControlMgrq s c C si t j d t j } | j d d | j \ } } d } d j g t | D] } d ^ qT } t j r d GH| GHn d t
|
j t
|
j f GHd t
|
j GHd t j GHd t j GHd
|
GHt j GH| GHt j } | r?d t | GHxK t t | D]4 } | | } d | | j | j | j f GHqWn | GHt j j d } d | j GHd | j GH| GHt j } d | j | j! f GHd | j | j" f GHx t | j# D]t } | j$ | }
|
d |
|
j |
|
j% |
|
j& f GHx; t |
|
j' D]' } d |
|
j | |
|
j( | f GHqWqÑWt) j* ryt) j+ j, } d | GHn t- j. s6d t/ j0 j1 t/ j0 j2 f GHd t/ j0 j3 GHd t/ j0 j4 GHd t/ j0 j5 GHd t/ j0 j6 GHd t/ j0 j7 GHd t/ j0 j8 GHd t/ j0 j9 GHd t/ j0 j: GHn | GHd t; j< j= GHd t; j< j> GHd S( Nt clsi s -t s >>>Runing Debug Version Now<<<s< SERVER_DATA_VERSION_NO = %d, GAMESERVER_DATA_VERSION_NO = %ds) GAMESERVER_GAMEWORLD_DATA_VERSION_NO = %ds python version = %ss pymongo version = %ss Status:s Threads(%s):s %2s %20s(%s) %st
|
CenterGates recv pack queue %ss send pack queue %ss %s request queue %ss %s answer queue %ss %s state %s BlockCnt %ss %s queue[%s] %ss Launchstate = %ss SendBytes = %s, RecvBytes = %ss packDispatchThreadCount = %ss Merge_packDispatchCount = %ss LogicProcessCount = %ss DBProcessCount = %ss DBProcessTime = %ss asyncoreLoopTime = %ss packDispatchThreadTime = %ss logicProcessThread = %ss PackPoolCount = %ss PackPoolAllocCount = %s(? R t systemR t GetDCCt GotoXYt GetWindowSizeR t rangeR t IsDebugR t SERVER_DATA_VERSION_NOt GAMESERVER_DATA_VERSION_NOt$ GAMESERVER_GAMEWORLD_DATA_VERSION_NOt syst version_infot pymongot versionR t getLogStaticDictt threadingt enumeratet lent getNamet identt isAliveR t getServerMgrt GetServert recvQueueCntt sendQueueSizeR t
|
getCtrlMgrt dbRequestQueueCntt dbAnswerQueueCntt getCtrlDBCntt getCtrlDBt getStatet BlockCntt getPrioorityQueueCntt getPriorityQueueSizeR? R0 R* R4 t DBConfigt MultiThreadingR t GetStatt SendBytest RecvBytest packDispatchThreadCountt Merge_packDispatchCountt LogicProcessCountt DBProcessCountt DBProcessTimet asyncoreLoopTimet packDispatchThreadTimet logicProcessThreadR t getPackPoolt countt getAllocCnt( t consolet consoleWinWidtht consoleWinHeightt splitChart it splitLinet
|
threadListt threadObjt serverObjt ctrlMgrt ctrlDBt jt Launchstate( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt updateServerStatus¨ sf (
|
+ !) !c C s d S( N( ( t msg( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt OnPythonErrorò s c C s d } t j j | s( t j | n t j | d t j j | d } t t _ t j | d t
|
j t j d t j d | t
|
j f d S( s
|
ÈÕÖ¾³õʼ»¯s D:\ServerLogt txts MongoDBServer.txtsU -------------------------------------------------------------------------------------s- Initialize log ok!log file = %s, isdebug = %sN( R R R! t makedirsR t
|
InitializeR R R t InitMyLogR RH t info( t logPatht logFileName( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt InitLogö s c C s¶ t j d t j j t j t j t j } t j d | t
|
j | } | s t j d t j d | } t j | t d d St j d t
|
j t j d d S( s ¼ÓÔØ°æ±¾sU -------------------------------------------------------------------------------------s
|
reading %st fatals Load version file %s failed!iÿÿÿÿNs Current Version = %s( R R R R R R R R t CFG_PATHt VERSION_FILE_NAMEt ServerVersiont LoadVersionFileR t formatMsgt ERROR_NO_12t DesignErrort exitt getCurrentVersion( t versionFileNamet loadOKR ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyR s $
|
c C so t j d t j d t j \ } } | sQ t j d | t d d St j d t j d d S( NsU -------------------------------------------------------------------------------------s Initializing console window...s) Disable system menu failed!errorInfo = %siÿÿÿÿs Initialize console window ok!( R R R t SetConsoleWindowR ( t resultt errorInfo( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt InitConsoleWindow s
|
c C s
|
t j t j rE t j j t j j n t j t j t
|
t j t j rÙ t j j t j t j t j t j t j t j } | s¹ t d d St j d t j t j f n t j d t j t j f t j d t j t j d t j t! t" t# j$ t j d t j d t j% t j& f t j' t j( t j) t j% t j& sÖt* j+ d t* j, d t j% t j& t j( t j) f } t j- | t. t d d St j d
|
t j d t j/ t j0 f t j' t j1 t j2 t j/ t j0 svt* j+ d t* j3 d t j/ t j0 t j1 t j2 f } t j- | t. t d d St j d t j d t j4 t j5 f t j' t j6 t j7 t j4 t j5 st* j+ d t* j8 d t j4 t j5 t j6 t j2 f } t j- | t. t d d St j d t9 j9 t j d d } x% t j j: sgd GHt; d qCWyát< j= } t< j< d } | j> d | t< j< } | j> d | t j? } | ræt< j< d t@ } | j> d | n tA jB } tC jC | } | jD | tE jE | }
|
| jD |
|
tF jF | } | jD | tG jG | } | tH _I tJ jJ | | | } tJ jJ | | | } | r»tK jG d | } tL jJ d | | | } n t j t jM t j d t jN r)| jO | jP | jP | jP | r)| jP | jP q)n | jP t jQ d | jP t jR d | rk| jP t jS d n tT jU t. tT jV t@ t j t jW t j d t j d tX jY jZ j[ d t\ j] t^ j^ d t_ t. t. } t@ } t j rt j j` n t ja tb jc d d } xtT jd rGt jN sIte jf } tg jh d t@ d d te jf | tj jk _l te jf } | jm te jf | tj jk _n | rÁ| jm n | jm te jf } | jm te jf | tj jk _o | r | jm n te jf } | jm te jf | tj jk _p | jq n tg jh d t@ d d t jr | s| js n tt r/tu } | d k r£q/n t. } t jv jw | | | 7} | jx d d k rÞq/n | jy } | jz } d } t{ | d k r%| d } | d } n tT j| | | d } t@ } q/q/WWn t} j* k
|
r} t* j+ d t* j~ d! | } t j | tT j n@ t* j+ d t* j d" t j } t j | tT j n X| j t jN r/ | j | j | j | r" | j | j n | j
n t j rE tE j n t j r[ t j n t j t j tb jc d d# GHt j r¢ t j j n d } xÆ tT j sp
|
t jr tt r« tu } | d k rè q« n t jv jw | | | 7} | jx d d k r
|
q« n | j d d } | d$ k rH
|
t q« n d# GHd } tb jc d t; d% q« q« Wt j d S(& Niÿÿÿÿs9 EventShellDLL InitOK,EventShellIP =%s,EventShellPort = %ds< SERVER_DATA_VERSION_NO = %d, GAMESERVER_DATA_VERSION_NO = %ds python version = %ss pymongo version = %ssU -------------------------------------------------------------------------------------s login on user db %s:%s...t DeployErrors: LoginMongoDB failed:ip = %s, port = %s, user = %s,pwd = %ss login on user db ok!s login on sys db %s:%s...s login on sys db ok!s login on log db %s:%s...s login on log db ok!t DBEventConnectChecks! Please start EventServer first!!!i RB t GMToolt Merget mergeServerLogicProcessThreadt MergeServer_PackDispatchi s9 MongoDBServer start OK!You can open CenterGateServer now!s PyMongoDBServer version = %sR@ RA g ð?i s i R s socket error!err = %ss unknown err = %ss press'exit' to ExitR gü©ñÒMbP?( R? R/ R0 R* t OnSelfReadyt OnSelfStartR t setServerStateR t mssNoneR R Rd t EventShellEnableR t GetEventShellProxyt InitDllt EventShellDllLogPatht EventShellIPt EventShellPortt EventShellGroupIDt EventShellServerIDt EventShellHeartIntervalR R R R RI RJ RL RM RN RO R R t PegasusCollectorProxyt InitCollectorDllt
|
USER_DB_IPt USER_DB_PORTt LoginMongoDBt userdb_usert
|
userdb_pwdR R t ERROR_NO_13R R- t SYS_DB_IPt SYS_DB_PORTt
|
sysdb_usert sysdb_pwdt ERROR_NO_14t LOG_DB_IPt LOG_DB_PORTt
|
logdb_usert logdb_pwdt ERROR_NO_15R t IsConnectedR R RW t AddServert IsMergeServerR+ R R[ R t addCtrlDBR
|
R t LogicProcessThreadR t g_logicProcessThreadt PackDispatchThreadt MergeServer_LogicProcessR¡ t
|
mssInitingRe t startAllt startt PyMongoDBPortt PyMongoDBPort_GMToolt MergeServerPortR t setActivet
|
setCanExitt
|
mssRunningt ctypest windllt kernel32t SetConsoleTitleAR R R R t OnSelfStartOKt removeConsoleHandlerR RC t isActivet timeitt default_timert asyncoret loopR& R Rf Rn t runRo Rp Rm t processAllSendQueueR; t TickR R t stdoutt writet findt stript splitRS t
|
processCmdt sockett ERROR_NO_16R R9 t ERROR_NO_17t tracebackt
|
format_exct stopt stopAllt IsOpenLogDBFileSavet ReleaseLogDBFileSaveMgrt FreeEventShellProxyt OnSelfCloseOKt isCanExitt replacet ExitR2 ( t isInitOKR t testEventConnectt ServerMgrR| t GMToolServerObjt isMergeServert MergeServerObjt ctrlDBMgrt sysCtrlDBt logCtrlDBt usrCtrlDBRp t packDispatchThreadt GMTool_packDispatchThreadR t Merge_packDispatchThreadt tmrUpdateServerStatust pauseUpdateServerStatusTimert usrCmdt tickt hitChart cmdListt usrParamt e( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt main! st
|
6
|
|
$4
|
$4
|
$4
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
|
|
|
|
|
c C s t j d d S( NR ( R R ( ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt testy s t __main__(G RL R t msvcrtR R t timeR RÛ Ré Ræ RÒ t CommonR R R R R t NetR t LogicProcessR R
|
R R RÇ t DBCommonR R R R R R R t ProtocolR R RÅ RN R R t
|
EventShellR t CollectionsR R R¡ RÈ RÙ t CmdShellR R¯ R t
|
__import__Rd R5 R7 R R& R> R? RQ t ImportErrort dummy_threadingR R R R R R R
|
R< ( ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt <module> s\ (" . 5 2 J ÿ Y
|
