Home
last modified time | relevance | path

Searched refs:callingPid (Results 1 - 25 of 91) sorted by relevance

1234

/foundation/resourceschedule/resource_schedule_service/ressched/test/unittest/src/
H A Dnotifier_mgr_test.cpp163 auto callingPid = IPCSkeleton::GetCallingPid(); in HWTEST_F() local
164 NotifierMgr::GetInstance().RegisterNotifier(callingPid, notifier); in HWTEST_F()
165 auto& info = NotifierMgr::GetInstance().notifierMap_[callingPid]; in HWTEST_F()
167 NotifierMgr::GetInstance().OnApplicationStateChange(APP_STATE_EXIT, callingPid); in HWTEST_F()
169 NotifierMgr::GetInstance().OnApplicationStateChange(2, callingPid); in HWTEST_F()
187 auto callingPid = IPCSkeleton::GetCallingPid(); in HWTEST_F() local
188 NotifierMgr::GetInstance().RegisterNotifier(callingPid, notifier); in HWTEST_F()
189 NotifierMgr::GetInstance().RegisterNotifier(callingPid, notifier1); in HWTEST_F()
190 auto realNotifier = NotifierMgr::GetInstance().notifierMap_[callingPid].notifier; in HWTEST_F()
205 auto callingPid in HWTEST_F() local
222 auto callingPid = IPCSkeleton::GetCallingPid(); HWTEST_F() local
238 auto callingPid = IPCSkeleton::GetCallingPid(); HWTEST_F() local
255 auto callingPid = IPCSkeleton::GetCallingPid(); HWTEST_F() local
[all...]
H A Devent_listener_mgr_test.cpp130 auto callingPid = IPCSkeleton::GetCallingPid(); in HWTEST_F() local
131 EventListenerMgr::GetInstance().RegisterEventListener(callingPid, eventListener, in HWTEST_F()
134 EventListenerMgr::GetInstance().RegisterEventListener(callingPid, eventListener1, in HWTEST_F()
138 eventListenerMap_[ResType::EventType::EVENT_DRAW_FRAME_REPORT][callingPid].listener; in HWTEST_F()
153 auto callingPid = IPCSkeleton::GetCallingPid(); in HWTEST_F() local
154 EventListenerMgr::GetInstance().RegisterEventListener(callingPid, eventListener, in HWTEST_F()
157 EventListenerMgr::GetInstance().RegisterEventListener(callingPid, eventListener, in HWTEST_F()
174 auto callingPid = IPCSkeleton::GetCallingPid(); in HWTEST_F() local
175 EventListenerMgr::GetInstance().RegisterEventListener(callingPid, eventListener, in HWTEST_F()
192 auto callingPid in HWTEST_F() local
211 auto callingPid = IPCSkeleton::GetCallingPid(); HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/bus_center/ipc/standard/src/
H A Dlnn_bus_center_ipc.cpp79 static bool IsRepeatJoinLNNRequest(const char *pkgName, int32_t callingPid, const ConnectionAddr *addr) in IsRepeatJoinLNNRequest() argument
82 if (strncmp(pkgName, (*iter).pkgName, strlen(pkgName)) != 0 || (*iter).pid != callingPid) { in IsRepeatJoinLNNRequest()
92 static int32_t AddJoinLNNInfo(const char *pkgName, int32_t callingPid, const ConnectionAddr *addr) in AddJoinLNNInfo() argument
103 info->pid = callingPid; in AddJoinLNNInfo()
109 static bool IsRepeatLeaveLNNRequest(const char *pkgName, int32_t callingPid, const char *networkId) in IsRepeatLeaveLNNRequest() argument
112 if (strncmp(pkgName, (*iter).pkgName, strlen(pkgName)) != 0 || (*iter).pid != callingPid) { in IsRepeatLeaveLNNRequest()
122 static int32_t AddLeaveLNNInfo(const char *pkgName, int32_t callingPid, const char *networkId) in AddLeaveLNNInfo() argument
138 info->pid = callingPid; in AddLeaveLNNInfo()
181 int32_t LnnIpcServerJoin(const char *pkgName, int32_t callingPid, void *addr, uint32_t addrTypeLen)
194 if (IsRepeatJoinLNNRequest(pkgName, callingPid, connAdd
[all...]
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service/unittest/pipeline/
H A Drs_unmarshal_thread_test.cpp95 pid_t callingPid = 1111; in HWTEST_F() local
96 RSUnmarshalThread::Instance().RecvParcel(data, isNonSystemAppCalling, callingPid); in HWTEST_F()
107 constexpr pid_t callingPid = -1; // invalid pid in HWTEST_F() local
114 ASSERT_EQ(instance.ReportTransactionDataStatistics(callingPid, transactionData.get(), !isSystemCall), false); in HWTEST_F()
115 ASSERT_EQ(instance.ReportTransactionDataStatistics(callingPid, transactionData.get(), !isSystemCall), false); in HWTEST_F()
116 ASSERT_EQ(instance.ReportTransactionDataStatistics(callingPid, transactionData.get(), !isSystemCall), false); in HWTEST_F()
119 ASSERT_EQ(instance.ReportTransactionDataStatistics(callingPid, transactionData.get(), isSystemCall), false); in HWTEST_F()
120 ASSERT_EQ(instance.ReportTransactionDataStatistics(callingPid, transactionData.get(), isSystemCall), false); in HWTEST_F()
121 ASSERT_EQ(instance.ReportTransactionDataStatistics(callingPid, transactionData.get(), isSystemCall), false); in HWTEST_F()
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/time_sync/src/
H A Dlnn_time_sync_manager_virtual.c21 int32_t LnnStartTimeSync(const char *pkgName, int32_t callingPid, const char *targetNetworkId, in LnnStartTimeSync() argument
25 (void)callingPid; in LnnStartTimeSync()
32 int32_t LnnStopTimeSync(const char *pkgName, const char *targetNetworkId, int32_t callingPid) in LnnStopTimeSync() argument
36 (void)callingPid; in LnnStopTimeSync()
/foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/
H A Devent_listener_mgr.cpp54 void EventListenerMgr::RegisterEventListener(int32_t callingPid, in RegisterEventListener() argument
57 RESSCHED_LOGD("%{public}s:called, pid = %{public}d.", __func__, callingPid); in RegisterEventListener()
68 if (iter != eventListenerMap_.end() && iter->second.find((pid_t)callingPid) != iter->second.end()) { in RegisterEventListener()
69 if (iter->second[(pid_t)callingPid].groups.count(listenerGroup) == 0) { in RegisterEventListener()
70 iter->second[(pid_t)callingPid].groups.emplace(listenerGroup); in RegisterEventListener()
72 __func__, callingPid, eventType, listenerGroup); in RegisterEventListener()
75 __func__, callingPid, eventType, listenerGroup); in RegisterEventListener()
81 info.pid = (pid_t)callingPid; in RegisterEventListener()
86 __func__, callingPid, eventType, listenerGroup); in RegisterEventListener()
89 void EventListenerMgr::UnRegisterEventListener(int32_t callingPid, uint32_ argument
[all...]
/foundation/communication/dsoftbus/core/bus_center/ipc/include/
H A Dlnn_bus_center_ipc.h31 int32_t LnnIpcServerJoin(const char *pkgName, int32_t callingPid, void *addr, uint32_t addrTypeLen);
32 int32_t LnnIpcServerLeave(const char *pkgName, int32_t callingPid, const char *networkId);
37 int32_t LnnIpcRegDataLevelChangeCb(const char *pkgName, int32_t callingPid);
38 int32_t LnnIpcUnregDataLevelChangeCb(const char *pkgName, int32_t callingPid);
42 const char *pkgName, int32_t callingPid, const char *targetNetworkId, int32_t accuracy, int32_t period);
43 int32_t LnnIpcStopTimeSync(const char *pkgName, const char *targetNetworkId, int32_t callingPid);
46 int32_t LnnIpcRefreshLNN(const char *pkgName, int32_t callingPid, const SubscribeInfo *info);
47 int32_t LnnIpcStopRefreshLNN(const char *pkgName, int32_t callingPid, int32_t refreshId);
/foundation/communication/dsoftbus/core/bus_center/ipc/mini/
H A Dlnn_bus_center_ipc.c49 int32_t LnnIpcServerJoin(const char *pkgName, int32_t callingPid, void *addr, uint32_t addrTypeLen) in LnnIpcServerJoin() argument
51 (void)callingPid; in LnnIpcServerJoin()
56 int32_t LnnIpcServerLeave(const char *pkgName, int32_t callingPid, const char *networkId) in LnnIpcServerLeave() argument
58 (void)callingPid; in LnnIpcServerLeave()
98 int32_t LnnIpcStartTimeSync(const char *pkgName, int32_t callingPid, const char *targetNetworkId, in LnnIpcStartTimeSync() argument
101 return LnnStartTimeSync(pkgName, callingPid, targetNetworkId, (TimeSyncAccuracy)accuracy, (TimeSyncPeriod)period); in LnnIpcStartTimeSync()
104 int32_t LnnIpcStopTimeSync(const char *pkgName, const char *targetNetworkId, int32_t callingPid) in LnnIpcStopTimeSync() argument
106 return LnnStopTimeSync(pkgName, targetNetworkId, callingPid); in LnnIpcStopTimeSync()
119 int32_t LnnIpcRefreshLNN(const char *pkgName, int32_t callingPid, const SubscribeInfo *info) in LnnIpcRefreshLNN() argument
121 (void)callingPid; in LnnIpcRefreshLNN()
128 LnnIpcStopRefreshLNN(const char *pkgName, int32_t callingPid, int32_t refreshId) LnnIpcStopRefreshLNN() argument
[all...]
/foundation/communication/dsoftbus/core/common/security/permission/standard/
H A Dsoftbus_permission.cpp58 static int32_t CalcPermType(pid_t callingUid, pid_t callingPid) in CalcPermType() argument
61 if (callingUid == static_cast<pid_t>(getuid()) && callingPid == getpid()) { in CalcPermType()
80 int32_t CheckTransPermission(pid_t callingUid, pid_t callingPid, in CheckTransPermission() argument
88 int32_t permType = CalcPermType(callingUid, callingPid); in CheckTransPermission()
89 SoftBusPermissionItem *pItem = CreatePermissionItem(permType, callingUid, callingPid, pkgName, actions); in CheckTransPermission()
101 callingUid=%{public}d, callingPid=%{public}d", permType, ret, tmpName, callingUid, callingPid); in CheckTransPermission()
154 int32_t GrantTransPermission(int32_t callingUid, int32_t callingPid, const char *sessionName) in GrantTransPermission() argument
159 return AddDynamicPermission(callingUid, callingPid, sessionName); in GrantTransPermission()
/foundation/communication/dsoftbus/core/common/security/permission/small/
H A Dsoftbus_permission.c46 static int32_t GetPermType(pid_t callingUid, pid_t callingPid, const char *pkgName) in GetPermType() argument
49 if (callingUid == (pid_t)getuid() && callingPid == getpid()) { in GetPermType()
74 int32_t CheckTransPermission(pid_t callingUid, pid_t callingPid, in CheckTransPermission() argument
77 int32_t permType = GetPermType(callingUid, callingPid, pkgName); in CheckTransPermission()
81 SoftBusPermissionItem *pItem = CreatePermissionItem(permType, callingUid, callingPid, pkgName, actions); in CheckTransPermission()
/foundation/communication/dsoftbus/core/frame/standard/init/src/
H A Dsoftbus_server.cpp94 pid_t callingPid = OHOS::IPCSkeleton::GetCallingPid(); in CreateSessionServer() local
95 return TransCreateSessionServer(pkgName, sessionName, (int32_t)callingUid, (int32_t)callingPid); in CreateSessionServer()
185 pid_t callingPid = OHOS::IPCSkeleton::GetCallingPid(); in JoinLNN() local
186 return LnnIpcServerJoin(pkgName, (int32_t)callingPid, addr, addrTypeLen); in JoinLNN()
191 pid_t callingPid = OHOS::IPCSkeleton::GetCallingPid(); in LeaveLNN() local
192 return LnnIpcServerLeave(pkgName, (int32_t)callingPid, networkId); in LeaveLNN()
218 int32_t callingPid = (int32_t)OHOS::IPCSkeleton::GetCallingPid(); in RegDataLevelChangeCb() local
219 return LnnIpcRegDataLevelChangeCb(pkgName, callingPid); in RegDataLevelChangeCb()
224 int32_t callingPid = (int32_t)OHOS::IPCSkeleton::GetCallingPid(); in UnregDataLevelChangeCb() local
225 return LnnIpcUnregDataLevelChangeCb(pkgName, callingPid); in UnregDataLevelChangeCb()
236 pid_t callingPid = OHOS::IPCSkeleton::GetCallingPid(); StartTimeSync() local
242 pid_t callingPid = OHOS::IPCSkeleton::GetCallingPid(); StopTimeSync() local
273 pid_t callingPid = OHOS::IPCSkeleton::GetCallingPid(); RefreshLNN() local
279 pid_t callingPid = OHOS::IPCSkeleton::GetCallingPid(); StopRefreshLNN() local
[all...]
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/time_sync/include/
H A Dlnn_time_sync_manager.h26 int32_t LnnStartTimeSync(const char *pkgName, int32_t callingPid, const char *targetNetworkId,
28 int32_t LnnStopTimeSync(const char *pkgName, const char *targetNetworkId, int32_t callingPid);
/foundation/communication/ipc/ipc/native/src/napi_common/source/
H A Dnapi_process_skeleton.cpp31 napi_value callingPid = nullptr; in NAPI_getCallingPid() local
32 napi_get_named_property(env, global, "callingPid_", &callingPid); in NAPI_getCallingPid()
33 return callingPid; in NAPI_getCallingPid()
/foundation/communication/dsoftbus/core/bus_center/ipc/small/src/
H A Dlnn_bus_center_ipc.c203 int32_t LnnIpcServerJoin(const char *pkgName, int32_t callingPid, void *addr, uint32_t addrTypeLen) in LnnIpcServerJoin() argument
205 (void)callingPid; in LnnIpcServerJoin()
242 int32_t LnnIpcServerLeave(const char *pkgName, int32_t callingPid, const char *networkId) in LnnIpcServerLeave() argument
244 (void)callingPid; in LnnIpcServerLeave()
316 int32_t LnnIpcStartTimeSync(const char *pkgName, int32_t callingPid, const char *targetNetworkId, in LnnIpcStartTimeSync() argument
319 return LnnStartTimeSync(pkgName, callingPid, targetNetworkId, (TimeSyncAccuracy)accuracy, (TimeSyncPeriod)period); in LnnIpcStartTimeSync()
322 int32_t LnnIpcStopTimeSync(const char *pkgName, const char *targetNetworkId, int32_t callingPid) in LnnIpcStopTimeSync() argument
324 return LnnStopTimeSync(pkgName, targetNetworkId, callingPid); in LnnIpcStopTimeSync()
337 int32_t LnnIpcRefreshLNN(const char *pkgName, int32_t callingPid, const SubscribeInfo *info) in LnnIpcRefreshLNN() argument
339 (void)callingPid; in LnnIpcRefreshLNN()
346 LnnIpcStopRefreshLNN(const char *pkgName, int32_t callingPid, int32_t refreshId) LnnIpcStopRefreshLNN() argument
[all...]
/foundation/communication/dsoftbus/tests/core/frame/unittest/mock/
H A Dsoftbus_server_stub_test_mock.cpp40 int32_t CheckTransPermission(pid_t callingUid, pid_t callingPid, const char *pkgName, in CheckTransPermission() argument
43 return GetSoftbusServerStubTestInterface()->CheckTransPermission(callingUid, callingPid, pkgName, in CheckTransPermission()
101 bool CheckUidAndPid(const char *sessionName, pid_t callingUid, pid_t callingPid) in CheckUidAndPid() argument
103 return GetSoftbusServerStubTestInterface()->CheckUidAndPid(sessionName, callingUid, callingPid); in CheckUidAndPid()
H A Dsoftbus_server_stub_test_mock.h36 virtual int32_t CheckTransPermission(pid_t callingUid, pid_t callingPid, const char *pkgName,
54 virtual bool CheckUidAndPid(const char *sessionName, pid_t callingUid, pid_t callingPid) = 0;
60 MOCK_METHOD5(CheckTransPermission, int32_t (pid_t callingUid, pid_t callingPid, const char *pkgName,
78 MOCK_METHOD3(CheckUidAndPid, bool (const char *sessionName, pid_t callingUid, pid_t callingPid));
/foundation/communication/dsoftbus/tests/core/common/security/permission/common/unittest/
H A Dpermission_entry_test.cpp146 int32_t callingPid = 0; in HWTEST_F() local
153 ret = AddDynamicPermission(callingUid, callingPid, DBINDER_BUS_NAME_PREFIX); in HWTEST_F()
156 ret = AddDynamicPermission(callingUid, callingPid, DBINDER_SERVICE_NAME); in HWTEST_F()
159 ret = AddDynamicPermission(callingUid, callingPid, sessionNameWrong); in HWTEST_F()
/foundation/systemabilitymgr/samgr/services/samgr/native/include/schedule/
H A Dsystem_ability_state_context.h56 int32_t callingPid = -1; member
63 int32_t callingPid; member
65 :unloadEvent(ue), systemAbilityId(said), callingPid(cpid) {} in UnloadRequestInfo()
/foundation/communication/dsoftbus/core/common/include/
H A Dsoftbus_permission.h42 int32_t CheckTransPermission(pid_t callingUid, pid_t callingPid,
48 int32_t GrantTransPermission(int32_t callingUid, int32_t callingPid, const char *sessionName);
/foundation/communication/dsoftbus/core/common/security/permission/mini/
H A Dsoftbus_permission.c28 int32_t CheckTransPermission(pid_t callingUid, pid_t callingPid, in CheckTransPermission() argument
32 (void)callingPid; in CheckTransPermission()
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/transaction/
H A Drs_render_service_connection_stub.cpp186 std::shared_ptr<MessageParcel> CopyParcelIfNeed(MessageParcel& old, pid_t callingPid) in CopyParcelIfNeed() argument
189 RSMainThread::Instance()->GetDesktopPidForRotationScene() != callingPid) { in CopyParcelIfNeed()
270 bool IsValidCallingPid(pid_t pid, pid_t callingPid) in IsValidCallingPid() argument
272 return (callingPid == getpid()) || (callingPid == pid); in IsValidCallingPid()
282 pid_t callingPid = GetCallingPid(); in OnRemoteRequest() local
318 parsedParcel = CopyParcelIfNeed(data, callingPid); in OnRemoteRequest()
328 if (!transactionData->IsCallingPidValid(callingPid, nodeMap, conflictCommandPid, in OnRemoteRequest()
330 RS_LOGE("RSRenderServiceConnectionStub::COMMIT_TRANSACTION non-system callingPid %{public}d" in OnRemoteRequest()
332 callingPid, conflictCommandPi in OnRemoteRequest()
[all...]
/foundation/communication/ipc/interfaces/innerkits/ipc_napi_common/include/
H A Dnapi_remote_object.h25 pid_t callingPid; member
36 napi_value callingPid; member
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Drdb_delegate.cpp202 const int32_t callingPid) in Query()
210 if (count > MAX_RESULTSET_COUNT && IsLimit(count, callingPid)) { in Query()
219 ZLOGE("Query failed %{public}s, pid: %{public}d", tableName.c_str(), callingPid); in Query()
226 ZLOGE("query failed, err:%{public}d, pid:%{public}d", E_SQLITE_ERROR, callingPid); in Query()
229 resultSetCallingPids.Compute(callingPid, [](const uint32_t &, int32_t &value) { in Query()
236 std::shared_ptr<DataShareResultSet> result = { new DataShareResultSet(bridge), [callingPid, beginTime](auto p) { in Query()
242 ZLOGE("pid %{public}d query time is %{public}" PRId64 ", %{public}d resultSet is used.", callingPid, in Query()
245 resultSetCallingPids.ComputeIfPresent(callingPid, [](const uint32_t &, int32_t &value) { in Query()
298 bool RdbDelegate::IsLimit(int count, const int32_t callingPid) in IsLimit() argument
316 ZLOGE("resultSetCount is full, pid: %{public}d, owner is %{public}s", callingPid, logSt in IsLimit()
200 Query(const std::string &tableName, const DataSharePredicates &predicates, const std::vector<std::string> &columns, const int32_t callingPid) Query() argument
[all...]
/foundation/communication/dsoftbus/tests/core/bus_center/test/mock/src/
H A Dbus_center_ipc_mock.cpp76 int32_t callingPid, const char *targetNetworkId, TimeSyncAccuracy accuracy, TimeSyncPeriod period) in LnnStartTimeSync()
78 return BusCenterIpcInterfaceInstance()->LnnStartTimeSync(pkgName, callingPid, targetNetworkId, accuracy, period); in LnnStartTimeSync()
81 int32_t LnnStopTimeSync(const char *pkgName, const char *targetNetworkId, int32_t callingPid) in LnnStopTimeSync() argument
83 return BusCenterIpcInterfaceInstance()->LnnStopTimeSync(pkgName, targetNetworkId, callingPid); in LnnStopTimeSync()
75 LnnStartTimeSync(const char *pkgName, int32_t callingPid, const char *targetNetworkId, TimeSyncAccuracy accuracy, TimeSyncPeriod period) LnnStartTimeSync() argument
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_unmarshal_thread.cpp82 void RSUnmarshalThread::RecvParcel(std::shared_ptr<MessageParcel>& parcel, bool isNonSystemAppCalling, pid_t callingPid) in RecvParcel() argument
90 RSTaskMessage::RSTask task = [this, parcel = parcel, isPendingUnmarshal, isNonSystemAppCalling, callingPid]() { in RecvParcel()
102 if (!transData->IsCallingPidValid(callingPid, nodeMap, conflictCommandPid, commandMapDesc)) { in RecvParcel()
103 RS_LOGE("RSUnmarshalThread::RecvParcel non-system callingPid %{public}d" in RecvParcel()
105 callingPid, conflictCommandPid, commandMapDesc.c_str()); in RecvParcel()
107 bool shouldDrop = ReportTransactionDataStatistics(callingPid, transData.get(), isNonSystemAppCalling); in RecvParcel()

Completed in 16 milliseconds

1234