Method handle_websocket

lib_acl_cpp/src/http/http_aclient.cpp:368–417

}

bool http_aclient::handle_websocket()
{
	acl_assert(ws_in_);

	if (!ws_in_->is_head_finish()) {
		if (!ws_in_->peek_frame_head()) {
			if (ws_in_->eof()) {
				return false;
			}
			return true;
		}

		// ����������֡ͷʱ�����ݲ�ͬ֡���ͻص���ͬ����
		unsigned char opcode = ws_in_->get_frame_opcode();
		switch (opcode) {
		case FRAME_TEXT:
			if (!this->on_ws_frame_text()) {
				return false;
			}
			break;
		case FRAME_BINARY:
			if (!this->on_ws_frame_binary()) {
				return false;
			}
			break;
		case FRAME_CLOSE:
			this->on_ws_frame_closed();
			return false;
		case FRAME_PING:
			return true;
		case FRAME_PONG:
			return true;
		default:
			return true;
		}
	}

	unsigned char opcode = ws_in_->get_frame_opcode();
	switch (opcode) {
	case FRAME_TEXT:
	case FRAME_BINARY:
		return handle_ws_data();
	case FRAME_PING:
		return handle_ws_ping();
	case FRAME_PONG:
		return handle_ws_pong();
	default:
		return handle_ws_other();
	}
}

// SSL ���ֺͶ� Websocket ����֡�׶Σ��÷������ᱻ��ε��á�
// ������ SSL ģʽʱ���� SSL ���ֽ׶Σ��÷����ᱻ��ε��ã�ֱ�� SSL ���ֳɹ�