| /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 …]
|
| D | callback_common.h | 69 : call_(call), func_(std::move(f)), ops_(ops) { in CallbackWithStatusTag()
85 grpc_call* call_;
105 g_core_codegen_interface->grpc_call_unref(call_); in Run()
126 : call_(call), func_(std::move(f)), ops_(ops) { in CallbackWithSuccessTag()
139 grpc_call* call_;
157 g_core_codegen_interface->grpc_call_unref(call_); in Run()
|
| D | server_context.h | 213 auth_context_ = CreateAuthContext(call_); in auth_context()
239 grpc_call* c_call() { return call_; } in c_call()
284 void set_call(grpc_call* call) { call_ = call; } in set_call()
293 grpc_call* call_; variable
|
| D | call.h | 626 CallOpSet() : cq_tag_(this), return_tag_(this), call_(nullptr) {} in CallOpSet()
635 call_ = call; in FillOps()
647 g_core_codegen_interface->grpc_call_unref(call_); in FinalizeResult()
664 grpc_call* call_; variable
674 call_(call), in Call()
681 call_(call), in Call()
688 grpc_call* call() const { return call_; } in call()
696 grpc_call* call_; variable
|
| D | client_context.h | 277 auth_context_ = CreateAuthContext(call_); in auth_context()
360 grpc_call* c_call() { return call_; } in c_call()
402 grpc_call* call() const { return call_; } in call()
424 grpc_call* call_; variable
|
| D | server_interface.h | 164 grpc_call* call_; variable
229 call_, GRPC_STATUS_INTERNAL, "Unable to parse request", nullptr); in FinalizeResult()
230 g_core_codegen_interface->grpc_call_unref(call_); in FinalizeResult()
|
| /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/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()
|
| D | server_cc.cc | 175 server, tag_, &call_, &deadline_, &request_metadata_, in Request()
186 if (grpc_server_request_call(server, &call_, call_details_, in Request()
211 call_(mrd->call_, server, &cq_, server->max_receive_message_size()), in CallData()
218 ctx_.set_call(mrd->call_); in CallData()
233 ctx_.BeginCompletionOp(&call_); in Run()
238 &call_, &ctx_, request_payload_)); in Run()
254 internal::Call call_; member in grpc::Server::SyncRequest::CallData
267 grpc_call* call_; member in grpc::Server::SyncRequest
680 call_(nullptr) { in BaseAsyncRequest()
690 context_->set_call(call_); in FinalizeResult()
[all …]
|
| /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()
|
| D | cli_call.h | 89 std::unique_ptr<grpc::GenericClientAsyncReaderWriter> call_; variable
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | call_inliner.cc | 36 : call_(call), outer_(call->parent()) { in SubcomputationInsertionVisitor()
37 CHECK_EQ(HloOpcode::kCall, call_->opcode()); in SubcomputationInsertionVisitor()
72 parameter, call_->mutable_operand(parameter->parameter_number()))); in HandleParameter()
80 VLOG(1) << "Replacing all uses of " << call_->ToString() in FinishVisit()
82 call_->ClearCalledComputations(); in FinishVisit()
83 return outer_->ReplaceInstruction(call_, new_root); in FinishVisit()
118 HloInstruction* call_; member in xla::__anona1e1e8bc0111::SubcomputationInsertionVisitor
|
| /external/webrtc/talk/app/webrtc/ |
| D | fakemediacontroller.h | 40 : channel_manager_(channel_manager), call_(call) { in FakeMediaController()
42 RTC_DCHECK(nullptr != call_); in FakeMediaController()
45 webrtc::Call* call_w() override { return call_; } in call_w()
52 webrtc::Call* call_; variable
|
| D | mediacontroller.cc | 58 return call_.get(); in call_w()
74 call_.reset(webrtc::Call::Create(config)); in Construct_w()
78 call_.reset(); in Destruct_w()
83 rtc::scoped_ptr<webrtc::Call> call_; member in __anond59772c90111::MediaController
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_call.h | 106 Tag(UntypedCall* call, Callback cb) : call_(call), callback_(cb) {} in Tag()
114 call_->RequestReceived(service, ok); in OnCompleted()
120 call_->RequestCancelled(service, ok); in OnCompleted()
123 call_->Unref(); // Ref acquired when tag handed to grpc. in OnCompleted()
127 UntypedCall* const call_; // `this` owns one reference.
|
| D | grpc_state.h | 92 call_ = std::move( in StartCall()
94 call_->StartCall(); in StartCall()
95 call_->Finish(&response_buf_, &status_, this); in StartCall()
154 std::unique_ptr<::grpc::GenericClientAsyncResponseReader> call_; variable
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | server_helper.cc | 56 return grpc_call_test_only_get_compression_algorithm(context_.call_); in GetCallCompressionAlgorithm()
60 return grpc_call_test_only_get_encodings_accepted_by_peer(context_.call_); in GetEncodingsAcceptedByClient()
64 return grpc_call_test_only_get_message_flags(context_.call_); in GetMessageFlags()
|
| D | client_helper.h | 49 return grpc_call_test_only_get_compression_algorithm(context_.call_); in GetCallCompressionAlgorithm()
53 return grpc_call_test_only_get_message_flags(context_.call_); in GetMessageFlags()
|
| /external/v8/src/compiler/ |
| D | js-inlining.cc | 43 explicit JSCallAccessor(Node* call) : call_(call) { in JSCallAccessor()
50 return call_->InputAt(0); in target()
54 DCHECK_EQ(IrOpcode::kJSCall, call_->opcode()); in receiver()
55 return call_->InputAt(1); in receiver()
59 DCHECK_EQ(IrOpcode::kJSConstruct, call_->opcode()); in new_target()
60 return call_->InputAt(formal_arguments() + 1); in new_target()
65 return NodeProperties::GetFrameStateInput(call_); in frame_state()
72 return call_->op()->ValueInputCount() - 2; in formal_arguments()
76 return (call_->opcode() == IrOpcode::kJSCall) in frequency()
77 ? CallParametersOf(call_->op()).frequency() in frequency()
[all …]
|
| /external/webrtc/webrtc/call/ |
| D | call_unittest.cc | 27 call_.reset(webrtc::Call::Create(config)); in CallHelper()
30 webrtc::Call* operator->() { return call_.get(); } in operator ->()
34 rtc::scoped_ptr<webrtc::Call> call_; member
|
| /external/webrtc/talk/media/webrtc/ |
| D | webrtcvoiceengine_unittest.cc | 78 : call_(webrtc::Call::Config()), in WebRtcVoiceEngineTestFake()
88 channel_ = engine_.CreateChannel(&call_, cricket::AudioOptions()); in SetupEngine()
108 EXPECT_TRUE(call_.GetAudioSendStream(kSsrc1)); in SetupForMultiSendStream()
111 EXPECT_FALSE(call_.GetAudioSendStream(kSsrc1)); in SetupForMultiSendStream()
123 const auto* send_stream = call_.GetAudioSendStream(ssrc); in GetSendStream()
129 const auto* send_stream = call_.GetAudioSendStream(ssrc); in GetSendStreamConfig()
135 const auto* recv_stream = call_.GetAudioReceiveStream(ssrc); in GetRecvStreamConfig()
142 channel_ = engine_.CreateChannel(&call_, cricket::AudioOptions()); in TestInsertDtmf()
229 EXPECT_NE(call_.GetAudioSendStream(kSsrc1), in TestSetSendRtpHeaderExtensions()
230 call_.GetAudioSendStream(kSsrc2)); in TestSetSendRtpHeaderExtensions()
[all …]
|
| D | webrtcvideoengine2.cc | 620 : call_(call), in WebRtcVideoChannel2()
878 call_->SetBitrateConfig(bitrate_config_); in SetSendCodecs()
972 call_, sp, config, external_encoder_factory_, options_, in AddSendStream()
1101 call_, sp, config, external_decoder_factory_, default_stream, in AddRecvStream()
1207 webrtc::Call::Stats stats = call_->GetStats(); in GetStats()
1298 call_->Receiver()->DeliverPacket( in OnPacketReceived()
1341 if (call_->Receiver()->DeliverPacket( in OnPacketReceived()
1359 call_->Receiver()->DeliverPacket( in OnRtcpReceived()
1367 call_->SignalNetworkState(ready ? webrtc::kNetworkUp : webrtc::kNetworkDown); in OnReadyToSend()
1462 call_->SetBitrateConfig(bitrate_config_); in SetMaxSendBandwidth()
[all …]
|
| D | webrtcvoiceengine.cc | 1082 call_(call), in WebRtcAudioSendStream()
1098 call_->DestroyAudioSendStream(stream_); in ~WebRtcAudioSendStream()
1105 call_->DestroyAudioSendStream(stream_); in RecreateAudioSendStream()
1110 stream_ = call_->CreateAudioSendStream(config_); in RecreateAudioSendStream()
1190 webrtc::Call* call_ = nullptr; member in cricket::WebRtcVoiceMediaChannel::WebRtcAudioSendStream
1210 : call_(call), in WebRtcAudioReceiveStream()
1223 call_->DestroyAudioReceiveStream(stream_); in ~WebRtcAudioReceiveStream()
1257 call_->DestroyAudioReceiveStream(stream_); in RecreateAudioReceiveStream()
1263 stream_ = call_->CreateAudioReceiveStream(config_); in RecreateAudioReceiveStream()
1268 webrtc::Call* call_ = nullptr; member in cricket::WebRtcVoiceMediaChannel::WebRtcAudioReceiveStream
[all …]
|