| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/interface/src/ |
| H A D | collection.cpp | 36 executor_ = nullptr; in ~Collection()
53 if (executor_ == nullptr) { in InsertDocument()
70 return executor_->InsertData(name_, key, valSet); in InsertDocument()
75 if (executor_ == nullptr) { in GetDocumentById()
83 if (executor_ == nullptr) { in DeleteDocument()
94 return executor_->DelData(name_, key); in DeleteDocument()
100 if (executor_ == nullptr) { in GetMatchedDocument()
113 if (executor_ == nullptr) { in UpsertDocument()
132 return executor_->PutData(name_, key, valSet); in UpsertDocument()
137 if (executor_ == nullptr) { in UpdateDocument()
[all …]
|
| H A D | document_store.cpp | 36 delete executor_; in ~DocumentStore()
60 if (executor_ == nullptr) { in CreateCollection()
78 executor_->Commit(); in CreateCollection()
80 executor_->Rollback(); in CreateCollection()
101 if (executor_ == nullptr) { in DropCollection()
124 executor_->Commit(); in DropCollection()
126 executor_->Rollback(); in DropCollection()
250 executor_->Commit(); in UpdateDataIntoDB()
425 executor_->Commit(); in UpsertDataIntoDB()
590 executor_->Commit(); in DeleteDataFromDB()
[all …]
|
| /ohos5.0/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()
151 RefObject::IncObjRef(executor_); in MessageCallback()
152 executor_->ReceiveMessage(deviceId, inMsg); in MessageCallback()
153 RefObject::DecObjRef(executor_); in MessageCallback()
[all …]
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/scene/player/internal/ |
| H A D | playing_state.h | 40 ret = executor_.DoResume(); in Enter()
42 ret = executor_.DoPlay(); in Enter()
58 auto ret = executor_.DoSeek(info.hstTime, info.mode, true); in Seek()
74 auto ret = executor_.DoOnComplete(); in OnComplete()
75 if (executor_.IsSingleLoop()) { in OnComplete()
77 auto seekRes = executor_.DoSeek(0, Plugin::SeekMode::SEEK_PREVIOUS_SYNC, false); in OnComplete()
|
| H A D | idle_state.h | 35 auto ret = executor_.DoSetSource(source); in SetSource()
42 return {executor_.DoReset(), Action::ACTION_BUTT}; in Enter()
|
| H A D | eos_state.h | 32 auto ret = executor_.DoSeek(0, Plugin::SeekMode::SEEK_PREVIOUS_SYNC, false); in Play()
50 auto ret = executor_.DoPause(); in Enter()
|
| H A D | ready_state.h | 38 auto rtv = executor_.DoOnReady(); in Enter()
52 auto ret = executor_.DoSeek(info.hstTime, info.mode, true); in Seek()
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/scene/recorder/internal/ |
| H A D | recording_setting_state.h | 38 auto ret = executor_.DoSetVideoSource(param); in SetVideoSource()
45 auto ret = executor_.DoSetAudioSource(param); in SetAudioSource()
52 auto ret = executor_.DoConfigure(param); in Configure()
59 auto ret = executor_.DoSetOutputFormat(param); in SetOutputFormat()
66 auto rtv = executor_.DoPrepare(); in Prepare()
81 auto ret = executor_.DoStop(param); in Stop()
|
| H A D | recording_state.h | 40 ret = executor_.DoResume(); in Enter()
42 ret = executor_.DoStart(); in Enter()
64 auto ret = executor_.DoStop(param); in Stop()
71 auto ret = executor_.DoOnComplete(); in OnComplete()
|
| H A D | init_state.h | 37 auto ret = executor_.DoSetVideoSource(param); in SetVideoSource()
44 auto ret = executor_.DoSetAudioSource(param); in SetAudioSource()
56 auto ret = executor_.DoOnComplete(); in OnComplete()
|
| H A D | pause_state.h | 37 auto ret = executor_.DoPause(); in Enter()
62 auto ret = executor_.DoStop(param); in Stop()
|
| /ohos5.0/base/useriam/user_auth_framework/frameworks/native/executors/src/framework/ |
| H A D | framework_executor_callback.cpp | 40 FrameworkExecutorCallback::FrameworkExecutorCallback(std::weak_ptr<Executor> executor) : executor_(… in FrameworkExecutorCallback()
103 auto executor = executor_.lock(); in OnMessengerReady()
161 auto executor = executor_.lock(); in OnSendData()
202 auto executor = executor_.lock(); in ProcessAuthCommand()
212 … command = Common::MakeShared<AuthCommand>(executor_, scheduleId, properties, executorMessenger_); in ProcessAuthCommand()
228 auto executor = executor_.lock(); in ProcessCancelCommand()
241 auto executor = executor_.lock(); in ProcessDeleteTemplateCommand()
271 auto executor = executor_.lock(); in ProcessSetCachedTemplates()
289 auto executor = executor_.lock(); in ProcessNotifyExecutorReady()
307 auto command = Common::MakeShared<CustomCommand>(executor_, properties); in ProcessCustomCommand()
[all …]
|
| /ohos5.0/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()
|
| /ohos5.0/foundation/multimedia/audio_framework/frameworks/native/audiocapturer/test/unittest/capturer_test/include/ |
| H A D | audio_capturer_unit_test.h | 57 if (executor_) { in OnReadData()
58 executor_(length); in OnReadData()
64 executor_ = executor; in Install()
72 std::function<void(size_t)> executor_;
|
| /ohos5.0/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()
|
| /ohos5.0/base/useriam/user_auth_framework/frameworks/native/executors/src/async_command/ |
| H A D | async_command_base.cpp | 39 executor_(executor), in AsyncCommandBase()
58 auto executor = executor_.lock(); in StartProcess()
135 std::shared_ptr<Executor> executor = executor_.lock(); in OnMessageInner()
156 auto executor = executor_.lock(); in GetAuthType()
167 auto executor = executor_.lock(); in EndProcess()
190 auto executor = executor_.lock(); in GetExecutorHdi()
|
| /ohos5.0/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_;
|
| /ohos5.0/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()
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/common/utils/watchdog/ |
| H A D | watchdog.cpp | 30 executor_ = executor; in Init()
57 if (executor_) { in WaitForWakeUP()
58 executor_(); in WaitForWakeUP()
|
| /ohos5.0/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()
|
| /ohos5.0/base/update/updateservice/services/firmware/upgrade/flow/src/ |
| H A D | firmware_flow_manager.cpp | 63 executor_ = CreateInstance(nextStep_); in Execute()
64 if (executor_ != nullptr) { in Execute()
65 executor_->Execute(); in Execute()
|
| /ohos5.0/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, wat… in StartTimer()
58 …assetChangeTasks_[key] = executor_->Reset(assetChangeTasks_[key], std::chrono::milliseconds(WAIT_I… in StartTimer()
82 executor_->Remove(assetChangeTasks_[key]); in StopTimer()
|
| /ohos5.0/foundation/multimedia/player_framework/services/services/sa_media/server/ |
| H A D | media_server_manager.cpp | 612 executor_.Commit(itScreenCapture->first); in DestroyAVScreenCaptureStubForPid()
624 executor_.Commit(itScreenCaptureMonitor->first); in DestroyAVScreenCaptureStubForPid()
636 executor_.Commit(itScreenCaptureController->first); in DestroyAVScreenCaptureStubForPid()
650 executor_.Commit(itTranscoder->first); in DestroyAVTranscoderStubForPid()
664 executor_.Commit(itAvCodec->first); in DestroyAVCodecStubForPid()
675 executor_.Commit(itAvCodecList->first); in DestroyAVCodecStubForPid()
689 executor_.Commit(itPlayer->first); in DestroyAVPlayerStubForPid()
700 executor_.Commit(itAvMetadata->first); in DestroyAVPlayerStubForPid()
714 executor_.Commit(itRecorder->first); in DestroyAVRecorderStubForPid()
725 executor_.Commit(itMediaProfile->first); in DestroyAVRecorderStubForPid()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/processor/ |
| H A D | wifi_direct_processor.h | 38 executor_ = executor; in BindExecutor()
66 WifiDirectExecutor *executor_ {};
|
| /ohos5.0/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_; variable
|