| /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 | 209 private BlockingQueue<MockClientTransportInfo> transports; field in ManagedChannelImplTest
254 transports = TestUtils.captureTransports(mockTransportFactory); in setUp()
354 MockClientTransportInfo transportInfo = transports.poll(); in channelzMembership_subchannel()
391 MockClientTransportInfo transportInfo = transports.poll(); in channelzMembership_oob()
442 MockClientTransportInfo transportInfo = transports.poll(); in subtestCallsAndShutdown()
577 MockClientTransportInfo transportInfo1 = transports.poll(); in noMoreCallbackAfterLoadBalancerShutdown()
578 MockClientTransportInfo transportInfo2 = transports.poll(); in noMoreCallbackAfterLoadBalancerShutdown()
643 MockClientTransportInfo transportInfo = transports.poll(); in callOptionsExecutor()
867 MockClientTransportInfo badTransportInfo = transports.poll(); in firstResolvedServerFailedToConnect()
875 MockClientTransportInfo goodTransportInfo = transports.poll(); in firstResolvedServerFailedToConnect()
[all …]
|
| /external/adhd/cras/src/server/ |
| D | cras_bt_transport.c | 40 static struct cras_bt_transport *transports; variable
63 DL_APPEND(transports, transport); in cras_bt_transport_create()
75 DL_DELETE(transports, transport); in cras_bt_transport_destroy()
89 while (transports) { in cras_bt_transport_reset()
91 transports->object_path); in cras_bt_transport_reset()
92 cras_bt_transport_destroy(transports); in cras_bt_transport_reset()
101 DL_FOREACH(transports, transport) { in cras_bt_transport_get()
116 DL_FOREACH(transports, transport) { in cras_bt_transport_get_list()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_transports.py | 7 from asyncio import transports
67 class MyTransport(transports._FlowControlMixin,
68 transports.Transport):
|
| /external/python/cpython3/Lib/asyncio/ |
| D | __init__.py | 19 from .transports import *
36 transports.__all__)
|
| D | proactor_events.py | 20 from . import transports
24 class _ProactorBasePipeTransport(transports._FlowControlMixin,
25 transports.BaseTransport):
157 transports.ReadTransport):
297 transports.WriteTransport):
430 transports.Transport):
442 transports.Transport):
|
| D | base_subprocess.py | 6 from . import transports
10 class BaseSubprocessTransport(transports.SubprocessTransport):
|
| D | sslproto.py | 11 from . import transports
284 class _SSLProtocolTransport(transports._FlowControlMixin,
285 transports.Transport):
|
| D | unix_events.py | 24 from . import transports
422 class _UnixReadPipeTransport(transports.ReadTransport):
548 class _UnixWritePipeTransport(transports._FlowControlMixin,
549 transports.WriteTransport):
|
| D | selector_events.py | 27 from . import transports
566 class _SelectorTransport(transports._FlowControlMixin,
567 transports.Transport):
|
| D | base_events.py | 44 from . import transports
181 if not isinstance(transp, transports._FlowControlMixin):
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 107 private final List<NettyClientTransport> transports = new ArrayList<>(); field in NettyClientTransportTest
130 for (NettyClientTransport transport : transports) { in teardown()
146 transports.clear(); in testToString()
179 transports.add(transport); in setSoLingerChannelOption()
239 final List<Rpc> rpcs = new ArrayList<>(transports.size()); in creatingMultipleTlsTransportsShouldSucceed()
240 for (NettyClientTransport transport : transports) { in creatingMultipleTlsTransportsShouldSucceed()
382 serverListener.transports.get(0).channel().pipeline().firstContext().close(); in bufferedStreamsShouldBeClosedWhenConnectionTerminates()
419 transports.add(transport); in failingToConstructChannelShouldFailGracefully()
597 transports.add(transport); in newTransport()
753 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/oj-libjdwp/src/share/back/ |
| D | debugInit.c | 82 static struct bag *transports; /* of TransportSpec */ variable
819 (void)bagEnumerateOver(transports, startTransport, &arg); in initialize()
904 (void)bagEnumerateOver(transports, startTransport, &arg); in debugInit_reset()
1164 transports = bagCreateBag(sizeof(TransportSpec), 3); in parseOptions()
1165 if (transports == NULL) { in parseOptions()
1182 currentTransport = bagAdd(transports); in parseOptions()
1345 if (bagSize(transports) == 0) { in parseOptions()
1354 if (bagSize(transports) > 1) { in parseOptions()
1361 jboolean specified = bagEnumerateOver(transports, checkAddress, NULL); in parseOptions()
|
| /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,
78 asyncio implements transports for TCP, UDP, SSL, and subprocess pipes.
89 Base class for all transports. Contains methods that all
90 asyncio transports share.
181 Categories of information that can be queried on some transports:
369 .. _asyncio-subprocess-transports:
425 If the subprocess hasn't returned yet, and close transports of
436 together with :ref:`transports <asyncio-transport>`.
[all …]
|
| D | asyncio-future.rst | 74 :ref:`transports <asyncio-transports-protocols>`)
|
| D | asyncio-subprocess.rst | 111 as well as the :ref:`Subprocess Transports <asyncio-subprocess-transports>`
|
| /external/webrtc/webrtc/p2p/base/ |
| D | sessiondescription.h | 96 const TransportInfos& transports, in SessionDescription() argument
99 transport_infos_(transports), in SessionDescription()
|
| D | faketransportcontroller.h | 523 for (auto& kv : transports()) { in Connect_w()
530 for (auto& kv : transports()) { in ConnectChannels_w()
|
| D | transportcontroller.h | 119 const std::map<std::string, Transport*>& transports() { return transports_; } in transports() function
|
| /external/grpc-grpc/doc/core/ |
| D | transport_explainer.md | 8 transports](https://github.com/grpc/grpc/tree/master/src/core/ext/transport)
11 the transports are nominally written in C++ though they are idiomatically C. The
12 existing transports are:
117 complete. In some transports, a send can sometimes complete before the recv on
|
| /external/grpc-grpc-java/documentation/ |
| D | android-channel-builder.md | 29 both the OkHttp and Cronet transports in the future, but the network listener
|
| /external/perfetto/protos/perfetto/ipc/ |
| D | producer_port.proto | 217 // This message also transports the file descriptor for the shared memory
|