/foundation/multimedia/camera_framework/services/deferred_processing_service/src/schedule/video_processor/ |
H A D | deferred_video_processor.cpp | 48 void DeferredVideoProcessor::AddVideo(const std::string& videoId, in AddVideo() argument 51 DP_DEBUG_LOG("entered, videoId: %{public}s", videoId.c_str()); in AddVideo() 52 repository_->AddVideoJob(videoId, srcFd, dstFd); in AddVideo() 55 void DeferredVideoProcessor::RemoveVideo(const std::string& videoId, bool restorable) in RemoveVideo() argument 57 bool isNeedStop = repository_->RemoveVideoJob(videoId, restorable); in RemoveVideo() 58 DP_DEBUG_LOG("entered, videoId: %{public}s, isNeedStop: %{public}d, restorable: %{public}d", in RemoveVideo() 59 videoId.c_str(), isNeedStop, restorable); in RemoveVideo() 60 DP_CHECK_EXECUTE(isNeedStop, postProcessor_->PauseRequest(videoId, ScheduleType::REMOVE)); in RemoveVideo() 61 DP_CHECK_EXECUTE(!restorable, postProcessor_->RemoveRequest(videoId)); in RemoveVideo() 64 RestoreVideo(const std::string& videoId) RestoreVideo() argument 70 OnProcessDone(const int32_t userId, const std::string& videoId, const sptr<IPCFileDescriptor>& ipcFd) OnProcessDone() argument 79 OnError(const int32_t userId, const std::string& videoId, DpsError errorCode) OnError() argument 100 auto videoId = work->GetDeferredVideoJob()->GetVideoId(); PostProcess() local [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/schedule/video_processor/video_job_repository/ |
H A D | video_job_repository.cpp | 33 void VideoJobRepository::AddVideoJob(const std::string& videoId, in AddVideoJob() argument 37 DeferredVideoJobPtr jobPtrFind = GetJobUnLocked(videoId); in AddVideoJob() 38 DP_CHECK_RETURN_LOG(jobPtrFind != nullptr, "already existed, videoId: %{public}s", videoId.c_str()); in AddVideoJob() 40 DeferredVideoJobPtr jobPtr = std::make_shared<DeferredVideoJob>(videoId, srcFd, dstFd); in AddVideoJob() 42 jobMap_.emplace(videoId, jobPtr); in AddVideoJob() 44 DP_INFO_LOG("add video job size: %{public}d, videoId: %{public}s, srcFd: %{public}d", in AddVideoJob() 45 static_cast<int>(jobQueue_->GetSize()), videoId.c_str(), srcFd->GetFd()); in AddVideoJob() 48 bool VideoJobRepository::RemoveVideoJob(const std::string& videoId, bool restorable) in RemoveVideoJob() argument 50 DP_INFO_LOG("entered, videoId in RemoveVideoJob() 69 RestoreVideoJob(const std::string& videoId) RestoreVideoJob() argument 80 SetJobPending(const std::string& videoId) SetJobPending() argument 92 SetJobRunning(const std::string& videoId) SetJobRunning() argument 103 SetJobCompleted(const std::string& videoId) SetJobCompleted() argument 115 SetJobFailed(const std::string& videoId) SetJobFailed() argument 127 SetJobPause(const std::string& videoId) SetJobPause() argument 138 SetJobError(const std::string& videoId) SetJobError() argument 190 GetJobUnLocked(const std::string& videoId) GetJobUnLocked() argument [all...] |
/foundation/multimedia/media_library/frameworks/services/media_multistages_capture/src/deferred_processing/ |
H A D | multistages_capture_deferred_video_proc_session_callback.cpp | 39 int32_t MultiStagesCaptureDeferredVideoProcSessionCallback::UpdateVideoQuality(const std::string &videoId)
in UpdateVideoQuality() argument 45 updateCmd.GetAbsRdbPredicates()->EqualTo(PhotoColumn::PHOTO_ID, videoId);
in UpdateVideoQuality() 49 void MultiStagesCaptureDeferredVideoProcSessionCallback::OnProcessVideoDone(const std::string& videoId,
in OnProcessVideoDone() argument 52 if (videoId.empty()) {
in OnProcessVideoDone() 53 MEDIA_ERR_LOG("OnProcessVideoDone, videoId is empty");
in OnProcessVideoDone() 57 MEDIA_INFO_LOG("OnProcessVideoDone, videoId: %{public}s", videoId.c_str());
in OnProcessVideoDone() 61 vector<string> whereArgs { videoId };
in OnProcessVideoDone() 68 MultiStagesCaptureDfxTotalTime::GetInstance().RemoveStartTime(videoId);
in OnProcessVideoDone() 69 MultiStagesCaptureDfxResult::Report(videoId, static_cas in OnProcessVideoDone() 99 OnError(const std::string& videoId, const CameraStandard::DpsErrorCode errorCode) OnError() argument [all...] |
H A D | deferred_video_proc_adapter.cpp | 85 void DeferredVideoProcessingAdapter::AddVideo(const std::string &videoId, int srcFd, int dstFd)
in AddVideo() argument 87 MEDIA_INFO_LOG("DeferredVideoProcessingAdapter::AddVideo videoId: %{public}s", videoId.c_str());
in AddVideo() 104 deferredVideoProcSession_->AddVideo(videoId, src, dst);
in AddVideo() 108 void DeferredVideoProcessingAdapter::RemoveVideo(const std::string &videoId, const bool isRestorable)
in RemoveVideo() argument 110 MEDIA_INFO_LOG("DeferredVideoProcessingAdapter::RemoveVideo videoId: %{public}s", videoId.c_str());
in RemoveVideo() 116 deferredVideoProcSession_->RemoveVideo(videoId, isRestorable);
in RemoveVideo() 120 void DeferredVideoProcessingAdapter::RestoreVideo(const std::string &videoId)
in RestoreVideo() argument 122 MEDIA_INFO_LOG("DeferredVideoProcessingAdapter::RestoreVideo videoId in RestoreVideo() [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/post_processor/ |
H A D | video_post_processor.cpp | 84 int32_t OnProcessDone(const std::string& videoId) override; 85 int32_t OnError(const std::string& videoId, OHOS::HDI::Camera::V1_2::ErrorCode errorCode) override; 86 void ReportEvent(const std::string& videoId); 100 int32_t VideoPostProcessor::VideoProcessListener::OnProcessDone(const std::string& videoId) in OnProcessDone() argument 102 DP_INFO_LOG("entered, videoId: %{public}s", videoId.c_str()); in OnProcessDone() 105 process->OnProcessDone(videoId); in OnProcessDone() 109 int32_t VideoPostProcessor::VideoProcessListener::OnError(const std::string& videoId, in OnError() argument 112 DP_INFO_LOG("entered, videoId: %{public}s, error: %{public}d", videoId in OnError() 165 auto videoId = work->GetDeferredVideoJob()->GetVideoId(); ProcessRequest() local 185 RemoveRequest(const std::string& videoId) RemoveRequest() argument 197 PauseRequest(const std::string& videoId, const ScheduleType& type) PauseRequest() argument 207 PrepareStreams(const std::string& videoId, const int inputFd) PrepareStreams() argument 262 StartMpeg(const std::string& videoId, const sptr<IPCFileDescriptor>& inputFd) StartMpeg() argument 280 auto videoId = work->GetDeferredVideoJob()->GetVideoId(); StopMpeg() local 303 StartTimer(const std::string& videoId, const DeferredVideoWorkPtr& work) StartTimer() argument 311 StopTimer(const std::string& videoId) StopTimer() argument 328 GetRunningWork(const std::string& videoId) GetRunningWork() argument 352 OnProcessDone(const std::string& videoId) OnProcessDone() argument 365 OnError(const std::string& videoId, DpsError errorCode) OnError() argument 390 OnTimerOut(const std::string& videoId) OnTimerOut() argument [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/dfx/ |
H A D | dps_video_report.cpp | 37 void DfxVideoReport::ReportAddVideoEvent(const std::string &videoId, DpsCallerInfo callerInfo) in ReportAddVideoEvent() argument 41 .videoId = videoId, in ReportAddVideoEvent() 48 if (!processVideoInfo_.Find(videoId, videoRecordFound)) { in ReportAddVideoEvent() 49 processVideoInfo_.Insert(videoId, videoRecord); in ReportAddVideoEvent() 59 EVENT_KEY_VIDEOID, videoId); in ReportAddVideoEvent() 62 void DfxVideoReport::ReportRemoveVideoEvent(const std::string &videoId, DpsCallerInfo callerInfo) in ReportRemoveVideoEvent() argument 66 if (processVideoInfo_.Find(videoId, videoRecordFound)) { in ReportRemoveVideoEvent() 67 processVideoInfo_.Erase(videoId); in ReportRemoveVideoEvent() 75 EVENT_KEY_VIDEOID, videoId); in ReportRemoveVideoEvent() 78 ReportPauseVideoEvent(const std::string& videoId, int32_t pauseReason) ReportPauseVideoEvent() argument 105 ReportResumeVideoEvent(const std::string &videoId) ReportResumeVideoEvent() argument 139 ReportCompleteVideoEvent(const std::string &videoId) ReportCompleteVideoEvent() argument [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/schedule/video_processor/video_job_repository/ |
H A D | video_job_repository.h | 33 void AddVideoJob(const std::string& videoId, const sptr<IPCFileDescriptor>& srcFd, 35 bool RemoveVideoJob(const std::string& videoId, bool restorable); 36 void RestoreVideoJob(const std::string& videoId); 37 void SetJobPending(const std::string& videoId); 38 void SetJobRunning(const std::string& videoId); 39 void SetJobCompleted(const std::string& videoId); 40 void SetJobFailed(const std::string& videoId); 41 void SetJobPause(const std::string& videoId); 42 void SetJobError(const std::string& videoId); 52 DeferredVideoJobPtr GetJobUnLocked(const std::string& videoId); [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/session/video_session/ |
H A D | deferred_video_processing_session.cpp | 59 int32_t DeferredVideoProcessingSession::AddVideo(const std::string& videoId, in AddVideo() argument 68 videoIds_.emplace(videoId, info); in AddVideo() 72 auto ret = DPS_SendCommand<AddVideoCommand>(userId_, videoId, infd, outFd); in AddVideo() 73 DP_CHECK_ERROR_PRINT_LOG(ret != DP_OK, "add videoId: %{public}s failed. ret: %{public}d", videoId.c_str(), ret); in AddVideo() 74 DfxVideoReport::GetInstance().ReportAddVideoEvent(videoId, GetDpsCallerInfo()); in AddVideo() 78 int32_t DeferredVideoProcessingSession::RemoveVideo(const std::string& videoId, bool restorable) in RemoveVideo() argument 82 auto ret = DPS_SendCommand<RemoveVideoCommand>(userId_, videoId, restorable); in RemoveVideo() 83 DP_CHECK_ERROR_PRINT_LOG(ret != DP_OK, "remove videoId: %{public}s failed. ret: %{public}d", videoId in RemoveVideo() 89 RestoreVideo(const std::string& videoId) RestoreVideo() argument [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/post_processor/ |
H A D | video_post_processor.h | 45 void RemoveRequest(const std::string& videoId); 46 void PauseRequest(const std::string& videoId, const ScheduleType& type); 58 bool PrepareStreams(const std::string& videoId, const int inputFd); 61 bool StartMpeg(const std::string& videoId, const sptr<IPCFileDescriptor>& inputFd); 64 void StartTimer(const std::string& videoId, const DeferredVideoWorkPtr& work); 65 void StopTimer(const std::string& videoId); 66 void OnTimerOut(const std::string& videoId); 69 void OnProcessDone(const std::string& videoId); 70 void OnError(const std::string& videoId, DpsError errorCode); 72 DeferredVideoWorkPtr GetRunningWork(const std::string& videoId); [all...] |
/foundation/multimedia/media_library/frameworks/services/media_multistages_capture/src/ |
H A D | multistages_video_capture_manager.cpp | 51 void MultiStagesVideoCaptureManager::AddVideoInternal(const std::string &videoId,
in AddVideoInternal() argument 88 deferredProcSession_->AddVideo(videoId, srcFd, dstFd);
in AddVideoInternal() 92 void MultiStagesVideoCaptureManager::AddVideo(const std::string &videoId,
in AddVideo() argument 95 if (videoId.empty()) {
in AddVideo() 96 MEDIA_ERR_LOG("videoId is empty");
in AddVideo() 114 values.PutString(MEDIA_DATA_DB_PHOTO_ID, videoId);
in AddVideo() 125 AddVideoInternal(videoId, filePath);
in AddVideo() 154 string videoId = GetStringVal(MEDIA_DATA_DB_PHOTO_ID, resultSet);
in SyncWithDeferredVideoProcSessionInternal() local 157 AddVideoInternal(videoId, filePath);
in SyncWithDeferredVideoProcSessionInternal() 160 RemoveVideo(videoId, tru in SyncWithDeferredVideoProcSessionInternal() 191 RemoveVideo(const std::string &videoId, const bool restorable) RemoveVideo() argument 221 RestoreVideo(const std::string &videoId) RestoreVideo() argument [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/dfx/ |
H A D | dps_video_report.h | 37 std::string videoId; member 53 void ReportAddVideoEvent(const std::string& videoId, DpsCallerInfo callerInfo); 54 void ReportRemoveVideoEvent(const std::string& videoId, DpsCallerInfo callerInfo); 55 void ReportPauseVideoEvent(const std::string& videoId, int32_t pauseReason); 56 void ReportResumeVideoEvent(const std::string& videoId); 57 void ReportCompleteVideoEvent(const std::string &videoId);
|
/foundation/multimedia/camera_framework/interfaces/inner_api/native/camera/include/deferred_proc_session/ |
H A D | deferred_video_proc_session.h | 37 virtual void OnProcessVideoDone(const std::string& videoId, const sptr<IPCFileDescriptor> ipcFd) = 0; 38 virtual void OnError(const std::string& videoId, const DpsErrorCode errorCode) = 0; 48 void AddVideo(const std::string& videoId, const sptr<IPCFileDescriptor> srcFd, 50 void RemoveVideo(const std::string& videoId, const bool restorable = false); 51 void RestoreVideo(const std::string& videoId); 81 ErrCode OnProcessVideoDone(const std::string& videoId, const sptr<IPCFileDescriptor>& ipcFileDescriptor) override; 82 ErrCode OnError(const std::string& videoId, int32_t errorCode) override;
|
/foundation/multimedia/camera_framework/frameworks/native/camera/src/deferred_proc_session/ |
H A D | deferred_video_proc_session.cpp | 25 int32_t DeferredVideoProcessingSessionCallback::OnProcessVideoDone(const std::string& videoId, in OnProcessVideoDone() argument 30 deferredVideoProcSession_->GetCallback()->OnProcessVideoDone(videoId, ipcFileDescriptor); in OnProcessVideoDone() 37 int32_t DeferredVideoProcessingSessionCallback::OnError(const std::string& videoId, in OnError() argument 42 deferredVideoProcSession_->GetCallback()->OnError(videoId, DpsErrorCode(errorCode)); in OnError() 99 void DeferredVideoProcSession::AddVideo(const std::string& videoId, const sptr<IPCFileDescriptor> srcFd, in AddVideo() argument 106 auto ret = remoteSession_->AddVideo(videoId, srcFd, dstFd); in AddVideo() 111 void DeferredVideoProcSession::RemoveVideo(const std::string& videoId, const bool restorable) in RemoveVideo() argument 117 auto ret = remoteSession_->RemoveVideo(videoId, restorable); in RemoveVideo() 122 void DeferredVideoProcSession::RestoreVideo(const std::string& videoId) in RestoreVideo() argument 128 auto ret = remoteSession_->RestoreVideo(videoId); in RestoreVideo() [all...] |
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_multistages_capture_test/src/ |
H A D | medialibrary_multistages_video_capture_test.cpp | 235 string videoId = "202408011800";
in HWTEST_F() local 240 instance.AddVideo(videoId, to_string(fileId), filePath);
in HWTEST_F() 262 string videoId = "202408021800";
in HWTEST_F() local 281 instance.AddVideo(videoId, "", filePath);
in HWTEST_F() 289 instance.AddVideo(videoId, to_string(fileId), "");
in HWTEST_F() 306 string videoId = "202408031800";
in HWTEST_F() local 311 instance.AddVideo(videoId, to_string(fileId), filePath);
in HWTEST_F() 326 string videoId = "202408051800";
in HWTEST_F() local 329 int32_t result = SetVideoId(fileId, videoId);
in HWTEST_F() 339 instance.RemoveVideo(videoId, tru in HWTEST_F() 355 string videoId = "202408061800"; HWTEST_F() local 393 string videoId = "202408071800"; HWTEST_F() local 427 string videoId = "202408081800"; HWTEST_F() local 464 string videoId = "202408091800"; HWTEST_F() local 498 string videoId = "202408101800"; HWTEST_F() local [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/binder/server/src/ |
H A D | deferred_video_processing_session_stub.cpp | 48 std::string videoId = Str16ToStr8(data.ReadString16()); in OnRemoteRequest() local 59 ErrCode errCode = AddVideo(videoId, srcFd, dstFd); in OnRemoteRequest() 66 std::string videoId = Str16ToStr8(data.ReadString16()); in OnRemoteRequest() local 68 ErrCode errCode = RemoveVideo(videoId, restorable); in OnRemoteRequest() 75 std::string videoId = Str16ToStr8(data.ReadString16()); in OnRemoteRequest() local 76 ErrCode errCode = RestoreVideo(videoId); in OnRemoteRequest()
|
H A D | deferred_video_processing_session_callback_stub.cpp | 34 std::string videoId = Str16ToStr8(data.ReadString16()); in OnRemoteRequest() local 36 ErrCode errCode = OnProcessVideoDone(videoId, fd); in OnRemoteRequest() 43 std::string videoId = Str16ToStr8(data.ReadString16()); in OnRemoteRequest() local 45 ErrCode errCode = OnError(videoId, errorCode); in OnRemoteRequest()
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/session/command/ |
H A D | video_command.cpp | 24 VideoCommand::VideoCommand(const int32_t userId, const std::string& videoId) in VideoCommand() argument 25 : userId_(userId), videoId_(videoId) in VideoCommand() 27 DP_DEBUG_LOG("entered. userId: %{public}d, videoId: %{public}s", userId_, videoId_.c_str()); in VideoCommand() 49 AddVideoCommand::AddVideoCommand(const int32_t userId, const std::string& videoId, in AddVideoCommand() argument 51 : VideoCommand(userId, videoId), srcFd_(srcFd), dstFd_(dstFd) in AddVideoCommand() 53 DP_DEBUG_LOG("AddVideoCommand, videoId: %{public}s, srcFd: %{public}d, dstFd: %{public}d", in AddVideoCommand() 67 RemoveVideoCommand::RemoveVideoCommand(const int32_t userId, const std::string& videoId, const bool restorable) in RemoveVideoCommand() argument 68 : VideoCommand(userId, videoId), restorable_(restorable) in RemoveVideoCommand() 70 DP_DEBUG_LOG("RemoveVideoCommand, videoId: %{public}s, restorable: %{public}d", videoId_.c_str(), restorable_); in RemoveVideoCommand()
|
H A D | sync_command.cpp | 74 for (auto& videoId : hdiVideoIds) { in Executing() 75 auto item = videoIds_.find(videoId); in Executing() 77 processor_->AddVideo(videoId, item->second->srcFd_, item->second->dstFd_); in Executing() 78 videoIds_.erase(videoId); in Executing() 80 processor_->RemoveVideo(videoId, false); in Executing()
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/schedule/video_processor/ |
H A D | deferred_video_processor.h | 33 void AddVideo(const std::string& videoId, const sptr<IPCFileDescriptor>& srcFd, 35 void RemoveVideo(const std::string& videoId, bool restorable); 36 void RestoreVideo(const std::string& videoId); 38 void OnProcessDone(const int32_t userId, const std::string& videoId, const sptr<IPCFileDescriptor>& ipcFd) override; 39 void OnError(const int32_t userId, const std::string& videoId, DpsError errorCode) override;
|
/foundation/multimedia/media_library/frameworks/services/media_multistages_capture/include/ |
H A D | multistages_video_capture_manager.h | 39 EXPORT void AddVideoInternal(const std::string &videoId, const std::string &filePath);
40 EXPORT void AddVideo(const std::string &videoId, const std::string &fileId, const std::string &filePath);
41 EXPORT void RemoveVideo(const std::string &videoId, const bool restorable);
42 EXPORT void RestoreVideo(const std::string &videoId);
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/binder/client/src/ |
H A D | deferred_video_processing_session_proxy.cpp | 76 const std::string& videoId, in AddVideo() 88 if (!data.WriteString16(Str8ToStr16(videoId))) { in AddVideo() 115 const std::string& videoId, in RemoveVideo() 126 if (!data.WriteString16(Str8ToStr16(videoId))) { in RemoveVideo() 150 const std::string& videoId) in RestoreVideo() 160 if (!data.WriteString16(Str8ToStr16(videoId))) { in RestoreVideo() 75 AddVideo( const std::string& videoId, const sptr<IPCFileDescriptor>& srcFd, const sptr<IPCFileDescriptor>& dstFd) AddVideo() argument 114 RemoveVideo( const std::string& videoId, bool restorable) RemoveVideo() argument 149 RestoreVideo( const std::string& videoId) RestoreVideo() argument
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/binder/base/include/ |
H A D | ideferred_video_processing_session.h | 38 const std::string& videoId, 43 const std::string& videoId, 47 const std::string& videoId) = 0;
|
/foundation/multimedia/media_library/frameworks/services/media_multistages_capture/include/deferred_processing/ |
H A D | deferred_video_proc_adapter.h | 40 void AddVideo(const std::string &videoId, int srcFd, int dstFd);
42 EXPORT virtual void RemoveVideo(const std::string &videoId, const bool isRestorable = true);
43 EXPORT void RestoreVideo(const std::string &videoId);
|
H A D | multistages_capture_deferred_video_proc_session_callback.h | 33 void OnProcessVideoDone(const std::string& videoId, const sptr<IPCFileDescriptor> ipcFd) override;
34 EXPORT void OnError(const std::string& videoId, const CameraStandard::DpsErrorCode errorCode) override;
38 EXPORT int32_t UpdateVideoQuality(const std::string &videoId);
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/binder/client/include/ |
H A D | deferred_video_processing_session_proxy.h | 42 const std::string& videoId, 47 const std::string& videoId, 51 const std::string& videoId) override;
|