Method read_frame_head

lib_acl_cpp/src/http/websocket.cpp:404–465

#define	ntoh64(val) hton64(val)

bool websocket::read_frame_head(void)
{
	reset();

	unsigned char buf[8];

	if (client_.read(buf, 2) == -1) {
		if (last_error() != ACL_ETIMEDOUT) {
			//logger_error("read first two char error: %d, %s",
			//	last_error(), last_serror());
		}
		return false;
	}

	update_head_2bytes(buf[0], buf[1]);

	size_t count;

	// payload_len: <= 125 | 126 | 127

	if (header_.payload_len == 126) {
		count = 2;
	} else if (header_.payload_len > 126) {
		count = 8;
	} else {
		count = 0;
	}

	if (count > 0) {
		int  ret;

		if ((ret = client_.read(buf, count)) == -1) {
			if (last_error() != ACL_ETIMEDOUT) {
				logger_error("read ext_payload_len error:"
					" %d, %s", last_error(), last_serror());
			}
			return false;
		} else if (ret == 2) {
			unsigned short n;
			memcpy(&n, buf, ret);
			header_.payload_len = ntohs(n);
		} else {
			// ret == 8
			memcpy(&header_.payload_len, buf, ret);
			header_.payload_len = ntoh64(header_.payload_len);
		}
	}

	if (!header_.mask) {
		return true;
	}

	if (client_.read(&header_.masking_key, sizeof(unsigned int)) == -1) {
		if (last_error() != ACL_ETIMEDOUT) {
			logger_error("read masking_key error: %d, %s",
				last_error(), last_serror());
		}
		return false;