| 21 | } |
| 22 | |
| 23 | void http_rpc::rpc_onover() |
| 24 | { |
| 25 | // ���� rpc ���� |
| 26 | rpc_del(); |
| 27 | |
| 28 | if (!proc_quit_ && keep_alive_) |
| 29 | { |
| 30 | rpc_read_wait_add(); |
| 31 | |
| 32 | // ����첽���Ƿ�ɶ� |
| 33 | client_->read_wait(10); |
| 34 | } |
| 35 | else |
| 36 | // �ر��첽������ |
| 37 | client_->close(); |
| 38 | |
| 39 | // �ͻ��˷�����Ҫ������������˳������� |
| 40 | if (proc_quit_) |
| 41 | handle_.stop(); |
| 42 | } |
| 43 | |
| 44 | // ���� service_.rpc_fork ���� RPC ��������߳��е��ñ����� |
| 45 | // ��������������ģ�鷢����������Ϣ |
nothing calls this directly
no test coverage detected