| /external/tensorflow/tensorflow/core/lib/io/ |
| inputstream_interface.cc | 34 int64 bytes_to_read = std::min<int64>(kMaxSkipSize, bytes_to_skip); local
35 TF_RETURN_IF_ERROR(ReadNBytes(bytes_to_read, &unused));
36 bytes_to_skip -= bytes_to_read;
|
| random_inputstream.cc | 32 Status RandomAccessInputStream::ReadNBytes(int64 bytes_to_read,
34 if (bytes_to_read < 0) {
38 result->resize(bytes_to_read);
41 Status s = file_->Read(pos_, bytes_to_read, &data, result_buffer);
54 if (data.size() < bytes_to_read) {
81 int64 bytes_to_read = std::min<int64>(kMaxSkipSize, bytes_to_skip); local
83 Status s = file_->Read(pos_, bytes_to_read, &data, scratch.get());
89 if (data.size() < bytes_to_read) {
92 bytes_to_skip -= bytes_to_read;
|
| zlib_inputstream.cc | 74 int bytes_to_read = input_buffer_capacity_; local
87 bytes_to_read -= z_stream_->avail_in;
94 Status s = input_stream_->ReadNBytes(bytes_to_read, &data);
101 // Note: data.size() could be different from bytes_to_read.
123 size_t ZlibInputStream::ReadBytesFromCache(size_t bytes_to_read,
127 size_t can_read_bytes = std::min(bytes_to_read, unread_bytes);
142 Status ZlibInputStream::ReadNBytes(int64 bytes_to_read, string* result) {
145 bytes_to_read -= ReadBytesFromCache(bytes_to_read, result);
147 while (bytes_to_read > 0)
[all...] |
| inputstream_interface.h | 32 // Reads the next bytes_to_read from the file. Typical return codes:
35 virtual Status ReadNBytes(int64 bytes_to_read, string* result) = 0;
|
| inputstream_interface_test.cc | 30 Status ReadNBytes(int64 bytes_to_read, string* result) override {
32 if (pos_ + bytes_to_read > content_.size()) {
35 *result = content_.substr(pos_, bytes_to_read);
36 pos_ += bytes_to_read;
|
| buffered_inputstream.cc | 88 Status BufferedInputStream::ReadNBytes(int64 bytes_to_read, string* result) {
89 if (bytes_to_read < 0) {
91 bytes_to_read);
94 if (!file_status_.ok() && bytes_to_read > 0) {
97 result->reserve(bytes_to_read);
100 while (result->size() < static_cast<size_t>(bytes_to_read)) {
112 std::min<int64>(limit_ - pos_, bytes_to_read - result->size());
120 (result->size() == static_cast<size_t>(bytes_to_read))) {
|
| zlib_inputstream.h | 50 // Reads bytes_to_read bytes into *result, overwriting *result.
59 Status ReadNBytes(int64 bytes_to_read, string* result) override;
114 // Starts reading bytes at `next_unread_byte_` till either `bytes_to_read`
118 size_t ReadBytesFromCache(size_t bytes_to_read, string* result);
|
| inputbuffer.cc | 74 Status InputBuffer::ReadNBytes(int64 bytes_to_read, string* result) {
76 if (bytes_to_read < 0) {
78 bytes_to_read);
80 result->resize(bytes_to_read);
82 Status status = ReadNBytes(bytes_to_read, &(*result)[0], &bytes_read);
83 if (bytes_read < bytes_to_read) result->resize(bytes_read);
87 Status InputBuffer::ReadNBytes(int64 bytes_to_read, char* result,
89 if (bytes_to_read < 0) {
91 bytes_to_read);
95 while (*bytes_read < static_cast<size_t>(bytes_to_read)) {
[all...] |
| random_inputstream.h | 35 Status ReadNBytes(int64 bytes_to_read, string* result) override;
|
| buffered_inputstream.h | 44 Status ReadNBytes(int64 bytes_to_read, string* result) override;
|
| inputbuffer.h | 48 // Reads bytes_to_read bytes into *result, overwriting *result.
53 Status ReadNBytes(int64 bytes_to_read, string* result);
56 // bytes_to_read) is valid to be overwritten. Returns OK iff "*bytes_read ==
57 // bytes_to_read".
58 Status ReadNBytes(int64 bytes_to_read, char* result, size_t* bytes_read);
|
| /external/tensorflow/tensorflow/core/lib/io/snappy/ |
| snappy_inputbuffer.cc | 32 Status SnappyInputBuffer::ReadNBytes(int64 bytes_to_read, string* result) {
35 bytes_to_read -= ReadBytesFromCache(bytes_to_read, result);
37 while (bytes_to_read > 0) {
44 bytes_to_read -= ReadBytesFromCache(bytes_to_read, result);
64 size_t SnappyInputBuffer::ReadBytesFromCache(size_t bytes_to_read,
66 size_t can_read_bytes = std::min(bytes_to_read, avail_out_);
124 size_t bytes_to_read = 4; local
125 while (bytes_to_read > 0)
145 int bytes_to_read = input_buffer_capacity_; local
[all...] |
| snappy_inputbuffer.h | 44 // Reads bytes_to_read bytes into *result, overwriting *result.
57 Status ReadNBytes(int64 bytes_to_read, string* result) override;
85 // Starts reading bytes at `next_out_` till either `bytes_to_read`
89 size_t ReadBytesFromCache(size_t bytes_to_read, string* result);
|
| snappy_buffers_test.cc | 92 size_t bytes_to_read = 256; local
93 char* scratch = new char[bytes_to_read];
94 char* buffer = new char[bytes_to_read];
97 while ((file_reader->Read(file_pos, bytes_to_read, &data, scratch)).ok()) {
|
| /system/update_engine/payload_consumer/ |
| extent_reader.cc | 73 uint64_t bytes_to_read = local
80 bytes_to_read,
84 static_cast<ssize_t>(bytes_to_read));
86 bytes_read += bytes_to_read;
87 cur_extent_bytes_read_ += bytes_to_read;
88 offset_ += bytes_to_read;
|
| /development/host/windows/usb/api/ |
| adb_endpoint_object.cpp | 51 ULONG bytes_to_read,
57 bytes_to_read,
77 ULONG bytes_to_read,
82 bytes_to_read,
|
| adb_endpoint_object.h | 116 @param[in] bytes_to_read Number of bytes to be read.
128 ULONG bytes_to_read,
156 @param[in] bytes_to_read Number of bytes to be read.
165 ULONG bytes_to_read,
|
| /external/tensorflow/tensorflow/core/kernels/ |
| decode_compressed_op.cc | 37 Status ReadNBytes(int64 bytes_to_read, string* result) override {
39 if (bytes_to_read < 0) {
41 bytes_to_read);
43 int64 bytes = bytes_to_read;
45 if (pos_ + bytes_to_read > len_) {
|
| fixed_length_record_reader_op.cc | 107 int bytes_to_read = record_bytes_ + footer_bytes_ - lookahead_cache_.size(); variable
108 Status s = buffered_inputstream_->ReadNBytes(bytes_to_read, value);
117 lookahead_cache_.append(*value, 0, bytes_to_read);
|
| /system/update_engine/common/ |
| file_fetcher.cc | 107 size_t bytes_to_read = buffer_.size(); local
109 bytes_to_read = std::min(static_cast<uint64_t>(bytes_to_read),
113 if (!bytes_to_read) {
120 bytes_to_read,
|
| hash_calculator.cc | 56 off_t bytes_to_read = buffer.size(); local
57 if (length >= 0 && bytes_to_read > length - bytes_processed) {
58 bytes_to_read = length - bytes_processed;
60 ssize_t rc = HANDLE_EINTR(read(fd, buffer.data(), bytes_to_read));
|
| /external/puffin/src/ |
| puffin_stream.cc | 224 auto bytes_to_read = std::min(length - bytes_read, end_byte - start_byte); local
225 TEST_AND_RETURN_FALSE(bytes_to_read >= 1);
228 TEST_AND_RETURN_FALSE(stream_->Read(bytes + bytes_read, bytes_to_read));
232 if ((start_byte + bytes_to_read) * 8 > cur_deflate_->offset) {
233 bytes[bytes_read + bytes_to_read - 1] &=
249 deflate_bit_pos_ += bytes_to_read * 8;
255 bytes_read += bytes_to_read;
256 puff_pos_ += bytes_to_read;
265 auto bytes_to_read = end_byte - start_byte; local
275 deflate_buffer_->resize(bytes_to_read);
[all...] |
| /external/autotest/client/cros/ |
| network.py | 165 bytes_to_read = min(bytes_left, _MAX_FETCH_READ_BYTES)
166 bytes_read = len(result.read(bytes_to_read))
168 if bytes_read != bytes_to_read:
171 (bytes_to_read, bytes_read))
|
| /external/libmojo/mojo/edk/system/ |
| data_pipe_consumer_dispatcher.cc | 169 uint32_t bytes_to_read = std::min(max_num_bytes_to_read, bytes_available_); local
170 if (bytes_to_read == 0) {
184 std::min(options_.capacity_num_bytes - read_offset_, bytes_to_read);
185 uint32_t head_bytes_to_copy = bytes_to_read - tail_bytes_to_copy;
191 *num_bytes = bytes_to_read;
195 read_offset_ = (read_offset_ + bytes_to_read) % options_.capacity_num_bytes;
196 bytes_available_ -= bytes_to_read;
199 NotifyRead(bytes_to_read);
228 uint32_t bytes_to_read = std::min(bytes_available_, local
237 *buffer_num_bytes = bytes_to_read;
[all...] |
| /external/autotest/client/cros/i2c/ |
| usb_to_i2c.py | 80 def read(self, slave_addr, bytes_to_read):
84 @param bytes_to_read: The number of bytes to read from device.
160 def read(self, slave_addr, bytes_to_read):
163 bytes_to_read,
|
