Home
last modified time | relevance | path

Searched refs:call_ (Results 1 – 25 of 42) sorted by relevance

12

/third_party/grpc/src/cpp/client/
Dclient_context.cc58 call_(nullptr), in ClientContext()
69 if (call_) { in ~ClientContext()
70 grpc_call_unref(call_); in ~ClientContext()
81 if (creds_ != nullptr && call_ != nullptr) { in set_credentials()
82 if (!creds_->ApplyToCall(call_)) { in set_credentials()
84 grpc_call_cancel_with_status(call_, GRPC_STATUS_CANCELLED, in set_credentials()
94 ctx->propagate_from_call_ = context.call_.call; in FromInternalServerContext()
118 GPR_ASSERT(call_ == nullptr); in set_call()
119 call_ = call; in set_call()
121 if (creds_ && !creds_->ApplyToCall(call_)) { in set_call()
[all …]
/third_party/grpc/include/grpcpp/impl/codegen/
Dsync_stream_impl.h191 call_.PerformOps(&ops); in WaitForInitialMetadata()
196 int result = call_.max_receive_message_size(); in NextMessageSize()
214 call_.PerformOps(&ops); in Read()
227 call_.PerformOps(&ops); in Finish()
236 ::grpc::internal::Call call_;
249 call_(channel->CreateCall(method, context, &cq_)) {
259 call_.PerformOps(&ops);
310 call_.PerformOps(&ops); in WaitForInitialMetadata()
340 call_.PerformOps(&ops); in Write()
347 call_.PerformOps(&ops); in WritesDone()
[all …]
Dsync_stream.h191 call_.PerformOps(&ops); in WaitForInitialMetadata()
196 int result = call_.max_receive_message_size(); in NextMessageSize()
214 call_.PerformOps(&ops); in Read()
227 call_.PerformOps(&ops); in Finish()
236 ::grpc::internal::Call call_;
249 call_(channel->CreateCall(method, context, &cq_)) {
259 call_.PerformOps(&ops);
309 call_.PerformOps(&ops); in WaitForInitialMetadata()
339 call_.PerformOps(&ops); in Write()
346 call_.PerformOps(&ops); in WritesDone()
[all …]
Dasync_stream.h231 call_.PerformOps(&meta_ops_); in ReadInitialMetadata()
241 call_.PerformOps(&read_ops_); in Read()
256 call_.PerformOps(&finish_ops_); in Finish()
264 : context_(context), call_(call), started_(start) { in ClientAsyncReader()
279 call_.PerformOps(&init_ops_); in StartCallInternal()
283 ::grpc::internal::Call call_;
378 call_.PerformOps(&meta_ops_); in ReadInitialMetadata()
386 call_.PerformOps(&write_ops_); in Write()
398 call_.PerformOps(&write_ops_); in Write()
405 call_.PerformOps(&write_ops_); in WritesDone()
[all …]
Dasync_stream_impl.h231 call_.PerformOps(&meta_ops_); in ReadInitialMetadata()
241 call_.PerformOps(&read_ops_); in Read()
256 call_.PerformOps(&finish_ops_); in Finish()
265 : context_(context), call_(call), started_(start) { in ClientAsyncReader()
280 call_.PerformOps(&init_ops_); in StartCallInternal()
284 ::grpc::internal::Call call_;
379 call_.PerformOps(&meta_ops_); in ReadInitialMetadata()
387 call_.PerformOps(&write_ops_); in Write()
399 call_.PerformOps(&write_ops_); in Write()
406 call_.PerformOps(&write_ops_); in WritesDone()
[all …]
Dcallback_common.h86 : call_(call), func_(std::move(f)), ops_(ops) { in CallbackWithStatusTag()
106 grpc_call* call_;
130 g_core_codegen_interface->grpc_call_unref(call_); in Run()
152 CallbackWithSuccessTag() : call_(nullptr) {} in CallbackWithSuccessTag()
167 GPR_CODEGEN_ASSERT(call_ == nullptr); in Set()
169 call_ = call; in Set()
177 if (call_ != nullptr) { in Clear()
178 grpc_call* call = call_; in Clear()
179 call_ = nullptr; in Clear()
194 operator bool() const { return call_ != nullptr; }
[all …]
Dclient_callback_impl.h430 void StartCall() { call_->StartCall(); } in StartCall()
436 void BindCall(ClientCallbackUnary* call) { call_ = call; } in BindCall()
437 ClientCallbackUnary* call_; variable
482 call_.PerformOps(&start_ops_); in StartCall()
488 call_.PerformOps(&read_ops_); in StartCall()
491 call_.PerformOps(&write_ops_); in StartCall()
494 call_.PerformOps(&writes_done_ops_); in StartCall()
496 call_.PerformOps(&finish_ops_); in StartCall()
517 call_.PerformOps(&read_ops_); in Read()
541 call_.PerformOps(&write_ops_); in Write()
[all …]
Dclient_callback.h435 void StartCall() { call_->StartCall(); } in StartCall()
441 void BindCall(ClientCallbackUnary* call) { call_ = call; } in BindCall()
442 ClientCallbackUnary* call_; variable
487 call_.PerformOps(&start_ops_); in StartCall()
493 call_.PerformOps(&read_ops_); in StartCall()
496 call_.PerformOps(&write_ops_); in StartCall()
499 call_.PerformOps(&writes_done_ops_); in StartCall()
501 call_.PerformOps(&finish_ops_); in StartCall()
522 call_.PerformOps(&read_ops_); in Read()
546 call_.PerformOps(&write_ops_); in Write()
[all …]
Dinterceptor_common.h56 if (call_->client_rpc_info() != nullptr) { in Proceed()
59 GPR_CODEGEN_ASSERT(call_->server_rpc_info() != nullptr); in Proceed()
66 call_->client_rpc_info() != nullptr); in Hijack()
69 auto* rpc_info = call_->client_rpc_info(); in Hijack()
184 auto* info = call_->client_rpc_info(); in GetInterceptedChannel()
215 void SetCall(Call* call) { call_ = call; } in SetCall()
224 auto* client_rpc_info = call_->client_rpc_info(); in InterceptorsListEmpty()
233 auto* server_rpc_info = call_->server_rpc_info(); in InterceptorsListEmpty()
247 auto* client_rpc_info = call_->client_rpc_info(); in RunInterceptors()
257 auto* server_rpc_info = call_->server_rpc_info(); in RunInterceptors()
[all …]
Dserver_callback_handlers.h125 call_.call(), in Finish()
149 call_.PerformOps(&finish_ops_); in Finish()
161 call_.call(), in SendInitialMetadata()
176 call_.PerformOps(&meta_ops_); in SendInitialMetadata()
188 call_(*call), in ServerCallbackUnaryImpl()
210 grpc_call* call = call_.call(); in CallOnDone()
235 ::grpc::internal::Call call_;
313 call_.call(), in Finish()
337 call_.PerformOps(&finish_ops_); in Finish()
347 call_.call(), in SendInitialMetadata()
[all …]
Dcall.h40 call_(nullptr), in Call()
46 call_(call), in Call()
53 call_(call), in Call()
61 call_(call), in Call()
69 grpc_call* call() const { return call_; } in call()
85 grpc_call* call_; variable
Dasync_unary_call_impl.h127 call_.PerformOps(&single_buf); in ReadInitialMetadata()
143 call_.PerformOps(&finish_buf); in Finish()
150 call_.PerformOps(&single_buf); in Finish()
157 ::grpc::internal::Call call_;
165 : context_(context), call_(call), started_(start) { in ClientAsyncResponseReader()
201 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncResponseWriter()
220 call_.PerformOps(&meta_buf_); in SendInitialMetadata()
256 call_.PerformOps(&finish_buf_); in Finish()
283 call_.PerformOps(&finish_buf_); in FinishWithError()
287 void BindCall(::grpc::internal::Call* call) override { call_ = *call; } in BindCall()
[all …]
Dasync_unary_call.h249 read_initial_metadata_(context_, &call_, single_buf_, tag); in ReadInitialMetadata()
260 finish_(context_, &call_, initial_metadata_read_, single_buf_, &finish_buf_, in Finish()
267 ::grpc::internal::Call call_;
273 : context_(context), call_(call) {} in ClientAsyncResponseReader()
298 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncResponseWriter()
317 call_.PerformOps(&meta_buf_); in SendInitialMetadata()
353 call_.PerformOps(&finish_buf_); in Finish()
380 call_.PerformOps(&finish_buf_); in FinishWithError()
384 void BindCall(::grpc::internal::Call* call) override { call_ = *call; } in BindCall()
386 ::grpc::internal::Call call_;
Dcall_op_set.h876 call_(other.call_), in CallOpSet()
883 call_ = other.call_;
892 call_ = in FillOps()
906 call_.cq()->CompleteAvalanching(); in FinalizeResult()
912 g_core_codegen_interface->grpc_call_unref(call_.call()); in FinalizeResult()
925 g_core_codegen_interface->grpc_call_unref(call_.call()); in FinalizeResult()
967 call_.call(), ops, nops, core_cq_tag(), nullptr); in ContinueFillOpsAfterInterception()
986 call_.call(), nullptr, 0, core_cq_tag(), nullptr) == in ContinueFinalizeResultAfterInterception()
995 interceptor_methods_.SetCall(&call_); in RunInterceptors()
1007 call_.cq()->RegisterAvalanching(); in RunInterceptors()
[all …]
/third_party/grpc/src/cpp/server/
Dserver_context.cc49 : call_(*call), in CompletionOp()
66 if (call_.server_rpc_info()) { in ~CompletionOp()
67 call_.server_rpc_info()->Unref(); in ~CompletionOp()
130 GPR_ASSERT(grpc_call_start_batch(call_.call(), nullptr, 0, core_cq_tag_, in ContinueFinalizeResultAfterInterception()
140 internal::Call call_; member in grpc::ServerContextBase::CompletionOp
155 grpc_call* call = call_.call(); in Unref()
167 interceptor_methods_.SetCall(&call_); in FillOps()
315 grpc_call_cancel_with_status(call_.call, GRPC_STATUS_CANCELLED, in TryCancel()
351 if (call_.call) { in peer()
352 char* c_peer = grpc_call_get_peer(call_.call); in peer()
[all …]
Dserver_cc.cc128 call_(nullptr), in BaseAsyncRequest()
151 context_->set_call(call_); in FinalizeResult()
156 call_, server_, call_cq_, server_->max_receive_message_size(), nullptr); in FinalizeResult()
162 if (*status && call_ && call_wrapper_.server_rpc_info()) { in FinalizeResult()
178 if (*status && call_) { in FinalizeResult()
216 server_->server(), registered_method, &call_, in IssueRequest()
233 GPR_ASSERT(grpc_server_request_call(server->server(), &call_, &call_details_, in GenericAsyncRequest()
256 call_, server_, call_cq_, server_->max_receive_message_size(), in FinalizeResult()
371 server, method_tag_, &call_, &deadline_, &request_metadata_, in Request()
382 if (grpc_server_request_call(server, &call_, call_details_, in Request()
[all …]
/third_party/grpc/test/cpp/util/
Dcli_call.cc64 call_ = stub_->PrepareCall(&ctx_, method, &cq_); in CliCall()
65 call_->StartCall(tag(1)); in CliCall()
84 call_->Write(send_buffer, tag(2)); in Write()
95 call_->Read(&recv_buffer, tag(3)); in Read()
118 call_->WritesDone(tag(4)); in WritesDone()
128 call_->Write(send_buffer, tag(2)); in WriteAndWait()
138 call_->WritesDone(tag(4)); in WritesDoneAndWait()
152 call_->Read(&recv_buffer, tag(3)); in ReadAndMaybeNotifyWrite()
201 call_->Finish(&status, tag(5)); in Finish()
/third_party/grpc/test/cpp/interop/
Dserver_helper.cc57 return grpc_call_test_only_get_compression_algorithm(context_.call_); in GetCallCompressionAlgorithm()
61 return grpc_call_test_only_get_encodings_accepted_by_peer(context_.call_); in GetEncodingsAcceptedByClient()
65 return (grpc_call_test_only_get_message_flags(context_.call_) & in WasCompressed()
67 (grpc_call_test_only_get_message_flags(context_.call_) & in WasCompressed()
Dclient_helper.h55 return grpc_call_test_only_get_compression_algorithm(context_.call_); in GetCallCompressionAlgorithm()
59 return (grpc_call_test_only_get_message_flags(context_.call_) & in WasCompressed()
61 (grpc_call_test_only_get_message_flags(context_.call_) & in WasCompressed()
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc297 call_ = SubchannelCall::Create(std::move(args), &error).release(); in StartCall()
301 call_->SetAfterCallStackDestroy(&after_call_stack_destruction_); in StartCall()
316 call_->Ref(DEBUG_LOCATION, "on_complete").release(); in StartCall()
350 call_->Ref(DEBUG_LOCATION, "recv_initial_metadata_ready").release(); in StartCall()
358 call_->Ref(DEBUG_LOCATION, "recv_message_ready").release(); in StartCall()
394 batch->handler_private.extra_arg = call_; in StartBatch()
413 self->call_->Unref(DEBUG_LOCATION, "cancel"); in OnCancelComplete()
424 self->call_->StartTransportStreamOpBatch(batch); in StartCancel()
431 call_->Ref(DEBUG_LOCATION, "cancel").release(); in Cancel()
446 self->call_->Unref(DEBUG_LOCATION, "on_complete"); in OnComplete()
[all …]
/third_party/boost/libs/local_function/example/
Dimpl_tparam_tricks.cpp16 : obj_(obj), call_(call) {} in casting_func()
18 inline void operator()(const int& num) { call_(obj_, num); } in operator ()()
21 void (*call_)(void*, const int&); member
/third_party/grpc/src/core/ext/xds/
Dxds_client.cc278 grpc_call* call_; member in grpc_core::XdsClient::ChannelState::AdsCallState
375 grpc_call* call_; member in grpc_core::XdsClient::ChannelState::LrsCallState
686 call_ = grpc_channel_create_pollset_set_call( in AdsCallState()
690 GPR_ASSERT(call_ != nullptr); in AdsCallState()
699 xds_client(), chand(), this, call_); in AdsCallState()
714 call_, ops, static_cast<size_t>(op - ops), nullptr); in AdsCallState()
749 call_, ops, static_cast<size_t>(op - ops), &on_response_received_); in AdsCallState()
766 call_, ops, static_cast<size_t>(op - ops), &on_status_received_); in AdsCallState()
776 GPR_ASSERT(call_ != nullptr); in ~AdsCallState()
777 grpc_call_unref(call_); in ~AdsCallState()
[all …]
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_client.cc265 grpc_call* call_; member in grpc_core::XdsClient::ChannelState::AdsCallState
362 grpc_call* call_; member in grpc_core::XdsClient::ChannelState::LrsCallState
686 call_ = grpc_channel_create_pollset_set_call( in AdsCallState()
691 GPR_ASSERT(call_ != nullptr); in AdsCallState()
700 xds_client(), chand(), this, call_); in AdsCallState()
714 call_error = grpc_call_start_batch_and_execute(call_, ops, (size_t)(op - ops), in AdsCallState()
751 call_error = grpc_call_start_batch_and_execute(call_, ops, (size_t)(op - ops), in AdsCallState()
768 call_error = grpc_call_start_batch_and_execute(call_, ops, (size_t)(op - ops), in AdsCallState()
779 GPR_ASSERT(call_ != nullptr); in ~AdsCallState()
780 grpc_call_unref(call_); in ~AdsCallState()
[all …]
/third_party/boost/boost/container_hash/detail/
Dfloat_functions.hpp219 boost::hash_detail::call_##cpp_func<double> {}; \
252 struct call_##cpp_func<type1> : \
264 struct call_##cpp_func<type1> { \
/third_party/boost/boost/xpressive/detail/static/transforms/
Das_set.hpp119 this->call_(expr, typename Expr::proto_tag()); in operator ()()
126 void call_(Expr const &expr, Tag) const in call_() function
138 void call_(Expr const &expr, tag::bitwise_or) const in call_() function

12