MCPcopy Create free account
hub / github.com/apache/impala / SerializeResponseTo

Method SerializeResponseTo

be/src/kudu/rpc/inbound_call.cc:212–221  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

210}
211
212void InboundCall::SerializeResponseTo(TransferPayload* slices) const {
213 TRACE_EVENT0("rpc", "InboundCall::SerializeResponseTo");
214 DCHECK_GT(response_hdr_buf_.size(), 0);
215 DCHECK_GT(response_msg_buf_.size(), 0);
216 slices->push_back(Slice(response_hdr_buf_));
217 slices->push_back(Slice(response_msg_buf_));
218 for (auto& sidecar : outbound_sidecars_) {
219 sidecar->AppendSlices(slices);
220 }
221}
222
223Status InboundCall::AddOutboundSidecar(unique_ptr<RpcSidecar> car, int* idx) {
224 // Check that the number of sidecars does not exceed the number of payload

Callers 1

QueueResponseForCallMethod · 0.80

Calls 4

push_backMethod · 0.80
SliceClass · 0.70
sizeMethod · 0.45
AppendSlicesMethod · 0.45

Tested by

no test coverage detected