Home
last modified time | relevance | path

Searched refs:bytes_to_read (Results 1 – 25 of 48) sorted by relevance

12

/external/tensorflow/tensorflow/core/lib/io/snappy/
Dsnappy_inputbuffer.cc33 Status SnappyInputBuffer::ReadNBytes(int64_t bytes_to_read, tstring* result) { in ReadNBytes() argument
35 result->resize_uninitialized(bytes_to_read); in ReadNBytes()
40 size_t bytes_read = ReadBytesFromCache(bytes_to_read, result_ptr); in ReadNBytes()
41 bytes_to_read -= bytes_read; in ReadNBytes()
44 while (bytes_to_read > 0) { in ReadNBytes()
51 bytes_read = ReadBytesFromCache(bytes_to_read, result_ptr); in ReadNBytes()
52 bytes_to_read -= bytes_read; in ReadNBytes()
70 size_t SnappyInputBuffer::ReadBytesFromCache(size_t bytes_to_read, in ReadBytesFromCache() argument
72 size_t can_read_bytes = std::min(bytes_to_read, avail_out_); in ReadBytesFromCache()
130 size_t bytes_to_read = 4; in ReadCompressedBlockLength() local
[all …]
Dsnappy_inputstream.cc46 Status SnappyInputStream::ReadNBytes(int64_t bytes_to_read, tstring* result) { in ReadNBytes() argument
48 result->resize_uninitialized(bytes_to_read); in ReadNBytes()
53 size_t bytes_read = ReadBytesFromCache(bytes_to_read, result_ptr); in ReadNBytes()
54 bytes_to_read -= bytes_read; in ReadNBytes()
57 while (bytes_to_read > 0) { in ReadNBytes()
63 size_t bytes_read = ReadBytesFromCache(bytes_to_read, result_ptr); in ReadNBytes()
64 bytes_to_read -= bytes_read; in ReadNBytes()
72 Status SnappyInputStream::ReadNBytes(int64_t bytes_to_read, in ReadNBytes() argument
76 TF_RETURN_IF_ERROR(ReadNBytes(bytes_to_read, &buf)); in ReadNBytes()
132 size_t SnappyInputStream::ReadBytesFromCache(size_t bytes_to_read, in ReadBytesFromCache() argument
[all …]
Dsnappy_inputstream.h47 Status ReadNBytes(int64_t bytes_to_read, tstring* result) override;
50 Status ReadNBytes(int64_t bytes_to_read, absl::Cord* result) override;
63 size_t ReadBytesFromCache(size_t bytes_to_read, char* result);
Dsnappy_inputbuffer.h57 Status ReadNBytes(int64_t bytes_to_read, tstring* result) override;
89 size_t ReadBytesFromCache(size_t bytes_to_read, char* result);
/external/tensorflow/tensorflow/core/lib/io/
Dinputbuffer.cc79 Status InputBuffer::ReadNBytes(int64_t bytes_to_read, std::string* result) { in ReadNBytes() argument
81 if (bytes_to_read < 0) { in ReadNBytes()
83 bytes_to_read); in ReadNBytes()
85 result->resize(bytes_to_read); in ReadNBytes()
87 Status status = ReadNBytes(bytes_to_read, &(*result)[0], &bytes_read); in ReadNBytes()
88 if (bytes_read < bytes_to_read) result->resize(bytes_read); in ReadNBytes()
92 Status InputBuffer::ReadNBytes(int64_t bytes_to_read, char* result, in ReadNBytes() argument
94 if (bytes_to_read < 0) { in ReadNBytes()
96 bytes_to_read); in ReadNBytes()
100 while (*bytes_read < static_cast<size_t>(bytes_to_read)) { in ReadNBytes()
[all …]
Drandom_inputstream.cc32 Status RandomAccessInputStream::ReadNBytes(int64_t bytes_to_read, in ReadNBytes() argument
34 if (bytes_to_read < 0) { in ReadNBytes()
38 result->resize_uninitialized(bytes_to_read); in ReadNBytes()
41 Status s = file_->Read(pos_, bytes_to_read, &data, result_buffer); in ReadNBytes()
53 Status RandomAccessInputStream::ReadNBytes(int64_t bytes_to_read, in ReadNBytes() argument
55 if (bytes_to_read < 0) { in ReadNBytes()
59 Status s = file_->Read(pos_, bytes_to_read, result); in ReadNBytes()
88 int64_t bytes_to_read = std::min<int64>(kMaxSkipSize, bytes_to_skip); in SkipNBytes() local
90 Status s = file_->Read(pos_, bytes_to_read, &data, scratch.get()); in SkipNBytes()
96 if (data.size() < static_cast<size_t>(bytes_to_read)) { in SkipNBytes()
[all …]
Dzlib_inputstream.cc124 int bytes_to_read = input_buffer_capacity_; in ReadFromStream() local
139 bytes_to_read -= z_stream_def_->stream->avail_in; in ReadFromStream()
146 Status s = input_stream_->ReadNBytes(bytes_to_read, &data); in ReadFromStream()
175 size_t ZlibInputStream::ReadBytesFromCache(size_t bytes_to_read, in ReadBytesFromCache() argument
180 size_t can_read_bytes = std::min(bytes_to_read, unread_bytes); in ReadBytesFromCache()
196 Status ZlibInputStream::ReadNBytes(int64_t bytes_to_read, tstring* result) { in ReadNBytes() argument
203 bytes_to_read -= ReadBytesFromCache(bytes_to_read, result); in ReadNBytes()
205 while (bytes_to_read > 0) { in ReadNBytes()
224 bytes_to_read -= ReadBytesFromCache(bytes_to_read, result); in ReadNBytes()
232 Status ZlibInputStream::ReadNBytes(int64_t bytes_to_read, absl::Cord* result) { in ReadNBytes() argument
[all …]
Dbuffered_inputstream.cc96 Status BufferedInputStream::ReadNBytes(int64_t bytes_to_read, tstring* result) { in ReadNBytes() argument
97 if (bytes_to_read < 0) { in ReadNBytes()
99 bytes_to_read); in ReadNBytes()
102 if (pos_ == limit_ && !file_status_.ok() && bytes_to_read > 0) { in ReadNBytes()
105 result->reserve(bytes_to_read); in ReadNBytes()
108 while (result->size() < static_cast<size_t>(bytes_to_read)) { in ReadNBytes()
120 std::min<int64>(limit_ - pos_, bytes_to_read - result->size()); in ReadNBytes()
128 (result->size() == static_cast<size_t>(bytes_to_read))) { in ReadNBytes()
Dinputstream_interface_test.cc30 Status ReadNBytes(int64_t bytes_to_read, tstring* result) override { in ReadNBytes() argument
32 if (pos_ + bytes_to_read > content_.size()) { in ReadNBytes()
35 *result = content_.substr(pos_, bytes_to_read); in ReadNBytes()
36 pos_ += bytes_to_read; in ReadNBytes()
Dinputstream_interface.cc34 int64_t bytes_to_read = std::min<int64>(kMaxSkipSize, bytes_to_skip); in SkipNBytes() local
35 TF_RETURN_IF_ERROR(ReadNBytes(bytes_to_read, &unused)); in SkipNBytes()
36 bytes_to_skip -= bytes_to_read; in SkipNBytes()
Dzlib_inputstream.h69 Status ReadNBytes(int64_t bytes_to_read, tstring* result) override;
72 Status ReadNBytes(int64_t bytes_to_read, absl::Cord* result) override;
115 size_t ReadBytesFromCache(size_t bytes_to_read, tstring* result);
Dinputbuffer.h55 Status ReadNBytes(int64_t bytes_to_read, std::string* result);
60 Status ReadNBytes(int64_t bytes_to_read, char* result, size_t* bytes_read);
79 Status Hint(int64_t bytes_to_read);
Dinputstream_interface.h38 virtual Status ReadNBytes(int64_t bytes_to_read, tstring* result) = 0;
44 virtual Status ReadNBytes(int64_t bytes_to_read, absl::Cord* cord) { in ReadNBytes() argument
Drandom_inputstream.h36 Status ReadNBytes(int64_t bytes_to_read, tstring* result) override;
39 Status ReadNBytes(int64_t bytes_to_read, absl::Cord* result) override;
/external/pigweed/pw_stream/
Dmemory_stream.cc50 size_t bytes_to_read = in DoRead() local
52 if (bytes_to_read == 0) { in DoRead()
59 std::memcpy(dest.data(), source_.data() + position_, bytes_to_read); in DoRead()
60 position_ += bytes_to_read; in DoRead()
62 return StatusWithSize(bytes_to_read); in DoRead()
/external/puffin/src/
Dpuffin_stream.cc222 auto bytes_to_read = std::min(length - bytes_read, end_byte - start_byte); in Read() local
223 TEST_AND_RETURN_FALSE(bytes_to_read >= 1); in Read()
226 TEST_AND_RETURN_FALSE(stream_->Read(bytes + bytes_read, bytes_to_read)); in Read()
230 if ((start_byte + bytes_to_read) * 8 > cur_deflate_->offset) { in Read()
231 bytes[bytes_read + bytes_to_read - 1] &= in Read()
247 deflate_bit_pos_ += bytes_to_read * 8; in Read()
253 bytes_read += bytes_to_read; in Read()
254 puff_pos_ += bytes_to_read; in Read()
263 auto bytes_to_read = end_byte - start_byte; in Read() local
273 deflate_buffer_->resize(bytes_to_read); in Read()
[all …]
/external/pdfium/core/fxcodec/
Dcfx_codec_memory.cpp26 size_t bytes_to_read = std::min(size, size_ - pos_); in ReadBlock() local
27 memcpy(buffer, buffer_.get() + pos_, bytes_to_read); in ReadBlock()
28 pos_ += bytes_to_read; in ReadBlock()
29 return bytes_to_read; in ReadBlock()
/external/tensorflow/tensorflow/core/kernels/
Ddecode_compressed_op.cc37 Status ReadNBytes(int64_t bytes_to_read, tstring* result) override { in ReadNBytes() argument
39 if (bytes_to_read < 0) { in ReadNBytes()
41 bytes_to_read); in ReadNBytes()
43 int64_t bytes = bytes_to_read; in ReadNBytes()
45 if (pos_ + bytes_to_read > len_) { in ReadNBytes()
/external/autotest/client/cros/
Dnetwork.py103 bytes_to_read = min(bytes_left, _MAX_FETCH_READ_BYTES)
104 bytes_read = len(result.read(bytes_to_read))
106 if bytes_read != bytes_to_read:
109 (bytes_to_read, bytes_read))
/external/libchrome/mojo/core/
Ddata_pipe_consumer_dispatcher.cc150 uint32_t bytes_to_read = std::min(max_num_bytes_to_read, bytes_available_); in ReadData() local
151 if (bytes_to_read == 0) { in ReadData()
168 std::min(options_.capacity_num_bytes - read_offset_, bytes_to_read); in ReadData()
169 uint32_t head_bytes_to_copy = bytes_to_read - tail_bytes_to_copy; in ReadData()
175 *num_bytes = bytes_to_read; in ReadData()
179 read_offset_ = (read_offset_ + bytes_to_read) % options_.capacity_num_bytes; in ReadData()
180 bytes_available_ -= bytes_to_read; in ReadData()
183 NotifyRead(bytes_to_read); in ReadData()
214 uint32_t bytes_to_read = in BeginReadData() local
223 *buffer_num_bytes = bytes_to_read; in BeginReadData()
[all …]
/external/webrtc/modules/audio_processing/agc2/rnn_vad/
Dtest_utils.h76 const std::streamsize bytes_to_read = dst.size() * sizeof(T); in ReadChunk() local
78 is_.read(reinterpret_cast<char*>(dst.data()), bytes_to_read); in ReadChunk()
80 is_.read(reinterpret_cast<char*>(buf_.data()), bytes_to_read); in ReadChunk()
84 return is_.gcount() == bytes_to_read; in ReadChunk()
/external/arm-trusted-firmware/drivers/brcm/emmc/
Demmc_pboot_hal_memory_drv.c33 size_t bytes_to_read);
166 size_t storage_size, size_t bytes_to_read) in emmc_read() argument
176 storage_size, bytes_to_read); in emmc_read()
323 size_t storage_size, size_t bytes_to_read) in sdio_read() argument
331 storage_addr, mem_addr, bytes_to_read); in sdio_read()
333 if (storage_size < bytes_to_read) in sdio_read()
352 remSize = bytes_to_read; in sdio_read()
/external/libchrome/base/
Dsync_socket_posix.cc182 const size_t bytes_to_read = std::min(Peek(), length - bytes_read_total); in ReceiveWithTimeout() local
185 if (!bytes_to_read) in ReceiveWithTimeout()
189 Receive(static_cast<char*>(buffer) + bytes_read_total, bytes_to_read); in ReceiveWithTimeout()
191 if (bytes_received != bytes_to_read) in ReceiveWithTimeout()
/external/libchrome/base/files/
Dfile_proxy.cc177 ReadHelper(FileProxy* proxy, File file, int bytes_to_read) in ReadHelper() argument
179 buffer_(new char[bytes_to_read]), in ReadHelper()
180 bytes_to_read_(bytes_to_read), in ReadHelper()
303 bool FileProxy::Read(int64_t offset, int bytes_to_read, ReadCallback callback) { in Read() argument
305 if (bytes_to_read < 0) in Read()
308 ReadHelper* helper = new ReadHelper(this, std::move(file_), bytes_to_read); in Read()
/external/webrtc/test/fuzzers/
Daudio_encoder_fuzzer.cc41 const size_t bytes_to_read = block_size_bytes + sizeof(uint32_t); in FuzzAudioEncoder() local
42 while (data.CanReadBytes(bytes_to_read)) { in FuzzAudioEncoder()

12