Method Write

src/brpc/progressive_attachment.cpp:118–150

}

int ProgressiveAttachment::Write(const butil::IOBuf& data) {
    if (data.empty()) {
        LOG_EVERY_SECOND(WARNING)
            << "Write an empty chunk. To suppress this warning, check emptiness"
            " of the chunk before calling ProgressiveAttachment.Write()";
        return 0;
    }

    int rpc_state = _rpc_state.load(butil::memory_order_acquire);
    if (rpc_state == RPC_RUNNING) {
        std::unique_lock<butil::Mutex> mu(_mutex);
        rpc_state = _rpc_state.load(butil::memory_order_acquire);
        if (rpc_state == RPC_RUNNING) {
            if (_saved_buf.size() >= (size_t)FLAGS_socket_max_unwritten_bytes ||
                _pause_from_mark_rpc_as_done) {
                errno = EOVERCROWDED;
                return -1;
            }
            AppendAsChunk(&_saved_buf, data, _before_http_1_1);
            return 0;
        }
    }
    // The RPC is already done (http headers were written into the socket)
    // write into the socket directly.
    if (rpc_state == RPC_SUCCEED) {
        butil::IOBuf tmpbuf;
        AppendAsChunk(&tmpbuf, data, _before_http_1_1);
        return _httpsock->Write(&tmpbuf);
    } else {
        errno = ECANCELED;
        return -1;
    }
}

int ProgressiveAttachment::Write(const void* data, size_t n) {
    if (data == NULL || n == 0) {