Home
last modified time | relevance | path

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

12345678

/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.cc156 return *static_cast<MockFileDescriptor*>(stream_->fd_interface_.get()); in fd_mock()
162 stream_.reset(new FileStream(std::move(fd), access_mode)); in CreateStream()
187 return stream_->WaitForData(mode, {}, error); in CallWaitForData()
190 std::unique_ptr<FileStream> stream_; member in brillo::FileStreamTest
202 EXPECT_TRUE(stream_->IsOpen()); in TEST_F()
204 EXPECT_FALSE(stream_->IsOpen()); in TEST_F()
209 EXPECT_TRUE(stream_->CanRead()); in TEST_F()
211 EXPECT_FALSE(stream_->CanRead()); in TEST_F()
213 EXPECT_TRUE(stream_->CanRead()); in TEST_F()
215 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 …]
/external/libtextclassifier/utils/zlib/
Dzlib.cc35 memset(&stream_, 0, sizeof(stream_)); in ZlibDecompressor()
36 stream_.zalloc = Z_NULL; in ZlibDecompressor()
37 stream_.zfree = Z_NULL; in ZlibDecompressor()
39 if (inflateInit(&stream_) != Z_OK) { in ZlibDecompressor()
44 inflateSetDictionary(&stream_, dictionary, dictionary_size) != Z_OK) { in ZlibDecompressor()
53 inflateEnd(&stream_); in ~ZlibDecompressor()
64 stream_.next_in = reinterpret_cast<const Bytef*>(buffer); in Decompress()
65 stream_.avail_in = buffer_size; in Decompress()
66 stream_.next_out = reinterpret_cast<Bytef*>(const_cast<char*>(out->c_str())); in Decompress()
67 stream_.avail_out = uncompressed_size; in Decompress()
[all …]
/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/adhd/cras/src/tests/
Dcras_client_unittest.cc73 memset(&stream_, 0, sizeof(stream_)); in SetUp()
74 stream_.id = FIRST_STREAM_ID; in SetUp()
80 stream_.config = config; in SetUp()
84 if (stream_.config) { in TearDown()
85 free(stream_.config); in TearDown()
86 stream_.config = NULL; in TearDown()
94 struct client_stream stream_; member in __anon58917f850111::CrasClientTestSuite
123 struct cras_audio_shm *shm = &stream_.capture_shm; in TEST_F()
125 stream_.direction = CRAS_STREAM_INPUT; in TEST_F()
129 stream_.config->buffer_frames = 480; in TEST_F()
[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 …]
/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/antlr/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/bsdiff/
Dbz2_decompressor.cc19 BZ2_bzDecompressEnd(&stream_); in ~BZ2Decompressor()
29 stream_.next_in = reinterpret_cast<char*>(const_cast<uint8_t*>(input_data)); in SetInputData()
30 stream_.avail_in = size; in SetInputData()
31 stream_.bzalloc = nullptr; in SetInputData()
32 stream_.bzfree = nullptr; in SetInputData()
33 stream_.opaque = nullptr; in SetInputData()
34 int bz2err = BZ2_bzDecompressInit(&stream_, 0, 0); in SetInputData()
48 stream_.next_out = reinterpret_cast<char*>(output_data); in Read()
52 stream_.avail_out = output_size; in Read()
54 size_t prev_avail_in = stream_.avail_in; in Read()
[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_ << "\"nullptr\""; in AppendArgValue()
107 WriteJSONStringToStream(value.as_string, stream_); in AppendArgValue()
119 stream_ << arg_stringified; in AppendArgValue()
126 : stream_(stream) { in JSONTraceWriter()
127 stream_ << "{\"" << tag << "\":["; in JSONTraceWriter()
[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/tensorflow/tensorflow/compiler/xla/tests/
Dtransfer_manager_test.cc50 stream_ = stream_ptr_.get();
65 se::Stream* stream_; member in xla::__anonf12072500111::TransferManagerTest
77 ASSERT_IS_OK(transfer_manager_->TransferLiteralToDevice(stream_, literal, in XLA_TEST_F()
81 transfer_manager_->TransferLiteralFromDevice(stream_, device_buffer)); in XLA_TEST_F()
93 ASSERT_IS_OK(transfer_manager_->TransferLiteralToDevice(stream_, literal, in XLA_TEST_F()
97 transfer_manager_->TransferLiteralFromDevice(stream_, device_buffer)); in XLA_TEST_F()
111 ASSERT_IS_OK(transfer_manager_->TransferLiteralToDevice(stream_, literal, in XLA_TEST_F()
115 transfer_manager_->TransferLiteralFromDevice(stream_, device_buffer)); in XLA_TEST_F()
127 ASSERT_IS_OK(transfer_manager_->TransferLiteralToDevice(stream_, literal, in XLA_TEST_F()
131 transfer_manager_->TransferLiteralFromDevice(stream_, device_buffer)); in XLA_TEST_F()
[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 …]
/external/deqp-deps/SPIRV-Tools/source/
Ddisassemble.cpp57 stream_(out_.get()), in Disassembler()
122 std::ostream& stream_; // The output std::stream. member in __anone1d590aa0111::Disassembler
138 stream_ << "; SPIR-V\n" in HandleHeader()
144 stream_ << "(" << SPV_GENERATOR_TOOL_PART(generator) << ")"; in HandleHeader()
148 stream_ << "; " << SPV_GENERATOR_MISC_PART(generator) << "\n" in HandleHeader()
165 stream_ << std::setw(std::max(0, indent_ - 3 - int(id_name.size()))); in HandleInstruction()
166 stream_ << "%" << id_name; in HandleInstruction()
168 stream_ << " = "; in HandleInstruction()
170 stream_ << std::string(indent_, ' '); in HandleInstruction()
173 stream_ << "Op" << spvOpcodeString(static_cast<SpvOp>(inst.opcode)); in HandleInstruction()
[all …]
/external/swiftshader/third_party/SPIRV-Tools/source/
Ddisassemble.cpp57 stream_(out_.get()), in Disassembler()
122 std::ostream& stream_; // The output std::stream. member in __anon56cff7640111::Disassembler
138 stream_ << "; SPIR-V\n" in HandleHeader()
144 stream_ << "(" << SPV_GENERATOR_TOOL_PART(generator) << ")"; in HandleHeader()
148 stream_ << "; " << SPV_GENERATOR_MISC_PART(generator) << "\n" in HandleHeader()
165 stream_ << std::setw(std::max(0, indent_ - 3 - int(id_name.size()))); in HandleInstruction()
166 stream_ << "%" << id_name; in HandleInstruction()
168 stream_ << " = "; in HandleInstruction()
170 stream_ << std::string(indent_, ' '); in HandleInstruction()
173 stream_ << "Op" << spvOpcodeString(static_cast<SpvOp>(inst.opcode)); in HandleInstruction()
[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 …]
/external/antlr/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 …]
/external/perfetto/src/perfetto_cmd/
Dpacket_writer.cc94 z_stream stream_{}; member in perfetto::__anon0433f89c0111::ZipPacketWriter
165 CheckEq(deflate(&stream_, Z_SYNC_FLUSH), Z_OK); in WritePacket()
169 PERFETTO_DCHECK(end_ >= stream_.next_out); in WritePacket()
170 size_t remaining = static_cast<size_t>(end_ - stream_.next_out); in WritePacket()
180 memset(&stream_, 0, sizeof(stream_)); in WritePacket()
181 CheckEq(deflateInit(&stream_, 9), Z_OK); in WritePacket()
183 stream_.next_out = start_; in WritePacket()
184 stream_.avail_out = static_cast<unsigned int>(end_ - start_); in WritePacket()
203 CheckEq(deflate(&stream_, Z_FINISH), Z_STREAM_END); in FinalizeCompressedPacket()
205 size_t size = static_cast<size_t>(stream_.next_out - start_); in FinalizeCompressedPacket()
[all …]
/external/grpc-grpc/test/cpp/qps/
Dclient_sync.cc150 stream_(num_threads_), in SynchronousStreamingClient()
160 stream_[thread_idx]->Finish().IgnoreError(); in ~SynchronousStreamingClient()
166 std::vector<std::unique_ptr<StreamType>> stream_; member in grpc::testing::SynchronousStreamingClient
179 Status s = stream_[thread_idx]->Finish(); in FinishStream()
201 if (stream_[i]) { in CleanupAllStreams()
227 [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); }); in ~SynchronousStreamingPingPongClient()
235 stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]); in InitThreadFuncImpl()
249 if (stream_[thread_idx]->Write(request_) && in ThreadFuncImpl()
250 stream_[thread_idx]->Read(&responses_[thread_idx])) { in ThreadFuncImpl()
262 stream_[thread_idx]->WritesDone(); in ThreadFuncImpl()
[all …]

12345678