Method on_message

lib_acl_cpp/src/ipc/rpc.cpp:222–237

* @override * ������ӿڣ����յ���Ϣʱ�Ļص����� * @param nMsg {int} �û����ӵ��Զ�����Ϣֵ * @param data {void*} ��Ϣ���� * @param dlen {int} ��Ϣ���ݵij��� */

	 * @param dlen {int} ��Ϣ���ݵij���
	 */
	void on_message(int nMsg, void* data, int dlen)
	{
		if (!(data && dlen == sizeof(RPC_DAT))) {
			abort();
		}
		RPC_DAT* dat = (RPC_DAT*) data;
		if (dat->req == NULL) {
			abort();
		}

		if (nMsg == RPC_MSG) {
			dat->req->rpc_onover();
		} else if (nMsg == RPC_SIG) {
			dat->req->rpc_wakeup(dat->ctx);
		}
	}

	// @override
	// ������ӿ�