/external/chromium_org/third_party/libjingle/source/talk/app/webrtc/ |
H A D | mediastream_unittest.cc | 59 stream_ = MediaStream::Create(kStreamLabel1); 60 ASSERT_TRUE(stream_.get() != NULL); 71 EXPECT_TRUE(stream_->AddTrack(video_track_)); 72 EXPECT_FALSE(stream_->AddTrack(video_track_)); 73 EXPECT_TRUE(stream_->AddTrack(audio_track_)); 74 EXPECT_FALSE(stream_->AddTrack(audio_track_)); 92 scoped_refptr<MediaStreamInterface> stream_; member in class:webrtc::MediaStreamTest 98 ASSERT_EQ(1u, stream_->GetVideoTracks().size()); 99 ASSERT_EQ(1u, stream_->GetAudioTracks().size()); 103 stream_ [all...] |
H A D | mediastreamhandler_unittest.cc | 111 stream_ = MediaStream::Create(kStreamLabel1); 115 EXPECT_TRUE(stream_->AddTrack(video_track_)); 120 EXPECT_TRUE(stream_->AddTrack(audio_track_)); 122 handlers_.AddLocalAudioTrack(stream_, stream_->GetAudioTracks()[0], 130 handlers_.AddLocalVideoTrack(stream_, stream_->GetVideoTracks()[0], 137 handlers_.RemoveLocalTrack(stream_, audio_track_); 145 handlers_.RemoveLocalTrack(stream_, video_track_); 151 EXPECT_TRUE(stream_ 178 talk_base::scoped_refptr<MediaStreamInterface> stream_; member in class:webrtc::MediaStreamHandlerTest [all...] |
/external/chromium_org/net/websockets/ |
H A D | websocket_deflater.cc | 22 if (stream_) { 23 deflateEnd(stream_.get()); 24 stream_.reset(NULL); 29 DCHECK(!stream_); 30 stream_.reset(new z_stream); 34 memset(stream_.get(), 0, sizeof(*stream_)); 35 int result = deflateInit2(stream_.get(), 42 deflateEnd(stream_.get()); 43 stream_ [all...] |
/external/chromium_org/net/tools/quic/ |
H A D | quic_spdy_client_stream_test.cc | 52 stream_.reset(new QuicSpdyClientStream(3, &session_)); 57 scoped_ptr<QuicSpdyClientStream> stream_; member in class:net::tools::test::__anon9160::QuicSpdyClientStreamTest 68 EXPECT_EQ(headers_string_.size(), stream_->ProcessData( 71 stream_->ProcessData(body_.c_str(), body_.size())); 72 EXPECT_EQ(200u, stream_->headers().parsed_response_code()); 73 EXPECT_EQ(body_, stream_->data()); 79 EXPECT_EQ(message.size(), stream_->ProcessData( 81 EXPECT_EQ(200u, stream_->headers().parsed_response_code()); 82 EXPECT_EQ(body_, stream_->data()); 88 EXPECT_EQ(headers_string_.size(), stream_ [all...] |
/external/chromium_org/third_party/sfntly/cpp/src/sfntly/data/ |
H A D | 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_ [all...] |
H A D | 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/sfntly/cpp/src/sfntly/data/ |
H A D | 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_ [all...] |
H A D | 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/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/C/ |
H A D | 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_<toke [all...] |
/external/chromium_org/net/quic/ |
H A D | quic_data_stream_test.cc | 98 stream_.reset(new TestStream(kClientDataStreamId1, session_.get(), 109 scoped_ptr<TestStream> stream_; member in class:net::test::__anon8867::QuicDataStreamTest 122 stream_->OnStreamHeadersPriority(QuicUtils::HighestPriority()); 123 stream_->OnStreamHeaders(headers); 124 EXPECT_EQ(headers, stream_->data()); 125 stream_->OnStreamHeadersComplete(false, headers.size()); 126 EXPECT_EQ(QuicUtils::HighestPriority(), stream_->EffectivePriority()); 127 EXPECT_EQ(headers, stream_->data()); 128 EXPECT_FALSE(stream_->IsDoneReading()); 137 stream_ [all...] |
H A D | quic_crypto_client_stream_test.cc | 33 stream_(new QuicCryptoClientStream( 35 session_->SetCryptoStream(stream_.get()); 41 EXPECT_TRUE(stream_->CryptoConnect()); 42 CryptoTestUtils::HandshakeWithFakeServer(connection_, stream_.get()); 53 scoped_ptr<QuicCryptoClientStream> stream_; member in class:net::test::__anon8863::QuicCryptoClientStreamTest 60 EXPECT_FALSE(stream_->encryption_established()); 61 EXPECT_FALSE(stream_->handshake_confirmed()); 66 EXPECT_TRUE(stream_->encryption_established()); 67 EXPECT_TRUE(stream_->handshake_confirmed()); 77 stream_ [all...] |
H A D | reliable_quic_stream_test.cc | 124 stream_.reset(new TestStream(kHeadersStreamId, session_.get(), 130 bool fin_sent() { return ReliableQuicStreamPeer::FinSent(stream_.get()); } 131 bool rst_sent() { return ReliableQuicStreamPeer::RstSent(stream_.get()); } 145 scoped_ptr<TestStream> stream_; member in class:net::test::__anon8903::ReliableQuicStreamTest 164 stream_->WriteOrBufferData(kData1, false, NULL); 173 EXPECT_DFATAL(stream_->WriteOrBufferData(StringPiece(), false, NULL), ""); 184 stream_->WriteOrBufferData(StringPiece(kData1, 2), false, NULL); 197 stream_->WriteOrBufferData(StringPiece(kData1, 2), true, NULL); 208 stream_->WriteOrBufferData(StringPiece(), true, NULL); 224 stream_ [all...] |
H A D | quic_crypto_stream_test.cc | 52 stream_(&session_) { 67 MockQuicCryptoStream stream_; member in class:net::test::__anon8865::QuicCryptoStreamTest 76 EXPECT_FALSE(stream_.encryption_established()); 77 EXPECT_FALSE(stream_.handshake_confirmed()); 82 stream_.ProcessRawData(message_data_->data(), 84 ASSERT_EQ(1u, stream_.messages()->size()); 85 const CryptoHandshakeMessage& message = (*stream_.messages())[0]; 102 EXPECT_EQ(0u, stream_.ProcessRawData(bad.data(), bad.length())); 107 EXPECT_FALSE(stream_.flow_controller()->IsEnabled());
|
H A D | quic_reliable_client_stream_test.cc | 46 stream_ = new QuicReliableClientStream(kStreamId, &session_, BoundNetLog()); 47 session_.ActivateStream(stream_); 48 stream_->SetDelegate(&delegate_); 83 QuicReliableClientStream* stream_; member in class:net::test::__anon8884::QuicReliableClientStreamTest 98 stream_->OnStreamHeaders(uncompressed_headers); 99 stream_->OnStreamHeadersComplete(false, uncompressed_headers.length()); 104 stream_->OnStreamFrame(frame2); 112 EXPECT_EQ(arraysize(data), stream_->ProcessData(data, arraysize(data))); 123 EXPECT_EQ(0u, stream_->ProcessData(data, arraysize(data))); 129 stream_ [all...] |
H A D | quic_http_stream.cc | 33 stream_(NULL), 58 DCHECK(!stream_); 78 session_, &stream_, base::Bind(&QuicHttpStream::OnStreamReady, 83 stream_->SetDelegate(this); 92 DCHECK(rv == OK || !stream_); 94 stream_->SetDelegate(this); 105 CHECK(stream_); 112 stream_->set_priority(priority); 154 if (stream_ == NULL) 196 if (!stream_) { [all...] |
/external/oprofile/libutil++/ |
H A D | stream_util.cpp | 16 io_state::io_state(ios & stream_) argument 18 stream(stream_),
|
/external/chromium_org/net/spdy/ |
H A D | 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_ [all...] |
H A D | spdy_http_stream.cc | 49 if (stream_.get()) { 50 stream_->DetachDelegate(); 51 DCHECK(!stream_.get()); 59 DCHECK(!stream_); 65 int error = spdy_session_->GetPushStream(request_info_->url, &stream_, 70 // |stream_| may be NULL even if OK was returned. 71 if (stream_.get()) { 72 DCHECK_EQ(stream_->type(), SPDY_PUSH_STREAM); 73 stream_->SetDelegate(this); 85 stream_ [all...] |
H A D | 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_ [all...] |
/external/chromium_org/media/audio/sounds/ |
H A D | audio_stream_handler.cc | 41 stream_(NULL), 53 if (!stream_) { 60 stream_ = AudioManager::Get()->MakeAudioOutputStreamProxy(params, 62 if (!stream_ || !stream_->Open()) { 66 stream_->SetVolume(kOutputVolumePercent); 87 stream_->Start(g_audio_source_for_testing); 89 stream_->Start(this); 98 if (stream_) 99 stream_ 146 AudioOutputStream* stream_; member in class:media::AudioStreamHandler::AudioStreamContainer [all...] |
/external/chromium_org/native_client_sdk/src/libraries/nacl_io/stream/ |
H A D | stream_event_emitter.cc | 16 StreamEventEmitter::StreamEventEmitter() : stream_(NULL) { 21 stream_ = stream; 28 stream_ = NULL;
|
H A D | stream_event_emitter.h | 28 StreamNode* stream() { return stream_; } 36 StreamNode* stream_; member in class:nacl_io::StreamEventEmitter
|
/external/chromium_org/media/midi/ |
H A D | usb_midi_output_stream_unittest.cc | 55 stream_.reset(new UsbMidiOutputStream(jack)); 59 scoped_ptr<UsbMidiOutputStream> stream_; member in class:media::__anon8140::UsbMidiOutputStreamTest 66 stream_->Send(std::vector<uint8>()); 74 stream_->Send(ToVector(data)); 79 stream_->Send(std::vector<uint8>(1, 0x90)); 80 stream_->Send(std::vector<uint8>(1, 0x45)); 83 stream_->Send(std::vector<uint8>(1, 0x7f)); 87 stream_->Send(std::vector<uint8>(1, 0x90)); 88 stream_->Send(std::vector<uint8>(1, 0x45)); 96 stream_ [all...] |
/external/chromium_org/mojo/public/cpp/environment/lib/ |
H A D | logging.cc | 36 stream_ << GetFilename(file) << '(' << line << "): "; 41 stream_.str().c_str());
|
/external/chromium_org/media/filters/ |
H A D | fake_demuxer_stream_unittest.cc | 50 stream_.reset( 58 stream_.reset(new FakeDemuxerStream(1, kNumBuffersInOneConfig, false)); 80 EXPECT_TRUE(stream_->SupportsConfigChanges()); 102 stream_->Read(base::Bind(&FakeDemuxerStreamTest::BufferReady, 111 stream_->Read(base::Bind(&FakeDemuxerStreamTest::BufferReady, 121 stream_->SatisfyRead(); 128 stream_->Reset(); 141 EXPECT_EQ(num_buffers_received_, stream_->num_buffers_returned()); 159 stream_.reset(new FakeDemuxerStream( 162 const VideoDecoderConfig& config = stream_ 170 scoped_ptr<FakeDemuxerStream> stream_; member in class:media::FakeDemuxerStreamTest [all...] |