Home
last modified time | relevance | path

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

/external/libbrillo/brillo/streams/
Dstream_utils_test.cc54 EXPECT_FALSE(stream_utils::ErrorStreamClosed(FROM_HERE, &error)); in TEST()
62 EXPECT_FALSE(stream_utils::ErrorOperationNotSupported(FROM_HERE, &error)); in TEST()
70 EXPECT_FALSE(stream_utils::ErrorReadPastEndOfStream(FROM_HERE, &error)); in TEST()
79 EXPECT_TRUE(stream_utils::CheckInt64Overflow(FROM_HERE, 0, 0, nullptr)); in TEST()
80 EXPECT_TRUE(stream_utils::CheckInt64Overflow( in TEST()
82 EXPECT_TRUE(stream_utils::CheckInt64Overflow( in TEST()
84 EXPECT_TRUE(stream_utils::CheckInt64Overflow(FROM_HERE, 100, -90, nullptr)); in TEST()
85 EXPECT_TRUE(stream_utils::CheckInt64Overflow( in TEST()
89 EXPECT_FALSE(stream_utils::CheckInt64Overflow(FROM_HERE, 100, -101, &error)); in TEST()
94 EXPECT_FALSE(stream_utils::CheckInt64Overflow( in TEST()
[all …]
Dfake_stream.cc52 *mode = stream_utils::MakeAccessMode(read, write); in GetMinDelayAndMode()
164 return stream_utils::IsReadAccessMode(mode_); in CanRead()
168 return stream_utils::IsWriteAccessMode(mode_); in CanWrite()
172 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking()
179 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek()
204 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in ReadNonBlocking()
207 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking()
268 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WriteNonBlocking()
271 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WriteNonBlocking()
330 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in FlushBlocking()
[all …]
Dinput_stream_set.cc94 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking()
108 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek()
117 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking()
143 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WriteNonBlocking()
165 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WaitForData()
167 if (stream_utils::IsWriteAccessMode(mode)) in WaitForData()
168 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WaitForData()
184 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WaitForDataBlocking()
186 if (stream_utils::IsWriteAccessMode(in_mode)) in WaitForDataBlocking()
187 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WaitForDataBlocking()
Dfile_stream.cc88 if (stream_utils::IsReadAccessMode(mode)) { in WaitForData()
102 if (stream_utils::IsWriteAccessMode(mode)) { in WaitForData()
130 if (stream_utils::IsReadAccessMode(in_mode)) in WaitForDataBlocking()
133 if (stream_utils::IsWriteAccessMode(in_mode)) in WaitForDataBlocking()
145 *out_mode = stream_utils::MakeAccessMode(FD_ISSET(fd_, &read_fds), in WaitForDataBlocking()
348 return IsOpen() && stream_utils::IsReadAccessMode(access_mode_); in CanRead()
352 return IsOpen() && stream_utils::IsWriteAccessMode(access_mode_); in CanWrite()
369 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in SetSizeBlocking()
371 if (!stream_utils::CheckInt64Overflow(FROM_HERE, size, 0, error)) in SetSizeBlocking()
403 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in Seek()
[all …]
Dtls_stream.cc253 bool is_read = stream_utils::IsReadAccessMode(mode); in WaitForData()
254 bool is_write = stream_utils::IsWriteAccessMode(mode); in WaitForData()
263 mode = stream_utils::MakeAccessMode(is_read, is_write); in WaitForData()
271 bool is_read = stream_utils::IsReadAccessMode(in_mode); in WaitForDataBlocking()
272 bool is_write = stream_utils::IsWriteAccessMode(in_mode); in WaitForDataBlocking()
281 in_mode = stream_utils::MakeAccessMode(is_read, is_write); in WaitForDataBlocking()
485 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking()
492 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek()
501 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking()
511 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()
248 CHECK(stream_utils::IsReadAccessMode(mode)); in OnReadAvailable()
311 CHECK(stream_utils::IsWriteAccessMode(mode)); in OnWriteAvailable()
332 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.cc18 namespace stream_utils { namespace
/external/libbrillo/brillo/http/
Dhttp_connection_curl.cc201 stream_utils::ErrorStreamClosed(FROM_HERE, error); in ExtractDataStream()
/external/libbrillo/
DAndroid.bp104 "brillo/streams/stream_utils.cc",
DBUILD.gn160 "brillo/streams/stream_utils.cc",