ó
|
QPc @ sI d d l m Z d d d YZ d d d YZ d a d Z d S(
|
iÿÿÿÿ( t timet MergeServerProxyClientc B s; e Z d Z d Z d Z d Z d Z d Z RS( i c C sC | | _ | | _ | | _ | | _ d | _ t | _ d | _ d S( Ni ( t sessionIDt
|
clientGUIDt operatort serverIDt* _MergeServerProxyClient__lastHeartbeatTickt Truet isValidt. _MergeServerProxyClient__lastSendHeartbeatTick( t selfR R R R ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt __init__ s c C s t | _ d S( N( R R ( R
|
( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt refreshHeartbeat s c C s+ t } | | j | j d k r' t St S( Ni ( R R t HeartbeatIntervalR t False( R
|
t now( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt checkHeartbeat s c C s4 | j s t St } | | j | j k r0 t St S( N( R R R R R ( R
|
R ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt shouldSendHeartbeat! s c C s t | _ d S( N( R R ( R
|
( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt refreshSendHeartbeatTick) s ( t __name__t
|
__module__R R R R R R ( ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyR
|
s t MergeServerProxyClientMgrc B sP e Z d Z d Z d Z d Z d Z d Z d Z d Z RS( c C s i | _ i | _ i | _ d S( N( t* _MergeServerProxyClientMgr__sessionIDIndext+ _MergeServerProxyClientMgr__clientGUIDIndext1 _MergeServerProxyClientMgr__operatorServerIDIndex( R
|
( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyR . s c C s | j j | S( N( R t get( R
|
t guid( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt findClientByGUID3 s c C s d | | f S( Ns [%s-%s]( ( R
|
R R ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt getCompoundKey6 s c C sI | | j | j <| | j | j <| j | j | j } | | j | <d S( N( R R R R R R R R ( R
|
t clientt compoundKey( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt addClient9 s c C sî | j | } | s; t | | | | } | j | d S| j } | j | j | j } | | _ | | _ | | _ t | _ | j | | } | j j
|
| r± | j | =n | | j | <| j j
|
| rÝ | j | =n | | j | <d S( N( R R R R R R R R R R t has_keyR ( R
|
R R R R R t oldSessionIDt
|
compoudKeyt newCompoundKey( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt updateClient? s$ c C s" | j | | } | j j | S( N( R R R ( R
|
R R R ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt findClientByCompoundKeyW s c C s | j j | S( N( R R ( R
|
R ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt findClientBySessionID[ s c C s | j j S( N( R t values( R
|
( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt getClientList^ s (
|
R R R R R R R$ R% R& R( ( ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyR - s c C s t s t a n t S( N( t __gMergeProxyClientMgrR ( ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt getMergeProxyClientMgrc s N( ( ( R R R t NoneR) R* ( ( ( s4 .\server\db\PyMongoDataServer\MergeProxyClientMgr.pyt <module> s #4
|
