| /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 | 452 grpc_core::ExecutorType::DEFAULT, in do_read()
488 grpc_core::ExecutorType::DEFAULT, in OnRead()
552 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 | StreamingPingPongsPerSecondBenchmark.java | 78 super.setup(ExecutorType.DIRECT, in setup()
79 ExecutorType.DIRECT, in setup()
|
| D | StreamingResponseBandwidthBenchmark.java | 79 super.setup(ExecutorType.DIRECT, in setup()
80 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/mobile-data-download/javatests/com/google/android/libraries/mobiledatadownload/ |
| D | DownloadFileGroupCancellationIntegrationTest.java | 19 …rt static com.google.android.libraries.mobiledatadownload.testing.MddTestDependencies.ExecutorType;
106 @TestParameter ExecutorType controlExecutorType;
|
| D | MobileDataDownloadIntegrationTest.java | 24 …rt static com.google.android.libraries.mobiledatadownload.testing.MddTestDependencies.ExecutorType;
128 @Parameter public ExecutorType controlExecutorType;
134 {ExecutorType.SINGLE_THREADED}, {ExecutorType.MULTI_THREADED}, in data()
674 if (controlExecutorType.equals(ExecutorType.SINGLE_THREADED)) { in download_failure_logsEvent()
1011 if (controlExecutorType.equals(ExecutorType.SINGLE_THREADED)) { in handleTask_duplicateInvocations_logsDownloadCompleteOnce()
|
| D | MobileDataDownloadIsolatedStructuresIntegrationTest.java | 22 …rt static com.google.android.libraries.mobiledatadownload.testing.MddTestDependencies.ExecutorType;
107 @TestParameter ExecutorType controlExecutorType;
|
| D | DownloadFileIntegrationTest.java | 19 …rt static com.google.android.libraries.mobiledatadownload.testing.MddTestDependencies.ExecutorType;
98 @TestParameter ExecutorType controlExecutorType;
|
| D | MddGarbageCollectionWithAndroidSharingIntegrationTest.java | 18 …rt static com.google.android.libraries.mobiledatadownload.testing.MddTestDependencies.ExecutorType;
107 @TestParameter ExecutorType controlExecutorType;
|
| D | DownloadFileGroupIntegrationTest.java | 24 …rt static com.google.android.libraries.mobiledatadownload.testing.MddTestDependencies.ExecutorType;
135 @TestParameter ExecutorType controlExecutorType;
|
| D | DownloadFileGroupAndroidSharingIntegrationTest.java | 22 …rt static com.google.android.libraries.mobiledatadownload.testing.MddTestDependencies.ExecutorType;
123 ExecutorType controlExecutorType;
|
| D | ImportFilesIntegrationTest.java | 23 …rt static com.google.android.libraries.mobiledatadownload.testing.MddTestDependencies.ExecutorType;
165 @TestParameter ExecutorType controlExecutorType;
|
| /external/mobile-data-download/javatests/com/google/android/libraries/mobiledatadownload/testing/ |
| D | MddTestDependencies.java | 80 public enum ExecutorType { enum in MddTestDependencies
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | function.h | 970 static std::string ExecutorType(const InstantiateOptions& options,
|
| D | function.cc | 965 string FunctionLibraryRuntime::ExecutorType(const InstantiateOptions& options, in ExecutorType() function in tensorflow::FunctionLibraryRuntime
1102 string executor_type = FunctionLibraryRuntime::ExecutorType(options, attrs); in Canonicalize()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | function.cc | 823 item->executor_type = ExecutorType(options, attrs); in Instantiate()
|