* �����麯�������������ӵ������ô˻ص����� * @param client {aio_socket_stream*} �첽�ͻ����� * @return {bool} ���� true ��֪ͨ�������������� */
| 158 | * @return {bool} ���� true ��֪ͨ�������������� |
| 159 | */ |
| 160 | bool accept_callback(acl::aio_socket_stream* client) |
| 161 | { |
| 162 | // �����첽�ͻ������Ļص���������첽�����а� |
| 163 | io_callback* callback = new io_callback(client); |
| 164 | |
| 165 | // ע���첽���Ķ��ص����� |
| 166 | client->add_read_callback(callback); |
| 167 | |
| 168 | // ע���첽����д�ص����� |
| 169 | client->add_write_callback(callback); |
| 170 | |
| 171 | // ע���첽���Ĺرջص����� |
| 172 | client->add_close_callback(callback); |
| 173 | |
| 174 | // ע���첽���ij�ʱ�ص����� |
| 175 | client->add_timeout_callback(callback); |
| 176 | |
| 177 | // ���첽�������ݰ�ͷ |
| 178 | client->read(sizeof(DAT_HDR), __timeout); |
| 179 | return true; |
| 180 | } |
| 181 | }; |
| 182 | |
| 183 | static void usage(const char* procname) |
nothing calls this directly
no test coverage detected