Home
last modified time | relevance | path

Searched refs:expectedLen (Results 1 - 25 of 58) sorted by relevance

123

/foundation/multimedia/media_foundation/engine/plugin/plugins/source/file_source/
H A Dfile_fd_source_plugin.cpp85 Status FileFdSourcePlugin::Read(std::shared_ptr<Buffer>& buffer, size_t expectedLen) in Read() argument
92 bufData = buffer->AllocMemory(GetAllocator(), expectedLen); in Read()
96 expectedLen = std::min(static_cast<size_t>(size_ + offset_ - position_), expectedLen); in Read()
97 expectedLen = std::min(bufData->GetCapacity(), expectedLen); in Read()
98 MEDIA_LOG_DD("buffer position " PUBLIC_LOG_U64 ", expectedLen " PUBLIC_LOG_ZU, position_, expectedLen); in Read()
99 auto size = read(fd_, bufData->GetWritableAddr(expectedLen), expectedLen); in Read()
[all...]
H A Dfile_source_plugin.cpp149 Status FileSourcePlugin::Read(std::shared_ptr<Buffer>& buffer, size_t expectedLen) in Read() argument
163 bufData = buffer->AllocMemory(GetAllocator(), expectedLen); in Read()
167 expectedLen = std::min(static_cast<size_t>(fileSize_ - position_), expectedLen); in Read()
168 expectedLen = std::min(bufData->GetCapacity(), expectedLen); in Read()
170 MEDIA_LOG_DD("buffer position " PUBLIC_LOG_U64 ", expectedLen " PUBLIC_LOG_ZU, position_, expectedLen); in Read()
171 auto size = std::fread(bufData->GetWritableAddr(expectedLen), sizeof(char), expectedLen, fp in Read()
[all...]
H A Dfile_fd_source_plugin.h34 Status Read(std::shared_ptr<Buffer>& buffer, size_t expectedLen) override;
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/std_stream_source/
H A Dstd_stream_source_plugin.cpp161 Status StdStreamSourcePlugin::Read(std::shared_ptr<Buffer>& buffer, size_t expectedLen) in Read() argument
168 expectedLen = std::min(static_cast<size_t>(size_ - offset_), expectedLen); in Read()
169 expectedLen = std::min(static_cast<size_t>(memory->GetSize()), expectedLen); in Read()
170 realLen = dataSrc_->ReadAt(static_cast<int64_t>(offset_), expectedLen, memory); in Read()
172 expectedLen = std::min(static_cast<size_t>(memory->GetSize()), expectedLen); in Read()
173 realLen = dataSrc_->ReadAt(expectedLen, memory); in Read()
/foundation/multimedia/av_codec/services/media_engine/plugins/source/
H A Dfile_source_plugin.cpp159 Status FileSourcePlugin::Read(std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) in Read() argument
161 return Read(0, buffer, offset, expectedLen); in Read()
164 Status FileSourcePlugin::Read(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) in Read() argument
180 bufData = buffer->AllocMemory(GetAllocator(), expectedLen); in Read()
187 expectedLen = std::min(static_cast<size_t>(fileSize_ - position_), expectedLen); in Read()
188 expectedLen = std::min(bufData->GetCapacity(), expectedLen); in Read()
190 MEDIA_LOG_DD("buffer position " PUBLIC_LOG_U64 ", expectedLen " PUBLIC_LOG_ZU, position_, expectedLen); in Read()
[all...]
H A Dfile_fd_source_plugin.cpp156 Status FileFdSourcePlugin::Read(std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) in Read() argument
158 return Read(0, buffer, offset, expectedLen); in Read()
161 Status FileFdSourcePlugin::Read(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) in Read() argument
165 return ReadOnlineFile(0, buffer, offset, expectedLen); in Read()
167 return ReadOfflineFile(0, buffer, offset, expectedLen); in Read()
172 uint64_t offset, size_t expectedLen) in ReadOfflineFile()
174 std::shared_ptr<Memory> bufData = GetBufferPtr(buffer, expectedLen); in ReadOfflineFile()
176 expectedLen = std::min(static_cast<size_t>(GetLastSize(position_)), expectedLen); in ReadOfflineFile()
177 expectedLen in ReadOfflineFile()
171 ReadOfflineFile(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) ReadOfflineFile() argument
195 ReadOnlineFile(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) ReadOnlineFile() argument
642 GetBufferPtr(std::shared_ptr<Buffer>& buffer, size_t expectedLen) GetBufferPtr() argument
[all...]
H A Ddata_stream_source_plugin.cpp133 Status DataStreamSourcePlugin::Read(std::shared_ptr<Plugins::Buffer>& buffer, uint64_t offset, size_t expectedLen) in Read() argument
135 MEDIA_LOG_D("Read, offset: " PUBLIC_LOG_D64 ", expectedLen: " PUBLIC_LOG_ZU ", seekable: " PUBLIC_LOG_D32, in Read()
136 offset, expectedLen, seekable_); in Read()
143 expectedLen = std::min(static_cast<size_t>(size_ - offset_), expectedLen); in Read()
144 expectedLen = std::min(static_cast<size_t>(memory->GetSize()), expectedLen); in Read()
145 realLen = dataSrc_->ReadAt(static_cast<int64_t>(offset_), expectedLen, memory); in Read()
147 expectedLen = std::min(static_cast<size_t>(memory->GetSize()), expectedLen); in Read()
[all...]
H A Dfile_fd_source_plugin.h44 Status Read(std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) override;
45 Status Read(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) override;
63 Status ReadOfflineFile(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen);
64 Status ReadOnlineFile(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen);
70 std::shared_ptr<Memory> GetBufferPtr(std::shared_ptr<Buffer>& buffer, size_t expectedLen);
H A Dfile_source_plugin.h51 Status Read(std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) override;
52 Status Read(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) override;
/foundation/multimedia/av_codec/services/media_engine/modules/demuxer/
H A Dtype_finder.cpp134 Status TypeFinder::ReadAt(int64_t offset, std::shared_ptr<Buffer>& buffer, size_t expectedLen) in ReadAt() argument
136 if (!buffer || expectedLen == 0 || !IsOffsetValid(offset)) { in ReadAt()
137 MEDIA_LOG_E("Buffer empty: " PUBLIC_LOG_D32 ", expectedLen: " PUBLIC_LOG_ZU ", offset: " in ReadAt()
138 PUBLIC_LOG_D64, !buffer, expectedLen, offset); in ReadAt()
144 while ((checkRange_(streamID_, offset, expectedLen) != Status::OK) && (i < maxTryTimes)) { in ReadAt()
152 FALSE_LOG_MSG(peekRange_(streamID_, static_cast<uint64_t>(offset), expectedLen, buffer) == Status::OK, in ReadAt()
H A Dstream_demuxer.h53 size_t expectedLen) override;
64 Status HandleReadHeader(int32_t streamID, int64_t offset, std::shared_ptr<Buffer>& buffer, size_t expectedLen);
65 Status HandleReadPacket(int32_t streamID, int64_t offset, std::shared_ptr<Buffer>& buffer, size_t expectedLen);
H A Dstream_demuxer.cpp345 size_t expectedLen) in HandleReadHeader()
348 ", expectedLen: " PUBLIC_LOG_ZU, offset, expectedLen); in HandleReadHeader()
349 if (expectedLen == 0) { in HandleReadHeader()
352 Status ret = getRange_(streamID, static_cast<uint64_t>(offset), expectedLen, buffer); in HandleReadHeader()
386 size_t expectedLen) in HandleReadPacket()
389 Status ret = getRange_(streamID, static_cast<uint64_t>(offset), expectedLen, buffer); in HandleReadPacket()
408 size_t expectedLen) in CallbackReadAt()
415 auto ret = HandleReadHeader(streamID, offset, buffer, expectedLen); in CallbackReadAt()
423 auto ret = HandleReadPacket(streamID, offset, buffer, expectedLen); in CallbackReadAt()
344 HandleReadHeader(int32_t streamID, int64_t offset, std::shared_ptr<Buffer>& buffer, size_t expectedLen) HandleReadHeader() argument
385 HandleReadPacket(int32_t streamID, int64_t offset, std::shared_ptr<Buffer>& buffer, size_t expectedLen) HandleReadPacket() argument
407 CallbackReadAt(int32_t streamID, int64_t offset, std::shared_ptr<Buffer>& buffer, size_t expectedLen) CallbackReadAt() argument
[all...]
/foundation/multimedia/media_foundation/engine/pipeline/filters/demux/
H A Dtype_finder.cpp142 Plugin::Status TypeFinder::ReadAt(int64_t offset, std::shared_ptr<Plugin::Buffer>& buffer, size_t expectedLen) in ReadAt() argument
144 if (!buffer || expectedLen == 0 || !IsOffsetValid(offset)) { in ReadAt()
145 MEDIA_LOG_E("ReadAt failed, buffer empty: " PUBLIC_LOG_D32 ", expectedLen: " PUBLIC_LOG_ZU ", offset: " in ReadAt()
146 PUBLIC_LOG_D64, !buffer, expectedLen, offset); in ReadAt()
151 while (!checkRange_(offset, expectedLen) && (i++ < maxTryTimes)) { in ReadAt()
158 FALSE_LOG_MSG(peekRange_(static_cast<uint64_t>(offset), expectedLen, buffer), "peekRange failed."); in ReadAt()
/foundation/multimedia/media_foundation/engine/plugin/core/
H A Dsource.cpp31 Status Source::Read(std::shared_ptr<Buffer>& buffer, size_t expectedLen) in Read() argument
33 return source_->Read(buffer, expectedLen); in Read()
H A Dplugin_wrapper.h32 Status ReadAt(int64_t offset, std::shared_ptr<Buffer>& buffer, size_t expectedLen) override;
H A Dplugin_wrapper.cpp72 Status DataSourceWrapper::ReadAt(int64_t offset, std::shared_ptr<Buffer>& buffer, size_t expectedLen) in ReadAt() argument
74 return helper->ReadAt(offset, buffer, expectedLen); in ReadAt()
H A Ddemuxer.h33 virtual Status ReadAt(int64_t offset, std::shared_ptr<Buffer> &buffer, size_t expectedLen) = 0;
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_lite_source/
H A Dhttp_lite_source_plugin.cpp254 Status HttpSourcePlugin::Read(std::shared_ptr<Buffer> &buffer, size_t expectedLen) in Read() argument
269 bufData = buffer->AllocMemory(GetAllocator(), expectedLen); in Read()
281 MEDIA_LOG_D("read pos " PUBLIC_LOG_U32 " write pos " PUBLIC_LOG_U32 " expectedLen " PUBLIC_LOG_ZU, in Read()
282 read, write, expectedLen); in Read()
286 httpHandle_->HttpRead(bufData->GetWritableAddr(expectedLen), expectedLen, realReadSize, isEos); in Read()
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/
H A Dhttp_source_plugin.cpp251 Status HttpSourcePlugin::Read(std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) in Read() argument
253 return Read(0, buffer, offset, expectedLen); in Read()
256 Status HttpSourcePlugin::Read(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) in Read() argument
259 + std::to_string(offset) + ", expectedLen: " + std::to_string(expectedLen)); in Read()
271 bufData = buffer->AllocMemory(nullptr, expectedLen); in Read()
283 readDataInfo.wantReadLength_ = expectedLen; in Read()
286 auto result = downloader_->Read(bufData->GetWritableAddr(expectedLen), readDataInfo); in Read()
H A Dhttp_source_plugin.h43 Status Read(std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) override;
44 Status Read(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) override;
/foundation/multimedia/av_codec/interfaces/plugin/
H A Dsource_plugin.h93 * @param expectedLen Expected data size to be read
99 virtual Status Read(std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) = 0;
108 * @param expectedLen Expected data size to be read
114 virtual Status Read(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) in Read() argument
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/
H A Dhttp_source_plugin.cpp180 Status HttpSourcePlugin::Read(std::shared_ptr<Buffer>& buffer, size_t expectedLen) in Read() argument
192 bufData = buffer->AllocMemory(GetAllocator(), expectedLen); in Read()
199 bool result = downloader_->Read(bufData->GetWritableAddr(expectedLen), expectedLen, realReadSize, isEos); in Read()
/foundation/multimedia/media_foundation/test/unittest/plugins/
H A DUtSourceTest1.h34 Status Read(std::shared_ptr<Buffer> &buffer, size_t expectedLen) override;
H A DUtSourceTest2.h34 Status Read(std::shared_ptr<Buffer> &buffer, size_t expectedLen) override;
H A DUtSourceTest2.cpp49 Status UtSourceTest2::Read(std::shared_ptr<Buffer> &buffer, size_t expectedLen) in Read() argument

Completed in 12 milliseconds

123