| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | DelayedClientTransport.java | 8 * http://www.apache.org/licenses/LICENSE-2.0
47 * transport for each pending stream.
49 * <p>This transport owns every stream that it has created until a real transport has been picked
50 * for that stream, at which point the ownership of the stream is transferred to the real transport,
51 * thus the delayed transport stops owning the stream.
91 * Creates a new delayed transport.
96 * @param syncContext all listener callbacks of the delayed transport will be run from this
132 * <p>Otherwise, if the delayed transport is not shutdown, then a {@link PendingStream} is
142 long pickerVersion = -1; in newStream()
206 * when {@link #reprocess} is called. The delayed transport will be terminated when there is no
[all …]
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_timeout.rs | 1 #![cfg(all(feature = "time", feature = "sync", feature = "io-util"))]
7 use futures::stream;
9 async fn maybe_sleep(idx: i32) -> i32 { in maybe_sleep()
16 fn ms(n: u64) -> Duration { in ms()
24 // Items 2 and 4 time out. If we run the stream until it completes, in basic_usage()
29 let stream = stream::iter(1..=4).then(maybe_sleep).timeout(ms(100)); in basic_usage() localVariable
30 let mut stream = task::spawn(stream); in basic_usage() localVariable
33 assert_ready_eq!(stream.poll_next(), Some(Ok(1))); in basic_usage()
35 // Second item is delayed 200ms, times out after 100ms in basic_usage()
36 assert_pending!(stream.poll_next()); in basic_usage()
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_constants.h | 2 // Use of this source code is governed by a BSD-style license that can be
29 // Default number of connections for N-connection emulation.
40 // max packet size is 1500 bytes, 1500 - 48 = 1452.
43 // 1500(Ethernet) - 20(IPv4 header) - 8(UDP header) = 1472.
49 // ETH_MAX_MTU - MAX(sizeof(iphdr), sizeof(ip6_hdr)) - sizeof(udphdr).
50 inline constexpr QuicByteCount kMaxGsoPacketSize = 65535 - 40 - 8;
74 // Minimum size of initial flow control window, for both stream and session.
78 // Default size of initial flow control window, for both stream and session.
82 // Maximum flow control receive window limits for connection and stream.
118 // https://tools.ietf.org/html/draft-ietf-quic-transport-25#section-17.2.5
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/fuzzer/ |
| D | qpack_round_trip_fuzzer.cc | 2 // Use of this source code is governed by a BSD-style license that can be
33 for (auto it = value->begin(); it != value->end(); ++it) { in TruncateValueOnInvalidChars()
35 value->erase(it, value->end()); in TruncateValueOnInvalidChars()
96 // preserving order within each stream but not among streams.
122 // Enqueues |encoded_header_block| for delayed transmission.
126 if (it == header_blocks_.end() || it->first != stream_id) { in SendEncodedHeaderBlock()
129 QUICHE_CHECK_EQ(stream_id, it->first); in SendEncodedHeaderBlock()
130 it->second.push(HeaderBlock(std::move(encoded_header_block))); in SendEncodedHeaderBlock()
140 provider_->ConsumeIntegralInRange<size_t>(0, header_blocks_.size() - 1); in MaybeTransmitSomeData()
143 const QuicStreamId stream_id = it->first; in MaybeTransmitSomeData()
[all …]
|
| /external/webrtc/net/dcsctp/public/ |
| D | dcsctp_options.h | 4 * Use of this source code is governed by a BSD-style license
30 // -40 IPV6 header
31 // -8 UDP
32 // -24 GCM Cipher
33 // -13 DTLS record header
34 // -4 TURN ChannelData
48 // constant and can't be currently increased in run-time as "Add Incoming
51 // The socket implementation doesn't have any per-stream fixed costs, which is
56 // constant and can't be currently increased in run-time as "Add Outgoing
59 // The socket implementation doesn't have any per-stream fixed costs, which is
[all …]
|
| /external/libbrillo/brillo/streams/ |
| D | fake_stream.h | 2 // Use of this source code is governed by a BSD-style license that can be
16 #include <brillo/streams/stream.h>
20 // Fake stream implementation for testing.
21 // This class allows to provide data for the stream in tests that can be later
22 // read through the Stream interface. Also, data written into the stream can be
27 // each other. Also, the stream implementation is sequential only (no seeking).
28 // Good examples of a use case for fake stream are:
29 // - read-only sequential streams (file, memory, pipe, ...)
30 // - write-only sequential streams (same as above)
31 // - independent channel read-write streams (sockets, ...)
[all …]
|
| /external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/ |
| D | ASN1InputStream.java | 12 * A general purpose ASN.1 decoder - note: this class differs from the
14 * the stream. If an ASN.1 NULL is encountered a DER/BER Null object is
34 * the stream is automatically limited to the length of the input array.
46 * the stream is automatically limited to the length of the input array.
49 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
61 * @param input stream containing ASN.1 encoded data.
75 * @param input stream containing ASN.1 encoded data.
76 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
89 * @param input stream containing ASN.1 encoded data.
91 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
[all …]
|
| /external/bouncycastle/repackaged/bcprov/src/main/java/com/android/org/bouncycastle/asn1/ |
| D | ASN1InputStream.java | 13 * A general purpose ASN.1 decoder - note: this class differs from the
15 * the stream. If an ASN.1 NULL is encountered a DER/BER Null object is
37 * the stream is automatically limited to the length of the input array.
50 * the stream is automatically limited to the length of the input array.
53 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
65 * @param input stream containing ASN.1 encoded data.
79 * @param input stream containing ASN.1 encoded data.
80 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
93 * @param input stream containing ASN.1 encoded data.
95 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
[all …]
|
| /external/bouncycastle/repackaged_platform/bcprov/src/main/java/com/android/internal/org/bouncycastle/asn1/ |
| D | ASN1InputStream.java | 13 * A general purpose ASN.1 decoder - note: this class differs from the
15 * the stream. If an ASN.1 NULL is encountered a DER/BER Null object is
36 * the stream is automatically limited to the length of the input array.
48 * the stream is automatically limited to the length of the input array.
51 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
63 * @param input stream containing ASN.1 encoded data.
77 * @param input stream containing ASN.1 encoded data.
78 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
91 * @param input stream containing ASN.1 encoded data.
93 * @param lazyEvaluate true if parsing inside constructed objects can be delayed.
[all …]
|
| /external/webrtc/p2p/base/ |
| D | pseudo_tcp_unittest.cc | 4 * Use of this source code is governed by a BSD-style license
182 TaskQueueBase::Current()->PostDelayedTask( in TcpWritePacket()
184 --packets_in_flight_; in TcpWritePacket()
185 other->NotifyPacket(packet.c_str(), packet.size()); in TcpWritePacket()
199 TaskQueueBase::Current()->PostDelayedTask( in UpdateClock()
241 // Prepare the receive stream. in TestTransfer()
250 elapsed = rtc::Time32() - start; in TestTransfer()
267 // Stream bytes to the recv stream as they arrive. in OnTcpReadable()
271 // TODO(?): OnTcpClosed() is currently only notified on error - in OnTcpReadable()
272 // there is no on-the-wire equivalent of TCP FIN. in OnTcpReadable()
[all …]
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ServerCallStreamObserver.java | 8 * http://www.apache.org/licenses/LICENSE-2.0
26 * <p>Like {@code StreamObserver}, implementations are not required to be thread-safe; if multiple
51 * 'inbound' {@link StreamObserver}. That also means that the callback will be delayed if other
53 * it can poll {@link #isCancelled()}, which is not delayed.
58 * <p>Setting the onCancelHandler will suppress the on-cancel exception thrown by
60 * substantially benefit from observing cancellation, using a no-op {@code onCancelHandler} is
113 * Set a {@link Runnable} that will be executed every time the stream {@link #isReady()} state
154 * all the messages and trailing metadata have been sent and the stream has been closed. Note
162 * the 'inbound' {@link StreamObserver}. That also means that the callback will be delayed if
170 @ExperimentalApi("https://github.com/grpc/grpc-java/issues/8467")
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/qbone/ |
| D | qbone_client_session.h | 2 // Use of this source code is governed by a BSD-style license that can be
32 // QuicSession overrides. This will initiate the crypto stream.
34 // Override to create control stream at FORWARD_SECURE encryption level.
38 // crypto stream. If the handshake has completed then this is one greater
39 // than the number of round-trips needed for the handshake.
42 // Returns true if early data (0-RTT data) was sent and the server accepted
46 // Returns true if the handshake was delayed one round trip by the server
83 // Config for QUIC crypto client stream, used by the client.
85 // Passed to the control stream.
87 // The unowned control stream.
|
| /external/cronet/base/task/sequence_manager/ |
| D | task_queue.h | 2 // Use of this source code is governed by a BSD-style license that can be
23 #include "third_party/abseil-cpp/absl/types/optional.h"
46 // methods are not thread safe (enforeced via CHECKs), but cross-thread task
47 // posting is supported with thread-safe task runners.
60 // delayed tasks if it's enabled. By delaying the desired wake up time to a
61 // different allowed wake up time, the Throttler can hold off delayed tasks
75 // - Restrict task execution by inserting/updating a fence.
76 // - Update the TaskQueue's next delayed wake up via UpdateWakeUp().
83 // the next delayed wake-up (which happens at least every time this queue is
85 // wake-up for the next pending delayed task in this queue (pending delayed
[all …]
|
| /external/sg3_utils/doc/ |
| D | sg_stream_ctl.8 | 1 .TH SG_STREAM_CTL "8" "March 2018" "sg3_utils\-1.43" SG3_UTILS
3 sg_stream_ctl \- send SCSI STREAM CONTROL or GET STREAM STATUS command
6 [\fI\-\-brief\fR] [\fI\-\-close\fR] [\fI\-\-ctl=CTL\fR] [\fI\-\-get\fR]
7 [\fI\-\-help\fR] [\fI\-\-id=SID\fR] [\fI\-\-maxlen=LEN\fR] [\fI\-\-open\fR]
8 [\fI\-\-readonly\fR] [\fI\-\-verbose\fR] [\fI\-\-version\fR] \fIDEVICE\fR
12 Sends a SCSI STREAM CONTROL or GET STREAM STATUS command to the \fIDEVICE\fR.
13 These commands, together with WRITE STREAM(16 and 32) and several fields in
15 The stream commands were added in SBC\-4 draft 8 (September 2015).
17 Both STREAM CONTROL and GET STREAM STATUS commands expect data from the
18 \fIDEVICE\fR (referred to as 'data\-in'). In the case of STREAM CONTROL
[all …]
|
| /external/freetype/src/base/ |
| D | ftmac.c | 11 * Copyright (C) 1996-2023 by
33 face->num_fixed_sizes is set to 0, because bitmap data in `NFNT'
38 - Check whether the offered stream points to a Mac suitcase file. This
40 stream that gets passed to our init_face() routine is a stdio stream,
42 resource fork. So we just grab the stream->pathname field.
44 - Read the FOND resource into memory, then check whether there is a
47 - If there is a Type 1 font available (as a separate `LWFN' file), read
49 it into a memory stream, load the Type 1 driver and delegate the rest
56 - If there is a TrueType font (an `sfnt' resource), read it into memory,
57 wrap it into a memory stream, load the TrueType driver and delegate
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedStreamTest.java | 8 * http://www.apache.org/licenses/LICENSE-2.0
74 private DelayedStream stream = new DelayedStream(); field in DelayedStreamTest
79 stream.setAuthority(authority); in setStream_setAuthority()
80 stream.start(listener); in setStream_setAuthority()
81 callMeMaybe(stream.setStream(realStream)); in setStream_setAuthority()
89 stream.start(listener); in setAuthority_afterStart()
90 stream.setAuthority("notgonnawork"); in setAuthority_afterStart()
95 stream.start(listener); in start_afterStart()
96 stream.start(mock(ClientStreamListener.class)); in start_afterStart()
102 stream.writeMessage(message); in writeMessage_beforeStart()
[all …]
|
| /external/cldr/tools/scripts/tr-archive/ |
| D | package-lock.json | 2 "name": "tr-archive",
8 "name": "tr-archive",
10 "license": "Unicode-3.0",
12 "@not-dalia/gfm-toc": "github:not-dalia/gfm-toc",
13 "anchor-js": "^5.0.0",
17 "marked-alert": "^2.0.1"
20 "node_modules/@not-dalia/gfm-toc": {
22 …"resolved": "git+ssh://git@github.com/not-dalia/gfm-toc.git#68f2db628606366b51b51a071c8bb87f490575…
25 "escape-html": "^1.0.3",
30 "gfm-toc": "bin/gfm-toc"
[all …]
|
| /external/webrtc/video/ |
| D | decode_synchronizer.h | 4 * Use of this source code is governed by a BSD-style license
36 // A video receive stream can use the DecodeSynchronizer by receiving a
39 // scheduler. This instance is owned by the receive stream, and is borrowed by
42 // scheduler may be destroyed by the receive stream.
44 // When a frame is scheduled for decode by a receive stream using the
52 // delayed stream to catch up quickly.
54 // DecodeSynchronizer is single threaded - all method calls must run on the
|
| D | buffered_frame_decryptor.h | 4 * Use of this source code is governed by a BSD-style license
35 // stream. For example going from a none state to a first decryption or going
40 // Called each time the decryption stream status changes. This call is
50 // delayed when frame encryption is enabled but the key hasn't arrived yet. In
52 // them to prevent re-requesting the key frame. This optimization is
71 // the video stream.
|
| /external/webrtc/modules/video_coding/utility/ |
| D | quality_scaler.h | 4 * Use of this source code is governed by a BSD-style license
36 // video stream down or up).
72 // Starts checking for QP in a delayed task. When the resulting CheckQpTask
106 // is desired to decrease the resolution or frame rate of the stream and when QP
107 // is low it is desired to increase the resolution or frame rate of the stream.
108 // Whether to reconfigure the stream is ultimately up to the handler, which is
|
| /external/caliper/caliper/src/main/java/com/google/caliper/bridge/ |
| D | OpenedSocket.java | 7 * http://www.apache.org/licenses/LICENSE-2.0
49 // This interacts poorly with another TCP feature called 'delayed acks' (RFC 1122) if the in fromSocket()
51 // by the worker may be delayed by up to the delayed ack timeout (on linux this is 40-500ms, in fromSocket()
94 // marker in the stream. Otherwise we just have to catch EOFException. in read()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| D | quic_spdy_client_session.h | 2 // Use of this source code is governed by a BSD-style license that can be
60 // crypto stream. If the handshake has completed then this is one greater
61 // than the number of round-trips needed for the handshake.
72 // Returns true if early data (0-RTT data) was sent and the server accepted
76 // Returns true if the handshake was delayed one round trip by the server
96 // If an outgoing stream can be created, return true.
100 // If an incoming stream can be created, return true.
104 // Create the crypto stream. Called by Initialize().
|
| /external/cronet/components/cronet/android/api/src/org/chromium/net/ |
| D | BidirectionalStream.java | 2 // Use of this source code is governed by a BSD-style license that can be
24 * Builder for {@link BidirectionalStream}s. Allows configuring stream before constructing it
46 /** Lowest stream priority. Passed to {@link #setPriority}. */
49 /** Very low stream priority. Passed to {@link #setPriority}. */
52 /** Low stream priority. Passed to {@link #setPriority}. */
56 * Medium stream priority. Passed to {@link #setPriority}. This is the default priority
57 * given to the stream.
61 /** Highest stream priority. Passed to {@link #setPriority}. */
65 * Sets priority of the stream which should be one of the {@link #STREAM_PRIORITY_IDLE
66 * STREAM_PRIORITY_*} values. The stream is given {@link #STREAM_PRIORITY_MEDIUM} priority
[all …]
|
| /external/grpc-grpc-java/api/src/main/java/io/grpc/ |
| D | ClientStreamTracer.java | 8 * http://www.apache.org/licenses/LICENSE-2.0
25 * {@link StreamTracer} for the client-side.
27 @ExperimentalApi("https://github.com/grpc/grpc-java/issues/2861")
31 * The call was delayed due to waiting for name resolution result.
38 * The stream is being created on a ready transport.
87 * Creates a {@link ClientStreamTracer} for a new client stream. This is called inside the
88 * transport when it's creating the stream.
90 * @param info information about the stream
91 * @param headers the mutable headers of the stream. It can be safely mutated within this
92 * method. Changes made to it will be sent by the stream. It should not be saved
[all …]
|
| /external/cronet/android/java/src/android/net/http/ |
| D | BidirectionalStream.java | 2 // Use of this source code is governed by a BSD-style license that can be
29 * Lowest stream priority. Passed to {@link Builder#setPriority}.
33 * Very low stream priority. Passed to {@link Builder#setPriority}.
37 * Low stream priority. Passed to {@link Builder#setPriority}.
41 * Medium stream priority. Passed to {@link Builder#setPriority}. This is the
42 * default priority given to the stream.
46 * Highest stream priority. Passed to {@link Builder#setPriority}.
62 * Builder for {@link BidirectionalStream}s. Allows configuring stream before constructing
88 * Sets priority of the stream which should be one of the {@link #STREAM_PRIORITY_IDLE
89 * STREAM_PRIORITY_*} values. The stream is given {@link #STREAM_PRIORITY_MEDIUM} priority
[all …]
|