Searched refs:input_stream_ (Results 1 – 11 of 11) sorted by relevance
| /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()
71 input_stream_.reset(new ZlibInputStream( in RecordReader()
72 input_stream_.release(), options.zlib_options.input_buffer_size, in RecordReader()
93 TF_RETURN_IF_ERROR(input_stream_->ReadNBytes(expected, result)); in ReadChecksummed()
119 TF_RETURN_IF_ERROR(input_stream_->Reset()); in GetMetadata()
145 TF_RETURN_IF_ERROR(input_stream_->SkipNBytes(length + kFooterSize)); in GetMetadata()
166 int64 curr_pos = input_stream_->Tell(); in ReadRecord()
171 TF_RETURN_IF_ERROR(input_stream_->Reset()); in ReadRecord()
172 TF_RETURN_IF_ERROR(input_stream_->SkipNBytes(desired_pos)); in ReadRecord()
[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()
138 Status s = input_stream_->SkipNBytes(bytes_to_skip - (limit_ - pos_)); in SkipNBytes()
150 return input_stream_->Tell() - (limit_ - pos_); in Tell()
190 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()
88 TF_RETURN_IF_ERROR(input_stream_->Reset()); in Reset()
139 Status s = input_stream_->ReadNBytes(bytes_to_read, &data); in ReadFromStream()
|
| D | zlib_inputstream.h | 79 InputStreamInterface* input_stream_; variable
|
| D | buffered_inputstream.h | 90 InputStreamInterface* input_stream_; // not owned. variable
|
| D | record_reader.h | 109 std::unique_ptr<InputStreamInterface> input_stream_; variable
|
| /external/tensorflow/tensorflow/contrib/hadoop/kernels/ |
| D | hadoop_dataset_ops.cc | 30 : input_stream_( in SequenceFileReader()
35 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()
98 "\" at pos ", input_stream_->Tell() - kSyncMarkerSize, in ReadRecord()
121 return input_stream_->SkipNBytes(length); in ReadString()
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()
[all …]
|
| /external/webrtc/webrtc/test/ |
| D | fake_audio_device.cc | 35 input_stream_(FileWrapper::Create()) { in FakeAudioDevice()
39 EXPECT_EQ(0, input_stream_->OpenFile(filename.c_str(), true, true)) in FakeAudioDevice()
51 if (file_utility_->InitPCMReading(*input_stream_.get()) != 0) in Init()
92 *input_stream_.get(), captured_audio_, kBufferSizeBytes); in CaptureAudio()
|
| D | fake_audio_device.h | 64 rtc::scoped_ptr<FileWrapper> input_stream_; variable
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | csv_dataset_op.cc | 230 if (input_stream_) { in GetNextInternal()
276 if (input_stream_ && num_buffer_reads_ > 0) { in SaveInternal()
306 Status s = input_stream_->SkipNBytes( in RestoreInternal()
625 Status s = input_stream_->ReadNBytes( in FillBuffer()
795 input_stream_ = std::make_shared<io::ZlibInputStream>( in SetupStreamsLocked()
800 input_stream_ = random_access_input_stream_; in SetupStreamsLocked()
822 input_stream_.reset(); in ResetStreamsLocked()
833 std::shared_ptr<io::InputStreamInterface> input_stream_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | reader_dataset_ops.cc | 229 input_stream_ = in SetupStreamsLocked()
234 input_stream_.get(), dataset()->options_.input_buffer_size, in SetupStreamsLocked()
241 input_stream_.get(), dataset()->options_.input_buffer_size, in SetupStreamsLocked()
249 input_stream_.reset(); in ResetStreamsLocked()
256 std::unique_ptr<io::RandomAccessInputStream> input_stream_
|