|
|
@ -144,17 +144,14 @@ void CallOpBuffer::FillOps(grpc_op *ops, size_t *nops) { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
void CallOpBuffer::ReleaseSendBuffer() { |
|
|
|
void CallOpBuffer::FinalizeResult(void *tag, bool *status) { |
|
|
|
|
|
|
|
// Release send buffers
|
|
|
|
if (write_buffer_) { |
|
|
|
if (write_buffer_) { |
|
|
|
grpc_byte_buffer_destroy(write_buffer_); |
|
|
|
grpc_byte_buffer_destroy(write_buffer_); |
|
|
|
write_buffer_ = nullptr; |
|
|
|
write_buffer_ = nullptr; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
void CallOpBuffer::FinalizeResult(void *tag, bool *status) { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void CCallDeleter::operator()(grpc_call* c) { |
|
|
|
void CCallDeleter::operator()(grpc_call* c) { |
|
|
|
grpc_call_destroy(c); |
|
|
|
grpc_call_destroy(c); |
|
|
|
} |
|
|
|
} |
|
|
@ -164,7 +161,6 @@ Call::Call(grpc_call* call, ChannelInterface* channel, CompletionQueue* cq) |
|
|
|
|
|
|
|
|
|
|
|
void Call::PerformOps(CallOpBuffer* buffer) { |
|
|
|
void Call::PerformOps(CallOpBuffer* buffer) { |
|
|
|
channel_->PerformOpsOnCall(buffer, this); |
|
|
|
channel_->PerformOpsOnCall(buffer, this); |
|
|
|
buffer->ReleaseSendBuffer(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} // namespace grpc
|
|
|
|
} // namespace grpc
|
|
|
|