| 19 | } |
| 20 | |
| 21 | void ClientConnection::run() |
| 22 | { |
| 23 | // �����Ƚ�����Ϊ����״̬����������ߵ��ö�ʱ�����̷��� -1 |
| 24 | acl_non_blocking(conn_->sock_handle(), ACL_BLOCKING); |
| 25 | |
| 26 | // ���������ַ����̽��ͻ������ִ�������� |
| 27 | if (ManagerTimer::transfer(this) == false) |
| 28 | // �������������ʧ�ܣ��������������У��ɶ�ʱ�� |
| 29 | // ����� |
| 30 | ClientManager::get_instance().set(this); |
| 31 | else |
| 32 | { |
| 33 | // ���ԴӼ�����ɾ�� |
| 34 | ClientManager::get_instance().del(this); |
| 35 | delete this; |
| 36 | } |
| 37 | } |
| 38 | |
| 39 | bool ClientConnection::expired() const |
| 40 | { |
nothing calls this directly
no test coverage detected