HomeSort by relevance Sort by last modified time
    Searched refs:stream_ (Results 1 - 25 of 186) sorted by null

1 2 3 4 5 6 7 8

  /external/chromium_org/third_party/libjingle/source/talk/app/webrtc/
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_->GetVideoTracks()[0])
    [all...]
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_->AddTrack(audio_track_))
178 talk_base::scoped_refptr<MediaStreamInterface> stream_; member in class:webrtc::MediaStreamHandlerTest
    [all...]
  /external/chromium_org/net/websockets/
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_.reset()
    [all...]
  /external/chromium_org/net/tools/quic/
quic_spdy_client_stream_test.cc 52 stream_.reset(new QuicSpdyClientStream(3, &session_));
57 scoped_ptr<QuicSpdyClientStream> stream_; member in class:net::tools::test::__anon13780::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_->ProcessData
    [all...]
  /external/chromium_org/third_party/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/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/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_data_stream_test.cc 98 stream_.reset(new TestStream(kClientDataStreamId1, session_.get(),
109 scoped_ptr<TestStream> stream_; member in class:net::test::__anon13487::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_->OnStreamHeaders(headers)
    [all...]
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::__anon13483::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_->ProcessRawData(message_data_->data(), message_data_->length())
    [all...]
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::__anon13523::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_->WriteOrBufferData(kData1, false, NULL)
    [all...]
quic_crypto_stream_test.cc 52 stream_(&session_) {
67 MockQuicCryptoStream stream_; member in class:net::test::__anon13485::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());
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::__anon13504::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_->OnError(ERR_INTERNET_DISCONNECTED)
    [all...]
  /external/chromium_org/native_client_sdk/src/libraries/nacl_io/stream/
stream_event_emitter.h 28 StreamNode* stream() { return stream_; }
36 StreamNode* stream_; member in class:nacl_io::StreamEventEmitter
stream_event_emitter.cc 16 StreamEventEmitter::StreamEventEmitter() : stream_(NULL) {
21 stream_ = stream;
28 stream_ = NULL;
  /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 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_ = 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/media/audio/sounds/
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_->Close()
146 AudioOutputStream* stream_; member in class:media::AudioStreamHandler::AudioStreamContainer
    [all...]
  /external/chromium_org/media/midi/
usb_midi_output_stream_unittest.cc 55 stream_.reset(new UsbMidiOutputStream(jack));
59 scoped_ptr<UsbMidiOutputStream> stream_; member in class:media::__anon12760::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_->Send(ToVector(data1))
    [all...]
  /external/chromium_org/media/cdm/ppapi/
cdm_logging.h 44 std::string message() { return stream_.str(); }
47 std::ostringstream stream_; member in class:media::CdmLogMessage
  /external/chromium_org/mojo/public/cpp/environment/lib/
logging.cc 36 stream_ << GetFilename(file) << '(' << line << "): ";
41 stream_.str().c_str());
  /external/chromium_org/media/filters/
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_->video_decoder_config()
170 scoped_ptr<FakeDemuxerStream> stream_; member in class:media::FakeDemuxerStreamTest
    [all...]

Completed in 2030 milliseconds

1 2 3 4 5 6 7 8