ó
|
Sªw\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\1.6\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\1.6\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\1.6\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\1.6\main.pyt DeInitX s c C s | j s t S| j S( N( R" R+ R, ( R# ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\1.6\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\1.6\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\1.6\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\1.6\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\1.6\main.pyt updateServerStatus¨ sf (
|
+ !) !c C s t j d S( N( t PegasusCollectorProxyt ErrorReport( t msg( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\1.6\main.pyt OnPythonErrorò s c C s d } t j j | s( t j | n t j | d t j j | d } 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 t InitMyLogR RH t info( t logPatht logFileName( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\1.6\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\1.6\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\1.6\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% t _% 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 j0 t j1 f t j( t j2 t j3 t j0 t j1 st+ j, d t+ j4 d t j0 t j1 t j2 t j3 f } t j. | t/ t d d St j d t j d t j5 t j6 f t j( t j7 t j8 t j5 t j6 s t+ j, d t+ j9 d t j5 t j6 t j7 t j3 f } t j. | t/ t d d St j d t: j: t j d d } x% t j j; spd GHt< d qLWyát= j> } t= j= d } | j? d | t= j= } | j? d | t j@ } | rït= j= d tA } | j? d | n tB jC } tD jD | } | jE | tF jF | }
|
| jE |
|
tG jG | } | jE | tH jH | } | tI _J tK jK | | | } tK jK | | | } | rÄtL jH d | } tM jK d | | | } n t j t jN t j d t jO r2| jP | jQ | jQ | jQ | r2| jQ | jQ q2n | jQ t jR d | jQ t jS d | rt| jQ t jT d n tU jV t/ tU jW tA t j t jX t j d t j d tY jZ j[ j\ d t] j^ t_ j_ d t` t/ t/ } tA } t j rt j ja n t jb tc jd d d } xtU je rPt jO sRtf jg } th ji d tA d d tf jg | tk jl _m tf jg } | jn tf jg | tk jl _o | rÊ| jn n | jn tf jg } | jn tf jg | tk jl _p | r| jn n tf jg } | jn tf jg | tk jl _q | jr n th ji d tA d d t js | s| jt n tu r8tv } | d k r¬q8n t/ } t jw jx | | | 7} | jy d d k rçq8n | jz } | j{ } d } t| | d k r.| d } | d } n tU j} | | d } tA } q8q8WWn t~ j+ k
|
r} t+ j, d t+ j d! | } t j | tU j n@ t+ j, d t+ j d" t j } t j | tU j n X| j
t jO r8 | j
| j
| j
| r+ | j
| j
n | j n t j rN tF j n t j rd t j n t j t j tc jd d d# GHt j r« t j j n d } xÆ tU j sy
|
t js tu r´ tv } | d k rñ q´ n t jw jx | | | 7} | jy d d k r&
|
q´ n | j d d } | d$ k rQ
|
t q´ n d# GHd } tc jd 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 R t InitCollectorDllR
t
|
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\1.6\main.pyt main sv
|
6
|
|
$4
|
$4
|
$4
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
|
|
|
|
|
c C s t j d d S( NR ( R R ( ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\1.6\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\1.6\main.pyt <module> s\ (" . 5 2 J ÿ Z
|
