Home
last modified time | relevance | path

Searched refs:invoker (Results 1 - 25 of 39) sorted by relevance

12

/foundation/communication/ipc/ipc/native/test/fuzztest/mock/binderinvoker_fuzzer/
H A Dbinderinvoker_fuzzer.cpp38 BinderInvoker *invoker = new BinderInvoker(); in TransactionTest() local
45 invoker->Transaction(trSecctx); in TransactionTest()
46 delete invoker; in TransactionTest()
56 BinderInvoker *invoker = new BinderInvoker(); in AddDeathRecipientTest() local
57 if (invoker == nullptr) { in AddDeathRecipientTest()
68 delete invoker; in AddDeathRecipientTest()
78 BinderInvoker *invoker = new BinderInvoker(); in WriteFileDescriptorTest() local
79 if (invoker == nullptr) { in WriteFileDescriptorTest()
82 invoker->WriteFileDescriptor(parcel, fd, takeOwnership); in WriteFileDescriptorTest()
83 invoker in WriteFileDescriptorTest()
96 BinderInvoker *invoker = new BinderInvoker(); FlattenObjectTest() local
107 BinderInvoker *invoker = new BinderInvoker(); GetCallerInfoTest() local
132 BinderInvoker *invoker = new BinderInvoker(); SetCallingIdentityTest() local
147 BinderInvoker *invoker = new BinderInvoker(); GetStrongRefCountForStubTest() local
159 BinderInvoker *invoker = new BinderInvoker(); SetRegistryObjectTest001() local
170 BinderInvoker *invoker = new BinderInvoker(); SetRegistryObjectTest002() local
183 BinderInvoker *invoker = new BinderInvoker(); SetRegistryObjectTest003() local
195 BinderInvoker *invoker = new BinderInvoker(); TranslateIRemoteObjectTest001() local
208 BinderInvoker *invoker = new BinderInvoker(); TranslateIRemoteObjectTest002() local
[all...]
/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_skeleton.cpp99 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); in GetCallingSid() local
100 if (invoker != nullptr) { in GetCallingSid()
101 return invoker->GetCallerSid(); in GetCallingSid()
108 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); in GetCallingPid() local
109 if (invoker != nullptr) { in GetCallingPid()
110 return invoker->GetCallerPid(); in GetCallingPid()
117 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); in GetCallingRealPid() local
118 if (invoker != nullptr) { in GetCallingRealPid()
119 return invoker->GetCallerRealPid(); in GetCallingRealPid()
126 IRemoteInvoker *invoker in GetCallingUid() local
135 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); GetCallingTokenID() local
144 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); GetCallingFullTokenID() local
153 IRemoteInvoker *invoker = IPCThreadSkeleton::GetDefaultInvoker(); GetSelfTokenID() local
162 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); GetFirstTokenID() local
175 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); GetFirstFullTokenID() local
188 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); GetLocalDeviceID() local
197 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); GetCallingDeviceID() local
212 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); IsLocalCalling() local
221 IRemoteInvoker *invoker = IPCThreadSkeleton::GetProxyInvoker(object); FlushCommands() local
244 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); ResetCallingIdentity() local
253 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); SetCallingIdentity() local
[all...]
H A Diremote_object.cpp37 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DEFAULT); in Marshalling() local
38 if (invoker != nullptr) { in Marshalling()
39 return invoker->FlattenObject(parcel, this); in Marshalling()
47 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DEFAULT); in Marshalling() local
48 if (invoker != nullptr) { in Marshalling()
49 return invoker->FlattenObject(parcel, object); in Marshalling()
57 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DEFAULT); in Unmarshalling() local
58 if (invoker != nullptr) { in Unmarshalling()
59 return invoker->UnflattenObject(parcel); in Unmarshalling()
H A Dipc_file_descriptor.cpp65 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DEFAULT); in Marshalling() local
66 if (invoker != nullptr) { in Marshalling()
67 return invoker->WriteFileDescriptor(parcel, fd_, false); in Marshalling()
75 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DEFAULT); in Marshalling() local
76 if (invoker != nullptr) { in Marshalling()
77 return invoker->WriteFileDescriptor(parcel, object->GetFd(), false); in Marshalling()
85 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DEFAULT); in Unmarshalling() local
88 if (invoker != nullptr) { in Unmarshalling()
89 fd = invoker->ReadFileDescriptor(parcel); in Unmarshalling()
H A Dipc_workthread.cpp67 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(proto); in JoinThread() local
68 if (invoker != nullptr) { in JoinThread()
71 invoker->JoinThread(false); in JoinThread()
74 invoker->JoinThread(true); in JoinThread()
77 invoker->JoinProcessThread(false); in JoinThread()
80 invoker->JoinProcessThread(true); in JoinThread()
116 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(param->proto); in ThreadHandler() local
123 ZLOGI(LOG_LABEL, "proto:%{public}d policy:%{public}d name:%{public}s invoker:%{public}u", in ThreadHandler()
124 param->proto, param->policy, threadName.c_str(), ProcessSkeleton::ConvertAddr(invoker)); in ThreadHandler()
134 ZLOGI(LOG_LABEL, "exit, proto:%{public}d policy:%{public}d name:%{public}s invoker in ThreadHandler()
142 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(proto_); StopWorkThread() local
[all...]
H A Dipc_thread_skeleton.cpp69 BinderInvoker *invoker = reinterpret_cast<BinderInvoker *>(current->invokers_[itemIndex]); in TlsDestructor() local
70 invoker->FlushCommands(nullptr); in TlsDestructor()
71 invoker->ExitCurrentThread(); in TlsDestructor()
164 for (auto &invoker : invokers_) { in ~IPCThreadSkeleton()
165 delete invoker; in ~IPCThreadSkeleton()
166 invoker = nullptr; in ~IPCThreadSkeleton()
215 IRemoteInvoker *invoker = nullptr; in GetRemoteInvoker() local
218 invoker = it; in GetRemoteInvoker()
221 invoker = factory.newInstance(proto); in GetRemoteInvoker()
222 if (invoker in GetRemoteInvoker()
279 IRemoteInvoker *invoker = GetRemoteInvoker(proto); JoinWorkThread() local
287 IRemoteInvoker *invoker = GetRemoteInvoker(proto); StopWorkThread() local
[all...]
H A Ddatabus_socket_listener.cpp78 DBinderDatabusInvoker *invoker = in ServerOnBind() local
80 if (invoker == nullptr) { in ServerOnBind()
81 ZLOGE(LABEL, "fail to get invoker"); in ServerOnBind()
85 invoker->OnReceiveNewConnection(socket, std::stoi(peerPid), std::stoi(peerUid), peerName, networkId); in ServerOnBind()
91 DBinderDatabusInvoker *invoker = in ServerOnShutdown() local
93 if (invoker == nullptr) { in ServerOnShutdown()
94 ZLOGE(LABEL, "fail to get invoker"); in ServerOnShutdown()
97 invoker->OnDatabusSessionServerSideClosed(socket); in ServerOnShutdown()
108 DBinderDatabusInvoker *invoker = in ClientOnShutdown() local
110 if (invoker in ClientOnShutdown()
134 DBinderDatabusInvoker *invoker = OnBytesReceived() local
[all...]
H A Dipc_object_proxy.cpp189 IRemoteInvoker *invoker = nullptr; in SendRequestInner() local
191 invoker = IPCThreadSkeleton::GetDefaultInvoker(); in SendRequestInner()
193 invoker = IPCThreadSkeleton::GetRemoteInvoker(proto_); in SendRequestInner()
195 if (invoker == nullptr) { in SendRequestInner()
196 ZLOGE(LABEL, "invoker is null, handle:%{public}u proto:%{public}d", handle_, proto_); in SendRequestInner()
201 int status = invoker->SendRequest(handle_, code, data, reply, option); in SendRequestInner()
335 IRemoteInvoker *invoker = IPCThreadSkeleton::GetDefaultInvoker(); in OnFirstStrongRef() local
336 if (invoker != nullptr) { in OnFirstStrongRef()
337 invoker->AcquireHandle(handle_); in OnFirstStrongRef()
412 IRemoteInvoker *invoker in OnLastStrongRef() local
532 IRemoteInvoker *invoker = IPCThreadSkeleton::GetDefaultInvoker(); SendObituary() local
563 IRemoteInvoker *invoker = IPCThreadSkeleton::GetDefaultInvoker(); ClearDeathRecipients() local
611 BinderInvoker *invoker = reinterpret_cast<BinderInvoker *>(IPCThreadSkeleton::GetDefaultInvoker()); GetStrongRefCountForStub() local
850 DBinderDatabusInvoker *invoker = MakeDBinderTransSession() local
1022 IRemoteInvoker *invoker = IPCThreadSkeleton::GetDefaultInvoker(); RegisterBinderDeathRecipient() local
1043 IRemoteInvoker *invoker = IPCThreadSkeleton::GetDefaultInvoker(); UnRegisterBinderDeathRecipient() local
[all...]
/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_skeleton_unittest.cpp74 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
76 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
78 EXPECT_CALL(*invoker, GetStatus()) in HWTEST_F()
83 delete invoker; in HWTEST_F()
96 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
98 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
100 EXPECT_CALL(*invoker, GetStatus()) in HWTEST_F()
106 delete invoker; in HWTEST_F()
118 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
120 current->invokers_[IRemoteObject::IF_PROT_BINDER] = invoker; in HWTEST_F()
143 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
168 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
234 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
262 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
293 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
319 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
345 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
370 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
400 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
426 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
450 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
476 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
[all...]
H A Dinvoker_factory_unittest.cpp54 IRemoteInvoker* invoker = nullptr; in HWTEST_F() local
55 auto invokerObject = [&invoker]() -> IRemoteInvoker* { in HWTEST_F()
56 invoker = new (std::nothrow) BinderInvoker(); in HWTEST_F()
57 if (invoker == nullptr) { in HWTEST_F()
60 return invoker; in HWTEST_F()
65 if (invoker != nullptr) { in HWTEST_F()
66 delete invoker; in HWTEST_F()
67 invoker = nullptr; in HWTEST_F()
75 if (invoker != nullptr) { in HWTEST_F()
76 delete invoker; in HWTEST_F()
[all...]
H A Dipc_capi_skeleton_unittest.cpp102 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
104 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
106 EXPECT_CALL(*invoker, GetStatus()) in HWTEST_F()
111 delete invoker; in HWTEST_F()
116 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
118 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
120 EXPECT_CALL(*invoker, GetStatus()) in HWTEST_F()
126 delete invoker; in HWTEST_F()
132 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
134 current->invokers_[IRemoteObject::IF_PROT_BINDER] = invoker; in HWTEST_F()
176 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
195 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
221 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
247 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
[all...]
H A Ddbinder_callback_stub_unittest.cpp149 BinderInvoker *invoker = new BinderInvoker(); in HWTEST_F() local
150 invoker->status_ = IRemoteInvoker::ACTIVE_INVOKER; in HWTEST_F()
151 invoker->callerPid_ = 1; in HWTEST_F()
152 invoker->callerUid_ = 1; in HWTEST_F()
154 current->invokers_[IRemoteObject::IF_PROT_DATABUS] = invoker; in HWTEST_F()
159 delete invoker; in HWTEST_F()
216 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
218 current->invokers_[IRemoteObject::IF_PROT_BINDER] = invoker; in HWTEST_F()
220 EXPECT_CALL(*invoker, GetStatus()) in HWTEST_F()
223 EXPECT_CALL(*invoker, GetCallerPi in HWTEST_F()
254 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
[all...]
H A Dipc_object_stub_unittest.cpp321 BinderInvoker *invoker = new BinderInvoker(); in HWTEST_F() local
322 invoker->status_ = IRemoteInvoker::ACTIVE_INVOKER; in HWTEST_F()
323 invoker->callerUid_ = ALLOWED_UID; in HWTEST_F()
325 current->invokers_[IRemoteObject::IF_PROT_BINDER] = invoker; in HWTEST_F()
329 delete invoker; in HWTEST_F()
345 BinderInvoker *invoker = new BinderInvoker(); in HWTEST_F() local
346 invoker->status_ = IRemoteInvoker::ACTIVE_INVOKER; in HWTEST_F()
347 invoker->callerUid_ = ALLOWED_UID; in HWTEST_F()
349 current->invokers_[IRemoteObject::IF_PROT_BINDER] = invoker; in HWTEST_F()
354 delete invoker; in HWTEST_F()
386 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
435 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
512 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
552 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
587 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
1038 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
1078 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
1118 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
1164 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
1189 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
[all...]
H A Dipc_file_desc_unittest.cpp105 BinderInvoker *invoker = nullptr; in HWTEST_F() local
107 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
120 BinderInvoker *invoker = nullptr; in HWTEST_F() local
122 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
136 BinderInvoker *invoker = new BinderInvoker(); in HWTEST_F() local
137 invoker->WriteFileDescriptor(parcel, fd, true); in HWTEST_F()
139 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
H A Dipc_object_proxy_unittest.cpp104 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
106 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
108 EXPECT_CALL(*invoker, GetStatus()) in HWTEST_F()
111 EXPECT_CALL(*invoker, SendRequest(testing::_, testing::_, testing::_, testing::_, testing::_)) in HWTEST_F()
117 delete invoker; in HWTEST_F()
235 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); in HWTEST_F() local
237 current->invokers_[IRemoteObject::IF_PROT_BINDER] = invoker; in HWTEST_F()
238 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker; in HWTEST_F()
240 EXPECT_CALL(*invoker, GetStatus()) in HWTEST_F()
243 EXPECT_CALL(*invoker, SendReques in HWTEST_F()
263 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
353 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
381 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
409 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
796 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
937 IRemoteInvoker *invoker = nullptr; HWTEST_F() local
1345 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
1371 MockIRemoteInvoker *invoker = new MockIRemoteInvoker(); HWTEST_F() local
[all...]
H A Dipc_binder_databus_invoker_unittest.cpp301 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DEFAULT); in HWTEST_F() local
302 ASSERT_NE(invoker, nullptr); in HWTEST_F()
308 delete invoker; in HWTEST_F()
1082 MockIRemoteInvoker *invoker = new MockIRemoteInvoker();
1084 current->invokers_[IRemoteObject::IF_PROT_BINDER] = invoker;
1085 current->invokers_[IRemoteObject::IF_PROT_DEFAULT] = invoker;
1087 EXPECT_CALL(*invoker, GetStatus())
1090 EXPECT_CALL(*invoker, GetSelfFirstCallerTokenID())
1096 delete invoker;
/foundation/communication/ipc/ipc/native/test/fuzztest/mock/dbinderdatabusinvoker_fuzzer/
H A Ddbinderdatabusinvoker_fuzzer.cpp35 DBinderDatabusInvoker invoker; in AcquireHandleTest() local
37 int ret = invoker.AcquireHandle(testHandle); in AcquireHandleTest()
50 DBinderDatabusInvoker invoker; in ReleaseHandleTest() local
52 int ret = invoker.ReleaseHandle(testHandle); in ReleaseHandleTest()
65 DBinderDatabusInvoker invoker; in QueryClientSessionObjectTest() local
68 testPeer = invoker.QueryClientSessionObject(testHandle); in QueryClientSessionObjectTest()
81 DBinderDatabusInvoker invoker; in QueryServerSessionObjectTest() local
84 testPeer = invoker.QueryServerSessionObject(testHandle); in QueryServerSessionObjectTest()
97 DBinderDatabusInvoker invoker; in OnMessageAvailableTest() local
101 invoker in OnMessageAvailableTest()
111 DBinderDatabusInvoker invoker; JoinThreadTest() local
123 DBinderDatabusInvoker invoker; StopWorkThreadTest() local
134 DBinderDatabusInvoker invoker; GetCallerPidTest() local
145 DBinderDatabusInvoker invoker; GetStatusTest() local
156 DBinderDatabusInvoker invoker; GetCallerUidTest() local
167 DBinderDatabusInvoker invoker; GetCallerTokenIDTest() local
178 DBinderDatabusInvoker invoker; GetFirstTokenIDTest() local
189 DBinderDatabusInvoker invoker; IsLocalCallingTest() local
202 DBinderDatabusInvoker invoker; FlushCommandsTest() local
216 DBinderDatabusInvoker invoker; ResetCallingIdentityTest() local
232 DBinderDatabusInvoker invoker; MakeThreadProcessInfoTest() local
248 DBinderDatabusInvoker invoker; ProcessTransactionTest() local
261 DBinderDatabusInvoker invoker; CheckTransactionDataTest() local
[all...]
/foundation/filemanagement/dfs_service/test/unittests/cloudsync_sa/system/reimplement/
H A Dipc_skeleton.cpp74 IRemoteInvoker *invoker = IPCThreadSkeleton::GetActiveInvoker(); in GetCallingFullTokenID() local
75 if (invoker != nullptr) { in GetCallingFullTokenID()
76 return invoker->GetCallerTokenID(); in GetCallingFullTokenID()
83 IRemoteInvoker *invoker = IPCThreadSkeleton::GetDefaultInvoker(); in GetSelfTokenID() local
84 if (invoker != nullptr) { in GetSelfTokenID()
85 return invoker->GetSelfTokenID(); in GetSelfTokenID()
/foundation/communication/ipc/ipc/native/c/manager/src/
H A Dipc_process_skeleton.c59 RemoteInvoker *invoker = GetRemoteInvoker(); in IpcProcessSkeleton() local
60 if (invoker == NULL) { in IpcProcessSkeleton()
62 RPC_LOG_ERROR("get remote invoker failed."); in IpcProcessSkeleton()
65 if ((invoker->SetMaxWorkThread)(SET_MAX_THREADS_DEFAULT) != ERR_NONE) { in IpcProcessSkeleton()
118 RemoteInvoker *invoker = GetRemoteInvoker(); in SetMaxWorkThread() local
119 if (invoker != NULL) { in SetMaxWorkThread()
120 return (invoker->SetMaxWorkThread)(maxThreadNum); in SetMaxWorkThread()
128 RemoteInvoker *invoker = GetRemoteInvoker(); in JoinMainWorkThread() local
129 if (invoker != NULL) { in JoinMainWorkThread()
130 (invoker in JoinMainWorkThread()
164 RemoteInvoker *invoker = GetRemoteInvoker(); SetRegistryObject() local
193 RemoteInvoker *invoker = GetRemoteInvoker(); DeleteHandle() local
206 RemoteInvoker *invoker = GetRemoteInvoker(); ProcessSendRequest() local
215 RemoteInvoker *invoker = GetRemoteInvoker(); ProcessFreeBuffer() local
261 RemoteInvoker *invoker = GetRemoteInvoker(); OnFirstStrongRef() local
323 RemoteInvoker *invoker = GetRemoteInvoker(); ProcessAddDeathRecipient() local
397 RemoteInvoker *invoker = GetRemoteInvoker(); SendObituary() local
447 RemoteInvoker *invoker = GetRemoteInvoker(); ResetIpc() local
[all...]
H A Diremote_invoker.c33 void DeinitRemoteInvoker(RemoteInvoker *invoker, int32_t proto) in DeinitRemoteInvoker() argument
35 if (invoker == NULL) { in DeinitRemoteInvoker()
39 DeinitIpcInvoker(invoker); in DeinitRemoteInvoker()
H A Dipc_thread_pool.c56 RemoteInvoker *invoker = g_invoker[threadContext->proto]; in TlsDestructor() local
58 if (invoker != NULL && invoker->ExitCurrentThread != NULL) { in TlsDestructor()
59 (invoker->ExitCurrentThread)(); in TlsDestructor()
92 RemoteInvoker *invoker = GetAndUpdateInvoker(proto); in ThreadHandler() local
93 if (invoker != NULL) { in ThreadHandler()
96 invoker->JoinThread(false); in ThreadHandler()
99 invoker->JoinThread(true); in ThreadHandler()
/foundation/communication/ipc/ipc/native/c/ipc/include/
H A Dipc_invoker.h26 void DeinitIpcInvoker(RemoteInvoker *invoker);
/foundation/arkui/napi/interfaces/inner_api/cjffi/native/
H A Dcj_lambda.h111 auto invoker = CJFFIFnInvoker::GetInstance()->GetCJFuncs().atCOHOSFFICallbackInvoker;
112 invoker(lambdaId, argc, argv, result);
/foundation/communication/ipc/ipc/native/c/manager/include/
H A Diremote_invoker.h45 void DeinitRemoteInvoker(RemoteInvoker *invoker, int32_t proto);
/foundation/communication/ipc/ipc/native/src/mock/source/
H A Dbinder_invoker.cpp357 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DATABUS); in AddCommAuth() local
358 if (invoker == nullptr) { in AddCommAuth()
359 ZLOGE(LABEL, "invoker is null"); in AddCommAuth()
362 if (invoker->SendRequest(flat->handle, DBINDER_ADD_COMMAUTH, data2, reply2, option2) != ERR_NONE) { in AddCommAuth()
1373 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(IRemoteObject::IF_PROT_DEFAULT); in Dealloc() local
1374 if (invoker != nullptr) { in Dealloc()
1375 invoker->FreeBuffer(data); in Dealloc()
1773 BinderInvoker *invoker = reinterpret_cast<BinderInvoker *>(remoteInvoker); in JoinActvThread() local
1775 if (invoker != nullptr) { in JoinActvThread()
1776 invoker in JoinActvThread()
1785 BinderInvoker *invoker = reinterpret_cast<BinderInvoker *>(remoteInvoker); IsActvBinderService() local
[all...]

Completed in 16 milliseconds

12