| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | wrapped_handler.hpp | 51 : dispatcher_(dispatcher), in wrapped_handler()
57 : dispatcher_(other.dispatcher_), in wrapped_handler()
63 : dispatcher_(other.dispatcher_), in wrapped_handler()
70 dispatcher_.dispatch(ASIO_MOVE_CAST(Handler)(handler_)); in operator ()()
75 dispatcher_.dispatch(handler_); in operator ()()
81 dispatcher_.dispatch(detail::bind_handler(handler_, arg1)); in operator ()()
87 dispatcher_.dispatch(detail::bind_handler(handler_, arg1)); in operator ()()
93 dispatcher_.dispatch(detail::bind_handler(handler_, arg1, arg2)); in operator ()()
99 dispatcher_.dispatch(detail::bind_handler(handler_, arg1, arg2)); in operator ()()
105 dispatcher_.dispatch(detail::bind_handler(handler_, arg1, arg2, arg3)); in operator ()()
[all …]
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | split_provider.cc | 27 if (!dispatcher_) { in GetNext()
28 dispatcher_ = in GetNext()
33 return dispatcher_->GetSplit(job_id_, repetition_, *split, in GetNext()
|
| D | test_cluster.cc | 52 TF_RETURN_IF_ERROR(NewDispatchServer(config, dispatcher_)); in Initialize()
53 TF_RETURN_IF_ERROR(dispatcher_->Start()); in Initialize()
54 dispatcher_address_ = absl::StrCat("localhost:", dispatcher_->BoundPort()); in Initialize()
|
| D | worker_impl.cc | 73 dispatcher_ = absl::make_unique<DataServiceDispatcherClient>( in Start()
75 TF_RETURN_IF_ERROR(dispatcher_->Initialize()); in Start()
144 dispatcher_->GetDatasetDef(task.task_def.dataset_id(), def)); in EnsureTaskInitialized()
272 TF_RETURN_IF_ERROR(dispatcher_->WorkerUpdate(worker_address_, task_progress)); in SendTaskUpdates()
321 dispatcher_->WorkerHeartbeat(worker_address_, transfer_address_, in Heartbeat()
|
| D | test_cluster.h | 45 std::unique_ptr<DispatchGrpcDataServer> dispatcher_; variable
|
| D | split_provider.h | 53 std::unique_ptr<DataServiceDispatcherClient> dispatcher_; variable
|
| D | worker_impl.h | 86 std::unique_ptr<DataServiceDispatcherClient> dispatcher_; variable
|
| /external/libchrome/mojo/core/ |
| D | watch.h | 66 const scoped_refptr<Dispatcher>& dispatcher() const { return dispatcher_; } in dispatcher()
97 const scoped_refptr<Dispatcher> dispatcher_; variable
|
| D | message_pipe_dispatcher.cc | 46 : dispatcher_(dispatcher) {} in PortObserverThunk()
52 void OnPortStatusChanged() override { dispatcher_->OnPortStatusChanged(); } in OnPortStatusChanged()
54 scoped_refptr<MessagePipeDispatcher> dispatcher_; member in mojo::core::MessagePipeDispatcher::PortObserverThunk
|
| D | watch.cc | 19 dispatcher_(dispatcher), in Watch()
|
| D | data_pipe_producer_dispatcher.cc | 58 : dispatcher_(dispatcher) {} in PortObserverThunk()
64 void OnPortStatusChanged() override { dispatcher_->OnPortStatusChanged(); } in OnPortStatusChanged()
66 scoped_refptr<DataPipeProducerDispatcher> dispatcher_; member in mojo::core::DataPipeProducerDispatcher::PortObserverThunk
|
| D | data_pipe_consumer_dispatcher.cc | 59 : dispatcher_(dispatcher) {} in PortObserverThunk()
65 void OnPortStatusChanged() override { dispatcher_->OnPortStatusChanged(); } in OnPortStatusChanged()
67 scoped_refptr<DataPipeConsumerDispatcher> dispatcher_; member in mojo::core::DataPipeConsumerDispatcher::PortObserverThunk
|
| /external/abseil-cpp/absl/strings/internal/str_format/ |
| D | arg.h | 208 return arg.dispatcher_(arg.data_, {}, out);
214 return arg.dispatcher_(arg.data_, conv, out);
219 return arg.dispatcher_;
339 dispatcher_ = &Dispatch<T>;
391 Dispatcher dispatcher_;
|
| /external/webrtc/third_party/abseil-cpp/absl/strings/internal/str_format/ |
| D | arg.h | 208 return arg.dispatcher_(arg.data_, {}, out);
214 return arg.dispatcher_(arg.data_, conv, out);
219 return arg.dispatcher_;
339 dispatcher_ = &Dispatch<T>;
391 Dispatcher dispatcher_;
|
| /external/openscreen/third_party/abseil/src/absl/strings/internal/str_format/ |
| D | arg.h | 279 return arg.dispatcher_(arg.data_, {}, out);
285 return arg.dispatcher_(arg.data_, conv, out);
290 return arg.dispatcher_;
419 dispatcher_ = &Dispatch<T>;
476 Dispatcher dispatcher_;
|
| /external/libtextclassifier/abseil-cpp/absl/strings/internal/str_format/ |
| D | arg.h | 265 return arg.dispatcher_(arg.data_, {}, out);
271 return arg.dispatcher_(arg.data_, conv, out);
276 return arg.dispatcher_;
405 dispatcher_ = &Dispatch<T>;
462 Dispatcher dispatcher_;
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/internal/str_format/ |
| D | arg.h | 265 return arg.dispatcher_(arg.data_, {}, out);
271 return arg.dispatcher_(arg.data_, conv, out);
276 return arg.dispatcher_;
405 dispatcher_ = &Dispatch<T>;
462 Dispatcher dispatcher_;
|
| /external/angle/third_party/abseil-cpp/absl/strings/internal/str_format/ |
| D | arg.h | 287 return arg.dispatcher_(arg.data_, {}, out);
293 return arg.dispatcher_(arg.data_, conv, out);
298 return arg.dispatcher_;
427 dispatcher_ = &Dispatch<T>;
484 Dispatcher dispatcher_;
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | data_service_dataset_op.cc | 233 Status s = dispatcher_->ReleaseJobClient(job_client_id_); in ~Iterator()
263 dispatcher_ = absl::make_unique<DataServiceDispatcherClient>( in Initialize()
274 return dispatcher_->GetOrCreateJob( in Initialize()
489 Status s = dispatcher_->ClientHeartbeat(req, resp); in Heartbeat()
830 std::unique_ptr<DataServiceDispatcherClient> dispatcher_; member in tensorflow::data::DataServiceDatasetOp::Dataset::Iterator
|