/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/include/ |
H A D | idaudio_hdi_callback.h | 29 virtual int32_t CreateStream(const int32_t streamId) = 0; 31 virtual int32_t DestroyStream(const int32_t streamId) = 0; 33 virtual int32_t SetParameters(const int32_t streamId, const AudioParamHDF ¶m) = 0; 35 virtual int32_t NotifyEvent(const int32_t streamId, const AudioEvent &event) = 0; 37 virtual int32_t WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) = 0; 39 virtual int32_t ReadStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) = 0; 41 virtual int32_t ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) = 0; 43 virtual int32_t RefreshAshmemInfo(const int32_t streamId,
|
H A D | daudio_manager_callback.h | 31 int32_t CreateStream(int32_t streamId) override; 33 int32_t DestroyStream(int32_t streamId) override; 35 int32_t SetParameters(int32_t streamId, 38 int32_t NotifyEvent(int32_t streamId, 41 int32_t WriteStreamData(int32_t streamId, 44 int32_t ReadStreamData(int32_t streamId, 47 int32_t ReadMmapPosition(int32_t streamId, uint64_t &frames, 50 int32_t RefreshAshmemInfo(int32_t streamId, int fd, int32_t ashmemLength, int32_t lengthPerTrans) override;
|
/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/test/unittest/daudio_manager_callback/include/ |
H A D | audio_test_utils.h | 30 int32_t CreateStream(const int32_t streamId) override 35 int32_t DestroyStream(const int32_t streamId) override 40 int32_t SetParameters(const int32_t streamId, const AudioParamHDF ¶m) override 45 int32_t NotifyEvent(const int32_t streamId, const AudioEvent &event) override 50 int32_t WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override 55 int32_t ReadStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override 61 int32_t ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) in ReadMmapPosition() argument 66 int32_t RefreshAshmemInfo(const int32_t streamId, int32_t fd, int32_t ashmemLength, int32_t lengthPerTrans) in RefreshAshmemInfo() argument
|
/foundation/multimedia/audio_framework/services/audio_policy/server/src/service/session/ |
H A D | audio_session.cpp | 82 uint32_t streamId = interruptPair.first.sessionId; in AddAudioInterrpt() local 83 AUDIO_INFO_LOG("AddAudioInterrpt: streamId %{public}u", streamId); in AddAudioInterrpt() 86 if (interruptMap_.count(streamId) != 0) { in AddAudioInterrpt() 87 AUDIO_WARNING_LOG("The streamId has been added. The old interrupt will be coverd."); in AddAudioInterrpt() 89 interruptMap_[streamId] = interruptPair; in AddAudioInterrpt() 98 uint32_t streamId = interruptPair.first.sessionId; in RemoveAudioInterrpt() local 99 AUDIO_INFO_LOG("RemoveAudioInterrpt: streamId %{public}u", streamId); in RemoveAudioInterrpt() 102 if (interruptMap_.count(streamId) in RemoveAudioInterrpt() 113 RemoveAudioInterrptByStreamId(const uint32_t &streamId) RemoveAudioInterrptByStreamId() argument [all...] |
/foundation/multimedia/camera_lite/services/impl/include/ |
H A D | camera_device.h | 47 virtual int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) in SetFrameConfig() argument 51 virtual int32_t Start(uint32_t streamId) in Start() argument 68 int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) override; 69 int32_t Start(uint32_t streamId) override; 82 int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) override; 83 int32_t Start(uint32_t streamId) override; 92 int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) override; 93 int32_t Start(uint32_t streamId) override; 101 int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) override; 102 int32_t Start(uint32_t streamId) overrid [all...] |
/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/test/unittest/daudio_hdi_handler/include/ |
H A D | audio_test_utils.h | 46 int32_t NotifyEvent(const std::string &adpName, int32_t devId, int32_t streamId, 58 int32_t CreateStream(const int32_t streamId) override 63 int32_t DestroyStream(const int32_t streamId) override 68 int32_t SetParameters(const int32_t streamId, const AudioParamHDF ¶m) override 73 int32_t NotifyEvent(const int32_t streamId, const AudioEvent &event) override 78 int32_t WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override 83 int32_t ReadStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override 88 int32_t ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) in ReadMmapPosition() argument 93 int32_t RefreshAshmemInfo(const int32_t streamId, int32_t fd, int32_t ashmemLength, int32_t lengthPerTrans) in RefreshAshmemInfo() argument
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/ |
H A D | dcamera_stream_data_process.cpp | 50 for (auto streamId : streamIds_) { in FeedStream() 52 DHLOGD("FeedStream devId %{public}s dhId %{public}s streamId %{public}d streamType %{public}d streamSize: " in FeedStream() 53 "%{public}" PRIu64, GetAnonyString(devId_).c_str(), GetAnonyString(dhId_).c_str(), streamId, in FeedStream() 73 for (auto streamId : streamIds) { in ConfigStreams() 74 DHLOGI("ConfigStreams devId %{public}s dhId %{public}s streamId %{public}d, width: %{public}d, height: " in ConfigStreams() 76 GetAnonyString(devId_).c_str(), GetAnonyString(dhId_).c_str(), streamId, dstConfig->width_, in ConfigStreams() 85 for (auto streamId : streamIds) { in ReleaseStreams() 86 DHLOGI("ReleaseStreams devId %{public}s dhId %{public}s streamId %{public}d streamType %{public}d", in ReleaseStreams() 87 GetAnonyString(devId_).c_str(), GetAnonyString(dhId_).c_str(), streamId, streamType_); in ReleaseStreams() 91 int32_t streamId in ReleaseStreams() local 122 uint32_t streamId = *iter; StartCapture() local 152 uint32_t streamId = *iter; StopCapture() local [all...] |
/foundation/multimedia/av_codec/services/media_engine/modules/demuxer/ |
H A D | demuxer_plugin_manager.cpp | 136 curAudioStreamID_ = info.streamId;
in InitAudioTrack() 137 streamInfoMap_[info.streamId].activated = true;
in InitAudioTrack() 144 streamInfoMap_[info.streamId].mediaInfo.tracks.push_back(format);
in InitAudioTrack() 145 streamInfoMap_[info.streamId].mediaInfo.general.Set<Tag::MEDIA_HAS_AUDIO>(true);
in InitAudioTrack() 146 streamInfoMap_[info.streamId].mediaInfo.general.Set<Tag::MEDIA_TRACK_COUNT>(1);
in InitAudioTrack() 148 streamInfoMap_[info.streamId].type = AUDIO;
in InitAudioTrack() 154 curVideoStreamID_ = info.streamId; // 获取第一个视频流
in InitVideoTrack() 155 streamInfoMap_[info.streamId].activated = true;
in InitVideoTrack() 164 streamInfoMap_[info.streamId].mediaInfo.tracks.push_back(format);
in InitVideoTrack() 165 streamInfoMap_[info.streamId] in InitVideoTrack() 427 int32_t streamId = iter->second.streamID; CheckTrackIsActive() local 504 StartPlugin(int32_t streamId, std::shared_ptr<BaseStreamDemuxer> streamDemuxer) StartPlugin() argument 524 StopPlugin(int32_t streamId, std::shared_ptr<BaseStreamDemuxer> streamDemuxer) StopPlugin() argument [all...] |
H A D | base_stream_demuxer.cpp | 74 void BaseStreamDemuxer::SetDemuxerState(int32_t streamId, DemuxerState state)
in SetDemuxerState() argument 76 pluginStateMap_[streamId] = state;
in SetDemuxerState() 77 if ((IsDash() || streamId == 0) && state == DemuxerState::DEMUXER_STATE_PARSE_FRAME) {
in SetDemuxerState() 78 source_->SetDemuxerState(streamId);
in SetDemuxerState()
|
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/dash/ |
H A D | dash_media_downloader.h | 55 Status SelectStream(int32_t streamId) override; 64 void UpdateDownloadFinished(int streamId); 67 void SetDemuxerState(int32_t streamId) override; 77 void VideoSegmentDownloadFinished(int streamId); 81 bool CheckAutoSelectBitrate(int streamId); 90 bool DoPreparedSwitchBitrate(bool preActionSwitchBitrate, int &streamId); 91 bool DoPreparedSwitchAudio(bool preActionSwitchAduio, int &streamId); 92 bool DoPreparedSwitchSubtitle(bool preActionSwitchSubtitle, int &streamId); 93 bool DoPreparedAction(int &streamId); 97 std::shared_ptr<DashSegmentDownloader> GetSegmentDownloader(int32_t streamId); [all...] |
H A D | dash_media_downloader.cpp | 98 MEDIA_LOG_E("GetSegmentDownloader failed when Read, streamId " PUBLIC_LOG_D32, readDataInfo.streamId_); in Read() 103 MEDIA_LOG_D("Read:streamId " PUBLIC_LOG_D32 " readRet:" PUBLIC_LOG_D32, readDataInfo.streamId_, ret); in Read() 105 MEDIA_LOG_I("Read:streamId " PUBLIC_LOG_D32 " segment all finished end", readDataInfo.streamId_); in Read() 119 std::shared_ptr<DashSegmentDownloader> DashMediaDownloader::GetSegmentDownloader(int32_t streamId) in GetSegmentDownloader() argument 122 std::shared_ptr<DashStreamDescription> streamDescription = mpdDownloader_->GetStreamByStreamId(streamId); in GetSegmentDownloader() 124 MEDIA_LOG_E("stream " PUBLIC_LOG_D32 " not exist", streamId); in GetSegmentDownloader() 144 void DashMediaDownloader::UpdateDownloadFinished(int streamId) in UpdateDownloadFinished() argument 146 MEDIA_LOG_I("UpdateDownloadFinished: " PUBLIC_LOG_D32, streamId); in UpdateDownloadFinished() 147 std::shared_ptr<DashStreamDescription> streamDesc = mpdDownloader_->GetStreamByStreamId(streamId); in UpdateDownloadFinished() 149 MEDIA_LOG_E("UpdateDownloadFinished get stream null id: " PUBLIC_LOG_D32, streamId); in UpdateDownloadFinished() 276 SelectStream(int32_t streamId) SelectStream() argument 418 int streamId = -1; ReceiveMpdParseOkEvent() local 439 VideoSegmentDownloadFinished(int streamId) VideoSegmentDownloadFinished() argument 583 CheckAutoSelectBitrate(int streamId) CheckAutoSelectBitrate() argument 674 int streamId = bitrateParam_.streamId_; IsSeekingInSwitch() local 688 int streamId = trackParam_.streamId_; IsSeekingInSwitch() local 838 DoPreparedSwitchBitrate(bool preActionSwitchBitrate, int &streamId) DoPreparedSwitchBitrate() argument 873 DoPreparedSwitchAudio(bool preActionSwitchAduio, int &streamId) DoPreparedSwitchAudio() argument 897 DoPreparedSwitchSubtitle(bool preActionSwitchSubtitle, int &streamId) DoPreparedSwitchSubtitle() argument 921 DoPreparedAction(int &streamId) DoPreparedAction() argument 1028 SetDemuxerState(int32_t streamId) SetDemuxerState() argument [all...] |
/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/src/ |
H A D | daudio_manager_callback.cpp | 35 int32_t DAudioManagerCallback::CreateStream(int32_t streamId /* for multistream */) in CreateStream() 39 if (callback_->CreateStream(streamId) != DH_SUCCESS) { in CreateStream() 46 int32_t DAudioManagerCallback::DestroyStream(int32_t streamId) in DestroyStream() argument 50 if (callback_->DestroyStream(streamId) != DH_SUCCESS) { in DestroyStream() 106 int32_t DAudioManagerCallback::SetParameters(int32_t streamId, const AudioParameter& param) in SetParameters() argument 116 ret = callback_->SetParameters(streamId, paramHDF); in SetParameters() 124 int32_t DAudioManagerCallback::NotifyEvent(int32_t streamId, in NotifyEvent() argument 163 int32_t ret = callback_->NotifyEvent(streamId, newEvent); in NotifyEvent() 171 int32_t DAudioManagerCallback::WriteStreamData(int32_t streamId, in WriteStreamData() argument 188 if (callback_->WriteStreamData(streamId, audioDat in WriteStreamData() 195 ReadStreamData(int32_t streamId, OHOS::HDI::DistributedAudio::Audioext::V2_0::AudioData &data) ReadStreamData() argument 212 ReadMmapPosition(int32_t streamId, uint64_t &frames, OHOS::HDI::DistributedAudio::Audioext::V2_0::CurrentTime &time) ReadMmapPosition() argument 228 RefreshAshmemInfo(int32_t streamId, int fd, int32_t ashmemLength, int32_t lengthPerTrans) RefreshAshmemInfo() argument [all...] |
/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/include/ |
H A D | dspeaker_dev.h | 54 int32_t CreateStream(const int32_t streamId) override; 55 int32_t DestroyStream(const int32_t streamId) override; 56 int32_t SetParameters(const int32_t streamId, const AudioParamHDF ¶m) override; 57 int32_t WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override; 58 int32_t ReadStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override; 59 int32_t NotifyEvent(const int32_t streamId, const AudioEvent &event) override; 60 int32_t ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) override; 61 int32_t RefreshAshmemInfo(const int32_t streamId,
|
H A D | dmic_dev.h | 59 int32_t CreateStream(const int32_t streamId) override; 60 int32_t DestroyStream(const int32_t streamId) override; 61 int32_t SetParameters(const int32_t streamId, const AudioParamHDF ¶m) override; 62 int32_t WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override; 63 int32_t ReadStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override; 64 int32_t NotifyEvent(const int32_t streamId, const AudioEvent &event) override; 65 int32_t ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) override; 66 int32_t RefreshAshmemInfo(const int32_t streamId,
|
/foundation/multimedia/media_utils_lite/hals/ |
H A D | hal_camera.h | 136 typedef void (*BufferAvailable)(uint32_t streamId, HalBuffer *halBuffer, uint32_t bufferNum);
224 int32_t HalCameraStreamCreate(uint32_t cameraId, const StreamAttr *stream, uint32_t *streamId);
225 int32_t HalCameraStreamDestroy(uint32_t cameraId, uint32_t streamId);
226 int32_t HalCameraGetDeviceId(uint32_t cameraId, uint32_t streamId, uint32_t *deviceId);
227 int32_t HalCameraStreamOn(uint32_t cameraId, uint32_t streamId);
228 int32_t HalCameraStreamOff(uint32_t cameraId, uint32_t streamId);
229 int32_t HalCameraDequeueBuf(uint32_t cameraId, uint32_t streamId, HalBuffer *buffer);
230 int32_t HalCameraQueueBuf(uint32_t cameraId, uint32_t streamId, const HalBuffer *buffer);
232 int32_t HalCameraStreamSetInfo(uint32_t cameraId, uint32_t streamId, const StreamInfo *info);
233 int32_t HalCameraStreamGetInfo(uint32_t cameraId, uint32_t streamId, StreamInf [all...] |
/foundation/multimedia/av_codec/test/unittest/dash_test/ |
H A D | dash_media_downloader_unit_test.cpp | 141 usingStreamId = stream.streamId; in HWTEST_F() 145 if (stream.streamId != usingStreamId) { in HWTEST_F() 171 switchingStreamId = stream.streamId; in HWTEST_F() 196 switchingStreamId = stream.streamId; in HWTEST_F() 240 usingStreamId = stream.streamId; in HWTEST_F() 244 if (stream.streamId != usingStreamId) { in HWTEST_F() 245 switchingStreamId = stream.streamId; in HWTEST_F() 286 usingAudioStreamId = stream.streamId; in HWTEST_F() 290 if (stream.streamId != usingAudioStreamId) { in HWTEST_F() 291 switchingAudioStreamId = stream.streamId; in HWTEST_F() [all...] |
/foundation/multimedia/camera_lite/services/impl/src/ |
H A D | camera_device.cpp | 432 int32_t RecordAssistant::SetFrameConfig(FrameConfig &fc, uint32_t *streamId) in SetFrameConfig() argument 450 ret = HalCameraStreamCreate(cameraId_, &stream, streamId); in SetFrameConfig() 456 streamId_ = *streamId; in SetFrameConfig() 457 streamIdNum_[num] = *streamId; in SetFrameConfig() 463 HalCameraStreamSetInfo(cameraId_, *streamId, &streamInfo); in SetFrameConfig() 466 HalCameraGetDeviceId(cameraId_, *streamId, &deviceId); in SetFrameConfig() 486 int32_t RecordAssistant::Start(uint32_t streamId) in Start() argument 491 HalCameraStreamOn(cameraId_, streamId); in Start() 544 int32_t PreviewAssistant::SetFrameConfig(FrameConfig &fc, uint32_t *streamId) in SetFrameConfig() argument 555 int32_t ret = HalCameraStreamCreate(cameraId_, &stream, streamId); in SetFrameConfig() 570 Start(uint32_t streamId) Start() argument 603 SetFrameConfig(FrameConfig &fc, uint32_t *streamId) SetFrameConfig() argument 642 Start(uint32_t streamId) Start() argument 712 SetFrameConfig(FrameConfig &fc, uint32_t *streamId) SetFrameConfig() argument 739 Start(uint32_t streamId) Start() argument 852 TriggerLoopingCapture(FrameConfig &fc, uint32_t *streamId) TriggerLoopingCapture() argument 933 TriggerSingleCapture(FrameConfig &fc, uint32_t *streamId) TriggerSingleCapture() argument [all...] |
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/ |
H A D | stream_common_data.cpp | 24 auto stream = std::make_unique<StreamCommonData>(info.streamId, info.seqNum, info); in MakeCommonStream() 30 StreamCommonData::StreamCommonData(uint32_t streamId, uint16_t seq, const StreamFrameInfo& frameInfo) in StreamCommonData() argument 33 curStreamId_ = streamId; in StreamCommonData()
|
/foundation/multimedia/camera_lite/frameworks/passthrough/src/ |
H A D | camera_device_client.cpp | 70 uint32_t streamId = 0; in TriggerLoopingCapture() local 71 return device_->TriggerLoopingCapture(fc, &streamId); in TriggerLoopingCapture() 81 uint32_t streamId = 0; in TriggerSingleCapture() local 82 int32_t ret = device_->TriggerSingleCapture(fc, &streamId); in TriggerSingleCapture()
|
/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/src/ |
H A D | dspeaker_dev.cpp | 109 int32_t DSpeakerDev::CreateStream(const int32_t streamId) in CreateStream() argument 111 DHLOGI("Open stream of speaker device, streamId: %{public}d.", streamId); in CreateStream() 129 streamId_ = streamId; in CreateStream() 135 int32_t DSpeakerDev::DestroyStream(const int32_t streamId) in DestroyStream() argument 137 DHLOGI("Close stream of speaker device streamId: %{public}d.", streamId); in DestroyStream() 161 int32_t DSpeakerDev::SetParameters(const int32_t streamId, const AudioParamHDF ¶m) in SetParameters() argument 181 int32_t DSpeakerDev::NotifyEvent(const int32_t streamId, const AudioEvent &event) in NotifyEvent() argument 290 int32_t DSpeakerDev::ReadStreamData(const int32_t streamId, st argument 298 WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) WriteStreamData() argument 319 ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) ReadMmapPosition() argument 330 RefreshAshmemInfo(const int32_t streamId, int32_t fd, int32_t ashmemLength, int32_t lengthPerTrans) RefreshAshmemInfo() argument [all...] |
/foundation/multimedia/player_framework/frameworks/native/system_sound_manager/system_tone_player/ |
H A D | system_tone_player_impl.cpp | 448 int32_t SystemTonePlayerImpl::Stop(const int32_t &streamId) in Stop() argument 450 MEDIA_LOGI("Enter Stop() with streamId %{public}d", streamId); in Stop() 455 if (playerMap_.count(streamId) == 0 || playerMap_[streamId] == nullptr) { in Stop() 456 MEDIA_LOGW("The stream has been stopped or the id %{public}d is invalid.", streamId); in Stop() 460 int32_t result = playerMap_[streamId]->Stop(); in Stop() 461 DeletePlayer(streamId); in Stop() 496 void SystemTonePlayerImpl::DeletePlayer(const int32_t &streamId) in DeletePlayer() argument 498 MEDIA_LOGI("DeletePlayer for streamId in DeletePlayer() 524 NotifyEndofStreamEvent(const int32_t &streamId) NotifyEndofStreamEvent() argument 531 NotifyInterruptEvent(const int32_t &streamId, const AudioStandard::InterruptEvent &interruptEvent) NotifyInterruptEvent() argument 538 SystemTonePlayerCallback(int32_t streamId, std::shared_ptr<SystemTonePlayerImpl> systemTonePlayerImpl) SystemTonePlayerCallback() argument [all...] |
/foundation/multimedia/camera_framework/services/camera_service/binder/server/src/ |
H A D | hstream_metadata_callback_stub.cpp | 44 int32_t streamId = data.ReadInt32(); in HandleMetadataResult() local 47 return OnMetadataResult(streamId, metadata); in HandleMetadataResult()
|
/foundation/multimedia/camera_framework/services/camera_service/binder/client/src/ |
H A D | hstream_metadata_callback_proxy.cpp | 26 int32_t HStreamMetadataCallbackProxy::OnMetadataResult(const int32_t streamId, in OnMetadataResult() argument 35 data.WriteInt32(streamId); in OnMetadataResult()
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/test/unittest/common/distributedcameramgr/ |
H A D | dcamera_source_dev_test.cpp | 233 int streamId = 1; in HWTEST_F() local 234 streamIds.push_back(streamId); in HWTEST_F() 285 int streamId = 1; in HWTEST_F() local 286 captureInfo->streamIds_.push_back(streamId); in HWTEST_F() 298 streamIds.push_back(streamId); in HWTEST_F() 313 int streamId = 1; in HWTEST_F() local 314 captureInfo->streamIds_.push_back(streamId); in HWTEST_F() 332 streamIds.push_back(streamId); in HWTEST_F() 488 int32_t streamId = 1; in HWTEST_F() local 489 streamIds.push_back(streamId); in HWTEST_F() 584 int32_t streamId = 1; HWTEST_F() local 603 int streamId = 1; HWTEST_F() local [all...] |
/foundation/multimedia/av_codec/services/media_engine/plugins/source/ |
H A D | file_fd_source_plugin.h | 45 Status Read(int32_t streamId, std::shared_ptr<Buffer>& buffer, uint64_t offset, size_t expectedLen) override; 51 void SetDemuxerState(int32_t streamId) 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);
|