| /external/tensorflow/tensorflow/core/lib/io/ |
| D | record_reader.cc | 60 input_stream_(new RandomAccessInputStream(file)), in RecordReader()
63 input_stream_.reset(new BufferedInputStream(input_stream_.release(), in RecordReader()
72 input_stream_.reset(new ZlibInputStream( in RecordReader()
73 input_stream_.release(), options.zlib_options.input_buffer_size, in RecordReader()
77 input_stream_.reset( in RecordReader()
78 new SnappyInputStream(input_stream_.release(), in RecordReader()
99 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(expected, result)); in ReadChecksummed()
125 TF_RETURN_IF_ERROR(input_stream_->Reset()); in GetMetadata()
151 TF_RETURN_IF_ERROR(input_stream_->SkipNBytes(length + kFooterSize)); in GetMetadata()
171 int64_t curr_pos = input_stream_->Tell(); in PositionInputStream()
[all …]
|
| D | buffered_inputstream.cc | 26 : input_stream_(input_stream), in BufferedInputStream()
39 delete input_stream_; in ~BufferedInputStream()
49 Status s = input_stream_->ReadNBytes(size_, &buf_); in FillBuffer()
146 Status s = input_stream_->SkipNBytes(bytes_to_skip - (limit_ - pos_)); in SkipNBytes()
158 return input_stream_->Tell() - (limit_ - pos_); in Tell()
168 const int64_t buf_lower_limit = input_stream_->Tell() - limit_; in Seek()
209 TF_RETURN_IF_ERROR(input_stream_->Reset()); in Reset()
|
| D | zlib_inputstream.cc | 61 input_stream_(input_stream), in ZlibInputStream()
83 delete input_stream_; in ~ZlibInputStream()
91 TF_RETURN_IF_ERROR(input_stream_->Reset()); in Reset()
146 Status s = input_stream_->ReadNBytes(bytes_to_read, &data); in ReadFromStream()
|
| D | zlib_inputstream.h | 83 InputStreamInterface* input_stream_; variable
|
| D | buffered_inputstream.h | 101 InputStreamInterface* input_stream_; // not owned. variable
|
| D | record_reader.h | 123 std::unique_ptr<InputStreamInterface> input_stream_; variable
|
| /external/tink/cc/streamingaead/ |
| D | shared_input_stream.h | 36 : input_stream_(input_stream) {} in SharedInputStream()
41 return input_stream_->Next(data); in Next()
45 input_stream_->BackUp(count); in BackUp()
49 return input_stream_->Position(); in Position()
53 crypto::tink::InputStream* input_stream_;
|
| D | buffered_input_stream.cc | 41 input_stream_ = std::move(input_stream); in BufferedInputStream()
54 if (direct_access_) return input_stream_->Next(data); in Next()
80 return input_stream_->Next(data); in Next()
87 auto next_result = input_stream_->Next(&buf); in Next()
107 input_stream_->BackUp(count); in BackUp()
142 if (direct_access_) return input_stream_->Position(); in Position()
|
| D | buffered_input_stream.h | 57 std::unique_ptr<crypto::tink::InputStream> input_stream_;
|
| /external/cronet/tot/net/tools/content_decoder_tool/ |
| D | content_decoder_tool.cc | 34 : SourceStream(SourceStream::TYPE_NONE), input_stream_(input_stream) {} in StdinSourceStream()
45 if (input_stream_->eof()) in Read()
47 if (input_stream_) { in Read()
48 input_stream_->read(dest_buffer->data(), buffer_size); in Read()
49 int bytes = input_stream_->gcount(); in Read()
60 std::istream* input_stream_; member in net::__anon14a0409a0111::StdinSourceStream
|
| /external/cronet/stable/net/tools/content_decoder_tool/ |
| D | content_decoder_tool.cc | 34 : SourceStream(SourceStream::TYPE_NONE), input_stream_(input_stream) {} in StdinSourceStream()
45 if (input_stream_->eof()) in Read()
47 if (input_stream_) { in Read()
48 input_stream_->read(dest_buffer->data(), buffer_size); in Read()
49 int bytes = input_stream_->gcount(); in Read()
60 std::istream* input_stream_; member in net::__anonc2042afe0111::StdinSourceStream
|
| /external/tensorflow/tensorflow/core/lib/io/snappy/ |
| D | snappy_inputstream.cc | 28 : input_stream_(input_stream), in SnappyInputStream()
42 delete input_stream_; in ~SnappyInputStream()
88 input_stream_->ReadNBytes(sizeof(uint32), &compressed_block_length_ts)); in Inflate()
99 input_stream_->ReadNBytes(compressed_block_length, &compressed_block); in Inflate()
147 TF_RETURN_IF_ERROR(input_stream_->Reset()); in Reset()
|
| D | snappy_inputstream.h | 65 InputStreamInterface* input_stream_; variable
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | text_line_dataset_op.cc | 196 input_stream_ = in SetupStreamsLocked()
201 input_stream_.get(), dataset()->options_.input_buffer_size, in SetupStreamsLocked()
208 input_stream_.get(), dataset()->options_.input_buffer_size, false); in SetupStreamsLocked()
215 input_stream_.reset(); in ResetStreamsLocked()
222 std::unique_ptr<io::RandomAccessInputStream> input_stream_
|
| /external/tensorflow/tensorflow/core/data/ |
| D | snapshot_utils.cc | 755 input_stream_ = std::make_unique<io::RandomAccessInputStream>(file_.get()); in Initialize()
767 input_stream_ = std::make_unique<io::ZlibInputStream>( in Initialize()
768 input_stream_.release(), zlib_options.input_buffer_size, in Initialize()
772 input_stream_ = std::make_unique<io::SnappyInputBuffer>( in Initialize()
776 input_stream_ = in Initialize()
922 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(kHeaderSize, &header)); in ReadRecord()
924 return input_stream_->ReadNBytes(length, record); in ReadRecord()
930 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(kHeaderSize, &header)); in ReadRecord()
933 return input_stream_->ReadNBytes(length, record); in ReadRecord()
936 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(length, tmp_str)); in ReadRecord()
|
| D | snapshot_utils.h | 305 std::unique_ptr<io::InputStreamInterface> input_stream_; variable
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | csv_dataset_op.cc | 295 if (input_stream_) { in GetNextInternal()
343 if (input_stream_ && num_buffer_reads_ > 0) { in SaveInternal()
373 Status s = input_stream_->SkipNBytes( in RestoreInternal()
699 Status s = input_stream_->ReadNBytes( in FillBuffer()
870 input_stream_ = std::make_shared<io::ZlibInputStream>( in SetupStreamsLocked()
875 input_stream_ = random_access_input_stream_; in SetupStreamsLocked()
897 input_stream_.reset(); in ResetStreamsLocked()
908 std::shared_ptr<io::InputStreamInterface> input_stream_
|
| /external/vixl/src/aarch64/ |
| D | debugger-aarch64.h | 202 void SetInputStream(std::istream* stream) { input_stream_ = stream; } in SetInputStream()
260 std::istream* input_stream_; variable
|
| D | debugger-aarch64.cc | 42 : sim_(sim), input_stream_(&std::cin), ostream_(sim->GetOutputStream()) { in Debugger()
99 std::getline(*input_stream_, line); in Debug()
109 if (input_stream_ != &std::cin) { in Debug()
|