| 182 | |
| 183 | private: |
| 184 | bool handle_client(acl::aio_socket_stream* client) { |
| 185 | // �����첽�ͻ������Ļص���������첽�����а� |
| 186 | io_callback* callback = new io_callback(client); |
| 187 | |
| 188 | // ע���첽���Ķ��ص����� |
| 189 | client->add_read_callback(callback); |
| 190 | |
| 191 | // ע���첽����д�ص����� |
| 192 | client->add_write_callback(callback); |
| 193 | |
| 194 | // ע���첽���Ĺرջص����� |
| 195 | client->add_close_callback(callback); |
| 196 | |
| 197 | // ע���첽���ij�ʱ�ص����� |
| 198 | client->add_timeout_callback(callback); |
| 199 | |
| 200 | // ���������������ʱ |
| 201 | if (__max > 0) { |
| 202 | client->set_buf_max(__max); |
| 203 | } |
| 204 | |
| 205 | // ���첽����һ������ |
| 206 | client->gets(__timeout, false); |
| 207 | return true; |
| 208 | } |
| 209 | }; |
| 210 | |
| 211 | class mytimer : public acl::aio_timer_callback |
nothing calls this directly
no test coverage detected