| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/interface/src/ |
| H A D | collection.cpp | 25 Collection::Collection(const std::string &name, KvStoreExecutor *executor) : executor_(executor) in Collection()
36 executor_ = nullptr; in ~Collection()
43 int errCode = executor_->InsertData(name_, key, valSet); in InsertUntilSuccess()
47 errCode = executor_->InsertData(name_, key, valSet); in InsertUntilSuccess()
53 if (executor_ == nullptr) { in InsertDocument()
70 return executor_->InsertData(name_, key, valSet); in InsertDocument()
75 if (executor_ == nullptr) { in GetDocumentById()
78 return executor_->GetDataById(name_, key, document); in GetDocumentById()
83 if (executor_ == nullptr) { in DeleteDocument()
94 return executor_ in DeleteDocument()
[all...] |
| H A D | document_store.cpp | 32 DocumentStore::DocumentStore(KvStoreExecutor *executor) : executor_(executor) {} in DocumentStore()
36 delete executor_; in ~DocumentStore()
60 if (executor_ == nullptr) { in CreateCollection()
63 errCode = executor_->StartTransaction(); in CreateCollection()
70 errCode = executor_->CreateCollection(lowerCaseName, oriOptStr, ignoreExists); in CreateCollection()
78 executor_->Commit(); in CreateCollection()
80 executor_->Rollback(); in CreateCollection()
101 if (executor_ == nullptr) { in DropCollection()
104 errCode = executor_->StartTransaction(); in DropCollection()
109 errCode = executor_ in DropCollection()
[all...] |
| /foundation/multimedia/media_foundation/engine/scene/player/internal/ |
| H A D | playing_state.h | 40 ret = executor_.DoResume();
42 ret = executor_.DoPlay();
58 auto ret = executor_.DoSeek(info.hstTime, info.mode, true);
74 auto ret = executor_.DoOnComplete();
75 if (executor_.IsSingleLoop()) {
77 auto seekRes = executor_.DoSeek(0, Plugin::SeekMode::SEEK_PREVIOUS_SYNC, false);
|
| H A D | idle_state.h | 35 auto ret = executor_.DoSetSource(source);
42 return {executor_.DoReset(), Action::ACTION_BUTT};
|
| H A D | ready_state.h | 38 auto rtv = executor_.DoOnReady();
52 auto ret = executor_.DoSeek(info.hstTime, info.mode, true);
|
| H A D | eos_state.h | 32 auto ret = executor_.DoSeek(0, Plugin::SeekMode::SEEK_PREVIOUS_SYNC, false);
50 auto ret = executor_.DoPause();
|
| H A D | pause_state.h | 38 auto ret = executor_.DoPause();
54 auto ret = executor_.DoSeek(info.hstTime, info.mode, true);
|
| H A D | stopped_state.h | 29 return {executor_.DoStop(), Action::ACTION_BUTT};
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | generic_virtual_device.cpp | 33 executor_(nullptr) in GenericVirtualDevice()
70 if (executor_ != nullptr) { in ~GenericVirtualDevice()
71 RefObject::KillAndDecObjRef(executor_); in ~GenericVirtualDevice()
72 executor_ = nullptr; in ~GenericVirtualDevice()
117 executor_ = new (std::nothrow) RemoteExecutor(); in Initialize()
118 if (executor_ == nullptr) { in Initialize()
121 executor_->Initialize(syncInterface, communicateHandle_); in Initialize()
150 if (inMsg->GetMessageId() == REMOTE_EXECUTE_MESSAGE && executor_ != nullptr) { in MessageCallback()
151 RefObject::IncObjRef(executor_); in MessageCallback()
152 executor_ in MessageCallback()
[all...] |
| /foundation/multimedia/media_foundation/engine/scene/recorder/internal/ |
| H A D | recording_setting_state.h | 38 auto ret = executor_.DoSetVideoSource(param);
45 auto ret = executor_.DoSetAudioSource(param);
52 auto ret = executor_.DoConfigure(param);
59 auto ret = executor_.DoSetOutputFormat(param);
66 auto rtv = executor_.DoPrepare();
81 auto ret = executor_.DoStop(param);
|
| H A D | recording_state.h | 40 ret = executor_.DoResume();
42 ret = executor_.DoStart();
64 auto ret = executor_.DoStop(param);
71 auto ret = executor_.DoOnComplete();
|
| H A D | init_state.h | 37 auto ret = executor_.DoSetVideoSource(param);
44 auto ret = executor_.DoSetAudioSource(param);
56 auto ret = executor_.DoOnComplete();
|
| H A D | pause_state.h | 37 auto ret = executor_.DoPause();
62 auto ret = executor_.DoStop(param);
|
| /foundation/multimedia/audio_framework/frameworks/native/audiocapturer/test/unittest/capturer_test/include/ |
| H A D | audio_capturer_unit_test.h | 57 if (executor_) {
58 executor_(length);
64 executor_ = executor; in Install()
72 std::function<void(size_t)> executor_; member in OHOS::AudioStandard::AudioCapturerReadCallbackMock
|
| /foundation/multimedia/audio_framework/frameworks/native/audiorenderer/test/unittest/renderer_test/include/ |
| H A D | audio_renderer_unit_test.h | 62 if (executor_) { in OnWriteData()
63 executor_(length); in OnWriteData()
69 executor_ = executor; in Install()
77 std::function<void(size_t)> executor_; member in OHOS::AudioStandard::AudioRendererWriteCallbackMock
|
| /foundation/multimedia/ringtone_library/services/ringtone_scanner/src/ |
| H A D | ringtone_scanner_manager.cpp | 62 executor_.Commit(move(scanner)); in ScanFile()
110 executor_.Commit(move(scanner)); in ScanDir()
146 executor_.Start(); in Start()
148 executor_.Commit(scanner); in Start()
157 this->executor_.Stop(); in Stop()
|
| /foundation/multimedia/media_library/frameworks/services/media_scanner/src/scanner/ |
| H A D | media_scanner_manager.cpp | 64 executor_.Commit(move(scanner)); in ScanFile()
139 executor_.Commit(move(scanner)); in ScanDir()
168 executor_.Start(); in Start()
171 executor_.Commit(move(scanner)); in Start()
177 this->executor_.Stop(); in Stop()
185 executor_.Commit(move(scanner)); in ScanError()
192 executor_.Commit(move(scanner)); in ErrorRecord()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/ |
| H A D | db_delegate.cpp | 25 std::shared_ptr<ExecutorPool> DBDelegate::executor_ = nullptr;
member in OHOS::DataShare::DBDelegate
57 executor_ = std::move(executor);
in SetExecutorPool()
78 if (executor_ == nullptr || taskId_ != Executor::INVALID_TASK_ID) {
in StartTimer()
81 taskId_ = executor_->Schedule(
in StartTimer()
85 if (executor_ == nullptr || taskId_ == Executor::INVALID_TASK_ID) {
in StartTimer()
88 executor_->Remove(taskId_);
in StartTimer()
|
| H A D | extension_ability_manager.cpp | 33 executor_ = executor; in SetExecutorPool()
65 executor_->Schedule(std::chrono::seconds(time), [bundleName, this]() { in Disconnect()
|
| /foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/processor/ |
| H A D | wifi_direct_processor.h | 38 executor_ = executor; in BindExecutor()
66 WifiDirectExecutor *executor_ {};
|
| /foundation/distributeddatamgr/udmf/framework/innerkitsimpl/client/ |
| H A D | async_obtain_data.cpp | 33 AsyncObtainData::AsyncObtainData() : executor_(MAX_THREADS, MIN_THREADS) {} in AsyncObtainData()
69 obtainDataTaskId_ = executor_.Execute(std::bind(&AsyncObtainData::ObtainDataTask, this)); in RunTask()
70 progressTaskId_ = executor_.Execute(std::bind(&AsyncObtainData::ProgressTask, this)); in RunTask()
80 obtainDataTaskId_ = executor_.Schedule(delay, std::bind(&AsyncObtainData::ObtainDataTask, this)); in ObtainDataTask()
125 progressTaskId_ = executor_.Schedule(delay, std::bind(&AsyncObtainData::ProgressTask, this)); in ProgressTask()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/ |
| H A D | auto_cache.cpp | 46 executor_ = std::move(executor); in Bind()
56 if (executor_ != nullptr) { in ~AutoCache()
57 executor_->Remove(taskId_, true); in ~AutoCache()
93 dbStore->SetExecutor(executor_); in GetStore()
126 if (executor_ == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in StartTimer()
129 taskId_ = executor_->Schedule( in StartTimer()
133 if (executor_ == nullptr || taskId_ == Executor::INVALID_TASK_ID) { in StartTimer()
136 executor_->Remove(taskId_); in StartTimer()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | asset_change_timer.cpp | 40 executor_ = std::make_shared<ExecutorPool>(MAX_THREADS, MIN_THREADS); in AssetChangeTimer()
56 executor_->Schedule(std::chrono::milliseconds(WAIT_INTERVAL), ProcessTask(sessionId, assetKey, watcher)); in StartTimer()
58 assetChangeTasks_[key] = executor_->Reset(assetChangeTasks_[key], std::chrono::milliseconds(WAIT_INTERVAL)); in StartTimer()
82 executor_->Remove(assetChangeTasks_[key]); in StopTimer()
|
| /foundation/multimedia/media_library/frameworks/services/media_dfx/include/ |
| H A D | dfx_worker.h | 36 DfxTask(DfxExecute executor, DfxData *data) : executor_(executor), data_(data), in DfxTask()
45 DfxExecute executor_; member in OHOS::Media::DfxTask
|
| /foundation/multimedia/player_framework/services/services/sa_media/server/ |
| H A D | media_server_manager.cpp | 631 executor_.Commit(itScreenCapture->first); in DestroyAVScreenCaptureStubForPid()
643 executor_.Commit(itScreenCaptureMonitor->first); in DestroyAVScreenCaptureStubForPid()
655 executor_.Commit(itScreenCaptureController->first); in DestroyAVScreenCaptureStubForPid()
669 executor_.Commit(itTranscoder->first); in DestroyAVTranscoderStubForPid()
683 executor_.Commit(itAvCodec->first); in DestroyAVCodecStubForPid()
694 executor_.Commit(itAvCodecList->first); in DestroyAVCodecStubForPid()
708 executor_.Commit(itPlayer->first); in DestroyAVPlayerStubForPid()
729 executor_.Commit(itAvMetadata->first); in DestroyAVPlayerStubForPid()
743 executor_.Commit(itRecorder->first); in DestroyAVRecorderStubForPid()
754 executor_ in DestroyAVRecorderStubForPid()
[all...] |