| 260 | } |
| 261 | |
| 262 | void rpc_service::on_accept(aio_socket_stream* client) |
| 263 | { |
| 264 | // �����������������߳���Ϣ�� IPC ���Ӷ��� |
| 265 | ipc_client* ipc = NEW rpc_client(magic_); |
| 266 | ipc->open(client); |
| 267 | |
| 268 | // ������Ϣ�ص����� |
| 269 | ipc->append_message(RPC_MSG); |
| 270 | ipc->append_message(RPC_SIG); |
| 271 | ipc->wait(); |
| 272 | } |
| 273 | |
| 274 | #ifdef ACL_WINDOWS |
| 275 | void rpc_service::win32_proc(HWND hWnd, UINT msg, WPARAM wParam, LPARAM lParam) |
no test coverage detected