Class rpc_client

lib_acl_cpp/src/ipc/rpc.cpp:208–246

// ����ʵ�������߳�������

class rpc_client : public ipc_client
{
public:
	rpc_client(acl_int64 magic) : ipc_client(magic) {}
	~rpc_client(void) {}

protected:
	/**
	 * @override
	 * ������ӿڣ����յ���Ϣʱ�Ļص�����
	 * @param nMsg {int} �û����ӵ��Զ�����Ϣֵ
	 * @param data {void*} ��Ϣ����
	 * @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
	// ������ӿ�
	void on_close(void)
	{
		delete this;
	}
private:
};

#ifdef ACL_WINDOWS
#include <process.h>