ó
|
"Û!\c @ 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 s: | | _ | | _ | | _ d | _ t | _ d | _ d S( Ni ( t sessionIDt
|
clientGUIDt groupIDt* _MergeServerProxyClient__lastHeartbeatTickt Truet isValidt. _MergeServerProxyClient__lastSendHeartbeatTick( t selfR R R ( ( s .\MergeProxyClientMgr.pyt __init__ s c C s t | _ d S( N( R R ( R ( ( s .\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( ( s .\MergeProxyClientMgr.pyt checkHeartbeat s c C sG | j s t St } | j | k r) t S| | j | j k rC t St S( N( R R R R R ( R R ( ( s .\MergeProxyClientMgr.pyt shouldSendHeartbeat s c C s t | _ d S( N( R R ( R ( ( s .\MergeProxyClientMgr.pyt refreshSendHeartbeatTick, s ( t __name__t
|
__module__R R
|
R R R R ( ( ( s .\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 ( ( s .\MergeProxyClientMgr.pyR
|
1 s c C s | j j | S( N( R t get( R t guid( ( s .\MergeProxyClientMgr.pyt findClientByGUID6 s c C s | S( N( ( R R ( ( s .\MergeProxyClientMgr.pyt getCompoundKey9 s c C sC | | j | j <| | j | j <| j | j } | | j | <d S( N( R R R R R R R ( R t clientt compoundKey( ( s .\MergeProxyClientMgr.pyt addClient< s c C sÙ | j | } | s8 t | | | } | j | d S| 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 t has_keyR ( R R R R R t oldSessionIDt
|
compoudKeyt newCompoundKey( ( s .\MergeProxyClientMgr.pyt updateClientB s" c C s | j | } | j j | S( N( R R R ( R R R ( ( s .\MergeProxyClientMgr.pyt findClientByCompoundKeyY s c C s | j j | S( N( R R ( R R ( ( s .\MergeProxyClientMgr.pyt findClientBySessionID] s c C s | j j S( N( R t values( R ( ( s .\MergeProxyClientMgr.pyt getClientList` s (
|
R R R
|
R R R R# R$ R% R' ( ( ( s .\MergeProxyClientMgr.pyR 0 s c C s t s t a n t S( N( t __gMergeProxyClientMgrR ( ( ( s .\MergeProxyClientMgr.pyt getMergeProxyClientMgre s N( ( ( R R R t NoneR( R) ( ( ( s .\MergeProxyClientMgr.pyt <module> s &3
|
