| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | InternalSubchannelTest.java | 126 private BlockingQueue<MockClientTransportInfo> transports; field in InternalSubchannelTest
136 transports = TestUtils.captureTransports(mockTransportFactory); in setUp()
188 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in singleAddressReconnect()
213 transports.poll().listener.transportShutdown(Status.RESOURCE_EXHAUSTED); in singleAddressReconnect()
236 transports.peek().listener.transportReady(); in singleAddressReconnect()
240 transports.peek().transport, in singleAddressReconnect()
245 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in singleAddressReconnect()
284 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
297 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
322 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
[all …]
|
| D | ManagedChannelImplTest.java | 208 private BlockingQueue<MockClientTransportInfo> transports; field in ManagedChannelImplTest
253 transports = TestUtils.captureTransports(mockTransportFactory); in setUp()
353 MockClientTransportInfo transportInfo = transports.poll(); in channelzMembership_subchannel()
390 MockClientTransportInfo transportInfo = transports.poll(); in channelzMembership_oob()
441 MockClientTransportInfo transportInfo = transports.poll(); in subtestCallsAndShutdown()
576 MockClientTransportInfo transportInfo1 = transports.poll(); in noMoreCallbackAfterLoadBalancerShutdown()
577 MockClientTransportInfo transportInfo2 = transports.poll(); in noMoreCallbackAfterLoadBalancerShutdown()
642 MockClientTransportInfo transportInfo = transports.poll(); in callOptionsExecutor()
866 MockClientTransportInfo badTransportInfo = transports.poll(); in firstResolvedServerFailedToConnect()
874 MockClientTransportInfo goodTransportInfo = transports.poll(); in firstResolvedServerFailedToConnect()
[all …]
|
| /external/python/python-api-core/tests/unit/operations_v1/ |
| D | test_operations_rest_client.py | 33 from google.api_core.operations_v1 import transports
64 transport = transports.rest.OperationsRestTransport(
128 "transport_class,transport_name", [(transports.OperationsRestTransport, "rest")]
169 transports.OperationsRestTransport,
174 assert transport == transports.OperationsRestTransport
179 [(AbstractOperationsClient, transports.OperationsRestTransport, "rest")],
212 client_info=transports.base.DEFAULT_CLIENT_INFO,
229 client_info=transports.base.DEFAULT_CLIENT_INFO,
246 client_info=transports.base.DEFAULT_CLIENT_INFO,
275 client_info=transports.base.DEFAULT_CLIENT_INFO,
[all …]
|
| /external/python/bumble/docs/mkdocs/src/hardware/ |
| D | index.md | 4 The Bumble Host connects to a controller over an [HCI Transport](../transports/index.md).
5 … transport is typically either [HCI over UART](../transports/serial.md) or [HCI over USB](../trans…
6 …transports/vhci.md) can be used to communicate with any controller hardware managed by the operati…
|
| /external/python/bumble/apps/ |
| D | controllers.py | 42 transports = []
46 transports.append(transport)
59 for transport in transports:
|
| /external/libwebsockets/lib/abstract/ |
| D | README.md | 1 # Abstract protocols and transports
10 "abstract protocols" and "abstract transports".
23 In the system, both the abstract protocols and transports are
31 completely different transports, eg, like serial, or to wire
47 The public api for defining abstract protocols and transports is
52 …- [transports.h](https://libwebsockets.org/git/libwebsockets/tree/include/libwebsockets/abstract/t…
144 ## Steps for adding new abstract transports
146 - add the public header in `./include/libwebsockets/abstract/transports/`
147 - add your transport sources under `./lib/abstract/transports/`
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowLocationManager.java | 1079 List<GnssStatusCallbackTransport> transports; in simulateGnssStatusStarted() local
1081 transports = gnssStatusTransports; in simulateGnssStatusStarted()
1084 for (GnssStatusCallbackTransport transport : transports) { in simulateGnssStatusStarted()
1092 List<GnssStatusCallbackTransport> transports; in simulateGnssStatusFirstFix() local
1094 transports = gnssStatusTransports; in simulateGnssStatusFirstFix()
1097 for (GnssStatusCallbackTransport transport : transports) { in simulateGnssStatusFirstFix()
1105 List<GnssStatusCallbackTransport> transports; in simulateGnssStatus() local
1107 transports = gnssStatusTransports; in simulateGnssStatus()
1110 for (GnssStatusCallbackTransport transport : transports) { in simulateGnssStatus()
1127 List<GnssStatusCallbackTransport> transports; in simulateGnssStatusStopped() local
[all …]
|
| /external/python/cpython3/Lib/asyncio/ |
| D | __init__.py | 21 from .transports import *
36 transports.__all__)
|
| D | proactor_events.py | 23 from . import transports
46 class _ProactorBasePipeTransport(transports._FlowControlMixin,
47 transports.BaseTransport):
178 transports.ReadTransport):
324 transports.WriteTransport):
456 transports.DatagramTransport):
586 transports.Transport):
598 transports.Transport):
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_transports.py | 7 from asyncio import transports
78 class MyTransport(transports._FlowControlMixin,
79 transports.Transport):
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 111 private final List<NettyClientTransport> transports = new ArrayList<>(); field in NettyClientTransportTest
136 for (NettyClientTransport transport : transports) { in teardown()
152 transports.clear(); in testToString()
185 transports.add(transport); in setSoLingerChannelOption()
245 final List<Rpc> rpcs = new ArrayList<>(transports.size()); in creatingMultipleTlsTransportsShouldSucceed()
246 for (NettyClientTransport transport : transports) { in creatingMultipleTlsTransportsShouldSucceed()
388 serverListener.transports.get(0).channel().pipeline().firstContext().close(); in bufferedStreamsShouldBeClosedWhenConnectionTerminates()
425 transports.add(transport); in failingToConstructChannelShouldFailGracefully()
608 transports.add(transport); in newTransport()
764 final List<NettyServerTransport> transports = new ArrayList<>(); field in NettyClientTransportTest.EchoServerListener
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | InternalSubchannel.java | 128 private final Collection<ConnectionClientTransport> transports = new ArrayList<>(); field in InternalSubchannel
248 transports.add(transport); in startNewTransport()
402 if (transports.isEmpty()) { in shutdown()
460 transportsCopy = new ArrayList<ManagedClientTransport>(transports); in shutdownNow()
505 transportsSnapshot = new ArrayList<InternalWithLogId>(transports); in getStats()
625 transports.remove(transport); in transportTerminated()
626 if (state.getState() == SHUTDOWN && transports.isEmpty()) { in transportTerminated()
|
| D | ServerImpl.java | 108 @GuardedBy("lock") private final Collection<ServerTransport> transports = field in ServerImpl
244 transportsCopy = new ArrayList<>(transports); in shutdownNow()
302 if (!transports.remove(transport)) { in transportClosed()
313 if (shutdown && transports.isEmpty() && transportServerTerminated) { in checkForTermination()
332 transports.add(transport); in transportCreated()
346 copiedTransports = new ArrayList<>(transports); in serverShutdown()
|
| /external/cronet/net/test/embedded_test_server/ |
| D | embedded_test_server_unittest.cc | 574 EXPECT_EQ(1u, delegate.transports().size()); in TEST_P()
575 EXPECT_EQ("foo", delegate.transports().back().accept_ch_frame); in TEST_P()
598 EXPECT_EQ(1u, delegate.transports().size()); in TEST_P()
599 EXPECT_EQ("a", delegate.transports().back().accept_ch_frame); in TEST_P()
610 EXPECT_EQ(1u, delegate.transports().size()); in TEST_P()
611 EXPECT_EQ("b", delegate.transports().back().accept_ch_frame); in TEST_P()
622 EXPECT_EQ(1u, delegate.transports().size()); in TEST_P()
623 EXPECT_EQ("c", delegate.transports().back().accept_ch_frame); in TEST_P()
|
| /external/oj-libjdwp/src/share/back/ |
| D | debugInit.c | 85 static struct bag *transports; /* of TransportSpec */ variable
822 (void)bagEnumerateOver(transports, startTransport, &arg); in initialize()
907 (void)bagEnumerateOver(transports, startTransport, &arg); in debugInit_reset()
1167 transports = bagCreateBag(sizeof(TransportSpec), 3); in parseOptions()
1168 if (transports == NULL) { in parseOptions()
1185 currentTransport = bagAdd(transports); in parseOptions()
1348 if (bagSize(transports) == 0) { in parseOptions()
1357 if (bagSize(transports) > 1) { in parseOptions()
1364 jboolean specified = bagEnumerateOver(transports, checkAddress, NULL); in parseOptions()
|
| /external/sg3_utils/suse/ |
| D | sg3_utils.spec | 44 devices. As well as devices on transports traditionally associated with
57 devices. As well as devices on transports traditionally associated with
77 devices. As well as devices on transports traditionally associated with
|
| /external/webrtc/pc/ |
| D | jsep_transport_collection.cc | 177 std::set<cricket::JsepTransport*> transports; in ActiveTransports() local
179 transports.insert(kv.second); in ActiveTransports()
181 return std::vector<cricket::JsepTransport*>(transports.begin(), in ActiveTransports()
182 transports.end()); in ActiveTransports()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio.rst | 55 :ref:`transports <asyncio-transports-protocols>`;
|
| D | asyncio-protocol.rst | 4 .. _asyncio-transports-protocols:
18 Essentially, transports and protocols should only be used in
63 * The `Examples`_ section showcases how to work with transports,
72 **Source code:** :source:`Lib/asyncio/transports.py`
82 asyncio implements transports for TCP, UDP, SSL, and subprocess pipes.
93 Base class for all transports. Contains methods that all
94 asyncio transports share.
185 Categories of information that can be queried on some transports:
373 .. _asyncio-subprocess-transports:
429 If the subprocess hasn't returned yet, and close transports of
[all …]
|
| /external/python/python-api-core/google/api_core/operations_v1/ |
| D | __init__.py | 20 from google.api_core.operations_v1.transports.rest import OperationsRestTransport
|
| /external/crosvm/system_api/src/protos/ |
| D | fido.rs | 377 pub transports: ::std::vec::Vec<AuthenticatorTransport>, field
459 &self.transports in get_transports()
462 self.transports.clear(); in clear_transports()
467 self.transports = v; in set_transports()
472 &mut self.transports in mut_transports()
477 ::std::mem::replace(&mut self.transports, ::std::vec::Vec::new()) in take_transports()
532 …::read_repeated_enum_with_unknown_fields_into(wire_type, is, &mut self.transports, 3, &mut self.un… in merge_from()
567 for value in &self.transports { in compute_size()
590 for v in &self.transports { in write_to_with_cached_sizes()
643 self.transports.clear(); in clear()
[all …]
|
| /external/python/bumble/docs/mkdocs/src/apps_and_tools/ |
| D | index.md | 11 …* [HCI Bridge](hci_bridge.md) - a HCI transport bridge to connect two HCI transports and filter/sn…
|
| /external/python/bumble/docs/mkdocs/src/platforms/ |
| D | linux.md | 34 See the [USB Transport page](../transports/usb.md) for general information on how to use HCI USB co…
58 See the [Serial Transport page](../transports/serial.md) for general information on how to use HCI …
63 See the [HCI Socket Transport page](../transports/hci_socket.md) for details on the `hci-socket` ta…
177 With the [VHCI transport](../transports/vhci.md) you can attach a Bumble virtual controller to the …
|
| /external/autotest/server/site_tests/cheets_CTS_R/ |
| D | control.x86.CtsWifiTestCases | 32 …/scripts/wifi connect %s %s' % (ssid, wifipass), 'android-sh -c \'dumpsys wifi transports -eth\''],
|
| D | control.arm.CtsHostsideNetworkTests | 32 …/scripts/wifi connect %s %s' % (ssid, wifipass), 'android-sh -c \'dumpsys wifi transports -eth\''],
|