Home
last modified time | relevance | path

Searched refs:SendMessagePtr (Results 1 – 8 of 8) sorted by relevance

/third_party/grpc/include/grpcpp/impl/codegen/
Dserver_callback_handlers.h144 finish_ops_.SendMessagePtr(response())); in Finish()
332 finish_ops_.SendMessagePtr(&resp_)); in Finish()
581 GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(resp, options).ok()); in Write()
589 GPR_CODEGEN_ASSERT(finish_ops_.SendMessagePtr(resp, options).ok()); in WriteAndFinish()
793 GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(resp, options).ok()); in Write()
800 GPR_CODEGEN_ASSERT(finish_ops_.SendMessagePtr(resp, options).ok()); in WriteAndFinish()
Dsync_stream.h257 GPR_CODEGEN_ASSERT(ops.SendMessagePtr(&request).ok());
335 if (!ops.SendMessagePtr(&msg, options).ok()) { in Write()
508 if (!ops.SendMessagePtr(&msg, options).ok()) { in Write()
665 if (!ctx_->pending_ops_.SendMessagePtr(&msg, options).ok()) { in Write()
744 if (!ctx_->pending_ops_.SendMessagePtr(&msg, options).ok()) { in Write()
Dsync_stream_impl.h257 GPR_CODEGEN_ASSERT(ops.SendMessagePtr(&request).ok());
336 if (!ops.SendMessagePtr(&msg, options).ok()) { in Write()
509 if (!ops.SendMessagePtr(&msg, options).ok()) { in Write()
666 if (!ctx_->pending_ops_.SendMessagePtr(&msg, options).ok()) { in Write()
746 if (!ctx_->pending_ops_.SendMessagePtr(&msg, options).ok()) { in Write()
Dclient_unary_call.h69 status_ = ops.SendMessagePtr(&request); in BlockingUnaryCallImpl()
Dcall_op_set.h299 Status SendMessagePtr(const M* message,
305 Status SendMessagePtr(const M* message) GRPC_MUST_USE_RESULT;
397 Status CallOpSendMessage::SendMessagePtr(const M* message, in SendMessagePtr() function
419 Status CallOpSendMessage::SendMessagePtr(const M* message) { in SendMessagePtr() function
420 return SendMessagePtr(message, WriteOptions()); in SendMessagePtr()
Dclient_callback.h93 ::grpc::Status s = ops->SendMessagePtr(request); in CallbackUnaryCallImpl()
531 GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(msg, options).ok()); in Write()
804 GPR_CODEGEN_ASSERT(start_ops_.SendMessagePtr(request).ok()); in ClientCallbackReaderImpl()
926 GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(msg, options).ok()); in Write()
1150 GPR_CODEGEN_ASSERT(start_ops_.SendMessagePtr(request).ok()); in ClientCallbackUnaryImpl()
Dclient_callback_impl.h88 ::grpc::Status s = ops->SendMessagePtr(request); in CallbackUnaryCallImpl()
526 GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(msg, options).ok()); in Write()
794 GPR_CODEGEN_ASSERT(start_ops_.SendMessagePtr(request).ok()); in ClientCallbackReaderImpl()
917 GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(msg, options).ok()); in Write()
1138 GPR_CODEGEN_ASSERT(start_ops_.SendMessagePtr(request).ok()); in ClientCallbackUnaryImpl()
Dmethod_handler.h70 status = ops.SendMessagePtr(rsp); in UnaryRunHandlerHelper()
173 status = ops.SendMessagePtr(&rsp); in RunHandler()