Lines Matching refs:stream_utils
85 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()
448 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking()
475 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WriteNonBlocking()
495 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in FlushBlocking()
518 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WaitForData()
528 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WaitForDataBlocking()
536 return stream_utils::ErrorOperationTimeout(FROM_HERE, error); in WaitForDataBlocking()