Home
last modified time | relevance | path

Searched refs:stream_ (Results 1 – 25 of 113) sorted by relevance

12345

/external/libbrillo/brillo/streams/
Dfake_stream_unittest.cc31 stream_.reset(new FakeStream{mode, &clock_}); in CreateStream()
42 bool ok = stream_->ReadNonBlocking(data.data(), data.size(), &size_read, in ReadString()
56 if (!stream_->WriteNonBlocking(data.data(), data.size(), &written, nullptr)) in WriteString()
64 std::unique_ptr<FakeStream> stream_; member in brillo::FakeStreamTest
70 EXPECT_TRUE(stream_->IsOpen()); in TEST_F()
71 EXPECT_TRUE(stream_->CanRead()); in TEST_F()
72 EXPECT_FALSE(stream_->CanWrite()); in TEST_F()
73 EXPECT_FALSE(stream_->CanSeek()); in TEST_F()
74 EXPECT_FALSE(stream_->CanGetSize()); in TEST_F()
75 EXPECT_EQ(0, stream_->GetSize()); in TEST_F()
[all …]
Dinput_stream_set_unittest.cc28 stream_.reset(new InputStreamSet({itf1_.get(), itf2_.get()}, {}, 100)); in SetUp()
32 stream_.reset(); in TearDown()
39 std::unique_ptr<InputStreamSet> stream_; member in brillo::InputStreamSetTest
48 EXPECT_TRUE(stream_->CanRead()); in TEST_F()
49 EXPECT_FALSE(stream_->CanWrite()); in TEST_F()
50 EXPECT_FALSE(stream_->CanSeek()); in TEST_F()
51 EXPECT_EQ(100, stream_->GetSize()); in TEST_F()
52 EXPECT_FALSE(stream_->SetSizeBlocking(0, nullptr)); in TEST_F()
53 EXPECT_FALSE(stream_->GetPosition()); in TEST_F()
54 EXPECT_FALSE(stream_->Seek(0, Stream::Whence::FROM_BEGIN, nullptr, nullptr)); in TEST_F()
[all …]
Dopenssl_stream_bio_unittests.cc25 stream_.reset(new StrictMock<MockStream>{}); in SetUp()
26 bio_ = BIO_new_stream(stream_.get()); in SetUp()
32 stream_.reset(); in TearDown()
35 std::unique_ptr<StrictMock<MockStream>> stream_; member in brillo::StreamBIOTest
41 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) in TEST_F()
50 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) in TEST_F()
59 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) in TEST_F()
69 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) in TEST_F()
79 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) in TEST_F()
87 EXPECT_CALL(*stream_, WriteNonBlocking(buffer, 10, _, _)) in TEST_F()
[all …]
Dmemory_stream_unittest.cc51 stream_.reset(new MemoryStream{std::move(container), 0}); in SetUp()
55 return *static_cast<MockMemoryContainer*>(stream_->container_.get()); in container_mock()
66 std::unique_ptr<MemoryStream> stream_; member in brillo::MemoryStreamTest
79 EXPECT_TRUE(stream_->CanRead()); in TEST_F()
87 EXPECT_FALSE(stream_->CanWrite()); in TEST_F()
88 EXPECT_TRUE(stream_->CanWrite()); in TEST_F()
92 EXPECT_TRUE(stream_->CanSeek()); in TEST_F()
101 EXPECT_EQ(0, stream_->GetSize()); in TEST_F()
102 EXPECT_EQ(1234, stream_->GetSize()); in TEST_F()
103 EXPECT_EQ(kSizeMax, stream_->GetSize()); in TEST_F()
[all …]
Dfile_stream_unittest.cc147 return *static_cast<MockFileDescriptor*>(stream_->fd_interface_.get()); in fd_mock()
153 stream_.reset(new FileStream(std::move(fd), access_mode)); in CreateStream()
178 return stream_->WaitForData(mode, {}, error); in CallWaitForData()
181 std::unique_ptr<FileStream> stream_; member in brillo::FileStreamTest
193 EXPECT_TRUE(stream_->IsOpen()); in TEST_F()
195 EXPECT_FALSE(stream_->IsOpen()); in TEST_F()
200 EXPECT_TRUE(stream_->CanRead()); in TEST_F()
202 EXPECT_FALSE(stream_->CanRead()); in TEST_F()
204 EXPECT_TRUE(stream_->CanRead()); in TEST_F()
206 EXPECT_FALSE(stream_->CanRead()); in TEST_F()
[all …]
/external/webrtc/talk/app/webrtc/
Dmediastream_unittest.cc73 stream_ = MediaStream::Create(kStreamLabel1); in SetUp()
74 ASSERT_TRUE(stream_.get() != NULL); in SetUp()
85 EXPECT_TRUE(stream_->AddTrack(video_track_)); in SetUp()
86 EXPECT_FALSE(stream_->AddTrack(video_track_)); in SetUp()
87 EXPECT_TRUE(stream_->AddTrack(audio_track_)); in SetUp()
88 EXPECT_FALSE(stream_->AddTrack(audio_track_)); in SetUp()
105 scoped_refptr<MediaStreamInterface> stream_; member in webrtc::MediaStreamTest
111 ASSERT_EQ(1u, stream_->GetVideoTracks().size()); in TEST_F()
112 ASSERT_EQ(1u, stream_->GetAudioTracks().size()); in TEST_F()
116 stream_->GetVideoTracks()[0]); in TEST_F()
[all …]
Dmediastreamobserver.cc35 : stream_(stream), in MediaStreamObserver()
38 stream_->RegisterObserver(this); in MediaStreamObserver()
42 stream_->UnregisterObserver(this); in ~MediaStreamObserver()
46 AudioTrackVector new_audio_tracks = stream_->GetAudioTracks(); in OnChanged()
47 VideoTrackVector new_video_tracks = stream_->GetVideoTracks(); in OnChanged()
57 SignalAudioTrackRemoved(cached_track.get(), stream_); in OnChanged()
69 SignalAudioTrackAdded(new_track.get(), stream_); in OnChanged()
81 SignalVideoTrackRemoved(cached_track.get(), stream_); in OnChanged()
93 SignalVideoTrackAdded(new_track.get(), stream_); in OnChanged()
/external/protobuf/src/google/protobuf/util/internal/
Dprotostream_objectsource.cc118 : stream_(stream), in ProtoStreamObjectSource()
131 : stream_(stream), in ProtoStreamObjectSource()
186 uint32 tag = stream_->ReadTag(), last_tag = tag + 1; in WriteMessage()
202 WireFormat::SkipField(stream_, tag, NULL); in WriteMessage()
203 tag = stream_->ReadTag(); in WriteMessage()
221 tag = stream_->ReadTag(); in WriteMessage()
242 tag_to_return = stream_->ReadTag(); in RenderList()
246 } while ((tag_to_return = stream_->ReadTag()) == list_tag); in RenderList()
261 stream_->ReadVarint32(&buffer32); // message length in RenderMap()
262 int old_limit = stream_->PushLimit(buffer32); in RenderMap()
[all …]
/external/sfntly/cpp/src/sfntly/data/
Dfont_input_stream.cc24 : stream_(is), position_(0), length_(0), bounded_(false) { in FontInputStream()
28 : stream_(is), position_(0), length_(length), bounded_(true) { in FontInputStream()
36 if (stream_) { in Available()
37 return stream_->Available(); in Available()
43 if (stream_) { in Close()
44 stream_->Close(); in Close()
49 if (stream_) { in Mark()
50 stream_->Mark(readlimit); in Mark()
55 if (stream_) { in MarkSupported()
56 return stream_->MarkSupported(); in MarkSupported()
[all …]
Dfont_output_stream.cc24 : stream_(os), in FontOutputStream()
33 if (stream_) { in Write()
34 stream_->Write(b); in Write()
48 assert(stream_); in Write()
58 stream_->Write(b, off, len); in Write()
64 assert(stream_); in Write()
73 stream_->Write(b, off, len); in Write()
117 if (stream_) { in Flush()
118 stream_->Flush(); in Flush()
123 if (stream_) { in Close()
[all …]
/external/webrtc/webrtc/base/
Dfilerotatingstream_unittest.cc36 stream_.reset(new FileRotatingStream(dir_path_, file_prefix, max_file_size, in Init()
41 stream_.reset(); in TearDown()
50 EXPECT_EQ(SR_SUCCESS, stream_->WriteAll(data, data_len, nullptr, nullptr)); in WriteAndFlush()
51 EXPECT_TRUE(stream_->Flush()); in WriteAndFlush()
91 scoped_ptr<FileRotatingStream> stream_; member in rtc::FileRotatingStreamTest
102 EXPECT_EQ(SS_CLOSED, stream_->GetState()); in TEST_F()
103 ASSERT_TRUE(stream_->Open()); in TEST_F()
104 EXPECT_EQ(SS_OPEN, stream_->GetState()); in TEST_F()
105 stream_->Close(); in TEST_F()
106 EXPECT_EQ(SS_CLOSED, stream_->GetState()); in TEST_F()
[all …]
Dsocketpool.cc149 : factory_(factory), stream_(NULL), checked_out_(false) { in ReuseSocketPool()
154 delete stream_; in ~ReuseSocketPool()
161 if (!stream_) { in RequestConnectedStream()
175 stream_ = new SocketStream(socket); in RequestConnectedStream()
177 if ((stream_->GetState() == SS_OPEN) && (remote == remote_)) { in RequestConnectedStream()
181 stream_->Close(); in RequestConnectedStream()
182 if ((stream_->GetSocket()->Connect(remote_) != 0) in RequestConnectedStream()
183 && !stream_->GetSocket()->IsBlocking()) { in RequestConnectedStream()
185 *err = stream_->GetSocket()->GetError(); in RequestConnectedStream()
191 stream_->SignalEvent.disconnect(this); in RequestConnectedStream()
[all …]
/external/v8/src/libplatform/tracing/
Dtrace-writer.cc62 stream_ << (value.as_bool ? "true" : "false"); in AppendArgValue()
65 stream_ << value.as_uint; in AppendArgValue()
68 stream_ << value.as_int; in AppendArgValue()
94 stream_ << real; in AppendArgValue()
100 stream_ << "\"" << value.as_pointer << "\""; in AppendArgValue()
105 stream_ << "\"NULL\""; in AppendArgValue()
107 WriteJSONStringToStream(value.as_string, stream_); in AppendArgValue()
119 stream_ << arg_stringified; in AppendArgValue()
122 JSONTraceWriter::JSONTraceWriter(std::ostream& stream) : stream_(stream) { in JSONTraceWriter()
123 stream_ << "{\"traceEvents\":["; in JSONTraceWriter()
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/C/
DAST.stg80 :{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<rewriteElemen…
100 :{it | stream_<it> = NULL;
101 #define CREATE_stream_<it> if (stream_<it> == NULL) {stream_<it> = antlr3RewriteRuleSubtreeStreamN…
143 …s.(actionScope).synpredgate> ) { <endif>CREATE_stream_<token>; stream_<token>->add(stream_<token>,…
157 …ns.(actionScope).synpredgate> ) {<endif>CREATE_stream_<token>; stream_<token>->add(stream_<token>,…
167 …ionScope).synpredgate> ) { <endif>CREATE_stream_<rule.name>; stream_<rule.name>->add(stream_<rule.…
179 …ionScope).synpredgate> ) { <endif>CREATE_stream_<rule.name>; stream_<rule.name>->add(stream_<rule.…
[all …]
/external/eigen/unsupported/Eigen/CXX11/src/Tensor/
DTensorDeviceCuda.h102 CudaStreamDevice() : stream_(&default_stream), scratch_(NULL), semaphore_(NULL) { in initializeDeviceProp()
107 …CudaStreamDevice(int device) : stream_(&default_stream), device_(device), scratch_(NULL), semaphor… in initializeDeviceProp()
115 : stream_(stream), device_(device), scratch_(NULL), semaphore_(NULL) { in initializeDeviceProp() function
135 const cudaStream_t& stream() const { return *stream_; } in initializeDeviceProp()
169 cudaError_t err = cudaMemsetAsync(semaphore_, 0, sizeof(unsigned int), *stream_); in initializeDeviceProp()
177 const cudaStream_t* stream_; in initializeDeviceProp()
186 explicit GpuDevice(const StreamInterface* stream) : stream_(stream), max_blocks_(INT_MAX) { in initializeDeviceProp()
189 …explicit GpuDevice(const StreamInterface* stream, int num_blocks) : stream_(stream), max_blocks_(n… in initializeDeviceProp()
194 return stream_->stream(); in initializeDeviceProp()
198 return stream_->allocate(num_bytes); in initializeDeviceProp()
[all …]
/external/webrtc/webrtc/sound/
Dpulseaudiosoundsystem.cc131 : pulse_(pulse), stream_(stream), flags_(flags) { in PulseAudioStream()
136 ASSERT(stream_ == NULL); in ~PulseAudioStream()
143 symbol_table()->pa_stream_set_state_callback()(stream_, NULL, NULL); in Close()
144 if (symbol_table()->pa_stream_disconnect()(stream_) != 0) { in Close()
148 symbol_table()->pa_stream_unref()(stream_); in Close()
149 stream_ = NULL; in Close()
163 int re = symbol_table()->pa_stream_get_latency()(stream_, &latency, in LatencyUsecs()
191 ASSERT(stream_ != NULL); in stream()
192 return stream_; in stream()
196 return stream_ == NULL; in IsClosed()
[all …]
Dalsasoundsystem.cc244 : stream_(alsa, handle, frame_size, wait_timeout_ms, flags, freq), in AlsaInputStream()
273 return StopReading() && stream_.Close(); in Close()
277 return stream_.CurrentDelayUsecs(); in LatencyUsecs()
289 snd_pcm_uframes_t avail = stream_.Wait(); in OnHaveWork()
292 size_t size = avail * stream_.frame_size(); in OnHaveWork()
299 snd_pcm_sframes_t read = stream_.symbol_table()->snd_pcm_readi()( in OnHaveWork()
300 stream_.handle(), in OnHaveWork()
305 stream_.Recover(read); in OnHaveWork()
313 read * stream_.frame_size(), in OnHaveWork()
328 return stream_.GetError(err); in GetError()
[all …]
/external/google-breakpad/src/processor/
Dbinarystream.h50 : stream_(which) {} in stream_() function
53 : stream_(str, which) {} in stream_() function
56 : stream_(string(str, size), which) {} in stream_() function
72 bool eof() const { return stream_.eof(); } in eof()
73 void clear() { stream_.clear(); } in clear()
74 string str() const { return stream_.str(); } in str()
75 void str(const string &s) { stream_.str(s); } in str()
79 stream_.seekg (0, ios::beg); in rewind()
80 stream_.seekp (0, ios::beg); in rewind()
83 stream_.clear(); in rewind()
[all …]
Dbinarystream.cc52 stream_.read(&buffer[0], length); in operator >>()
59 stream_.read((char *)&u8, 1); in operator >>()
65 stream_.read((char *)&temp, 2); in operator >>()
73 stream_.read((char *)&temp, 4); in operator >>()
91 stream_.write(str.c_str(), USHRT_MAX); in operator <<()
94 stream_.write(str.c_str(), str.length()); in operator <<()
100 stream_.write((const char*)&u8, 1); in operator <<()
106 stream_.write((const char*)&u16, 2); in operator <<()
112 stream_.write((const char*)&u32, 4); in operator <<()
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/Ruby/
DAST.stg26 …:{int |stream_<it> = ANTLR3::AST::RewriteRule<rewriteElementType>Stream.new( @adaptor, "token <it>…
28 …:{int |stream_<it> = ANTLR3::AST::RewriteRuleSubtreeStream.new( @adaptor, "rule <it>" )}; separato…
41 <gatedAction({stream_<token>.add( <label; format="label"> )})>
51 <gatedAction({stream_<token>.add( <label; format="label"> )})>
61 <gatedAction({stream_<rule.name>.add( <label; format="label">.tree )})>
70 <gatedAction({stream_<rule.name>.add( <label; format="label">.tree )})>
130 {it | stream_<it> = <rewriteElementType; format="snakecase">_stream( "token <it>", <it; format="lab…
133 {it | stream_<it> = <rewriteElementType; format="snakecase">_stream( "token <it>", list_of_<it; for…
136 {it | stream_<it> = subtree_stream( "wildcard <it>", <it; format="label"> )};
139 {it | stream_<it> = subtree_stream( "wildcard <it>", list_of_<it; format="label"> )};
[all …]
/external/parameter-framework/asio-1.10.6/include/asio/impl/
Dwrite.hpp94 stream_(stream), in write_op()
104 stream_(other.stream_), in write_op()
114 stream_(other.stream_), in write_op()
131 stream_.async_write_some(buffers_, in operator ()()
147 AsyncWriteStream& stream_; member in asio::detail::write_op
168 stream_(stream), in write_op()
178 stream_(other.stream_), in write_op()
188 stream_(other.stream_), in write_op()
206 stream_.async_write_some( in operator ()()
222 AsyncWriteStream& stream_; member in asio::detail::write_op
[all …]
Dread.hpp96 stream_(stream), in read_op()
106 stream_(other.stream_), in read_op()
116 stream_(other.stream_), in read_op()
133 stream_.async_read_some(buffers_, in operator ()()
149 AsyncReadStream& stream_; member in asio::detail::read_op
169 stream_(stream), in read_op()
179 stream_(other.stream_), in read_op()
189 stream_(other.stream_), in read_op()
207 stream_.async_read_some( in operator ()()
223 AsyncReadStream& stream_; member in asio::detail::read_op
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/ActionScript/
DAST.stg71 …:{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(…
73 …:{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}; se…
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>.…
134 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.tree);
195 …:{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(…
199 …:{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(…
203 …:{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<…
207 …:{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",li…
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/Java/
DAST.stg70 …:{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream…
72 …:{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}; s…
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>.…
133 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.getTr…
195 …:{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream…
199 …:{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream…
203 …:{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<…
207 …:{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",l…
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/JavaScript/
DAST.stg66 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleTokenStream(this.adaptor,"token <it>");}; …
68 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"rule <it>");};…
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>.…
133 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.getTr…
194 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRule<rewriteElementType>Stream(this.adaptor,"t…
198 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRule<rewriteElementType>Stream(this.adaptor,"t…
202 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"wildcard <it>"…
206 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"wildcard <it>"…
[all …]

12345