MCPcopy Create free account
hub / github.com/apache/brpc / push

Method push

src/brpc/stream.cpp:565–572  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

563 _size = 0;
564 }
565 void push(butil::IOBuf* buf) {
566 if (_size == _cap) {
567 flush();
568 }
569 _storage[_size++] = buf;
570 _total_length += buf->length();
571
572 }
573 size_t total_length() const { return _total_length; }
574private:
575 butil::IOBuf** _storage;

Callers 2

DEFINE_SMALL_ARRAYFunction · 0.45
pipelineRequestMethod · 0.45

Calls 1

lengthMethod · 0.45

Tested by

no test coverage detected