| /external/chromium_org/media/formats/mp2t/ |
| es_parser_test_base.cc | 41 stream_.resize(stream.length());
42 memcpy(&stream_[0], stream.data(), stream_.size());
79 DCHECK_LT(cur_pes_offset, stream_.size());
80 if (!es_parser->Parse(&stream_[cur_pes_offset], cur_pes_size, pts, dts))
103 DCHECK_GE(stream_.size(), cur->offset);
104 cur->size = stream_.size() - cur->offset;
109 DCHECK_GT(stream_.size(), 0u);
115 while (cur_pes_packet.offset < stream_.size()) {
|
| /external/chromium_org/net/quic/ |
| quic_http_stream.cc | 33 stream_(NULL),
58 DCHECK(!stream_);
79 session_, &stream_, base::Bind(&QuicHttpStream::OnStreamReady,
84 stream_->SetDelegate(this);
93 DCHECK(rv == OK || !stream_);
95 stream_->SetDelegate(this);
111 if (!stream_) {
116 stream_->set_priority(priority);
158 if (stream_ == NULL)
200 if (!stream_) {
[all...] |
| quic_crypto_server_stream_test.cc | 62 stream_(crypto_config_, &session_),
66 session_.SetCryptoStream(&stream_);
103 return CryptoTestUtils::HandshakeWithFakeClient(connection_, &stream_,
112 QuicCryptoServerStream stream_; member in class:net::test::__anon14084::QuicCryptoServerStreamTest
122 EXPECT_FALSE(stream_.encryption_established());
123 EXPECT_FALSE(stream_.handshake_confirmed());
132 EXPECT_TRUE(stream_.encryption_established());
133 EXPECT_TRUE(stream_.handshake_confirmed());
134 EXPECT_EQ(1, stream_.num_server_config_update_messages_sent());
236 stream_.ProcessRawData(message_data_->data(), message_data_->length())
[all...] |
| quic_stream_sequencer_test.cc | 65 stream_(&session_, 1),
66 sequencer_(new QuicStreamSequencer(&stream_)),
129 testing::StrictMock<MockStream> stream_; member in class:net::test::__anon14118::QuicStreamSequencerTest
135 EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3));
147 EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3));
159 EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3));
173 EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3));
178 EXPECT_CALL(stream_, ProcessRawData(StrEq("def"), 3)).WillOnce(Return(3));
179 EXPECT_CALL(stream_, OnFinRead());
190 EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3))
[all...] |
| /external/chromium_org/content/renderer/media/webrtc/ |
| media_stream_track_metrics_unittest.cc | 83 stream_ = new rtc::RefCountedObject<MockMediaStream>("stream");
88 stream_ = NULL;
100 scoped_refptr<MediaStreamInterface> stream_; member in class:content::MediaStreamTrackMetricsTest
138 stream_->AddTrack(audio.get());
139 stream_->AddTrack(video.get());
140 metrics_->AddStream(MediaStreamTrackMetrics::RECEIVED_STREAM, stream_.get());
172 stream_->AddTrack(audio.get());
173 stream_->AddTrack(video.get());
174 metrics_->AddStream(MediaStreamTrackMetrics::SENT_STREAM, stream_.get());
219 stream_->AddTrack(audio.get())
[all...] |
| /external/chromium_org/net/websockets/ |
| websocket_inflater.cc | 50 stream_.reset(new z_stream);
51 memset(stream_.get(), 0, sizeof(*stream_));
52 int result = inflateInit2(stream_.get(), -window_bits);
54 inflateEnd(stream_.get());
55 stream_.reset();
62 if (stream_) {
63 inflateEnd(stream_.get());
64 stream_.reset();
79 if (stream_->avail_in > 0
[all...] |
| websocket_basic_stream_test.cc | 77 scoped_ptr<WebSocketBasicStream> stream_; member in class:net::__anon14443::WebSocketBasicStreamTest
114 // stream_ has a reference to socket_data_ (via MockTCPClientSocket) and so
116 stream_.reset();
150 stream_ = WebSocketBasicStream::CreateWebSocketBasicStreamForTesting(
274 int result = stream_->ReadFrames(&frames_, cb_.callback());
283 int result = stream_->ReadFrames(&frames_, cb_.callback());
296 int result = stream_->ReadFrames(&frames_, cb_.callback());
306 int result = stream_->ReadFrames(&frames_, cb_.callback());
319 int result = stream_->ReadFrames(&frames_, cb_.callback());
333 EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()))
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/ObjC/ |
| AST.stg | 177 <ruleDescriptor.allTokenRefsInAltsWithRewrites:{it | ANTLRRewriteRuleTokenStream *stream_<it> =
180 <ruleDescriptor.allRuleRefsInAltsWithRewrites:{it | ANTLRRewriteRuleSubtreeStream *stream_<it> =
188 <[ruleDescriptor.allTokenRefsInAltsWithRewrites,ruleDescriptor.allRuleRefsInAltsWithRewrites]:{it | [stream_<it> release];}; separator="\n">
206 <referencedTokenLabels:{it | [stream_<it> release];}; separator="\n">
207 <referencedTokenListLabels:{it | [stream_<it> release];}; separator="\n">
208 <referencedRuleLabels:{it | [stream_<it> release];}; separator="\n">
209 <referencedRuleListLabels:{it | [stream_<it> release];}; separator="\n">
235 [stream_<token> addElement:<label>];<\n>
252 [stream_<token> addElement:<label>];<\n>
265 [stream_<rule.name> addElement:[<label> getTree]]
[all...] |
| /external/chromium_org/net/tools/quic/test_tools/ |
| quic_test_client.cc | 210 if (stream_) {
211 stream_->set_visitor(NULL);
249 stream_ = NULL; // Always force creation of a stream for SendMessage.
337 if (!stream_) {
338 stream_ = client_->CreateReliableClientStream();
339 if (stream_ == NULL) {
342 stream_->set_visitor(this);
343 reinterpret_cast<QuicSpdyClientStream*>(stream_)->set_priority(priority_);
345 ReliableQuicStreamPeer::SetFecPolicy(stream_, fec_policy_);
348 return stream_;
[all...] |
| /external/chromium_org/net/spdy/ |
| spdy_stream_test_util.cc | 19 const base::WeakPtr<SpdyStream>& stream) : stream_(stream) {
20 DCHECK(stream_);
37 DCHECK(stream_);
38 stream_->Close();
39 // The |stream_| may still be alive (if it is our delegate).
44 : stream_(stream),
53 stream_id_ = stream_->stream_id();
60 EXPECT_EQ(stream_->type() != SPDY_PUSH_STREAM, send_headers_completed_);
73 if (!stream_.get())
75 stream_id_ = stream_->stream_id()
[all...] |
| spdy_stream_test_util.h | 21 // Delegate that calls Close() on |stream_| on OnClose. Used by tests
37 bool StreamIsClosed() const { return !stream_.get(); }
40 base::WeakPtr<SpdyStream> stream_; member in class:net::test::ClosingDelegate
66 bool StreamIsClosed() const { return !stream_.get(); }
76 const base::WeakPtr<SpdyStream>& stream() { return stream_; }
79 base::WeakPtr<SpdyStream> stream_; member in class:net::test::StreamDelegateBase
|
| /external/chromium_org/content/child/npapi/ |
| plugin_stream.cc | 36 memset(&stream_, 0, sizeof(stream_));
37 stream_.url = base::strdup(url);
45 free(const_cast<char*>(stream_.url));
55 stream_.end = length;
56 stream_.lastmodified = last_modified;
57 stream_.pdata = 0;
58 stream_.ndata = id->ndata;
59 stream_.notifyData = notify_data_;
61 stream_.headers = headers_.c_str()
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/Python/ |
| AST.stg | 86 :{it | stream_<it> = RewriteRule<rewriteElementType>Stream(self._adaptor, "token <it>")}; separator="\n">
88 :{it | stream_<it> = RewriteRuleSubtreeStream(self._adaptor, "rule <it>")}; separator="\n">
112 <finishedBacktracking({stream_<token>.add(<label>)})>
126 <finishedBacktracking({stream_<token>.add(<label>)})>
138 <finishedBacktracking({stream_<rule.name>.add(<label>.tree)})>
150 <finishedBacktracking({stream_<rule.name>.add(<label>.tree)})>
213 :{it | stream_<it> = RewriteRule<rewriteElementType>Stream(self._adaptor, "token <it>", <it>)};
217 :{it | stream_<it> = RewriteRule<rewriteElementType>Stream(self._adaptor, "token <it>", list_<it>)};
221 :{it | stream_<it> = RewriteRuleSubtreeStream(self._adaptor, "wildcard <it>", <it>)};
225 :{it | stream_<it> = RewriteRuleSubtreeStream(self._adaptor, "wildcard <it>", list_<it>)}
[all...] |
| /external/chromium_org/android_webview/browser/net/ |
| input_stream_reader.cc | 18 : stream_(stream) {
48 if (!stream_->Read(dest, dest_size, &bytes_read))
58 if (!stream_->BytesAvailable(&size))
85 if (!stream_->Skip(bytes_to_skip, &skipped))
|
| /external/chromium_org/components/copresence/mediums/audio/ |
| audio_recorder.cc | 55 stream_(NULL),
121 stream_ = input_stream_for_testing_
126 if (!stream_ || !stream_->Open()) {
128 if (stream_) {
129 stream_->Close();
130 stream_ = NULL;
134 stream_->SetVolume(stream_->GetMaxVolume());
139 if (!stream_ || is_recording_
[all...] |
| /external/chromium_org/media/audio/ |
| audio_output_controller.cc | 30 stream_(NULL),
121 stream_ = diverting_to_stream_ ?
124 if (!stream_) {
130 if (!stream_->Open()) {
138 // stream_ was created via AudioManager.
139 if (stream_ != diverting_to_stream_)
143 stream_->SetVolume(volume_);
167 stream_->Start(this);
193 stream_->Stop();
244 stream_->SetVolume(volume_)
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/ActionScript/ |
| AST.stg | 71 :{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>");}; separator="\n">
73 :{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}; separator="\n">
96 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
110 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
122 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule.name>.add(<label>.tree);
134 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.tree);
195 :{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>",<it>);};
199 :{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>", list_<it>);};
203 :{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<it>);};
207 :{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",list_<it>);}
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/CSharp2/ |
| AST.stg | 97 :{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>");}; separator="\n">
99 :{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}; separator="\n">
122 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<token>.Add(<label>);<\n>
136 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<token>.Add(<label>);
148 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<rule.name>.Add(<label>.Tree);
160 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<rule>.Add(<label>.Tree);
217 :{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>",<it>);};
221 :{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>", list_<it>);};
225 :{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<it>);};
229 :{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",list_<it>);}
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/CSharp3/ |
| AST.stg | 98 :{it|<\n>RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>");}>
100 :{it|<\n>RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}>
120 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<token>.Add(<label>);<\n>
134 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<token>.Add(<label>);
146 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<rule.name>.Add(<label>.Tree);
158 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<rule>.Add(<label>.Tree);
215 :{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>",<it>);};
219 :{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>", list_<it>);};
223 :{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<it>);};
227 :{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",list_<it>);}
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/Java/ |
| AST.stg | 70 :{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>");}; separator="\n">
72 :{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}; separator="\n">
95 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
109 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
121 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule.name>.add(<label>.getTree());
133 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.getTree());
195 :{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>",<it>);};
199 :{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(adaptor,"token <it>", list_<it>);};
203 :{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<it>);};
207 :{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",list_<it>);}
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/JavaScript/ |
| AST.stg | 66 :{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleTokenStream(this.adaptor,"token <it>");}; separator="\n">
68 :{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"rule <it>");}; separator="\n">
91 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
105 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
121 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule.name>.add(<label>.getTree());
133 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.getTree());
194 :{var stream_<it>=new org.antlr.runtime.tree.RewriteRule<rewriteElementType>Stream(this.adaptor,"token <it>",<it>);};
198 :{var stream_<it>=new org.antlr.runtime.tree.RewriteRule<rewriteElementType>Stream(this.adaptor,"token <it>", list_<it>);};
202 :{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"wildcard <it>",<it>);};
206 :{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"wildcard <it>",list_<it>);}
[all...] |
| /external/chromium_org/content/browser/loader/ |
| stream_resource_handler.cc | 27 stream_ = new Stream(registry, this, url);
31 stream_->RemoveWriteObserver(this);
84 stream_->AddData(buffer, bytes_read);
86 if (!stream_->can_add_data())
96 stream_->Finalize();
|
| /external/chromium_org/net/http/ |
| http_response_body_drainer.cc | 17 : stream_(stream),
70 return stream_->ReadResponseBody(
84 if (stream_->IsResponseBodyComplete())
117 stream_->Close(true /* no keep-alive */);
120 stream_->Close(false /* keep-alive */);
|
| /external/chromium_org/third_party/webrtc/sound/ |
| pulseaudiosoundsystem.cc | 127 : pulse_(pulse), stream_(stream), flags_(flags) {
132 ASSERT(stream_ == NULL);
139 symbol_table()->pa_stream_set_state_callback()(stream_, NULL, NULL);
140 if (symbol_table()->pa_stream_disconnect()(stream_) != 0) {
144 symbol_table()->pa_stream_unref()(stream_);
145 stream_ = NULL;
159 int re = symbol_table()->pa_stream_get_latency()(stream_, &latency,
187 ASSERT(stream_ != NULL);
188 return stream_;
192 return stream_ == NULL
205 pa_stream *stream_; member in class:rtc::PulseAudioStream
567 PulseAudioStream stream_; member in class:rtc::PulseAudioInputStream
951 PulseAudioStream stream_; member in class:rtc::PulseAudioOutputStream
[all...] |
| /external/chromium_org/third_party/webrtc/base/ |
| socketpool.cc | 149 : factory_(factory), stream_(NULL), checked_out_(false) {
154 delete stream_;
161 if (!stream_) {
175 stream_ = new SocketStream(socket);
177 if ((stream_->GetState() == SS_OPEN) && (remote == remote_)) {
181 stream_->Close();
182 if ((stream_->GetSocket()->Connect(remote_) != 0)
183 && !stream_->GetSocket()->IsBlocking()) {
185 *err = stream_->GetSocket()->GetError();
191 stream_->SignalEvent.disconnect(this)
[all...] |
