Method handle_pkg

lib_acl_cpp/samples/aio/pkg_client/main.cpp:63–117

private:
	bool handle_pkg(acl::socket_stream& conn, int i)
	{
		DAT_HDR req_hdr;
		req_hdr.len = htonl(length_);
		ACL_SAFE_STRNCPY(req_hdr.cmd, "SEND", sizeof(req_hdr.cmd));

		// ��д����ͷ
		if (conn.write(&req_hdr, sizeof(req_hdr)) == -1) {
			printf("write hdr to server failed\r\n");
			return false;
		}

		// �������
		if (conn.write(req_dat_, length_) == -1) {
			printf("write dat to server failed\r\n");
			return false;
		}

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

		// �ȶ���Ӧͷ
		DAT_HDR res;
		if (conn.read(&res, sizeof(DAT_HDR)) == -1) {
			printf("read DAT_HDR error\r\n");
			return false;
		}

		// ����Ӧ�����ݳ���תΪ�����ֽ���
		res.len = ntohl(res.len);
		if (res.len <= 0) {
			printf("invalid length: %d\r\n", res.len);
			return false;
		}

		// ����Ƿ���Ҫ���·������Ӧ���ݵ��ڴ�
		if (res.len + 1 >= res_max_) {
			res_max_ = res.len + 1;
			res_dat_ = (char*) realloc(res_dat_, res_max_);
		}

		// �ٶ���Ӧ��
		if (conn.read(res_dat_, res.len) == -1) {
			printf("read data error, len: %d\r\n", res.len);
			return false;
		}

		res_dat_[res.len] = 0;
		if (i < 10) {
			printf("thread: %lu, cmd: %s, dat: %s, len: %d\r\n",
				(unsigned long) thread_id(), res.cmd,
				res_dat_, res.len);
		}

		return true;
	}

private:
	acl::string addr_;