| /external/pigweed/pw_rpc/ |
| D | base_server_writer.cc | 25 : call_(call), state_(kOpen) { in BaseServerWriter()
26 call_.server().RegisterWriter(*this); in BaseServerWriter()
35 other.call_.server().RemoveWriter(other); in operator =()
38 other.call_.server().RegisterWriter(*this); in operator =()
41 call_ = std::move(other.call_); in operator =()
47 uint32_t BaseServerWriter::method_id() const { return call_.method().id(); } in method_id()
63 return call_.channel().Send(Packet(PacketType::SERVER_STREAM_END, in Finish()
64 call_.channel().id(), in Finish()
65 call_.service().id(), in Finish()
76 response_ = call_.channel().AcquireBuffer(); in AcquirePayloadBuffer()
[all …]
|
| /external/webrtc/call/ |
| D | degraded_call.cc | 89 call_(call), in FakeNetworkPipeTransportAdapter()
116 call_->OnSentPacket(sent_packet); in SendRtp()
134 call_(std::move(call)), in DegradedCall()
144 receive_pipe_->SetReceiver(call_->Receiver()); in DegradedCall()
160 send_pipe_.get(), call_.get(), clock_, config.send_transport); in CreateAudioSendStream()
163 AudioSendStream* send_stream = call_->CreateAudioSendStream(degrade_config); in CreateAudioSendStream()
170 return call_->CreateAudioSendStream(config); in CreateAudioSendStream()
174 call_->DestroyAudioSendStream(send_stream); in DestroyAudioSendStream()
180 return call_->CreateAudioReceiveStream(config); in CreateAudioReceiveStream()
185 call_->DestroyAudioReceiveStream(receive_stream); in DestroyAudioReceiveStream()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/client/ |
| D | client_context.cc | 58 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 …]
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | sync_stream.h | 191 call_.PerformOps(&ops); in WaitForInitialMetadata()
196 *sz = call_.max_receive_message_size(); in NextMessageSize()
213 call_.PerformOps(&ops); in Read()
226 call_.PerformOps(&ops); in Finish()
235 ::grpc::internal::Call call_;
248 call_(channel->CreateCall(method, context, &cq_)) {
258 call_.PerformOps(&ops);
308 call_.PerformOps(&ops); in WaitForInitialMetadata()
338 call_.PerformOps(&ops); in Write()
345 call_.PerformOps(&ops); in WritesDone()
[all …]
|
| D | async_stream.h | 234 call_.PerformOps(&meta_ops_); in ReadInitialMetadata()
244 call_.PerformOps(&read_ops_); in Read()
259 call_.PerformOps(&finish_ops_); in Finish()
267 : context_(context), call_(call), started_(start) { in ClientAsyncReader()
282 call_.PerformOps(&init_ops_); in StartCallInternal()
286 ::grpc::internal::Call call_;
381 call_.PerformOps(&meta_ops_); in ReadInitialMetadata()
389 call_.PerformOps(&write_ops_); in Write()
401 call_.PerformOps(&write_ops_); in Write()
408 call_.PerformOps(&write_ops_); in WritesDone()
[all …]
|
| D | async_unary_call.h | 131 call_.PerformOps(&single_buf); in ReadInitialMetadata()
147 call_.PerformOps(&finish_buf); in Finish()
154 call_.PerformOps(&single_buf); in Finish()
161 ::grpc::internal::Call call_;
168 : context_(context), call_(call), started_(start) { in ClientAsyncResponseReader()
204 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncResponseWriter()
223 call_.PerformOps(&meta_buf_); in SendInitialMetadata()
258 call_.PerformOps(&finish_buf_); in Finish()
285 call_.PerformOps(&finish_buf_); in FinishWithError()
289 void BindCall(::grpc::internal::Call* call) override { call_ = *call; } in BindCall()
[all …]
|
| /external/grpc-grpc/src/cpp/client/ |
| D | client_context.cc | 53 call_(nullptr), in ClientContext()
63 if (call_) { in ~ClientContext()
64 grpc_call_unref(call_); in ~ClientContext()
72 ctx->propagate_from_call_ = context.call_; in FromServerContext()
85 GPR_ASSERT(call_ == nullptr); in set_call()
86 call_ = call; in set_call()
88 if (creds_ && !creds_->ApplyToCall(call_)) { in set_call()
93 grpc_call_cancel(call_, nullptr); in set_call()
112 if (call_) { in TryCancel()
113 grpc_call_cancel(call_, nullptr); in TryCancel()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | sync_stream.h | 191 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 …]
|
| D | async_stream.h | 231 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 …]
|
| D | callback_common.h | 86 : 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 …]
|
| D | client_callback.h | 435 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 …]
|
| D | interceptor_common.h | 56 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 …]
|
| D | server_callback_handlers.h | 125 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()
232 ::grpc::internal::Call call_;
310 call_.call(), in Finish()
334 call_.PerformOps(&finish_ops_); in Finish()
344 call_.call(), in SendInitialMetadata()
[all …]
|
| D | call.h | 40 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
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | sync_stream.h | 191 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 …]
|
| D | async_stream.h | 231 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 …]
|
| D | callback_common.h | 86 : 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 …]
|
| D | client_callback.h | 435 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 …]
|
| D | interceptor_common.h | 56 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 …]
|
| D | server_callback_handlers.h | 125 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()
232 ::grpc::internal::Call call_;
310 call_.call(), in Finish()
334 call_.PerformOps(&finish_ops_); in Finish()
344 call_.call(), in SendInitialMetadata()
[all …]
|
| D | call.h | 40 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
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_context.cc | 49 : 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 …]
|
| /external/webrtc/api/ |
| D | function_view.h | 67 : call_(CallVoidPtr<typename std::remove_reference<F>::type>) { in FunctionView()
79 : call_(f ? CallFunPtr<typename std::remove_pointer<F>::type> : nullptr) { in FunctionView()
88 FunctionView(F&& f) : call_(nullptr) {} in FunctionView()
91 FunctionView() : call_(nullptr) {} in FunctionView()
94 RTC_DCHECK(call_); in operator()
95 return call_(f_, std::forward<ArgT>(args)...); in operator()
99 explicit operator bool() const { return !!call_; }
125 RetT (*call_)(VoidUnion, ArgT...); variable
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_context.cc | 123 call_(nullptr), in ServerContext()
134 call_(nullptr), in ServerContext()
143 if (call_) { in ~ServerContext()
144 grpc_call_unref(call_); in ~ServerContext()
176 call_, GRPC_STATUS_CANCELLED, "Cancelled on the server side", nullptr); in TryCancel()
208 if (call_) { in peer()
209 char* c_peer = grpc_call_get_peer(call_); in peer()
217 return grpc_census_call_get_context(call_); in census_context()
222 if (call_ == nullptr) return; in SetLoadReportingCosts()
|
| /external/grpc-grpc/test/cpp/util/ |
| D | cli_call.cc | 64 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()
153 call_->Read(&recv_buffer, tag(3)); in ReadAndMaybeNotifyWrite()
202 call_->Finish(&status, tag(5)); in Finish()
|