Home
last modified time | relevance | path

Searched refs:notify (Results 1 - 25 of 61) sorted by relevance

123

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dobject_dms_handler_test.cpp46 DistributedSchedule::EventNotify notify; in HWTEST_F() local
47 notify.dSchedEventType_ = DistributedSchedule::DSchedEventType::DMS_CONTINUE; in HWTEST_F()
48 notify.srcNetworkId_ = localNetworkId; in HWTEST_F()
49 notify.dstNetworkId_ = "networkId2"; in HWTEST_F()
50 notify.srcBundleName_ = "bundleName1"; in HWTEST_F()
51 notify.destBundleName_ = "bundleName2"; in HWTEST_F()
53 listener.DSchedEventNotify(notify); in HWTEST_F()
72 DistributedSchedule::EventNotify notify; in HWTEST_F() local
73 notify.dSchedEventType_ = DistributedSchedule::DSchedEventType::DMS_CONTINUE; in HWTEST_F()
74 notify in HWTEST_F()
97 DistributedSchedule::EventNotify notify; HWTEST_F() local
130 DistributedSchedule::EventNotify notify; HWTEST_F() local
[all...]
/foundation/ability/dmsfwk/interfaces/innerkits/tests/
H A Ddms_sdk_demo.cpp74 for (auto notify : notifys) { in GetDSchedEventInfo()
76 cout << "eventResult: " << notify.eventResult_ << endl; in GetDSchedEventInfo()
77 cout << "srcNetworkId: " << notify.srcNetworkId_ << endl; in GetDSchedEventInfo()
78 cout << "dstNetworkId: " << notify.dstNetworkId_ << endl; in GetDSchedEventInfo()
79 cout << "srcBundleName: " << notify.srcBundleName_ << endl; in GetDSchedEventInfo()
80 cout << "srcModuleName: " << notify.srcModuleName_ << endl; in GetDSchedEventInfo()
81 cout << "srcAbilityName: " << notify.srcAbilityName_ << endl; in GetDSchedEventInfo()
82 cout << "destBundleName: " << notify.destBundleName_ << endl; in GetDSchedEventInfo()
83 cout << "destModuleName: " << notify.destModuleName_ << endl; in GetDSchedEventInfo()
84 cout << "destAbilityName: " << notify in GetDSchedEventInfo()
93 DSchedEventNotify(EventNotify& notify) DSchedEventNotify() argument
[all...]
H A Ddms_sdk_demo.h28 void DSchedEventNotify(EventNotify &notify) override;
/foundation/communication/dsoftbus/tests/adapter/bluetooth/
H A Dsoftbus_adapter_ble_gatt_client_test.cpp47 SoftBusGattcNotify notify; member in OHOS::GattcNotifyRecordCtx
412 SoftBusGattcNotify notify = { in HWTEST_F() local
420 ASSERT_TRUE(notificationReceiveCtx.Expect(clientId, OHOS_BT_STATUS_SUCCESS, &notify)); in HWTEST_F()
472 SoftBusFree(notify.charaUuid.uuid); in Reset()
473 notify.charaUuid.uuid = nullptr; in Reset()
474 SoftBusFree(notify.data); in Reset()
475 notify.data = nullptr; in Reset()
476 (void)memset_s(&notify, sizeof(SoftBusGattcNotify), 0, sizeof(SoftBusGattcNotify)); in Reset()
484 this->notify = *param; in Update()
485 notify in Update()
[all...]
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/liteos/dfile/
H A Dsys_dfile.c44 char notify = 0; in NotifyPipeEvent() local
46 if (write(session->receiverPipe[PIPE_IN], &notify, sizeof(notify)) <= 0) { in NotifyPipeEvent()
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/unix/dfile/
H A Dsys_dfile.c65 char notify = 0; in NotifyPipeEvent() local
67 if (write(session->receiverPipe[PIPE_IN], &notify, sizeof(notify)) <= 0) { in NotifyPipeEvent()
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/distributed_event/
H A Ddms_handler_test.h42 void DSchedEventNotify(EventNotify &notify);
52 void DSchedEventNotify(EventNotify &notify);
H A Ddms_sa_cilent_test.h50 void DSchedEventNotify(EventNotify &notify) override;
H A Ddms_listener_stub_test.h46 void DSchedEventNotify(EventNotify &notify);
H A Ddms_client_test.h48 void DSchedEventNotify(EventNotify &notify);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.cpp258 NotifyConflictAndObserverData notify = { in PrepareNotifyForEntries() local
261 int errCode = PrepareForNotifyConflictAndObserver(entry, notify, isDelete); in PrepareNotifyForEntries()
265 notifys.push_back(notify); in PrepareNotifyForEntries()
465 NotifyConflictAndObserverData notify; in SaveSyncDataItem() local
467 notify = { in SaveSyncDataItem()
471 errCode = PrepareForNotifyConflictAndObserver(entry, notify, isDelete); in SaveSyncDataItem()
478 PutIntoCommittedData(entry.key, entry.value, notify); in SaveSyncDataItem()
757 NotifyConflictAndObserverData &notify, bool isDelete) in PrepareForNotifyConflictAndObserver()
760 int errCode = DBCommon::CalcValueHash(entry.key, notify.hashKey); in PrepareForNotifyConflictAndObserver()
764 errCode = GetSyncDataPreByKey(entry.key, notify in PrepareForNotifyConflictAndObserver()
756 PrepareForNotifyConflictAndObserver(const Entry &entry, NotifyConflictAndObserverData &notify, bool isDelete) PrepareForNotifyConflictAndObserver() argument
[all...]
/foundation/ai/ai_engine/services/client/communication_adapter/source/
H A Dsa_client_proxy.cpp58 auto notify = reinterpret_cast<NotificationInitServer *>(owner); in Callback() local
59 ReadInt32(reply, &(notify->clientId)); in Callback()
60 ReadUint32(reply, &(notify->serverUid)); in Callback()
71 auto notify = reinterpret_cast<struct NotifyBuff *>(owner); in CallbackBuff() local
72 ReadInt32(reply, &(notify->retCode)); in CallbackBuff()
75 notify->ipcRetCode = UnParcelDataInfo(reply, &dataInfo); in CallbackBuff()
76 if (notify->ipcRetCode == RETCODE_SUCCESS) { in CallbackBuff()
77 notify->outLen = dataInfo.length; in CallbackBuff()
78 notify->outBuff = dataInfo.data; in CallbackBuff()
80 notify in CallbackBuff()
[all...]
/foundation/ability/ability_runtime/frameworks/native/ability/native/ability_runtime/
H A Djs_caller_complex.cpp297 auto task = [notify = this, &str] () { in OnReleaseNotify()
298 if (!FindJsCallerComplex(notify)) { in OnReleaseNotify()
302 notify->OnReleaseNotifyTask(str); in OnReleaseNotify()
332 auto task = [notify = this, &str] () { in OnRemoteStateChangedNotify()
333 if (!FindJsCallerComplex(notify)) { in OnRemoteStateChangedNotify()
337 notify->OnRemoteStateChangedNotifyTask(str); in OnRemoteStateChangedNotify()
412 auto task = [notify = this] (const std::string &str) { in SetOnReleaseCallBackInner()
413 if (!FindJsCallerComplexAndChangeState(notify, OBJSTATE::OBJ_EXECUTION)) { in SetOnReleaseCallBackInner()
417 notify->OnReleaseNotify(str); in SetOnReleaseCallBackInner()
452 auto task = [notify in SetOnRemoteStateChangedInner()
[all...]
/foundation/systemabilitymgr/samgr_lite/interfaces/kits/registry/
H A Diproxy_client.h65 int (*Invoke)(IClientProxy *proxy, int funcId, IpcIo *request, IOwner owner, INotify notify)
101 * by <b>funcId</b>. <b>notify</b> is a callback function used to process the response message. \n
107 * @param notify Indicates the callback function that notifies the client of the response
114 int (*Invoke)(IClientProxy *proxy, int funcId, IpcIo *request, IOwner owner, INotify notify);
/foundation/graphic/graphic_3d/lume/metaobject/src/engine/
H A Dengine_value_manager.cpp279 if (v.second.notify) { in NotifySyncs()
281 v.second.notify = false; in NotifySyncs()
296 bool notify = false; in Sync() local
303 v.second.notify = true; in Sync()
304 notify = true; in Sync()
308 notify = notify && !task_token_; in Sync()
309 if (notify && !queue_.expired()) { in Sync()
318 notify = false; in Sync()
321 if (notify) { in Sync()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_executor_cache.cpp259 // Put or delete. Prepare notify data here. in MigrateDataItem()
260 NotifyConflictAndObserverData notify; in MigrateDataItem() local
261 notify.committedData = syncData.committedData; in MigrateDataItem()
262 int errCode = PutIntoConflictAndCommitForMigrateCache(dataItem, {dataItem.dev.empty(), dataItem.dev}, notify, in MigrateDataItem()
270 if (notify.dataStatus.isDefeated) { in MigrateDataItem()
274 bool isUpdate = notify.dataStatus.preStatus != DataStatus::NOEXISTED; in MigrateDataItem()
351 // Get entry here. Prepare notify data in storageEngine. in MigrateDataItems()
753 const DeviceInfo &deviceInfo, NotifyConflictAndObserverData &notify, bool isPermitForceWrite) in PutIntoConflictAndCommitForMigrateCache()
755 int errCode = PrepareForNotifyConflictAndObserver(dataItem, deviceInfo, notify, isPermitForceWrite); in PutIntoConflictAndCommitForMigrateCache()
759 notify in PutIntoConflictAndCommitForMigrateCache()
752 PutIntoConflictAndCommitForMigrateCache(DataItem &dataItem, const DeviceInfo &deviceInfo, NotifyConflictAndObserverData &notify, bool isPermitForceWrite) PutIntoConflictAndCommitForMigrateCache() argument
[all...]
/foundation/arkui/napi/native_engine/impl/ark/
H A Dark_finalizers_pack.h43 void RegisterFinishNotify(ArkFinalizersPackFinishNotify notify) in RegisterFinishNotify() argument
45 notify_ = notify; in RegisterFinishNotify()
/foundation/arkui/ace_engine_lite/frameworks/packages/runtime-core/src/observer/
H A Dsubject.js72 Subject.prototype.notify = function(key) {
90 this._parent && this._parent.notify(this._key);
166 subject.notify(key);
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/
H A Dkernel_talker.cpp214 param.notify = NOTIFY_NONE; in HandleAllNotify()
216 if ((readSize < (int)sizeof(NotifyParam)) || (param.notify == NOTIFY_NONE)) { in HandleAllNotify()
225 int cmd = param.notify; in NotifyHandler()
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/
H A Dkernel_talker_test.cpp221 param.notify = NOTIFY_GET_SESSION; in HWTEST_F()
243 param.notify = NOTIFY_OFFLINE; in HWTEST_F()
265 param.notify = NOTIFY_NONE; in HWTEST_F()
/foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/
H A Ddefault_client.c53 static int ProxyInvoke(IClientProxy *proxy, int funcId, IpcIo *request, IOwner owner, INotify notify);
165 static int ProxyInvoke(IClientProxy *proxy, int funcId, IpcIo *request, IOwner owner, INotify notify) in ProxyInvoke() argument
183 IpcFlag flag = (notify == NULL) ? LITEIPC_FLAG_ONEWAY : LITEIPC_FLAG_DEFAULT; in ProxyInvoke()
194 if (notify != NULL) { in ProxyInvoke()
195 notify(owner, ret, &reply); in ProxyInvoke()
H A Ddefault_client_rpc.c20 static int ProxyInvoke(IClientProxy *proxy, int funcId, IpcIo *request, IOwner owner, INotify notify);
159 static int ProxyInvoke(IClientProxy *proxy, int funcId, IpcIo *request, IOwner owner, INotify notify) in ProxyInvoke() argument
172 flag.flags = (notify == NULL) ? TF_OP_ASYNC : TF_OP_SYNC; in ProxyInvoke()
192 if (notify != NULL) { in ProxyInvoke()
193 notify(owner, ret, &reply); in ProxyInvoke()
/foundation/filemanagement/app_file_service/tests/mock/module_ipc/src/
H A Dnotify_work_service_mock.cpp27 return BNotifyWorkService::notify->NotifyBundleDetail(bundleDetailInfo); in NotifyBundleDetail()
/foundation/ability/dmsfwk/interfaces/innerkits/distributed_event/include/
H A Ddistributed_event_listener.h31 virtual void DSchedEventNotify(EventNotify &notify) = 0;
/foundation/filemanagement/app_file_service/tests/mock/module_ipc/include/
H A Dnotify_work_service_mock.h31 static inline std::shared_ptr<BNotifyWorkService> notify = nullptr; member in OHOS::FileManagement::Backup::BNotifyWorkService

Completed in 17 milliseconds

123