Home
last modified time | relevance | path

Searched refs:ReadNBytes (Results 1 – 25 of 26) sorted by relevance

12

/external/tensorflow/tensorflow/core/lib/io/
Drandom_inputstream_test.cc26 TEST(RandomInputStream, ReadNBytes) { in TEST() argument
35 TF_ASSERT_OK(in.ReadNBytes(3, &read)); in TEST()
38 TF_ASSERT_OK(in.ReadNBytes(0, &read)); in TEST()
41 TF_ASSERT_OK(in.ReadNBytes(5, &read)); in TEST()
44 TF_ASSERT_OK(in.ReadNBytes(0, &read)); in TEST()
47 EXPECT_TRUE(errors::IsOutOfRange(in.ReadNBytes(20, &read))); in TEST()
50 TF_ASSERT_OK(in.ReadNBytes(0, &read)); in TEST()
66 TF_ASSERT_OK(in.ReadNBytes(0, &read)); in TEST()
69 TF_ASSERT_OK(in.ReadNBytes(4, &read)); in TEST()
74 TF_ASSERT_OK(in.ReadNBytes(2, &read)); in TEST()
[all …]
Dinputbuffer_test.cc151 TEST(InputBuffer, ReadNBytes) { in TEST() argument
163 TF_CHECK_OK(in.ReadNBytes(3, &read)); in TEST()
166 TF_CHECK_OK(in.ReadNBytes(0, &read)); in TEST()
169 TF_CHECK_OK(in.ReadNBytes(4, &read)); in TEST()
172 TF_CHECK_OK(in.ReadNBytes(0, &read)); in TEST()
175 EXPECT_TRUE(errors::IsOutOfRange(in.ReadNBytes(5, &read))); in TEST()
178 EXPECT_TRUE(errors::IsOutOfRange(in.ReadNBytes(5, &read))); in TEST()
181 TF_CHECK_OK(in.ReadNBytes(0, &read)); in TEST()
194 TF_ASSERT_OK(in.ReadNBytes(3, read, &bytes_read)); in TEST()
198 TF_ASSERT_OK(in.ReadNBytes(0, read, &bytes_read)); in TEST()
[all …]
Dbuffered_inputstream_test.cc156 TEST(BufferedInputStream, ReadNBytes) { in TEST() argument
169 TF_ASSERT_OK(in.ReadNBytes(3, &read)); in TEST()
172 TF_ASSERT_OK(in.ReadNBytes(0, &read)); in TEST()
175 TF_ASSERT_OK(in.ReadNBytes(4, &read)); in TEST()
178 TF_ASSERT_OK(in.ReadNBytes(0, &read)); in TEST()
181 EXPECT_TRUE(errors::IsOutOfRange(in.ReadNBytes(5, &read))); in TEST()
184 EXPECT_TRUE(errors::IsOutOfRange(in.ReadNBytes(5, &read))); in TEST()
187 TF_ASSERT_OK(in.ReadNBytes(0, &read)); in TEST()
210 TF_ASSERT_OK(in.ReadNBytes(2, &read)); in TEST()
217 TF_ASSERT_OK(in.ReadNBytes(1, &read)); in TEST()
[all …]
Dinputstream_interface_test.cc30 Status ReadNBytes(int64 bytes_to_read, string* result) override { in ReadNBytes() function in tensorflow::io::__anona6e301820111::TestStringStream
55 TF_ASSERT_OK(ss.ReadNBytes(4, &res)); in TEST()
58 TF_ASSERT_OK(ss.ReadNBytes(11, &res)); in TEST()
64 TF_ASSERT_OK(ss.ReadNBytes(4, &res)); in TEST()
Dzlib_buffers_test.cc89 TF_ASSERT_OK(in.ReadNBytes(data.size(), &result)); in TestAllCombinations()
146 TF_ASSERT_OK(in.ReadNBytes(data.size(), &decompressed_output)); in TestMultipleWrites()
190 Status read_status = in.ReadNBytes(data.size(), &result); in TEST()
237 TF_ASSERT_OK(in.ReadNBytes(first_half.size(), &bytes_read)); in TestTell()
245 in.ReadNBytes(data.size() - first_half.size(), &second_half)); in TestTell()
287 TF_ASSERT_OK(in.ReadNBytes(second_half.size(), &bytes_read)); in TestSkipNBytes()
Dinputbuffer.cc74 Status InputBuffer::ReadNBytes(int64 bytes_to_read, string* result) { in ReadNBytes() function in tensorflow::io::InputBuffer
82 Status status = ReadNBytes(bytes_to_read, &(*result)[0], &bytes_read); in ReadNBytes()
87 Status InputBuffer::ReadNBytes(int64 bytes_to_read, char* result, in ReadNBytes() function in tensorflow::io::InputBuffer
143 TF_RETURN_IF_ERROR(ReadNBytes(1, p, &unused_bytes_read)); in ReadVarintFallback()
Dinputbuffer.h53 Status ReadNBytes(int64 bytes_to_read, string* result);
58 Status ReadNBytes(int64 bytes_to_read, char* result, size_t* bytes_read);
Dbuffered_inputstream.cc49 Status s = input_stream_->ReadNBytes(size_, &buf_); in FillBuffer()
88 Status BufferedInputStream::ReadNBytes(int64 bytes_to_read, string* result) { in ReadNBytes() function in tensorflow::io::BufferedInputStream
Dinputstream_interface.h35 virtual Status ReadNBytes(int64 bytes_to_read, string* result) = 0;
Dzlib_inputstream.cc139 Status s = input_stream_->ReadNBytes(bytes_to_read, &data); in ReadFromStream()
189 Status ZlibInputStream::ReadNBytes(int64 bytes_to_read, string* result) { in ReadNBytes() function in tensorflow::io::ZlibInputStream
Dinputstream_interface.cc35 TF_RETURN_IF_ERROR(ReadNBytes(bytes_to_read, &unused)); in SkipNBytes()
Drandom_inputstream.h35 Status ReadNBytes(int64 bytes_to_read, string* result) override;
Dzlib_inputstream.h69 Status ReadNBytes(int64 bytes_to_read, string* result) override;
Dbuffered_inputstream.h44 Status ReadNBytes(int64 bytes_to_read, string* result) override;
Drandom_inputstream.cc32 Status RandomAccessInputStream::ReadNBytes(int64 bytes_to_read, in ReadNBytes() function in tensorflow::io::RandomAccessInputStream
Drecord_reader.cc93 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(expected, result)); in ReadChecksummed()
/external/tensorflow/tensorflow/contrib/hadoop/kernels/
Dhadoop_dataset_ops.cc35 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(4, &version)); in ReadHeader()
54 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(2, &buffer)); in ReadHeader()
82 input_stream_->ReadNBytes(kSyncMarkerSize, &sync_marker_)); in ReadHeader()
94 input_stream_->ReadNBytes(kSyncMarkerSize, &sync_marker)); in ReadRecord()
123 return input_stream_->ReadNBytes(length, value); in ReadString()
128 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(4, &buffer)); in ReadUInt32()
138 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(1, &buffer)); in ReadVInt()
153 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(remaining, &buffer)); in ReadVInt()
/external/tensorflow/tensorflow/core/kernels/
Ddecode_compressed_op.cc37 Status ReadNBytes(int64 bytes_to_read, string* result) override { in ReadNBytes() function in tensorflow::__anonae82e0830111::MemoryInputStream
110 Status s = zlib_stream->ReadNBytes(INT_MAX, &output_string); in Compute()
Dfixed_length_record_reader_op.cc108 Status s = buffered_inputstream_->ReadNBytes(bytes_to_read, value); in ReadLocked()
/external/tensorflow/tensorflow/core/lib/io/snappy/
Dsnappy_inputbuffer.h57 Status ReadNBytes(int64 bytes_to_read, string* result) override;
Dsnappy_inputbuffer.cc32 Status SnappyInputBuffer::ReadNBytes(int64 bytes_to_read, string* result) { in ReadNBytes() function in tensorflow::io::SnappyInputBuffer
Dsnappy_buffers_test.cc125 TF_RETURN_IF_ERROR(in.ReadNBytes(data.size(), &decompressed_output)); in TestMultipleWrites()
/external/tensorflow/tensorflow/core/kernels/data/
Dreader_dataset_ops.cc423 input_buffer_->ReadNBytes(dataset()->record_bytes_, &record)); in GetNextInternal()
546 TF_RETURN_IF_ERROR(buffered_input_stream_->ReadNBytes( in GetNextInternal()
560 Status s = buffered_input_stream_->ReadNBytes( in GetNextInternal()
647 TF_RETURN_IF_ERROR(buffered_input_stream_->ReadNBytes( in GetNextInternal()
703 TF_RETURN_IF_ERROR(buffered_input_stream_->ReadNBytes( in RestoreInternal()
/external/tensorflow/tensorflow/core/util/tensor_bundle/
Dtensor_bundle.cc101 TF_RETURN_IF_ERROR(buffered_file->ReadNBytes( in ReadStringTensor()
122 buffered_file->ReadNBytes(string_length, &(*buffer)[0], &bytes_read)); in ReadStringTensor()
153 buffered_file->ReadNBytes(string_length, &buffer[0], &bytes_read)); in ReadVariantTensor()
172 TF_RETURN_IF_ERROR(buffered_file->ReadNBytes( in ReadVariantTensor()
851 TF_RETURN_IF_ERROR(buffered_file->ReadNBytes(entry.size(), backing_buffer, in GetValue()
/external/tensorflow/tensorflow/python/lib/io/
Dfile_io.i237 tensorflow::Status status = stream->ReadNBytes(bytes, &result); in ReadFromStream()

12