| /foundation/communication/ipc/services/dbinder/c/ipc_adapter/mini/ |
| H A D | dbinder_ipc_adapter.c | 44 ProxyObject *proxyObject = (ProxyObject *)calloc(1, sizeof(ProxyObject)); in RpcGetSystemAbility() local
45 if (proxyObject == NULL) { in RpcGetSystemAbility()
48 proxyObject->proxy = (SvcIdentity *)malloc(sizeof(SvcIdentity)); in RpcGetSystemAbility()
49 if (proxyObject->proxy == NULL) { in RpcGetSystemAbility()
50 free(proxyObject); in RpcGetSystemAbility()
54 if (memcpy_s(proxyObject->proxy, sizeof(SvcIdentity), &target, sizeof(SvcIdentity)) != EOK) { in RpcGetSystemAbility()
55 free(proxyObject->proxy); in RpcGetSystemAbility()
56 free(proxyObject); in RpcGetSystemAbility()
60 return proxyObject; in RpcGetSystemAbility()
|
| /foundation/communication/ipc/services/dbinder/c/ipc_adapter/small/ |
| H A D | dbinder_ipc_adapter.c | 61 ProxyObject *proxyObject = (ProxyObject *)malloc(sizeof(ProxyObject)); in RpcGetSystemAbility() local
62 if (proxyObject == NULL) { in RpcGetSystemAbility()
66 proxyObject->proxy = (SvcIdentity *)malloc(sizeof(SvcIdentity)); in RpcGetSystemAbility()
67 if (proxyObject->proxy == NULL) { in RpcGetSystemAbility()
68 free(proxyObject); in RpcGetSystemAbility()
73 if (memcpy_s(proxyObject->proxy, sizeof(SvcIdentity), &svc, sizeof(SvcIdentity)) != EOK) { in RpcGetSystemAbility()
74 free(proxyObject->proxy); in RpcGetSystemAbility()
75 free(proxyObject); in RpcGetSystemAbility()
81 return proxyObject; in RpcGetSystemAbility()
|
| /foundation/communication/ipc/ipc/native/c/rpc/ipc_adapter/mini/ |
| H A D | ipc_proxy_inner.c | 43 static int32_t MakeInvokerListenReply(ProxyObject *proxyObject, uint64_t stubIndex, IpcIo *reply, uintptr_t *ptr) in MakeInvokerListenReply() argument
57 if (!WriteString(reply, proxyObject->sessionName)) { in MakeInvokerListenReply()
66 int32_t InvokerListenThread(ProxyObject *proxyObject, const char *localDeviceID, const char *remoteDeviceID, in InvokerListenThread() argument
69 if (proxyObject == NULL) { in InvokerListenThread()
73 int32_t sessionNameLen = strlen(proxyObject->sessionName); in InvokerListenThread()
80 if (CreateTransServer(proxyObject->sessionName) != ERR_NONE) { in InvokerListenThread()
96 if (strcpy_s(current->sessionName, sessionNameLen + 1, proxyObject->sessionName) != EOK) { in InvokerListenThread()
107 IpcObjectStub *cookie = (IpcObjectStub *)(proxyObject->proxy->cookie); in InvokerListenThread()
114 return MakeInvokerListenReply(proxyObject, stubIndex, reply, ptr); in InvokerListenThread()
117 int32_t GetPidAndUidInfo(ProxyObject *proxyObject) in GetPidAndUidInfo() argument
[all...] |
| /foundation/communication/ipc/ipc/native/c/rpc/ipc_adapter/small/ |
| H A D | ipc_proxy_inner.c | 115 int32_t InvokerListenThread(ProxyObject *proxyObject, const char *localDeviceID, const char *remoteDeviceID, in InvokerListenThread() argument
118 if (proxyObject == NULL || localDeviceID == NULL || remoteDeviceID == NULL) { in InvokerListenThread()
132 WriteString(&data, proxyObject->sessionName); in InvokerListenThread()
137 int32_t ret = SendRequest(*proxyObject->proxy, INVOKE_LISTEN_THREAD, &data, ipcReply, option, ptr); in InvokerListenThread()
144 int32_t GetPidAndUidInfo(ProxyObject *proxyObject) in GetPidAndUidInfo() argument
146 if (proxyObject == NULL) { in GetPidAndUidInfo()
160 int32_t ret = SendRequest(*proxyObject->proxy, GET_UIDPID_INFO, &data, &reply, option, &ptr); in GetPidAndUidInfo()
170 proxyObject->sessionName = (char *)malloc(len + 1); in GetPidAndUidInfo()
171 if (proxyObject->sessionName == NULL) { in GetPidAndUidInfo()
176 if (strcpy_s(proxyObject in GetPidAndUidInfo()
[all...] |
| /foundation/communication/ipc/services/dbinder/c/src/ |
| H A D | dbinder_service.c | 72 UTILS_DL_LIST proxyObject; member
100 UtilsListInit(&g_proxyObjectList.proxyObject); in InitDBinder()
433 UTILS_DL_LIST_FOR_EACH_ENTRY(node, &g_proxyObjectList.proxyObject, ProxyObject, list) in QueryProxyObject()
447 UtilsListAdd(&g_proxyObjectList.proxyObject, &proxy->list); in AttachProxyObject()
465 ProxyObject *proxyObject = (ProxyObject *)args; in DbinderSaDeathRecipient() local
466 RPC_LOG_INFO("DbinderSaDeathRecipient cbiId %d", proxyObject->cbId); in DbinderSaDeathRecipient()
467 DetachProxyObject(proxyObject); in DbinderSaDeathRecipient()
472 ProxyObject *proxyObject = QueryProxyObject(binderObject); in FindOrNewProxy() local
473 if (proxyObject != NULL) { in FindOrNewProxy()
475 return proxyObject; in FindOrNewProxy()
[all...] |
| /foundation/ability/ability_runtime/interfaces/inner_api/connectionobs_manager/src/ |
| H A D | connection_observer_client_impl.cpp | 247 auto proxyObject = serviceAdapter_->GetProxyObject(); in ResetProxy() local
248 if ((proxyObject != nullptr) && (proxyObject == remote.promote())) { in ResetProxy()
249 proxyObject->RemoveDeathRecipient(deathRecipient_); in ResetProxy()
|
| /foundation/communication/ipc/ipc/native/c/rpc/ipc_adapter/include/ |
| H A D | ipc_proxy_inner.h | 26 int32_t InvokerListenThread(ProxyObject *proxyObject, const char *localDeviceID,
|
| /foundation/multimedia/av_session/services/session/server/migrate/ |
| H A D | migrate_avsession_server.cpp | 82 sptr<IRemoteObject> proxyObject;
in CreateController() local
83 int32_t ret = servicePtr_->CreateControllerInner(sessionId, proxyObject);
in CreateController()
84 if (ret != AVSESSION_SUCCESS && !(ret == ERR_CONTROLLER_IS_EXIST && proxyObject != nullptr)) {
in CreateController()
88 sptr<AVControllerItem> controller = iface_cast<AVControllerItem>(proxyObject);
in CreateController()
|
| /foundation/communication/ipc/ipc/test/auxiliary/native/src/ |
| H A D | test_service_skeleton.cpp | 140 sptr<IRemoteObject> proxyObject = Remote(); in TestMultiThreadSendRequest() local
143 std::thread t([&proxyObject, &data, &reply] { in TestMultiThreadSendRequest()
151 int error = proxyObject->SendRequest(TRANS_ID_SYNC_TRANSACTION, dataParcel, replyParcel, option); in TestMultiThreadSendRequest()
|