| /external/chromium_org/net/quic/ |
| quic_client_session_test.cc | 123 std::vector<QuicReliableClientStream*> streams; local
127 streams.push_back(stream);
132 session_.CloseStream(streams[0]->id());
139 std::vector<QuicReliableClientStream*> streams; local
143 streams.push_back(stream);
154 session_.CloseStream(streams[0]->id());
164 // streams.
|
| quic_session.h | 5 // A QuicSession, which demuxes a single connection to individual streams.
83 // streams.
93 // Called by streams when they want to write data to the peer.
121 // Called by streams when they want to close the stream in both directions.
126 // Called when the session wants to go away and not accept any new streams.
180 // Returns the number of currently open streams, including those which have
182 // streams.
217 // stream. Returns NULL if max streams have already been opened.
237 // In this case, it deletes streams given that it's safe to do so (no other
238 // operations are being done on the streams at this time
241 base::hash_map<QuicStreamId, QuicDataStream*>* streams() { function in class:net::QuicSession
245 const base::hash_map<QuicStreamId, QuicDataStream*>* streams() const { function in class:net::QuicSession
[all...] |
| quic_stream_factory_test.cc | 228 // in streams on different sessions.
682 std::vector<QuicHttpStream*> streams; local
703 streams.push_back(stream.release());
720 streams.front()->Close(false);
728 STLDeleteElements(&streams);
[all...] |
| /external/antlr/antlr-3.4/runtime/C/include/ |
| antlr3recognizersharedstate.h | 191 /** Input stream stack, which allows the C programmer to switch input streams
195 pANTLR3_STACK streams; member in struct:ANTLR3_RECOGNIZER_SHARED_STATE_struct
197 /// A stack of token/tree rewrite streams that are available for use
200 /// allocate and deallocate rewtire streams on entry and exit. As
202 /// of the maximum number of allocated streams, which instead of
204 /// reuse. The streams are then all finally freed when this stack
|
| /external/antlr/antlr-3.4/tool/src/main/java/org/antlr/tool/ |
| GrammarSerializerFoo.java | 50 protected Stack streams = new Stack(); field in class:GrammarSerializerFoo
130 //streams.push(out);
138 //out = (DataOutputStream)streams.pop(); // restore previous stream
|
| /external/chromium_org/media/base/ |
| demuxer_perftest.cc | 51 typedef std::vector<media::DemuxerStream* > Streams;
63 // Returns true when all streams have reached end of stream.
67 const Streams& streams() { return streams_; } function in class:media::StreamReader
78 Streams streams_;
151 // Ignore streams at EOS.
|
| /external/chromium_org/net/spdy/ |
| spdy_write_queue_unittest.cc | 189 // RemovePendingWritesForStream() on one of the streams. No dequeued
223 // those streams without a stream id, or with a stream_id after that
236 base::WeakPtr<SpdyStream> streams[] = { local
243 streams[i % arraysize(streams)]);
248 for (int i = 0; i < 100; i += arraysize(streams)) {
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| diskcache.h | 43 // DiskCache - An LRU cache of streams, stored on disk.
45 // Streams are identified by a unique resource id. Multiple streams can be
47 // resources are flushed from the cache, all streams associated with those
84 size_t streams; member in struct:talk_base::DiskCache::Entry
|
| /external/chromium_org/third_party/webrtc/base/ |
| diskcache.h | 26 // DiskCache - An LRU cache of streams, stored on disk.
28 // Streams are identified by a unique resource id. Multiple streams can be
30 // resources are flushed from the cache, all streams associated with those
67 size_t streams; member in struct:rtc::DiskCache::Entry
|
| /external/sonivox/arm-fm-22k/lib_src/ |
| eas_data.h | 113 S_EAS_STREAM streams[MAX_NUMBER_STREAMS]; member in struct:s_eas_data_tag
|
| eas_miditypes.h | 101 S_SMF_STREAM *streams; /* pointer to individual streams in file */ member in struct:s_smf_data_tag
108 EAS_U16 numStreams; /* actual number of streams */
|
| /external/sonivox/arm-hybrid-22k/lib_src/ |
| eas_data.h | 113 S_EAS_STREAM streams[MAX_NUMBER_STREAMS]; member in struct:s_eas_data_tag
|
| eas_miditypes.h | 101 S_SMF_STREAM *streams; /* pointer to individual streams in file */ member in struct:s_smf_data_tag
108 EAS_U16 numStreams; /* actual number of streams */
|
| /external/sonivox/arm-wt-22k/lib_src/ |
| eas_data.h | 115 S_EAS_STREAM streams[MAX_NUMBER_STREAMS]; member in struct:s_eas_data_tag
|
| eas_miditypes.h | 101 S_SMF_STREAM *streams; /* pointer to individual streams in file */ member in struct:s_smf_data_tag
108 EAS_U16 numStreams; /* actual number of streams */
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| SequenceInputStreamTest.java | 69 InputStream streams[] = new InputStream[2]; field in class:SequenceInputStreamTest.StreamEnumerator
74 streams[0] = new ByteArrayInputStream(s1.getBytes("UTF-8"));
75 streams[1] = new ByteArrayInputStream(s2.getBytes("UTF-8"));
79 return count < streams.length;
83 return streams[count++];
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
| SpdyConnection.java | 45 * A socket connection to a remote peer. A connection hosts streams which can
63 // frameWriter (to do blocking I/O) and this (to create streams). Such
82 private final Map<Integer, SpdyStream> streams = new HashMap<Integer, SpdyStream>(); field in class:SpdyConnection
167 * Returns the number of {@link SpdyStream#isOpen() open streams} on this
171 return streams.size();
175 return streams.get(id);
179 SpdyStream stream = streams.remove(streamId);
180 if (stream != null && streams.isEmpty()) {
249 streams.put(streamId, stream);
257 throw new IllegalArgumentException("client streams shouldn't have associated stream IDs")
[all...] |
| /device/moto/shamu/camera/QCamera/HAL2/core/src/ |
| QCameraHWI.cpp | 58 camera_metadata_entry_t& streams)
64 for (uint32_t i = 0; i < streams.count; i++) {
65 int streamId = streams.data.u8[i];
90 for (uint32_t i = 0; i < streams.count; i++) {
91 int streamId = streams.data.u8[i];
101 for (uint32_t i = 0; i < streams.count; i++) {
102 int streamId = streams.data.u8[i];
146 /* Check the streams that need to be active in the stream request */
149 camera_metadata_entry_t streams; local
152 &streams);
[all...] |
| /external/chromium_org/third_party/protobuf/src/google/protobuf/io/ |
| zero_copy_stream_unittest.cc | 595 // Test that two concatenated gzip streams can be read correctly
886 // Now split it up into multiple streams of varying sizes.
899 ZeroCopyInputStream* streams[] = local
903 ConcatenatingInputStream input(streams, GOOGLE_ARRAYSIZE(streams));
|
| /external/protobuf/src/google/protobuf/io/ |
| zero_copy_stream_unittest.cc | 663 // Now split it up into multiple streams of varying sizes.
676 ZeroCopyInputStream* streams[] = local
680 ConcatenatingInputStream input(streams, GOOGLE_ARRAYSIZE(streams));
|
| /prebuilts/tools/common/m2/repository/org/sonatype/gshell/gshell-io/2.4/ |
| gshell-io-2.4.jar | |
| /libcore/luni/src/main/java/java/util/ |
| ResourceBundle.java | 909 InputStream streams = null; local
[all...] |
| /cts/tests/tests/media/src/android/media/cts/ |
| AudioManagerTest.java | 317 int[] streams = { AudioManager.STREAM_ALARM, local
327 for (int i = 0; i < streams.length; i++) {
331 int maxVolume = mAudioManager.getStreamMaxVolume(streams[i]);
333 mAudioManager.setStreamVolume(streams[i], 1, 0);
335 assertEquals(maxVolume, mAudioManager.getStreamVolume(streams[i]));
338 assertEquals(1, mAudioManager.getStreamVolume(streams[i]));
340 if (streams[i] == AudioManager.STREAM_MUSIC && mAudioManager.isWiredHeadsetOn()) {
350 mAudioManager.adjustStreamVolume(streams[i], ADJUST_RAISE, 0);
351 curvol = mAudioManager.getStreamVolume(streams[i]);
355 mAudioManager.setStreamVolume(streams[i], maxVolume, 0)
[all...] |
| /external/chromium_org/content/browser/renderer_host/media/ |
| media_stream_dispatcher_host_unittest.cc | 473 // This test generates two streams with video only using the same render view
532 // This test generates two streams with video only using two separate render
563 // This test request two streams with video only without waiting for the first
591 // Test that we can generate streams where a mandatory sourceId is specified in
630 // Test that we can generate streams where a optional sourceId is specified in
783 // Test that the same audio device has been opened in both streams.
820 size_t streams = 5; local
821 for (size_t i = 1; i <= streams; ++i) {
834 // Create first group of streams.
841 // Calling OnChannelClosing() to cancel all the pending/generated streams
[all...] |
| /device/asus/flo/camera/QCamera2/stack/mm-camera-test/inc/ |
| mm_qcamera_app.h | 124 mm_camera_stream_t streams[MAX_STREAM_NUM_IN_BUNDLE]; member in struct:__anon2815
|
