Method read_frame_data

lib_acl_cpp/src/http/websocket.cpp:467–495

}

int websocket::read_frame_data(void* buf, size_t size)
{
	if (payload_nread_ >= header_.payload_len) {
		return 0;
	}

	if (header_.payload_len < payload_nread_ + size) {
		size = (size_t) (header_.payload_len - payload_nread_);
	}

	int ret = client_.read(buf, size, false);
	if (ret == -1) {
		if (last_error() != ACL_ETIMEDOUT) {
			logger_error("read frame data error: %d, %s",
				last_error(), last_serror());
		}
		return -1;
	}

	if (header_.mask) {
		unsigned char* mask = (unsigned char*) &header_.masking_key;
		for (int i = 0; i < ret; i++) {
			((char*) buf)[i] ^= mask[(payload_nread_ + i) % 4];
		}
	}

	payload_nread_ += ret;
	return ret;
}

void websocket::update_head_2bytes(unsigned char ch1, unsigned ch2)
{