Method ~ProgressiveAttachment

src/brpc/progressive_attachment.cpp:44–69

}

ProgressiveAttachment::~ProgressiveAttachment() {
    if (_httpsock) {
        CHECK(_rpc_state.load(butil::memory_order_relaxed) != RPC_RUNNING);
        CHECK(_saved_buf.empty());
        if (!_before_http_1_1) {
            // note: _httpsock may already be failed.
            if (_rpc_state.load(butil::memory_order_relaxed) == RPC_SUCCEED) {
                butil::IOBuf tmpbuf;
                tmpbuf.append("0\r\n\r\n", 5);
                Socket::WriteOptions wopt;
                wopt.ignore_eovercrowded = true;
                _httpsock->Write(&tmpbuf, &wopt);
            }
        } else {
            // Close _httpsock to notify the client that all the content has
            // been transferred.
            // Note: invoke ReleaseAdditionalReference instead of SetFailed to
            // make sure that all the data has been written before the fd is
            // closed.
            _httpsock->ReleaseAdditionalReference();
        }
    }
    if (_notify_id != INVALID_BTHREAD_ID) {
        bthread_id_error(_notify_id, 0);
    }
}

static char s_hex_map[] = { '0', '1', '2', '3', '4', '5', '6', '7', '8',
                            '9', 'A', 'B', 'C', 'D', 'E', 'F' };