Home
last modified time | relevance | path

Searched refs:proto (Results 1 - 25 of 54) sorted by relevance

123

/foundation/communication/ipc/ipc/native/c/manager/src/
H A Dipc_thread_pool.c45 current->proto = IF_PROT_DEFAULT; in GetCurrentThreadContext()
56 RemoteInvoker *invoker = g_invoker[threadContext->proto]; in TlsDestructor()
63 static void ThreadContextDestructor(int32_t proto) in ThreadContextDestructor() argument
67 if (proto == IF_PROT_BINDER) { in ThreadContextDestructor()
69 } else if (proto == IF_PROT_DATABUS) { in ThreadContextDestructor()
75 static RemoteInvoker *GetAndUpdateInvoker(int32_t proto) in GetAndUpdateInvoker() argument
81 threadContext->proto = proto; in GetAndUpdateInvoker()
82 return g_invoker[proto]; in GetAndUpdateInvoker()
88 int32_t proto in ThreadHandler() local
141 SpawnNewThread(ThreadPool *threadPool, int32_t policy, int32_t proto) SpawnNewThread() argument
[all...]
H A Diremote_invoker.c22 RemoteInvoker *InitRemoteInvoker(int32_t proto) in InitRemoteInvoker() argument
25 if (proto == IF_PROT_BINDER) { in InitRemoteInvoker()
33 void DeinitRemoteInvoker(RemoteInvoker *invoker, int32_t proto) in DeinitRemoteInvoker() argument
38 if (proto == IF_PROT_BINDER) { in DeinitRemoteInvoker()
/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_workthread.cpp44 int proto; member
56 std::string IPCWorkThread::MakeBasicThreadName(int proto, int threadIndex) in MakeBasicThreadName() argument
58 if (proto == IRemoteObject::IF_PROT_DATABUS) { in MakeBasicThreadName()
65 void IPCWorkThread::JoinThread(int proto, int policy) in JoinThread() argument
67 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(proto); in JoinThread()
116 IRemoteInvoker *invoker = IPCThreadSkeleton::GetRemoteInvoker(param->proto); in ThreadHandler()
117 std::string basicName = MakeBasicThreadName(param->proto, param->index); in ThreadHandler()
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()
128 JoinThread(param->proto, para in ThreadHandler()
148 Start(int policy, int proto, int threadIndex) Start() argument
[all...]
H A Dipc_thread_pool.cpp76 bool IPCWorkThreadPool::SpawnThread(int policy, int proto) in SpawnThread() argument
79 if (!(proto == IRemoteObject::IF_PROT_DEFAULT && idleThreadNum_ > 0) && in SpawnThread()
80 !(proto == IRemoteObject::IF_PROT_DATABUS && idleSocketThreadNum_ > 0)) { in SpawnThread()
85 (proto != IRemoteObject::IF_PROT_BINDER || !BinderInvoker::IsActvBinderService())) { in SpawnThread()
90 std::string threadName = MakeThreadName(proto, threadIndex); in SpawnThread()
100 if (proto == IRemoteObject::IF_PROT_DEFAULT) { in SpawnThread()
104 if (proto == IRemoteObject::IF_PROT_DATABUS) { in SpawnThread()
108 newThread->Start(policy, proto, threadIndex); in SpawnThread()
114 std::string IPCWorkThreadPool::MakeThreadName(int proto, int &threadIndex) in MakeThreadName() argument
118 return IPCWorkThread::MakeBasicThreadName(proto, sequenc in MakeThreadName()
[all...]
H A Dipc_thread_skeleton.cpp195 IRemoteInvoker *IPCThreadSkeleton::GetRemoteInvoker(int proto) in GetRemoteInvoker() argument
197 if (proto < 0 || static_cast<uint32_t>(proto) >= IPCThreadSkeleton::INVOKER_MAX_COUNT) { in GetRemoteInvoker()
198 ZLOGE(LOG_LABEL, "invalid proto:%{public}d", proto); in GetRemoteInvoker()
216 auto it = current->invokers_[proto]; in GetRemoteInvoker()
221 invoker = factory.newInstance(proto); in GetRemoteInvoker()
226 ZLOGE(LOG_LABEL, "invoker is NULL, proto:%{public}d time:%{public}" PRIu64, proto, curTime); in GetRemoteInvoker()
231 current->invokers_[proto] in GetRemoteInvoker()
277 JoinWorkThread(int proto) JoinWorkThread() argument
285 StopWorkThread(int proto) StopWorkThread() argument
[all...]
/foundation/communication/ipc/ipc/native/c/rpc/ipc_adapter/mini/
H A Dipc_proxy_inner.c153 int32_t proto = IF_PROT_DATABUS; in GetSessionFromDBinderService() local
157 return proto; in GetSessionFromDBinderService()
163 return proto; in GetSessionFromDBinderService()
170 return proto; in GetSessionFromDBinderService()
179 return proto; in GetSessionFromDBinderService()
188 return proto; in GetSessionFromDBinderService()
192 return proto; in GetSessionFromDBinderService()
209 threadContext->proto = IF_PROT_DATABUS; in UpdateProto()
212 threadContext->proto = GetSessionFromDBinderService(svc); in UpdateProto()
213 RPC_LOG_INFO("UpdateProto get proto in UpdateProto()
[all...]
/foundation/communication/netmanager_base/services/netmanagernative/include/netsys/
H A Dnetlink_socket_diag.h63 int32_t ExecuteDestroySocket(uint8_t proto, const inet_diag_msg *msg);
67 int32_t ProcessSockDiagDumpResponse(uint8_t proto, const std::string &ipAddr, bool excludeLoopback);
68 int32_t SendSockDiagDumpRequest(uint8_t proto, uint8_t family, uint32_t states);
69 void SockDiagDumpCallback(uint8_t proto, const inet_diag_msg *msg, const std::string &ipAddr, bool excludeLoopback);
70 void SockDiagUidDumpCallback(uint8_t proto, const inet_diag_msg *msg, const DestroyFilter& destroy);
71 int32_t ProcessSockDiagUidDumpResponse(uint8_t proto, const DestroyFilter& destroy);
/foundation/communication/ipc/ipc/native/c/rpc/ipc_adapter/small/
H A Dipc_proxy_inner.c94 uint32_t proto; in GetSessionFromDBinderService() local
95 if (!ReadUint32(&reply, &proto)) { in GetSessionFromDBinderService()
100 switch (proto) { in GetSessionFromDBinderService()
106 proto = IF_PROT_BINDER; in GetSessionFromDBinderService()
112 return proto; in GetSessionFromDBinderService()
204 int32_t proto; in GetDataBusName() local
205 if (!ReadInt32(&reply, &proto)) { in GetDataBusName()
210 if (proto != IF_PROT_DATABUS) { in GetDataBusName()
249 threadContext->proto = IF_PROT_DATABUS; in UpdateProto()
252 threadContext->proto in UpdateProto()
[all...]
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dnetlink_socket_diag.cpp88 int32_t NetLinkSocketDiag::ExecuteDestroySocket(uint8_t proto, const inet_diag_msg *msg) in ExecuteDestroySocket() argument
101 .sdiag_protocol = proto, in ExecuteDestroySocket()
178 int32_t NetLinkSocketDiag::ProcessSockDiagDumpResponse(uint8_t proto, const std::string &ipAddr, bool excludeLoopback) in ProcessSockDiagDumpResponse() argument
198 SockDiagDumpCallback(proto, msg, ipAddr, excludeLoopback); in ProcessSockDiagDumpResponse()
209 int32_t NetLinkSocketDiag::SendSockDiagDumpRequest(uint8_t proto, uint8_t family, uint32_t states) in SendSockDiagDumpRequest() argument
220 request.req_ = {.sdiag_family = family, .sdiag_protocol = proto, .idiag_states = states}; in SendSockDiagDumpRequest()
231 void NetLinkSocketDiag::SockDiagDumpCallback(uint8_t proto, const inet_diag_msg *msg, const std::string &ipAddr, in SockDiagDumpCallback() argument
257 ExecuteDestroySocket(proto, msg); in SockDiagDumpCallback()
273 const int32_t proto = IPPROTO_TCP; in DestroyLiveSockets() local
277 int32_t ret = SendSockDiagDumpRequest(proto, famil in DestroyLiveSockets()
306 SockDiagUidDumpCallback(uint8_t proto, const inet_diag_msg *msg, const NetLinkSocketDiag::DestroyFilter& needDestroy) SockDiagUidDumpCallback() argument
317 ProcessSockDiagUidDumpResponse(uint8_t proto, const NetLinkSocketDiag::DestroyFilter& needDestroy) ProcessSockDiagUidDumpResponse() argument
361 const int32_t proto = IPPROTO_TCP; DestroyLiveSocketsWithUid() local
[all...]
/foundation/communication/ipc/ipc/native/test/fuzztest/mock/binderinvoker_fuzzer/
H A Dbinderinvoker_fuzzer.cpp61 int proto; in AddDeathRecipientTest() local
63 GenerateInt32(proto); in AddDeathRecipientTest()
64 sptr<IPCObjectProxy> proxy = new IPCObjectProxy(handle, u"proxyTest", proto); in AddDeathRecipientTest()
91 int proto; in FlattenObjectTest() local
93 GenerateInt32(proto); in FlattenObjectTest()
94 sptr<IRemoteObject> obj = new IPCObjectProxy(handle, u"proxyTest", proto); in FlattenObjectTest()
214 int proto; in TranslateIRemoteObjectTest002() local
217 GenerateInt32(proto); in TranslateIRemoteObjectTest002()
218 sptr<IRemoteObject> obj = new IPCObjectProxy(handle, u"", proto); in TranslateIRemoteObjectTest002()
/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_workthread.h44 static std::string MakeBasicThreadName(int proto, int threadIndex);
49 void Start(int policy, int proto, int threadIndex);
59 static void JoinThread(int proto, int policy);
H A Dipc_thread_skeleton.h46 static IRemoteInvoker *GetRemoteInvoker(int proto);
69 void JoinWorkThread(int proto);
71 void StopWorkThread(int proto);
H A Dipc_thread_pool.h46 bool SpawnThread(int policy = IPCWorkThread::SPAWN_PASSIVE, int proto = IRemoteObject::IF_PROT_DEFAULT);
62 std::string MakeThreadName(int proto, int &threadIndex);
/foundation/arkui/ace_engine/frameworks/bridge/js_frontend/engine/jsi/
H A Djsi_offscreen_canvas_bridge.cpp1573 auto proto = argv[0]; in JsFillStyleSetter() local
1574 if (!proto) { in JsFillStyleSetter()
1578 if (proto->IsString(runtime)) { in JsFillStyleSetter()
1579 auto colorStr = proto->ToString(runtime); in JsFillStyleSetter()
1587 auto typeVal = proto->GetProperty(runtime, "__type"); in JsFillStyleSetter()
1590 auto gradient = GetGradient(runtime, proto); in JsFillStyleSetter()
1597 auto pattern = GetPattern(runtime, proto); in JsFillStyleSetter()
1607 value->SetProperty(runtime, "__fillStyle", proto); in JsFillStyleSetter()
1623 auto proto = argv[0]; in JsStrokeStyleSetter() local
1624 if (!proto) { in JsStrokeStyleSetter()
1673 auto proto = argv[0]; JsLineCapSetter() local
1704 auto proto = argv[0]; JsLineJoinSetter() local
1735 auto proto = argv[0]; JsMiterLimitSetter() local
1760 auto proto = argv[0]; JsLineWidthSetter() local
1785 auto proto = argv[0]; JsTextAlignSetter() local
1811 auto proto = argv[0]; JsTextBaselineSetter() local
1838 auto proto = argv[0]; JsFontSetter() local
1884 auto proto = argv[0]; JsAlphaSetter() local
1909 auto proto = argv[0]; JsCompositeOperationSetter() local
1950 auto proto = argv[0]; JsLineDashOffsetSetter() local
1975 auto proto = argv[0]; JsShadowBlurSetter() local
2000 auto proto = argv[0]; JsShadowColorSetter() local
2026 auto proto = argv[0]; JsShadowOffsetXSetter() local
2051 auto proto = argv[0]; JsShadowOffsetYSetter() local
2076 auto proto = argv[0]; JsSmoothingEnabledSetter() local
2101 auto proto = argv[0]; JsSmoothingQualitySetter() local
2129 auto proto = argv[0]; JsFilterParamSetter() local
2162 auto proto = argv[0]; JsIsPointInStroke() local
2205 auto proto = argv[0]; JsIsPointInPath() local
[all...]
H A Djsi_canvas_bridge.cpp1968 auto proto = argv[0]; in JsFillStyleSetter() local
1969 if (!proto) { in JsFillStyleSetter()
1972 if (proto->IsString(runtime)) { in JsFillStyleSetter()
1973 auto colorStr = proto->ToString(runtime); in JsFillStyleSetter()
1978 auto typeVal = proto->GetProperty(runtime, "__type"); in JsFillStyleSetter()
1981 auto gradient = GetGradient(runtime, proto); in JsFillStyleSetter()
1985 auto pattern = GetPattern(runtime, proto); in JsFillStyleSetter()
1992 value->SetProperty(runtime, "__fillStyle", proto); in JsFillStyleSetter()
2008 auto proto = argv[0]; in JsStrokeStyleSetter() local
2009 if (!proto) { in JsStrokeStyleSetter()
2048 auto proto = argv[0]; JsLineCapSetter() local
2077 auto proto = argv[0]; JsLineJoinSetter() local
2106 auto proto = argv[0]; JsMiterLimitSetter() local
2129 auto proto = argv[0]; JsLineWidthSetter() local
2152 auto proto = argv[0]; JsTextAlignSetter() local
2176 auto proto = argv[0]; JsTextBaselineSetter() local
2201 auto proto = argv[0]; JsFontSetter() local
2246 auto proto = argv[0]; JsAlphaSetter() local
2269 auto proto = argv[0]; JsCompositeOperationSetter() local
2308 auto proto = argv[0]; JsLineDashOffsetSetter() local
2331 auto proto = argv[0]; JsShadowBlurSetter() local
2354 auto proto = argv[0]; JsShadowColorSetter() local
2378 auto proto = argv[0]; JsShadowOffsetXSetter() local
2401 auto proto = argv[0]; JsShadowOffsetYSetter() local
2424 auto proto = argv[0]; JsSmoothingEnabledSetter() local
2447 auto proto = argv[0]; JsSmoothingQualitySetter() local
[all...]
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/coap_discover/
H A Dcoap_client.c229 coap_proto_t proto = coapServerParameter->proto; in CoapGetSessionInner() local
232 if (proto != COAP_PROTO_UDP) { in CoapGetSessionInner()
233 DFINDER_LOGE(TAG, "unsupported proto"); in CoapGetSessionInner()
248 session = coap_new_client_session(ctx, &bindAddr, dst, proto); in CoapGetSessionInner()
270 coap_proto_t proto; in CoapGetSessionEx() local
277 proto = coapServerParameter->proto; in CoapGetSessionEx()
279 if (proto != COAP_PROTO_UDP) { in CoapGetSessionEx()
280 DFINDER_LOGE(TAG, "unsupported proto"); in CoapGetSessionEx()
[all...]
/foundation/communication/ipc/ipc/native/c/manager/include/
H A Dipc_thread_pool.h39 int32_t proto; member
61 int32_t SpawnNewThread(ThreadPool *threadPool, int32_t policy, int32_t proto);
H A Diremote_invoker.h44 RemoteInvoker *InitRemoteInvoker(int32_t proto);
45 void DeinitRemoteInvoker(RemoteInvoker *invoker, int32_t proto);
/foundation/graphic/graphic_2d/rosen/modules/platform/ipc_core/
H A Dipc_object_proxy.h28 int proto = IRemoteObject::IF_PROT_DEFAULT);
84 void SetProto(int proto);
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/include/coap_discover/
H A Dcoap_client.h31 coap_proto_t proto; member
/foundation/communication/ipc/interfaces/innerkits/ipc_core/include/
H A Dipc_object_proxy.h45 int proto = IRemoteObject::IF_PROT_DEFAULT);
253 * @param proto Indicates a proxy proto.
257 void SetProto(int proto);
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_native/client/hdi_client/hdi_interface/
H A Dwifi_hdi_common.c420 data->proto = HDI_PROTO_DEFAULT; in HdiConvertIe()
511 data->proto = HDI_PROTO_ONE; in HdiConvertIeRsn()
538 data->proto = HDI_PROTO_THREE; in HdiConvertIeRsn()
646 char* HdiGetIeTxt(char *pos, char *end, const char *proto, const uint8_t *ie, size_t ieLen) in HdiGetIeTxt() argument
652 ret = HdiTxtPrintf(pos, end - pos, "[%s-", proto); in HdiGetIeTxt()
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_native/common/
H A Dwifi_native_struct.h230 std::string proto; member
239 proto("RSN"), in HalP2pGroupConfig()
/foundation/graphic/graphic_3d/3d_widget_adapter/test/
H A D3d_widget_adapter_test.h38 void Clone(IEngine *proto) override{};
/foundation/graphic/graphic_3d/3d_widget_adapter/include/
H A Di_engine.h45 virtual void Clone(IEngine* proto) = 0;

Completed in 18 milliseconds

123