Home
last modified time | relevance | path

Searched refs:transports (Results 1 – 25 of 46) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DInternalSubchannelTest.java126 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 …]
DManagedChannelImplTest.java208 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/libwebsockets/lib/abstract/
DREADME.md1 # 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/adhd/cras/src/server/
Dcras_bt_transport.c42 static struct cras_bt_transport *transports; variable
65 DL_APPEND(transports, transport); in cras_bt_transport_create()
97 DL_DELETE(transports, transport); in cras_bt_transport_destroy()
113 while (transports) { in cras_bt_transport_reset()
115 transports->object_path); in cras_bt_transport_reset()
116 cras_bt_transport_destroy(transports); in cras_bt_transport_reset()
124 DL_FOREACH (transports, transport) { in cras_bt_transport_get()
139 DL_FOREACH (transports, transport) { in cras_bt_transport_get_list()
/external/python/cpython3/Lib/asyncio/
D__init__.py21 from .transports import *
40 transports.__all__)
Dproactor_events.py23 from . import transports
46 class _ProactorBasePipeTransport(transports._FlowControlMixin,
47 transports.BaseTransport):
178 transports.ReadTransport):
322 transports.WriteTransport):
583 transports.Transport):
595 transports.Transport):
Dbase_subprocess.py6 from . import transports
10 class BaseSubprocessTransport(transports.SubprocessTransport):
Dsslproto.py10 from . import transports
283 class _SSLProtocolTransport(transports._FlowControlMixin,
284 transports.Transport):
Dunix_events.py25 from . import transports
436 class _UnixReadPipeTransport(transports.ReadTransport):
572 class _UnixWritePipeTransport(transports._FlowControlMixin,
573 transports.WriteTransport):
Dselector_events.py27 from . import transports
613 class _SelectorTransport(transports._FlowControlMixin,
614 transports.Transport):
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_transports.py7 from asyncio import transports
72 class MyTransport(transports._FlowControlMixin,
73 transports.Transport):
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientTransportTest.java111 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/
DInternalSubchannel.java128 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()
DServerImpl.java108 @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/
DdebugInit.c82 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/
Dasyncio.rst55 :ref:`transports <asyncio-transports-protocols>`;
Dasyncio-protocol.rst4 .. _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 …]
Dasyncio-future.rst81 :ref:`transports <asyncio-transports-protocols>`)
/external/webrtc/pc/
Dcomposite_rtp_transport.cc22 std::vector<RtpTransportInternal*> transports) in CompositeRtpTransport() argument
23 : transports_(std::move(transports)) { in CompositeRtpTransport()
Dcomposite_rtp_transport.h43 explicit CompositeRtpTransport(std::vector<RtpTransportInternal*> transports);
Dpeer_connection_signaling_unittest.cc141 std::set<DtlsTransportInterface*> transports; in NumberOfDtlsTransports() local
149 transports.insert(transceiver->sender()->dtls_transport().get()); in NumberOfDtlsTransports()
152 EXPECT_EQ(0UL, transports.size()); in NumberOfDtlsTransports()
155 return transports.size(); in NumberOfDtlsTransports()
/external/grpc-grpc/doc/core/
Dtransport_explainer.md8 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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
DREADME.md41 construction. To customize this behavior, transports build
/external/grpc-grpc-java/documentation/
Dandroid-channel-builder.md29 both the OkHttp and Cronet transports in the future, but the network listener
/external/perfetto/protos/perfetto/ipc/
Dproducer_port.proto275 // On Android/Linux/Mac this message also transports the file descriptor for

12