Function ReadOneResponse

test/brpc_http_rpc_protocol_unittest.cpp:2002–2030

#undef BRPC_CRLF

void ReadOneResponse(brpc::SocketUniquePtr& sock,
    brpc::DestroyingPtr<brpc::policy::HttpContext>& imsg_guard) {
#if defined(OS_LINUX)
    ASSERT_EQ(0, bthread_fd_wait(sock->fd(), EPOLLIN));
#elif defined(OS_MACOSX)
    ASSERT_EQ(0, bthread_fd_wait(sock->fd(), EVFILT_READ));
#endif

    butil::IOPortal read_buf;
    int64_t start_time = butil::cpuwide_time_us();
    while (true) {
        const ssize_t nr = read_buf.append_from_file_descriptor(sock->fd(), 4096);
        LOG(INFO) << "nr=" << nr;
        LOG(INFO) << butil::ToPrintableString(read_buf);
        ASSERT_TRUE(nr > 0 || (nr < 0 && errno == EAGAIN));
        if (errno == EAGAIN) {
            ASSERT_LT(butil::cpuwide_time_us(), start_time + 1000000L) << "Too long!";
            bthread_usleep(1000);
            continue;
        }
        brpc::ParseResult pr = brpc::policy::ParseHttpMessage(&read_buf, sock.get(), false, NULL);
        ASSERT_TRUE(pr.error() == brpc::PARSE_ERROR_NOT_ENOUGH_DATA || pr.is_ok());
        if (pr.is_ok()) {
            imsg_guard.reset(static_cast<brpc::policy::HttpContext*>(pr.message()));
            break;
        }
    }
    ASSERT_TRUE(read_buf.empty());
}

TEST_F(HttpTest, http_expect) {
    const int port = 8923;