| 56 | } |
| 57 | |
| 58 | virtual bool read_wakeup() |
| 59 | { |
| 60 | // ����״̬ |
| 61 | rpc_read_wait_del(); |
| 62 | rpc_add(); |
| 63 | |
| 64 | // ���첽����������ȥ���Ը��첽���ļ�� |
| 65 | client_->disable_read(); |
| 66 | |
| 67 | // ����һ�� http �Ự���� |
| 68 | rpc_manager::get_instance().fork(http_); |
| 69 | |
| 70 | return true; |
| 71 | } |
| 72 | |
| 73 | private: |
| 74 | aio_socket_stream* client_; |
nothing calls this directly
no test coverage detected