| /external/chromium_org/net/tools/quic/ |
| quic_reliable_client_stream_test.cc | 39 stream_.reset(new QuicSpdyClientStream(3, &session_));
44 scoped_ptr<QuicReliableClientStream> stream_; member in class:net::tools::test::__anon11583::QuicClientStreamTest
52 EXPECT_EQ(headers_string_.size(), stream_->ProcessData(
55 stream_->ProcessData(body_.c_str(), body_.size()));
56 EXPECT_EQ(200u, stream_->headers().parsed_response_code());
57 EXPECT_EQ(body_, stream_->data());
63 EXPECT_EQ(message.size(), stream_->ProcessData(
65 EXPECT_EQ(200u, stream_->headers().parsed_response_code());
66 EXPECT_EQ(body_, stream_->data());
72 EXPECT_EQ(headers_string_.size(), stream_->ProcessData
[all...] |
| quic_reliable_server_stream_test.cc | 58 stream_.reset(new QuicSpdyServerStream(3, &session_));
117 scoped_ptr<QuicReliableServerStream> stream_; member in class:net::tools::test::__anon11584::QuicReliableServerStreamTest
131 EXPECT_EQ(headers_string_.size(), stream_->ProcessData(
133 EXPECT_EQ(body_.size(), stream_->ProcessData(body_.c_str(), body_.size()));
134 EXPECT_EQ(11u, stream_->headers().content_length());
135 EXPECT_EQ("https://www.google.com/", stream_->headers().request_uri());
136 EXPECT_EQ("POST", stream_->headers().request_method());
137 EXPECT_EQ(body_, stream_->body());
146 EXPECT_EQ(message.size(), stream_->ProcessData(
148 EXPECT_EQ(11u, stream_->headers().content_length())
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/app/webrtc/ |
| mediastream_unittest.cc | 58 stream_ = MediaStream::Create(kStreamLabel1);
59 ASSERT_TRUE(stream_.get() != NULL);
70 EXPECT_TRUE(stream_->AddTrack(video_track_));
71 EXPECT_FALSE(stream_->AddTrack(video_track_));
72 EXPECT_TRUE(stream_->AddTrack(audio_track_));
73 EXPECT_FALSE(stream_->AddTrack(audio_track_));
91 scoped_refptr<MediaStreamInterface> stream_; member in class:webrtc::MediaStreamTest
97 ASSERT_EQ(1u, stream_->GetVideoTracks().size());
98 ASSERT_EQ(1u, stream_->GetAudioTracks().size());
102 stream_->GetVideoTracks()[0])
[all...] |
| mediastreamhandler_unittest.cc | 107 stream_ = MediaStream::Create(kStreamLabel1);
111 EXPECT_TRUE(stream_->AddTrack(video_track_));
114 EXPECT_TRUE(stream_->AddTrack(audio_track_));
119 handlers_.AddLocalAudioTrack(stream_, stream_->GetAudioTracks()[0],
127 handlers_.AddLocalVideoTrack(stream_, stream_->GetVideoTracks()[0],
134 handlers_.RemoveLocalTrack(stream_, audio_track_);
142 handlers_.RemoveLocalTrack(stream_, video_track_);
147 handlers_.AddRemoteAudioTrack(stream_, stream_->GetAudioTracks()[0]
172 talk_base::scoped_refptr<MediaStreamInterface> stream_; member in class:webrtc::MediaStreamHandlerTest
[all...] |
| /external/sfntly/cpp/src/sfntly/data/ |
| font_input_stream.cc | 24 : stream_(is), position_(0), length_(0), bounded_(false) {
28 : stream_(is), position_(0), length_(length), bounded_(true) {
36 if (stream_) {
37 return stream_->Available();
43 if (stream_) {
44 stream_->Close();
49 if (stream_) {
50 stream_->Mark(readlimit);
55 if (stream_) {
56 return stream_->MarkSupported()
[all...] |
| font_output_stream.cc | 24 : stream_(os),
33 if (stream_) {
34 stream_->Write(b);
48 assert(stream_);
58 stream_->Write(b, off, len);
64 assert(stream_);
73 stream_->Write(b, off, len);
117 if (stream_) {
118 stream_->Flush();
123 if (stream_) {
[all...] |
| /external/chromium/net/spdy/ |
| spdy_http_stream.cc | 29 stream_(NULL),
41 stream_ = spdy_stream;
42 stream_->SetDelegate(this);
47 if (stream_)
48 stream_->DetachDelegate();
54 DCHECK(!stream_.get());
60 int error = spdy_session_->GetPushStream(request_info_->url, &stream_,
66 if (stream_.get())
70 request_info_->priority, &stream_,
87 CHECK(!stream_->cancelled())
[all...] |
| spdy_io_buffer.cc | 18 stream_(stream) {}
20 SpdyIOBuffer::SpdyIOBuffer() : priority_(0), position_(0), stream_(NULL) {}
26 stream_ = NULL;
|
| spdy_io_buffer.h | 37 const scoped_refptr<SpdyStream>& stream() const { return stream_; }
50 scoped_refptr<SpdyStream> stream_; member in class:net::SpdyIOBuffer
|
| /external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/C/ |
| AST.stg | 80 :{it | pANTLR3_REWRITE_RULE_<rewriteElementType>_STREAM stream_<it>;}; separator="\n">
82 :{it | pANTLR3_REWRITE_RULE_SUBTREE_STREAM stream_<it>;}; separator="\n">
97 :{it | stream_<it> = NULL;
98 #define CREATE_stream_<it> if (stream_<it> == NULL) {stream_<it> = antlr3RewriteRule<rewriteElementType>StreamNewAE(ADAPTOR, RECOGNIZER, (pANTLR3_UINT8)"token <it>"); \} }; separator="\n">
100 :{it | stream_<it> = NULL;
101 #define CREATE_stream_<it> if (stream_<it> == NULL) {stream_<it> = antlr3RewriteRuleSubtreeStreamNewAE(ADAPTOR, RECOGNIZER, (pANTLR3_UINT8)"rule <it>"); \}}; separator="\n">
143 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) { <endif>CREATE_stream_<token>; stream_<token>->add(stream_<token>, <label>, NULL);<if(backtracking)> }<endif><\n
[all...] |
| /external/chromium_org/net/quic/ |
| quic_reliable_client_stream_test.cc | 38 stream_(1, &session_, BoundNetLog()) {
39 stream_.SetDelegate(&delegate_);
44 QuicReliableClientStream stream_; member in class:net::test::__anon11343::QuicReliableClientStreamTest
51 stream_.TerminateFromPeer(true);
59 EXPECT_EQ(arraysize(data), stream_.ProcessData(data, arraysize(data)));
70 EXPECT_EQ(0u, stream_.ProcessData(data, arraysize(data)));
76 stream_.OnError(ERR_INTERNET_DISCONNECTED);
77 EXPECT_FALSE(stream_.GetDelegate());
|
| quic_crypto_client_stream_test.cc | 55 stream_(new QuicCryptoClientStream(kServerHostname, session_.get(),
57 session_->SetCryptoStream(stream_.get());
62 EXPECT_TRUE(stream_->CryptoConnect());
63 CryptoTestUtils::HandshakeWithFakeServer(connection_, stream_.get());
74 scoped_ptr<QuicCryptoClientStream> stream_; member in class:net::test::__anon11329::QuicCryptoClientStreamTest
86 EXPECT_FALSE(stream_->encryption_established());
87 EXPECT_FALSE(stream_->handshake_confirmed());
97 EXPECT_TRUE(stream_->encryption_established());
98 EXPECT_TRUE(stream_->handshake_confirmed());
113 stream_->ProcessData(message_data_->data(), message_data_->length())
[all...] |
| quic_crypto_stream_test.cc | 52 stream_(&session_) {
68 MockQuicCryptoStream stream_; member in class:net::test::__anon11331::QuicCryptoStreamTest
77 EXPECT_FALSE(stream_.encryption_established());
78 EXPECT_FALSE(stream_.handshake_confirmed());
84 stream_.OnError(&framer);
89 stream_.ProcessData(message_data_->data(),
91 ASSERT_EQ(1u, stream_.messages()->size());
92 const CryptoHandshakeMessage& message = (*stream_.messages())[0];
109 EXPECT_EQ(0u, stream_.ProcessData(bad.data(), bad.length()));
|
| reliable_quic_stream_test.cc | 101 stream_.reset(new TestStream(kStreamId, session_.get(),
114 scoped_ptr<TestStream> stream_; member in class:net::test::__anon11351::ReliableQuicStreamTest
133 EXPECT_EQ(kDataLen, stream_->WriteData(kData1, false).bytes_consumed);
147 stream_->WriteData(StringPiece(), false);
160 stream_->WriteData(StringPiece(kData1, 2), false);
174 stream_->WriteData(StringPiece(kData1, 2), true);
185 stream_->WriteData(StringPiece(), true);
202 EXPECT_EQ(kDataLen, stream_->WriteData(kData1, false).bytes_consumed);
206 EXPECT_EQ(kDataLen, stream_->WriteData(kData2, false).bytes_consumed);
216 stream_->OnCanWrite()
[all...] |
| /external/oprofile/libutil++/ |
| stream_util.cpp | 16 io_state::io_state(ios & stream_)
18 stream(stream_),
|
| /external/chromium_org/net/spdy/ |
| spdy_websocket_stream.cc | 47 stream_ = stream_request_.ReleaseStream();
48 DCHECK(stream_.get());
49 stream_->SetDelegate(this);
55 if (!stream_.get()) {
59 int result = stream_->SendRequestHeaders(headers.Pass(), MORE_DATA_TO_SEND);
66 if (!stream_.get()) {
74 stream_->SendData(buf.get(), length, MORE_DATA_TO_SEND);
79 if (stream_.get()) {
80 stream_->Close();
81 DCHECK(!stream_.get())
[all...] |
| spdy_http_stream.cc | 48 if (stream_.get()) {
49 stream_->DetachDelegate();
50 DCHECK(!stream_.get());
58 DCHECK(!stream_);
64 int error = spdy_session_->GetPushStream(request_info_->url, &stream_,
69 // |stream_| may be NULL even if OK was returned.
70 if (stream_.get()) {
71 DCHECK_EQ(stream_->type(), SPDY_PUSH_STREAM);
72 stream_->SetDelegate(this);
84 stream_ = stream_request_.ReleaseStream()
[all...] |
| 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...] |
| /external/chromium_org/net/tools/quic/test_tools/ |
| quic_test_client.cc | 159 stream_ = NULL;
171 if (stream_) {
172 stream_->set_visitor(NULL);
192 stream_ = NULL; // Always force creation of a stream for SendMessage.
245 if (!stream_) {
246 stream_ = client_->CreateReliableClientStream();
247 if (stream_ != NULL) {
248 stream_->set_visitor(this);
251 return stream_;
264 if (stream_ == NULL)
[all...] |
| /external/chromium_org/media/ffmpeg/ |
| ffmpeg_common_unittest.cc | 36 AVStream stream_; member in class:media::FFmpegCommonTest
53 stream_.time_base = kTimeBase;
54 stream_.index_entries = kIndexEntries;
55 stream_.index_entries_allocated_size = sizeof(kIndexEntries);
56 stream_.nb_index_entries = arraysize(kIndexEntries);
|
| /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));
50 free(const_cast<char*>(stream_.url));
51 stream_.url = base::strdup(url);
62 stream_.end = length;
63 stream_.lastmodified = last_modified;
64 stream_.pdata = 0;
65 stream_.ndata = id->ndata
[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/content/browser/streams/ |
| stream_handle_impl.cc | 15 : stream_(stream),
23 base::Bind(&Stream::CloseHandle, stream_));
|
| /external/chromium_org/content/renderer/media/ |
| media_stream_extra_data.h | 35 return stream_;
39 scoped_refptr<webrtc::MediaStreamInterface> stream_; member in class:content::MediaStreamExtraData
|
| /external/marisa-trie/lib/marisa/ |
| reader.cc | 15 : file_(NULL), fd_(-1), stream_(NULL), needs_fclose_(false) {}
18 : file_(file), fd_(-1), stream_(NULL), needs_fclose_(false) {}
21 : file_(NULL), fd_(fd), stream_(NULL), needs_fclose_(false) {}
24 : file_(NULL), fd_(-1), stream_(stream), needs_fclose_(false) {}
60 Swap(&stream_, &rhs->stream_);
82 } else if (stream_ != NULL) {
83 if (!stream_->read(static_cast<char *>(buf), size)) {
|
