Home
last modified time | relevance | path

Searched refs:stream_utils (Results 1 – 12 of 12) sorted by relevance

/external/libbrillo/brillo/streams/
Dstream_utils_unittest.cc52 EXPECT_FALSE(stream_utils::ErrorStreamClosed(FROM_HERE, &error)); in TEST()
60 EXPECT_FALSE(stream_utils::ErrorOperationNotSupported(FROM_HERE, &error)); in TEST()
68 EXPECT_FALSE(stream_utils::ErrorReadPastEndOfStream(FROM_HERE, &error)); in TEST()
77 EXPECT_TRUE(stream_utils::CheckInt64Overflow(FROM_HERE, 0, 0, nullptr)); in TEST()
78 EXPECT_TRUE(stream_utils::CheckInt64Overflow( in TEST()
80 EXPECT_TRUE(stream_utils::CheckInt64Overflow( in TEST()
82 EXPECT_TRUE(stream_utils::CheckInt64Overflow(FROM_HERE, 100, -90, nullptr)); in TEST()
83 EXPECT_TRUE(stream_utils::CheckInt64Overflow( in TEST()
87 EXPECT_FALSE(stream_utils::CheckInt64Overflow(FROM_HERE, 100, -101, &error)); in TEST()
92 EXPECT_FALSE(stream_utils::CheckInt64Overflow( in TEST()
[all …]
Dfake_stream.cc51 *mode = stream_utils::MakeAccessMode(read, write); in GetMinDelayAndMode()
163 return stream_utils::IsReadAccessMode(mode_); in CanRead()
167 return stream_utils::IsWriteAccessMode(mode_); in CanWrite()
171 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking()
178 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek()
203 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in ReadNonBlocking()
206 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking()
267 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WriteNonBlocking()
270 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WriteNonBlocking()
329 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in FlushBlocking()
[all …]
Dinput_stream_set.cc92 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking()
106 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek()
115 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking()
141 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WriteNonBlocking()
163 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WaitForData()
165 if (stream_utils::IsWriteAccessMode(mode)) in WaitForData()
166 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WaitForData()
182 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WaitForDataBlocking()
184 if (stream_utils::IsWriteAccessMode(in_mode)) in WaitForDataBlocking()
185 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WaitForDataBlocking()
Dfile_stream.cc85 if (stream_utils::IsReadAccessMode(mode)) { in WaitForData()
103 if (stream_utils::IsWriteAccessMode(mode)) { in WaitForData()
135 if (stream_utils::IsReadAccessMode(in_mode)) in WaitForDataBlocking()
138 if (stream_utils::IsWriteAccessMode(in_mode)) in WaitForDataBlocking()
150 *out_mode = stream_utils::MakeAccessMode(FD_ISSET(fd_, &read_fds), in WaitForDataBlocking()
358 return IsOpen() && stream_utils::IsReadAccessMode(access_mode_); in CanRead()
362 return IsOpen() && stream_utils::IsWriteAccessMode(access_mode_); in CanWrite()
379 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in SetSizeBlocking()
381 if (!stream_utils::CheckInt64Overflow(FROM_HERE, size, 0, error)) in SetSizeBlocking()
413 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in Seek()
[all …]
Dtls_stream.cc247 bool is_read = stream_utils::IsReadAccessMode(mode); in WaitForData()
248 bool is_write = stream_utils::IsWriteAccessMode(mode); in WaitForData()
257 mode = stream_utils::MakeAccessMode(is_read, is_write); in WaitForData()
265 bool is_read = stream_utils::IsReadAccessMode(in_mode); in WaitForDataBlocking()
266 bool is_write = stream_utils::IsWriteAccessMode(in_mode); in WaitForDataBlocking()
275 in_mode = stream_utils::MakeAccessMode(is_read, is_write); in WaitForDataBlocking()
479 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking()
486 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek()
495 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking()
505 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WriteNonBlocking()
[all …]
Dstream.cc22 if (!stream_utils::CheckInt64Overflow(FROM_HERE, position, 0, error)) in SetPosition()
94 return stream_utils::ErrorReadPastEndOfStream(FROM_HERE, error); in ReadAllBlocking()
247 CHECK(stream_utils::IsReadAccessMode(mode)); in OnReadAvailable()
309 CHECK(stream_utils::IsWriteAccessMode(mode)); in OnWriteAvailable()
330 stream_utils::ErrorReadPastEndOfStream(FROM_HERE, &error); in ReadAllAsyncCallback()
Dmemory_stream.cc121 !stream_utils::CalculateStreamPosition(FROM_HERE, offset, whence, in Seek()
182 return container_ || stream_utils::ErrorStreamClosed(FROM_HERE, error); in CheckContainer()
Dstream_utils.h13 namespace stream_utils {
Dstream_utils.cc14 namespace stream_utils { namespace
/external/libbrillo/brillo/http/
Dhttp_connection_curl.cc199 stream_utils::ErrorStreamClosed(FROM_HERE, error); in ExtractDataStream()
/external/libbrillo/
DAndroid.bp74 "brillo/streams/stream_utils.cc",
Dlibbrillo.gypi152 'brillo/streams/stream_utils.cc',