ó
|
lÆ{Pc @ s d d l m Z d d l Z d d l m Z d d l m Z d e j f d YZ d e j f d YZ d a d Z d S(
|
iÿÿÿÿ( t AsyncoreServerN( t Singleton( t SingletonObjectt MongoDBServerc B s2 e Z d e d Z d Z d Z d Z RS( iÿÿÿÿc C s# t j j | d | | | _ d S( NR ( R t AsynCoreServert __init__t _MongoDBServer__notifyPrepare( t selft MaxClientCntt notifyPrepare( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR s c C s" t j | | | | | j } | S( s ½ÓÊÕÁ¬½Óʼþ֪ͨ( t MongoDBServerClientR ( R t sockt addrt onClientDisconnectt recvQueuet client( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt onAcceptClient s c C s t j j } | j | | | j _ | | j _ | | j _ | | j _ | | j _ | j
|
| | j | d S( N( R t getPackPoolt alloct setSessionIDt getPackHeadt sessionIDt poolIndext typet
|
dstSvrTypet
|
srcSvrTypet setBuffert pushSend( R t sendViaSessionIDR R R R R t buft sendPack( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt packSendBySessionID& s c C s | j j | S( N( t clientMgrt getClientSessionIDByIndex( R t index( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR! 7 s ( t __name__t
|
__module__t TrueR R R R! ( ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR s t MongoDBServerMgrc B sb e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z RS(
|
c C s i | _ d S( N( t _MongoDBServerMgr__ServersDict( R ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR I s c C s( x! | j j D] } | j q Wd S( N( R' t valuest processSendQueue( R t v( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt processAllSendQueueM s c C s' | j j | r t S| | j | <t S( N( R' t has_keyt FalseR% ( R t Namet Server( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt AddServerQ s c C s | j j | d S( N( R' t gett None( R R. ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt GetServerY s c C s( x! | j j D] } | j q Wd S( N( R' R( t stop( R t oServer( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR4 c s c C s/ | j | j } | r+ | j | n d S( N( t FindServerByClientSessionIDt getSessionIDR ( R t packR5 ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR o s c C s i | _ d S( N( R' ( R ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt Clearu s c C s& | j | } | r" | j | Sd S( Niÿÿÿÿ( R3 R! ( R t nameR" t server( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt getClientSessionIDByNamey s c C s1 x* | j j D] } | j | r | Sq Wd S( N( R' R( t FindClientBySessionIDR2 ( R R R; ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR6 s c C s; | j | } | r7 | j | | | | | | | n d S( N( R6 R ( R R R R R R R R R; ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR
s ( R# R$ R R+ R0 R3 R4 R R9 R< R6 R ( ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyR& G s
|
c C s t r
|
t St a t S( N( t __MongoDBServerMgrR& ( ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt getServerMgr s ( t NetCoreR R
|
t CommonR t DBCommonR R R R& R2 R> R? ( ( ( s2 .\server\db\PyMongoDataServer\Net\MongoDBServer.pyt <module> s 7C
|
