| /third_party/grpc/test/core/end2end/ |
| D | generate_tests.bzl | 469 for poller in POLLERS:
470 if poller in topt.exclude_pollers:
473 name = "%s_test@%s@poller=%s" % (f, test_short_name, poller),
479 poller,
547 for poller in POLLERS:
548 if poller in topt.exclude_pollers:
551 name = "%s_nosec_test@%s@poller=%s" % (f, test_short_name, poller),
557 poller,
|
| /third_party/grpc/src/objective-c/ |
| D | README-CFSTREAM.md | 30 workaround to this problem with an alternative poller based on CFRunLoop. The poller can be enabled
31 by setting environment variable `GRPC_CFSTREAM_RUN_LOOP=1`. Note that the poller is a client side
32 only poller that does not support running a server on it. That means if an app opts in to the
33 CFRunLoop-based poller, the app cannot host a gRPC server (gRPC Objective-C does not support running
|
| /third_party/flutter/flutter/examples/platform_channel_swift/android/app/src/androidTest/java/com/example/platformchannel/ |
| D | ExampleInstrumentedTest.java | 29 final BitmapPoller poller = new BitmapPoller(5); in testBitmap() local
38 poller.start(flutterView); in testBitmap()
44 bitmap = poller.waitForBitmap(); in testBitmap()
|
| /third_party/flutter/flutter/examples/platform_channel/android/app/src/androidTest/java/com/example/platformchannel/ |
| D | ExampleInstrumentedTest.java | 29 final BitmapPoller poller = new BitmapPoller(5); in testBitmap() local
38 poller.start(flutterView); in testBitmap()
44 bitmap = poller.waitForBitmap(); in testBitmap()
|
| /third_party/python/Lib/test/ |
| D | _test_eintr.py | 446 poller = select.poll()
449 poller.poll(self.sleep_time * 1e3)
456 poller = select.epoll()
457 self.addCleanup(poller.close)
460 poller.poll(self.sleep_time)
478 poller = select.devpoll()
479 self.addCleanup(poller.close)
482 poller.poll(self.sleep_time * 1e3)
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | iomgr_custom.cc | 65 grpc_custom_poller_vtable* poller) { in grpc_custom_iomgr_init() argument
69 grpc_custom_pollset_init(poller); in grpc_custom_iomgr_init()
|
| D | iomgr_custom.h | 47 grpc_custom_poller_vtable* poller);
|
| /third_party/grpc/bazel/ |
| D | grpc_build_system.bzl | 176 # NOTE: these attributes won't be used for the poller-specific versions of a test
194 # support a single poller
204 # on linux we run the same test multiple times, once for each poller
205 for poller in POLLERS:
207 name = name + "@poller=" + poller,
215 poller,
|
| /third_party/grpc/test/core/iomgr/poller/ |
| D | BUILD | 20 name = "test/core/iomgr/poller",
22 ) # Used to test IO poller implementations.
|
| /third_party/flutter/flutter/packages/flutter_tools/test/general.shard/ |
| D | utils_test.dart | 128 Poller poller;
131 poller?.cancel();
136 poller = Poller(() async {
147 poller = Poller(() async {
156 // Make sure that the poller polls at delay + the time it took to run the callback.
159 poller = Poller(() async {
|
| /third_party/grpc/doc/core/ |
| D | grpc-polling-engines.md | 115 - The logic to choose a designated poller is quite complicated. Pollsets are internally sharded int…
117 …poller, we always try to find another worker on the current pollset. If there are no more workers …
118 …eeded to implement `grpc_pollset_kick` semantics) and a way randomly select a new designated poller
120 …poller is chosen. Similarly [`end_worker()`](https://github.com/grpc/grpc/blob/v1.15.1/src/core/li…
|
| D | combiner-explainer.md | 97 work happen. However, some operations are not covered by a poller
106 poller.
|
| D | epoll-polling-engine.md | 36 …an be in multiple `pollsets` and that each `pollset` might have multiple poller threads, it means …
119 …o wake up the polling threads in case of shutdowns or to re-evaluate the poller's interest in the …
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| D | grpc_aio.pyx.pxi | 17 cdef str _GRPC_ASYNCIO_ENGINE = os.environ.get('GRPC_ASYNCIO_ENGINE', 'poller').upper()
23 POLLER = 'poller'
|
| D | completion_queue.pyx.pxi | 85 # read the 1 byte sent by the poller thread. This setting is essential to allow
86 # multiple loops in multiple threads bound to the same poller.
|
| /third_party/grpc/test/core/end2end/tests/ |
| D | keepalive_timeout.cc | 233 grpc_core::UniquePtr<char> poller = GPR_GLOBAL_CONFIG_GET(grpc_poll_strategy); in test_read_delays_keepalive() local
235 if ((0 == strcmp(poller.get(), "poll"))) { in test_read_delays_keepalive()
|
| /third_party/skia/third_party/externals/dawn/infra/config/global/generated/ |
| D | luci-scheduler.cfg | 139 id: "primary-poller"
|
| /third_party/skia/third_party/externals/tint/infra/config/global/generated/ |
| D | luci-scheduler.cfg | 128 id: "primary-poller"
|
| /third_party/grpc/tools/ |
| D | bazel.rc | 90 build:python_poller_engine --test_env="GRPC_ASYNCIO_ENGINE=poller"
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | iomgr.pxd.pxi | 120 grpc_custom_poller_vtable* poller);
|
| /third_party/skia/third_party/externals/angle2/infra/config/generated/ |
| D | luci-scheduler.cfg | 298 id: "main-poller"
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/base/ |
| D | utils.dart | 279 printTrace('Error from poller: $error');
286 /// Cancels the poller.
|
| /third_party/libuv/docs/src/ |
| D | design.rst | 52 which have been added to the poller and callbacks will be fired indicating socket conditions
|
| /third_party/grpc/test/cpp/end2end/ |
| D | end2end_test.cc | 882 grpc_core::UniquePtr<char> poller = GPR_GLOBAL_CONFIG_GET(grpc_poll_strategy); in TEST_P() local
883 if (0 == strcmp(poller.get(), "poll")) { in TEST_P()
|
| D | async_end2end_test.cc | 414 grpc_core::UniquePtr<char> poller = GPR_GLOBAL_CONFIG_GET(grpc_poll_strategy); in TEST_P() local
415 if (0 == strcmp(poller.get(), "poll")) { in TEST_P()
|