| /external/python/cpython3/Lib/asyncio/ |
| __init__.py | 19 from .transports import *
36 transports.__all__)
|
| proactor_events.py | 20 from . import transports
24 class _ProactorBasePipeTransport(transports._FlowControlMixin,
25 transports.BaseTransport):
26 """Base class for pipe and socket transports."""
157 transports.ReadTransport):
297 transports.WriteTransport):
430 transports.Transport):
442 transports.Transport):
|
| sslproto.py | 11 from . import transports
284 class _SSLProtocolTransport(transports._FlowControlMixin,
285 transports.Transport):
|
| base_subprocess.py | 6 from . import transports
10 class BaseSubprocessTransport(transports.SubprocessTransport):
|
| unix_events.py | 24 from . import transports
422 class _UnixReadPipeTransport(transports.ReadTransport):
548 class _UnixWritePipeTransport(transports._FlowControlMixin,
549 transports.WriteTransport):
[all...] |
| selector_events.py | 27 from . import transports
566 class _SelectorTransport(transports._FlowControlMixin,
567 transports.Transport):
[all...] |
| base_events.py | 44 from . import transports
181 if not isinstance(transp, transports._FlowControlMixin):
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| InternalSubchannelTest.java | 126 private BlockingQueue<MockClientTransportInfo> transports; field in class:InternalSubchannelTest
136 transports = TestUtils.captureTransports(mockTransportFactory);
188 transports.poll().listener.transportShutdown(Status.UNAVAILABLE);
213 transports.poll().listener.transportShutdown(Status.RESOURCE_EXHAUSTED);
236 transports.peek().listener.transportReady();
240 transports.peek().transport,
245 transports.poll().listener.transportShutdown(Status.UNAVAILABLE);
284 transports.poll().listener.transportShutdown(Status.UNAVAILABLE);
297 transports.poll().listener.transportShutdown(Status.UNAVAILABLE);
322 transports.poll().listener.transportShutdown(Status.UNAVAILABLE)
[all...] |
| ManagedChannelImplTest.java | 209 private BlockingQueue<MockClientTransportInfo> transports; field in class:ManagedChannelImplTest
254 transports = TestUtils.captureTransports(mockTransportFactory);
354 MockClientTransportInfo transportInfo = transports.poll();
391 MockClientTransportInfo transportInfo = transports.poll();
442 MockClientTransportInfo transportInfo = transports.poll();
521 // After call is moved out of delayed transport, LoadBalancer, NameResolver and the transports
577 MockClientTransportInfo transportInfo1 = transports.poll();
578 MockClientTransportInfo transportInfo2 = transports.poll();
643 MockClientTransportInfo transportInfo = transports.poll();
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_transports.py | 1 """Tests for transports.py."""
7 from asyncio import transports
67 class MyTransport(transports._FlowControlMixin,
68 transports.Transport):
|
| /external/adhd/cras/src/server/ |
| cras_bt_transport.c | 40 static struct cras_bt_transport *transports; variable in typeref:struct:cras_bt_transport
63 DL_APPEND(transports, transport);
75 DL_DELETE(transports, transport);
89 while (transports) {
91 transports->object_path);
92 cras_bt_transport_destroy(transports);
101 DL_FOREACH(transports, transport) {
116 DL_FOREACH(transports, transport) {
|
| /external/syzkaller/vendor/google.golang.org/api/googleapi/transport/ |
| apikey.go | 5 // Package transport contains HTTP transports used to make
|
| /external/webrtc/webrtc/p2p/base/ |
| sessiondescription.h | 96 const TransportInfos& transports,
99 transport_infos_(transports),
|
| faketransportcontroller.h | 523 for (auto& kv : transports()) {
530 for (auto& kv : transports()) {
|
| transportcontroller.h | 43 // Can only be set before transports are created.
71 // Start gathering candidates for any new transports, or transports doing an
102 // If all transports done gathering => complete,
119 const std::map<std::string, Transport*>& transports() { return transports_; } function in class:cricket::TransportController
208 // TODO(deadbeef): Move the fields below down to the transports themselves
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| NettyClientTransportTest.java | 107 private final List<NettyClientTransport> transports = new ArrayList<>(); field in class:NettyClientTransportTest
130 for (NettyClientTransport transport : transports) {
146 transports.clear();
179 transports.add(transport);
225 * Verifies that we can create multiple TLS client transports from the same builder.
231 // Create a couple client transports.
239 final List<Rpc> rpcs = new ArrayList<>(transports.size());
240 for (NettyClientTransport transport : transports) {
382 serverListener.transports.get(0).channel().pipeline().firstContext().close();
419 transports.add(transport)
753 final List<NettyServerTransport> transports = new ArrayList<>(); field in class:NettyClientTransportTest.EchoServerListener
[all...] |
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| InternalSubchannel.java | 63 * Transports for a single {@link SocketAddress}.
123 * All transports that are not terminated. At the very least the value of {@link #activeTransport}
124 * will be present, but previously used transports that still have streams or are stopping may
128 private final Collection<ConnectionClientTransport> transports = new ArrayList<>(); field in class:InternalSubchannel
248 transports.add(transport);
402 if (transports.isEmpty()) {
407 } // else: the callback will be run once all transports have been terminated
460 transportsCopy = new ArrayList<ManagedClientTransport>(transports);
505 transportsSnapshot = new ArrayList<InternalWithLogId>(transports);
535 /** Listener for real transports. *
[all...] |
| ServerImpl.java | 68 * Default implementation of {@link io.grpc.Server}, for creation by transports.
108 @GuardedBy("lock") private final Collection<ServerTransport> transports = field in class:ServerImpl
124 * @param transportServer transport server that will create new incoming transports
238 // Short-circuiting not strictly necessary, but prevents transports from needing to handle
244 transportsCopy = new ArrayList<>(transports);
247 // Short-circuiting not strictly necessary, but prevents transports from needing to handle
302 if (!transports.remove(transport)) {
313 if (shutdown && transports.isEmpty() && transportServerTerminated) {
332 transports.add(transport);
344 // transports collection can be modified during shutdown(), even if we hold the lock, du
[all...] |
| /frameworks/base/cmds/bmgr/src/com/android/commands/bmgr/ |
| Bmgr.java | 617 ArraySet<String> transports = new ArraySet<>(); local
620 transports.add(transport);
622 if (transports.size() == 0) {
629 System.out.println("Initializing transports: " + transports);
631 userId, transports.toArray(new String[transports.size()]), observer);
641 String arg = nextArg(); // sets, transports, packages set#
642 if ("transports".equals(arg)) {
678 String[] transports = mBmgr.listAllTransportsForUser(userId) local
[all...] |
| /external/oj-libjdwp/src/share/back/ |
| debugInit.c | 82 static struct bag *transports; /* of TransportSpec */ variable in typeref:struct:bag
100 * Elements of the transports bag
812 * Initialize transports
819 (void)bagEnumerateOver(transports, startTransport, &arg);
823 * 1) none of the transports was successfully started, and
829 EXIT_ERROR(map2jvmtiError(arg.error), "No transports initialized");
904 (void)bagEnumerateOver(transports, startTransport, &arg);
[all...] |
| /cts/hostsidetests/net/app/src/com/android/cts/net/hostside/ |
| VpnTest.java | 906 int[] transports = mCM.getNetworkCapabilities(underlyingNetwork).getTransportTypes(); local
[all...] |
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| ChannelOptions.cs | 148 /// <summary>Initial sequence number for http2 transports</summary>
|
| /external/chromium-trace/catapult/common/py_vulcanize/third_party/rjsmin/bench/ |
| jquery-1.7.1.js | [all...] |
| /external/grpc-grpc-java/core/ |
| grpc-core-1.14.0.jar | |
