| /external/antlr/runtime/C/src/ |
| D | antlr3rewritestreams.c | 3 /// tree re-write rules to manipulate the tokens and trees produced
8 // Copyright (c) 2005-2009 Jim Idle, Temporal Wave LLC
9 // http://www.temporal-wave.com
25 // THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
38 // Static support function forward declarations for the stream types.
40 static void reset (pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream);
41 static void add (pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream, void * el, void (ANTLR3_CDECL *f…
42 static void * next (pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream);
43 static pANTLR3_BASE_TREE nextTree (pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream);
44 static void * nextToken (pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream);
[all …]
|
| D | antlr3commontreenodestream.c | 2 /// Defines the implementation of the common node stream the default
3 /// tree node stream used by ANTLR.
7 // Copyright (c) 2005-2009 Jim Idle, Temporal Wave LLC
8 // http://www.temporal-wave.com
24 // THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
41 // COMMON TREE STREAM API
52 // TREE NODE STREAM API
64 // INT STREAM API
66 static void consume (pANTLR3_INT_STREAM is);
67 static ANTLR3_MARKER tindex (pANTLR3_INT_STREAM is);
[all …]
|
| D | antlr3tokenstream.c | 6 // Copyright (c) 2005-2009 Jim Idle, Temporal Wave LLC
7 // http://www.temporal-wave.com
23 // THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
64 // INT STREAM API
66 static void consume (pANTLR3_INT_STREAM is);
67 static void dbgConsume (pANTLR3_INT_STREAM is);
68 static ANTLR3_UINT32 _LA (pANTLR3_INT_STREAM is, ANTLR3_INT32 i);
69 static ANTLR3_UINT32 dbgLA (pANTLR3_INT_STREAM is, ANTLR3_INT32 i);
70 static ANTLR3_MARKER mark (pANTLR3_INT_STREAM is);
71 static ANTLR3_MARKER dbgMark (pANTLR3_INT_STREAM is);
[all …]
|
| /external/cronet/net/base/ |
| D | chunked_upload_data_stream_unittest.cc | 2 // Use of this source code is governed by a BSD-style license that can be
27 constexpr size_t kTestDataSize = std::size(kTestData) - 1;
32 // Reads data once from the upload data stream, and returns the data as string.
34 std::string ReadSync(UploadDataStream* stream, int buffer_size) { in ReadSync() argument
36 int result = stream->Read(buf.get(), in ReadSync()
40 return std::string(buf->data(), result); in ReadSync()
43 // Check the case data is added after the first read attempt.
45 ChunkedUploadDataStream stream(0); in TEST() local
48 stream.Init(TestCompletionCallback().callback(), NetLogWithSource()), in TEST()
50 EXPECT_FALSE(stream.IsInMemory()); in TEST()
[all …]
|
| /external/oboe/docs/ |
| D | FullGuide.md | 2 Oboe is a C++ library which makes it easy to build high-performance audio apps on Android. Apps com…
6 …ams*, represented by the class `AudioStream`. The read/write calls can be blocking or non-blocking.
8 A stream is defined by the following:
10 * The *audio* *device* that is the source or sink for the data in the stream.
11 * The *sharing mode* that determines whether a stream has exclusive access to an audio device tha…
12 * The *format* of the audio data in the stream.
16 Each stream is attached to a single audio device.
18 An audio device is a hardware interface or virtual endpoint that acts as a source or sink for a con…
19 (a built-in mic or bluetooth headset) with the *Android device* (the phone or watch) that is runnin…
23 … a unique ID on the Android device. You can use the ID to bind an audio stream to a specific audi…
[all …]
|
| /external/rust/crates/h2/src/proto/streams/ |
| D | stream.rs | 7 /// Tracks Stream related state
11 /// There can be a number of outstanding handles to a single Stream. These are
13 /// number of outstanding userspace handles that can reach this stream.
15 /// It's important to note that when the stream is placed in an internal queue
16 /// (such as an accept queue), this is **not** tracked by a reference count.
17 /// Thus, `ref_count` can be zero and the stream still has to be kept around.
19 pub(super) struct Stream { struct
20 /// The h2 stream identifier
23 /// Current state of the stream
26 /// Set to `true` when the stream is counted against the connection's max
[all …]
|
| D | prioritize.rs | 18 /// Queued streams are ordered by stream ID, as we need to ensure that
19 /// lower-numbered streams are sent headers before higher-numbered ones.
20 /// This is because "idle" stream IDs – those which have been initiated but
22 /// frame on a higher stream ID. If these queues was not ordered by stream
23 /// IDs, some mechanism would be necessary to ensure that the lowest-numbered]
24 /// idle stream is opened first.
28 pending_send: store::Queue<stream::NextSend>,
31 pending_capacity: store::Queue<stream::NextSendCapacity>,
35 /// The `SendRequest` handle is `Clone`. This enables initiating requests
37 /// backpressure at some level is tricky. If there are many `SendRequest`
[all …]
|
| D | recv.rs | 24 /// The lowest stream ID that is still idle
27 /// The stream ID of the last processed stream
32 /// This starts as MAX, but is lowered when a GOAWAY is received.
36 /// > the identified last stream.
40 pending_window_updates: store::Queue<stream::NextWindowUpdate>,
43 pending_accept: store::Queue<stream::NextAccept>,
46 pending_reset_expired: store::Queue<stream::NextResetExpire>,
60 /// If extended connect protocol is enabled.
84 pub fn new(peer: peer::Dyn, config: &Config) -> Self { in new()
114 pub fn init_window_sz(&self) -> WindowSize { in init_window_sz()
[all …]
|
| /external/python/pyyaml/lib/yaml/ |
| D | __init__.py | 20 #------------------------------------------------------------------------------
21 # XXX "Warnings control" is now deprecated. Leaving in the API function to not
23 #------------------------------------------------------------------------------
25 if settings is None:
28 #------------------------------------------------------------------------------
29 def scan(stream, Loader=Loader): argument
31 Scan a YAML stream and produce scanning tokens.
33 loader = Loader(stream)
40 def parse(stream, Loader=Loader): argument
42 Parse a YAML stream and produce parsing events.
[all …]
|
| /external/sonic/ |
| D | sonic.c | 4 This file is part of the Sonic Library.
6 This file is licensed under the Apache 2.0 license.
24 return 0.5*(1.0 - cos(2*M_PI*x/N));
31 x -= N/2.0;
32 if (x > 1e-9 || x < -1e-9) {
59 0, 0, 0, 0, 0, 0, 0, -1, -1, -2, -2,
60 -3, -4, -6, -7, -9, -10, -12, -14, -17, -19, -21,
61 -24, -26, -29, -32, -34, -37, -40, -42, -44, -47, -48,
62 -50, -51, -52, -53, -53, -53, -52, -50, -48, -46, -43,
63 -39, -34, -29, -22, -16, -8, 0, 9, 19, 29, 41,
[all …]
|
| D | sonic.h | 7 This file is part of the Sonic Library.
9 This file is licensed under the Apache 2.0 license.
15 generates smooth speech at speed up factors as high as 6X, possibly more. It is
18 more, the following equation is used:
20 newSamples = period/(speed - 1.0)
23 where period is the current pitch period, determined using AMDF or any other
24 pitch estimator, and speed is the speedup factor. If the current position in
25 the input stream is pointed to by "samples", and the current output stream
26 position is pointed to by "out", then newSamples number of samples can be
29 out[t] = (samples[t]*(newSamples - t) + samples[t + period]*t)/newSamples;
[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/apache-commons-lang/src/main/java/org/apache/commons/lang3/stream/ |
| D | Streams.java | 9 * http://www.apache.org/licenses/LICENSE-2.0
12 * distributed under the License is distributed on an "AS IS" BASIS,
17 package org.apache.commons.lang3.stream;
36 import java.util.stream.Collector;
37 import java.util.stream.Collectors;
38 import java.util.stream.Stream;
39 import java.util.stream.StreamSupport;
48 …* Provides utility functions, and classes for working with the {@code java.util.stream} package, o…
55 * Consumer<java.lang.reflect.Method> consumer = m -> {
62 * stream.forEach(consumer);
[all …]
|
| /external/rust/crates/libz-sys/src/zlib/contrib/ada/ |
| D | zlib-streams.adb | 1 ----------------------------------------------------------------
2 -- ZLib for Ada thick binding. --
3 -- --
4 -- Copyright (C) 2002-2003 Dmitriy Anisimkov --
5 -- --
6 -- Open source license information is in the zlib.ads file. --
7 ----------------------------------------------------------------
9 -- $Id: zlib-streams.adb,v 1.10 2004/05/31 10:53:40 vagul Exp $
13 package body ZLib.Streams is
15 -----------
[all …]
|
| /external/dng_sdk/source/ |
| D | dng_stream.h | 2 // Copyright 2006-2007 Adobe Systems Incorporated
14 /** Data stream abstraction for serializing and deserializing sequences of
35 const uint64 kDNGStreamInvalidOffset = (uint64) (int64) -1;
39 /// Base stream abstraction. Has support for going between stream and pointer
103 /// Construct a stream with initial data.
104 /// \param data Pointer to initial contents of stream.
105 /// \param count Number of bytes data is valid for.
115 /// Getter for whether stream is swapping byte order on input/output.
123 /// Setter for whether stream is swapping byte order on input/output.
124 /// \param swapBytes If true, stream will swap byte order on input or
[all …]
|
| /external/antlr/runtime/ObjC/Framework/test/runtime/stream/ |
| D | ANTLRStringStreamTest.m | 16 -(void) testInitWithInput
18 NSString *input = @"This is a string used for ANTLRStringStream input ;)";
19 ANTLRStringStream *stream = [ANTLRStringStream newANTLRStringStream:input];
20 NSString *subString = [stream substring:0 To:10];
22 STAssertTrue([@"This is a " isEqualToString:subString], @"The strings do not match");
23 [stream release];
26 -(void) testConsumeAndReset
28 …ANTLRStringStream *stream = [ANTLRStringStream newANTLRStringStream:@"This is a string used for in…
29 [stream consume];
30 STAssertTrue(stream.index > 0, @"Index should be greater than 0 after consume");
[all …]
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Streams.java | 8 * http://www.apache.org/licenses/LICENSE-2.0
11 * distributed under the License is distributed on an "AS IS" BASIS,
45 import java.util.stream.BaseStream;
46 import java.util.stream.DoubleStream;
47 import java.util.stream.IntStream;
48 import java.util.stream.LongStream;
49 import java.util.stream.Stream;
50 import java.util.stream.StreamSupport;
55 * Static utility methods related to {@code Stream} instances.
63 * Returns a sequential {@link Stream} of the contents of {@code iterable}, delegating to {@link
[all …]
|
| /external/oj-libjdwp/src/share/back/ |
| D | inStream.c | 5 * This code is free software; you can redistribute it and/or modify it
11 * This code is distributed in the hope that it will be useful, but WITHOUT
14 * version 2 for more details (a copy is included in the LICENSE file that
19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
27 #include "stream.h"
41 inStream_init(PacketInputStream *stream, jdwpPacket packet) in inStream_init() argument
43 stream->packet = packet; in inStream_init()
44 stream->error = JDWP_ERROR(NONE); in inStream_init()
45 stream->left = packet.type.cmd.len; in inStream_init()
46 stream->current = packet.type.cmd.data; in inStream_init()
[all …]
|
| /external/python/google-api-python-client/docs/dyn/ |
| D | youtube_v3.liveStreams.html | 8 font-weight: inherit;
9 font-style: inherit;
10 font-size: 100%;
11 font-family: inherit;
12 vertical-align: baseline;
16 font-size: 13px;
21 font-size: 26px;
22 margin-bottom: 1em;
26 font-size: 24px;
27 margin-bottom: 1em;
[all …]
|
| /external/apache-commons-lang/src/main/java/org/apache/commons/lang3/ |
| D | Streams.java | 9 * http://www.apache.org/licenses/LICENSE-2.0
12 * distributed under the License is distributed on an "AS IS" BASIS,
30 import java.util.stream.Collector;
31 import java.util.stream.Collectors;
32 import java.util.stream.Stream;
40 * {@code java.util.stream} package, or more generally, with Java 8 lambdas. More
45 * Consumer<java.lang.reflect.Method> consumer = m -> {
52 * stream.forEach(consumer);
56 * Streams.failable(stream).forEach((m) -> m.invoke(o, args));
58 * Obviously, the second version is much more concise and the spirit of
[all …]
|
| /external/freetype/src/base/ |
| D | ftstream.c | 5 * I/O stream support (body).
7 * Copyright (C) 2000-2023 by
10 * This file is part of the FreeType project, and may only be used,
25 * The macro FT_COMPONENT is used in trace mode. It is an implicit
30 #define FT_COMPONENT stream
34 FT_Stream_OpenMemory( FT_Stream stream, in FT_Stream_OpenMemory() argument
38 stream->base = (FT_Byte*) base; in FT_Stream_OpenMemory()
39 stream->size = size; in FT_Stream_OpenMemory()
40 stream->pos = 0; in FT_Stream_OpenMemory()
41 stream->cursor = NULL; in FT_Stream_OpenMemory()
[all …]
|
| /external/libbrillo/brillo/streams/ |
| D | stream.h | 2 // Use of this source code is governed by a BSD-style license that can be
20 // Stream is a base class that specific stream storage implementations must
22 // The stream class provides general streaming I/O primitives to read, write and
23 // seek within a stream. It has methods for asynchronous (callback-based) as
24 // well as synchronous (both blocking and non-blocking) operations.
25 // The Stream class is abstract and cannot be created by itself.
26 // In order to construct a stream, you must use one of the derived classes'
27 // factory methods which return a stream smart pointer (StreamPtr):
33 // while (input_stream->ReadBlocking(buf, sizeof(buf), &read, nullptr)) {
35 // output_stream->WriteAllBlocking(buf, read, nullptr);
[all …]
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | mod.rs | 3 //! This module contains a number of functions for working with `Stream`s,
4 //! including the `StreamExt` trait which adds methods to `Stream` types.
7 use crate::stream::assert_stream;
14 use futures_core::stream::TryStream;
16 use futures_core::stream::{BoxStream, LocalBoxStream};
19 stream::{FusedStream, Stream},
28 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
32 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
36 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
40 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
[all …]
|
| /external/angle/third_party/logdog/logdog/ |
| D | stream.py | 2 # Use of this source code is governed under the Apache License, Version 2.0
28 # Magic number at the beginning of a Butler stream
31 # <luci-go>/logdog/client/butlerlib/streamproto
36 """Defines the set of parameters to apply to a new stream."""
38 # A text content stream.
40 # A binary content stream.
42 # A datagram content stream.
63 if self.tags is not None:
72 Converts stream parameters to JSON for Butler consumption.
85 if value is not None:
[all …]
|
| /external/rust/crates/async-stream/ |
| D | README.md | 3 Asynchronous stream of elements.
5 Provides two macros, `stream!` and `try_stream!`, allowing the caller to
9 The `stream!` macro returns an anonymous type implementing the [`Stream`]
10 trait. The `Item` associated type is the type of the values yielded from the
11 stream. The `try_stream!` also returns an anonymous type implementing the
12 [`Stream`] trait, but the `Item` associated type is `Result<T, Error>`. The
18 A basic stream yielding numbers. Values are yielded using the `yield`
19 keyword. The stream block must return `()`.
22 use async_stream::stream;
25 use futures_util::stream::StreamExt;
[all …]
|