Class http_ipc

lib_acl_cpp/src/http/http_service.cpp:490–546

//////////////////////////////////////////////////////////////////////////

class http_ipc : public ipc_client
{
public:
	http_ipc(acl_int64 magic) : ipc_client(magic) {}

	~http_ipc(void) {}

	// @override
	void on_message(int nMsg, void* data, int dlen)
	{
		if (dlen != sizeof(HTTP_IPC_DAT)) {
			abort();
		}
		HTTP_IPC_DAT* dat = (HTTP_IPC_DAT*) data;

		switch (nMsg) {
		case HTTP_MSG_HDR:
			dat->callback->on_hdr(dat->i_addr, dat->i_hdr_res);
			break;
		case HTTP_MSG_DAT:
			dat->callback->on_body(dat->i_ptr, dat->i_dlen);
			if (dat->i_ptr && dat->i_dlen > 0) {
				acl_myfree(dat->i_ptr);
			} else {
				// ���������������ٹ���
				dat->callback->destroy();
				if (dat->i_hdr_res) {
					http_hdr_res_free(dat->i_hdr_res);
				}
				this->close();  // �Զ�������������
			}
			break;
		case HTTP_MSG_ERR:
			dat->callback->on_error(dat->i_error);
			// ���������������ٹ���
			dat->callback->destroy();
			if (dat->i_hdr_res) {
				http_hdr_res_free(dat->i_hdr_res);
			}
			this->close();  // �Զ�������������
			break;
		default:
			// �������쳣��Ϣ
			logger_error("unknown ipc msg: %d", nMsg);
			break;
		}
	}

protected:
	// @override
	void on_close(void)
	{
		delete this;
	}
private:
	//HTTP_HDR_RES* hdr_res_;
};