B
|
©ÍÕdq ã @ s" d dl Z d dlZG dd dZdS )é Nc @ sd e Zd ZdZi Zi Zi Zedd Zedd Z edd Z
|
edd Z ed
|
d Z ed d Z dS )ÚClientSocketManagerÚtradec C sb || j krB|| jkr g | j|< | j| ||f¡ t ¡ | j|< n ||f| j|< t ¡ | j|< d S )N)ÚCLIENT_TYPE_TRADEÚsocket_client_dictÚappendÚ threadingÚLockÚsocket_client_lock_dict)ÚclsÚ_typeÚridÚsk© r ú2D:\workspace\GP\gp_middle_server\socket_manager.pyÚ
|
add_client s
|
|
|
z ClientSocketManager.add_clientc sà | j kr| jkrÜt j| fdddd}xª|D ]H}|d jkr6y j|d jddrd|S W q6 tjk
|
r| Y q6X q6W nX| jkrÜy6 j| }|d jkr j|d jddrÂ|S W n tjk
|
rÚ Y nX d S )Nc s" | d j kr j | d ¡S dS )Nr )Úactive_client_dictÚget)Úx)r
|
r r Ú<lambda> ó z4ClientSocketManager.acquire_client.<locals>.<lambda>T)ÚkeyÚreverser F)Úblocking)r r Úsortedr Úacquirer Ú TimeoutError)r
|
r Z client_listÚdr )r
|
r Úacquire_client s(
|
|
|
|
|
z"ClientSocketManager.acquire_clientc C s || j kr| j | ¡ d S )N)r Úrelease)r
|
r r r r Úrelease_client2 s
|
z"ClientSocketManager.release_clientc C s¢ || j kr| j |¡ x| jD ]|}t| j| tkrhxd| j| D ]"}|d |kr@| j| |¡ P q@W q t| j| tkr | j| d |kr | j |¡ P q W d S )Nr )r Úpopr ÚtypeÚlistÚremoveÚtuple)r
|
r Útr r r r Ú
|
del_client8 s
|
z ClientSocketManager.del_clientc C s t ¡ | j|< d S )N)Útimer )r
|
r r r r ÚheartK s zClientSocketManager.heartc C s8 x2| j ¡ D ]$}t ¡ | j | dkr | |¡ q W d S )Né )r Úkeysr' r& )r
|
Úkr r r Údel_invalid_clientsO s z'ClientSocketManager.del_invalid_clientsN)Ú__name__Ú
|
__module__Ú __qualname__r r r r Ú classmethodr r r r& r( r, r r r r r s r )r r' r r r r r Ú<module> s
|
