| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | executor.cc | 58 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)];
61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
83 executor_enqueue_fns_[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)]
390 if (executors[static_cast<size_t>(ExecutorType::DEFAULT)] != nullptr) { in InitAll()
391 GPR_ASSERT(executors[static_cast<size_t>(ExecutorType::RESOLVER)] != in InitAll()
396 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
398 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
[all …]
|
| D | executor.h | 42 enum class ExecutorType { enum
87 ExecutorType executor_type = ExecutorType::DEFAULT,
101 static bool IsThreaded(ExecutorType executor_type);
|
| D | udp_server.cc | 451 grpc_core::ExecutorType::DEFAULT, in do_read()
487 grpc_core::ExecutorType::DEFAULT, in OnRead()
551 grpc_core::ExecutorType::DEFAULT, in OnCanWrite()
|
| D | resolve_address_windows.cc | 149 grpc_core::ExecutorType::RESOLVER); in windows_resolve_address()
|
| D | resolve_address_posix.cc | 169 grpc_core::ExecutorType::RESOLVER); in posix_resolve_address()
|
| D | tcp_posix.cc | 486 grpc_core::ExecutorType::DEFAULT, in run_poller()
529 GRPC_ERROR_NONE, grpc_core::ExecutorType::DEFAULT, in cover_self()
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | FlowControlledMessagesPerSecondBenchmark.java | 52 public ExecutorType clientExecutor = ExecutorType.DIRECT;
86 ExecutorType.DIRECT, in setup()
|
| D | SingleThreadBlockingQpsBenchmark.java | 44 super.setup(ExecutorType.DIRECT, in setup()
45 ExecutorType.DIRECT, in setup()
|
| D | UnaryCallQpsBenchmark.java | 70 super.setup(ExecutorType.DIRECT, in setup()
71 ExecutorType.DIRECT, in setup()
|
| D | UnaryCallResponseBandwidthBenchmark.java | 76 super.setup(ExecutorType.DIRECT, in setup()
77 ExecutorType.DIRECT, in setup()
|
| D | StreamingResponseBandwidthBenchmark.java | 79 super.setup(ExecutorType.DIRECT, in setup()
80 ExecutorType.DIRECT, in setup()
|
| D | StreamingPingPongsPerSecondBenchmark.java | 78 super.setup(ExecutorType.DIRECT, in setup()
79 ExecutorType.DIRECT, in setup()
|
| D | AbstractBenchmark.java | 105 public enum ExecutorType { enum in AbstractBenchmark
187 public void setup(ExecutorType clientExecutor, in setup()
188 ExecutorType serverExecutor, in setup()
213 if (serverExecutor == ExecutorType.DIRECT) { in setup()
216 if (clientExecutor == ExecutorType.DIRECT) { in setup()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | function.h | 908 static std::string ExecutorType(const InstantiateOptions& options,
|
| D | function.cc | 924 string FunctionLibraryRuntime::ExecutorType(const InstantiateOptions& options, in ExecutorType() function in tensorflow::FunctionLibraryRuntime
1060 string executor_type = FunctionLibraryRuntime::ExecutorType(options, attrs); in Canonicalize()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | function.cc | 811 item->executor_type = ExecutorType(options, attrs); in Instantiate()
|