| /external/tensorflow/tensorflow/core/lib/io/ |
| D | zlib_inputstream.cc | 55 ZlibInputStream::ZlibInputStream( in ZlibInputStream() function in tensorflow::io::ZlibInputStream
71 ZlibInputStream::ZlibInputStream(InputStreamInterface* input_stream, in ZlibInputStream() function in tensorflow::io::ZlibInputStream
75 : ZlibInputStream(input_stream, input_buffer_bytes, output_buffer_bytes, in ZlibInputStream()
78 ZlibInputStream::~ZlibInputStream() { in ~ZlibInputStream()
87 Status ZlibInputStream::Reset() { in Reset()
98 void ZlibInputStream::InitZlibBuffer() { in InitZlibBuffer()
123 Status ZlibInputStream::ReadFromStream() { in ReadFromStream()
175 size_t ZlibInputStream::ReadBytesFromCache(size_t bytes_to_read, in ReadBytesFromCache()
189 size_t ZlibInputStream::NumUnreadBytes() const { in NumUnreadBytes()
196 Status ZlibInputStream::ReadNBytes(int64 bytes_to_read, tstring* result) { in ReadNBytes()
[all …]
|
| D | zlib_buffers_test.cc | 90 ZlibInputStream in(input_stream.get(), input_buf_size, output_buf_size, in TestAllCombinations()
145 ZlibInputStream in(input_stream.get(), input_buf_size, output_buf_size, in TestMultipleWrites()
165 TEST(ZlibInputStream, FailsToReadIfWindowBitsAreIncompatible) { in TEST() argument
193 ZlibInputStream in(input_stream.get(), input_buf_size, output_buf_size, in TEST()
235 ZlibInputStream in(input_stream.get(), input_buf_size, output_buf_size, in TestTell()
280 ZlibInputStream in(input_stream.get(), input_buf_size, output_buf_size, in TestSkipNBytes()
321 ZlibInputStream in(input_stream.get(), 100, 100, input_options); in TestSoftErrorOnDecompress()
333 ZlibInputStream in(input_stream.get(), 100, 100, input_options); in TestSoftErrorOnDecompress()
339 TEST(ZlibInputStream, TellDefaultOptions) { in TEST() argument
343 TEST(ZlibInputStream, TellRawDeflate) { in TEST() argument
[all …]
|
| D | zlib_inputstream.h | 40 class ZlibInputStream : public InputStreamInterface {
48 ZlibInputStream(InputStreamInterface* input_stream, size_t input_buffer_bytes,
54 ZlibInputStream(InputStreamInterface* input_stream, size_t input_buffer_bytes,
58 ~ZlibInputStream();
135 TF_DISALLOW_COPY_AND_ASSIGN(ZlibInputStream);
|
| D | record_reader.cc | 72 input_stream_.reset(new ZlibInputStream( in RecordReader()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | decode_compressed_op.cc | 105 std::unique_ptr<io::ZlibInputStream> zlib_stream( in Compute()
106 new io::ZlibInputStream( in Compute()
|
| D | fixed_length_record_reader_op.cc | 62 buffered_inputstream_.reset(new io::ZlibInputStream( in OnWorkStartedLocked()
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | text_line_dataset_op.cc | 198 zlib_input_stream_ = absl::make_unique<io::ZlibInputStream>( in SetupStreamsLocked()
222 std::unique_ptr<io::ZlibInputStream> zlib_input_stream_ TF_GUARDED_BY(mu_);
|
| D | fixed_length_record_dataset_op.cc | 360 buffered_input_stream_ = absl::make_unique<io::ZlibInputStream>( in GetNextInternal()
422 buffered_input_stream_ = absl::make_unique<io::ZlibInputStream>( in RestoreInternal()
|
| /external/tensorflow/tensorflow/compiler/jit/tests/ |
| D | auto_clustering_test_helper.cc | 185 io::ZlibInputStream in(input_stream.get(), in RunAutoClusteringTestWithGzippedPbtxt()
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | csv_dataset_op.cc | 858 input_stream_ = std::make_shared<io::ZlibInputStream>( in SetupStreamsLocked()
|
| D | snapshot_util.cc | 673 input_stream_ = absl::make_unique<io::ZlibInputStream>( in Initialize()
|