| 58 | } |
| 59 | |
| 60 | void ManagerTimer::timer_callback(unsigned int) |
| 61 | { |
| 62 | ClientConnection* client; |
| 63 | |
| 64 | // �ӿͻ��˹������������ӳٴ������Ŀͻ������Ӷ��� |
| 65 | // �����ݸ�����ˣ��������ʧ�ܣ����ٴ�����ͻ��˹��� |
| 66 | // �������´ζ�ʱ���ٴγ��Դ��� |
| 67 | |
| 68 | logger("total client: %d, total server: %d", |
| 69 | (int) ClientManager::get_instance().length(), |
| 70 | (int) ServerManager::get_instance().length()); |
| 71 | |
| 72 | while (true) |
| 73 | { |
| 74 | client = ClientManager::get_instance().pop(); |
| 75 | if (client == NULL) |
| 76 | break; |
| 77 | |
| 78 | if (transfer(client) == true) |
| 79 | { |
| 80 | ClientManager::get_instance().del(client); |
| 81 | delete client; |
| 82 | continue; |
| 83 | } |
| 84 | |
| 85 | // ����ڹ涨��ʱ������Ȼû�з�������������ӣ� |
| 86 | // ��ֱ��ɾ���ö��� |
| 87 | if (client->expired()) |
| 88 | { |
| 89 | logger_error("no server side, client(%s) expired!", |
| 90 | client->get_peer()); |
| 91 | delete client; |
| 92 | } |
| 93 | else |
| 94 | { |
| 95 | logger_warn("set client(%s) into queue", |
| 96 | client->get_peer()); |
| 97 | ClientManager::get_instance().set(client); |
| 98 | } |
| 99 | break; |
| 100 | } |
| 101 | } |