ó
|
c~Zc @ 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 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. sHd 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: 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& CreateRole_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! CreateRole_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¨ sh (
|
+ !) !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< d } | j> d | t< j< } | j> d | t< j< d t? } | j> d | t@ jA } tB jB | } | jC | tD jD | }
|
| jC |
|
tE jE | } | jC | tF jF | } | tG _H tI jI | | | } tI jI | | | } tI jI | | | } tJ jF d | } tK jI d | | | } t j t jL t j d t jM rC| jN | jO | jO | jO | jO | jO | jO n | jO t jP d | jO t jQ d | jO t jR d | jO t jS d 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 r3t j j` n t ja tb jc d d } x@tT jd rt jM ste jf } tg jh d t? d d te jf | tj jk _l te jf } | jm te jf | tj jk _n | jm te jf } | jm te jf | tj jk _o | jm te jf } | jm te jf | tj jk _p | jm te jf } | jm te jf | tj jk _q | jr ts jt n tg jh d t? d d t ju | sÊ| jv n tw rStx } | d k rîqSn t. } t jy jz | | | 7} | j{ d d k r)qSn | j| } | j} } d } t~ | d k rp| d } | d } n tT j | | d } t? } qSqSWWn 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 jM r{ | j | j | j | j | j | j | j n t j r tD 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 s¼
|
t ju tw r÷ tx } | d k r4
|
q÷ n t jy jz | | | 7} | j{ d d k ri
|
q÷ n | j d d } | d% k r
|
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
|
CreateRolet 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 AddServerR+ R R[ R t addCtrlDBR
|
R t LogicProcessThreadR t g_logicProcessThreadt PackDispatchThreadt MergeServer_LogicProcessR£ t
|
mssInitingRe t startAllt startt PyMongoDBPortt PyMongoDBPort_CreateRolet PyMongoDBPort_GMToolt MergePortR 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 Rq Rm t processAllSendQueueR t OnTimeCloseScribeTxtR; 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 CreateRoleServerObjt GMToolServerObjt MergeServerObjt ctrlDBMgrt sysCtrlDBt logCtrlDBt usrCtrlDBRq t packDispatchThreadt CreateRole_packDispatchThreadt GMTool_packDispatchThreadR¢ t Merge_packDispatchThreadt tmrUpdateServerStatust pauseUpdateServerStatusTimert usrCmdt tickt hitChart cmdListt usrParamt e( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt main! sx
|
6
|
|
$4
|
$4
|
$4
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
|
|
|
|
|
|
|
c C s t j d d S( NR ( R R ( ( ( sA .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\main.pyt testm 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 ÿ M
|
