ó
|
PºÆgc @ 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 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 l0 Z0 d d l1 m2 Z2 m3 Z3 d d l4 Z4 d d l) m5 Z5 d d l6 Z6 e7 d Z8 d Z9 d Z: d f d YZ; e< a= d Z> y d d l? Z? Wn e@ k
|
rSd d lA Z? n Xd ZB d ZC d ZD d ZE d ZF d ZG d ZH eI d k r©eG n d S( iÿÿÿÿN( t kbhitt getch( t sleep( t mylogt ConsoleCtrlt Timert ConsolePrintMgrt CommFunct
|
CommFuncEx( 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 Commandst ReloadModule( 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( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt __init__A 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) ( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt GetInstanceE 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% ( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt InitM s c C s# | j r | j j n d S( N( t IsInitOKR, t Deinitialize( R% ( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt DeInitY s c C s | j s t S| j S( N( R$ R- R. ( R% ( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyR2 ] 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--------------------------(
|
R2 R, t ProcessLogict GetStatet ssClosingR t CallStopt ssClosedt IsCanExitt CallExit( R% t state( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt ProcessLaunchControla s
|
|
N( t __name__t
|
__module__R- R$ R( R* R. R' R, R1 R4 R2 R= ( ( ( s@ .\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 ( ( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt GetLaunchControlMgrr s c C s 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> GH| GHd t t? 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 = %ss PlayerPackDataCount = %s(A 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 getPriorityQueueSizeRA R2 R, R6 t DBConfigt MultiThreadingR t GetStatt SendBytest RecvBytest packDispatchThreadCountt Merge_packDispatchCountt LogicProcessCountt DBProcessCountt DBProcessTimet asyncoreLoopTimet packDispatchThreadTimet logicProcessThreadR t getPackPoolt countt getAllocCntt
|
PyGameDatat g_packDataDict( t consolet consoleWinWidtht consoleWinHeightt splitChart it splitLinet
|
threadListt threadObjt serverObjt ctrlMgrt ctrlDBt jt Launchstate( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt updateServerStatus© sj (
|
+ !) !c C s t j d S( N( t PegasusCollectorProxyt ErrorReport( t msg( ( s@ .\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 j | d t j
|
t j d t j d | t j
|
f d S( s
|
ÈÕÖ¾³õʼ»¯s C:\ServerLogt txts MongoDBServer.txtsU -------------------------------------------------------------------------------------s- Initialize log ok!log file = %s, isdebug = %sN( R R R# t makedirsR t
|
InitializeR! R t InitMyLogR RJ t info( t logPatht logFileName( ( s@ .\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 ( ( s@ .\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( ( s@ .\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 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/ | t0 t d d St j d
|
t j d t j1 t j2 f t j) t j3 t j4 t j1 t j2 st, j- d t, j5 d t j1 t j2 t j3 t j4 f } t j/ | t0 t d d St j d t j d t j6 t j7 f t j) t j8 t j9 t j6 t j7 s)t, j- d t, j: d t j6 t j7 t j8 t j4 f } t j/ | t0 t d d St j d t; j; t j d d } t j rx( t j j< sd GHt= d q_Wn t j> rt? j@ jA t j> rt jB } tC } x t? jD t j> D] \ } } } | jE d rëqÇn x` | D]X } | jE | s qòn t0 } tF | d k ròd | } t jG | t d d SqòWqÇW| rtH jI d d tH jJ d k rt d d Sqn yátK jL } tK jK d }
|
| jM d |
|
tK jK } | jM d | t jN } | rtK jK d tC } | jM d | n tO jP } tQ jQ | } | jR | tS jS | } | jR | tT jT | } | jR | tU jU |
|
} | tV _W tX jX |
|
| | } tX jX | | | } | rÝtY jU d | } tZ jX d | | | } n t j t j[ t j d t j\ rK| j] | j^ | j^ | j^ | rK| j^ | j^ qKn |
|
j^ t j_ d | j^ t j` d | r| j^ t ja d n tb jc t0 tb jd tC t j t je t j d t j d tf jg jh ji d tj jk tl jl d tm t0 t0 } tC } t j r1t j jn n t jo t? jp d d } xtb jq ri t j\ sktr js } tt ju d tC d d tr js | tw jx _y tr js } | jz tr js | tw jx _{ | rã| jz n | jz tr js } | jz tr js | tw jx _| | r/| jz n tr js } | jz tr js | tw jx _} | j~ n tt ju d tC d d t j | s¡| j n t rQt } | d! k rÅqQn t0 } t j j | | | 7} | j
d" d k r qQn | j } | j } d } tF | d# k rG | d! } | d } n tb j | | d } tC } qQqQWWn t j, k
|
r¶ } t, j- d$ t, j d% | } t jG | tb j n@ t, j- d$ t, j d& t j } t jG | tb j n X| j t j\ rQ
|
| j | j | j | rD
|
| j | j n | j n t j rg
|
tS j n t j r}
|
t j n t j t j t? jp d d' GHt j rÄ
|
t j j n d } xÆ tb j s t j t rÍ
|
t } | d! k r
|
qÍ
|
n t j j | | | 7} | j
d" d k r? qÍ
|
n | j d" d } | d( k rj t qÍ
|
n d' GHd } t? jp 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 t BackupsF Íæ¼Ò±¸µµ¸öÊý´óÓÚ1¸ö£¬Çë¼ì²é±¸µµ×¼È·ÐÔºóÔÙÊÖ¶¯Æô¶¯·þÎñÆ÷!!!filenames=%ss Íæ¼Ò±¸µµÈ·ÈÏsD ´æÔÚÍæ¼Ò±¸µµ£¬·þÎñÆ÷Æô¶¯ºóÍæ¼Ò±¸µµ½«×Ô¶¯Èë¿â£¬ÊÇ·ñʹÓÃÍæ¼Ò±¸µµÆô¶¯£¿RD t GMToolt Merget mergeServerLogicProcessThreadt MergeServer_PackDispatchi s9 MongoDBServer start OK!You can open CenterGateServer now!s PyMongoDBServer version = %sRB RC g ð?i s i R s socket error!err = %ss unknown err = %ss press'exit' to ExitR gü©ñÒMbP?( RA R1 R2 R, t OnSelfReadyt OnSelfStartR t setServerStateR t mssNoneR R R Rf t EventShellEnableR t GetEventShellProxyt InitDllt EventShellDllLogPatht EventShellIPt EventShellPortt EventShellGroupIDt EventShellServerIDt EventShellHeartIntervalR R R R RK RL RN RO RP RQ 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 t PlayerBakRootR R R# t PlayerBakFileTypeR- t walkt endswithRU R R t
|
MessageBoxt MB_OKCANCELR RY t AddServert IsMergeServerR
|
R] R t addCtrlDBR R t LogicProcessThreadR t g_logicProcessThreadt PackDispatchThreadt MergeServer_LogicProcessR¨ t
|
mssInitingRg t startAllt startt PyMongoDBPortt PyMongoDBPort_GMToolt MergeServerPortR t setActivet
|
setCanExitt
|
mssRunningt ctypest windllt kernel32t SetConsoleTitleAR R R R
t OnSelfStartOKt removeConsoleHandlerRE t isActivet timeitt default_timert asyncoret loopR( R Rh Rp t runRq Rr Ro t processAllSendQueueR= t TickR R t stdoutt writet findt stript splitt
|
processCmdt sockett ERROR_NO_16R; t ERROR_NO_17t tracebackt
|
format_exct stopt stopAllt IsOpenLogDBFileSavet ReleaseLogDBFileSaveMgrt FreeEventShellProxyt OnSelfCloseOKt isCanExitt replacet ExitR4 ( t isInitOKR t testEventConnectt fileTypet
|
havePDFilet parentt _t filenamest filenamet ServerMgrR t GMToolServerObjt isMergeServert MergeServerObjt ctrlDBMgrt sysCtrlDBt logCtrlDBt usrCtrlDBRr t packDispatchThreadt GMTool_packDispatchThreadR§ t Merge_packDispatchThreadt tmrUpdateServerStatust pauseUpdateServerStatusTimert usrCmdt tickt hitChart cmdListt usrParamt e( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt main# s
|
|
6
|
|
$4
|
$4
|
$4
|
|
"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
|
|
|
|
|
c C s t j d d S( NR ( R R ( ( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt test s t __main__(J RN R t msvcrtR R t timeR Rç Rõ Rò RÞ t CommonR R R R R R t NetR t LogicProcessR
|
R R R RÓ t DBCommonR R R R R R R t ProtocolR R RÑ RP R R t
|
EventShellR t CollectionsR R R¨ RÔ Rå t CmdShellR R R R Rv t
|
__import__Rf R7 R9 R R( R@ RA RS t ImportErrort dummy_threadingR
R R R R¡ R R R> ( ( ( s@ .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt <module> s^ ." . 5 2 L ÿ q
|
