Home
last modified time | relevance | path

Searched refs:endpoint (Results 1 - 19 of 19) sorted by relevance

/foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/
H A Dendpoint.c15 #include "endpoint.h"
73 static int RegisterRemoteFeatures(Endpoint *endpoint);
74 static void Listen(Endpoint *endpoint);
77 static int AddPolicyToRouter(const Endpoint *endpoint, const SvcIdentity *saInfo,
86 Endpoint *endpoint = SAMGR_Malloc(sizeof(Endpoint)); in SAMGR_CreateEndpoint() local
87 if (endpoint == NULL) { in SAMGR_CreateEndpoint()
90 endpoint->deadId = INVALID_INDEX; in SAMGR_CreateEndpoint()
91 endpoint->context = OpenLiteIpc(LITEIPC_DEFAULT_MAP_SIZE); in SAMGR_CreateEndpoint()
92 endpoint->boss = NULL; in SAMGR_CreateEndpoint()
93 endpoint in SAMGR_CreateEndpoint()
104 SAMGR_AddRouter(Endpoint *endpoint, const SaName *saName, const Identity *id, IUnknown *proxy) SAMGR_AddRouter() argument
142 SAMGR_AddSysCap(const Endpoint *endpoint, const char *sysCap, BOOL isReg) SAMGR_AddSysCap() argument
174 SAMGR_GetSysCap(const Endpoint *endpoint, const char *sysCap, BOOL *isReg) SAMGR_GetSysCap() argument
207 SendGetAllSysCapsRequest(const Endpoint *endpoint, uint32 startIdx, IpcIo *reply, void **replyBuf) SendGetAllSysCapsRequest() argument
251 SAMGR_GetSystemCapabilities(const Endpoint *endpoint, char sysCaps[MAX_SYSCAP_NUM][MAX_SYSCAP_NAME_LEN], int32 *sysCapNum) SAMGR_GetSystemCapabilities() argument
280 SAMGR_ProcPolicy(const Endpoint *endpoint, const SaName *saName, int token) SAMGR_ProcPolicy() argument
310 Listen(Endpoint *endpoint) Listen() argument
319 AddPolicyToRouter(const Endpoint *endpoint, const SvcIdentity *saInfo, const PolicyTrans *policy, uint32 policyNum) AddPolicyToRouter() argument
357 Endpoint *endpoint = (Endpoint *)argv; Receive() local
398 Endpoint *endpoint = (Endpoint *)argv; Dispatch() local
440 Endpoint *endpoint = (Endpoint *)response->data; HandleIpc() local
523 RegisterRemoteFeatures(Endpoint *endpoint) RegisterRemoteFeatures() argument
581 Endpoint *endpoint = (Endpoint *)argv; OnSamgrServerExit() local
[all...]
H A Dsamgr_small_ipc_adapter.c19 Endpoint *endpoint; member
27 static int RegisterRemoteFeatures(Endpoint *endpoint);
70 void Listen(Endpoint *endpoint, int token, const char *service, const char *feature) in Listen() argument
72 if (endpoint->boss != NULL) { in Listen()
75 ThreadAttr attr = {endpoint->name, MAX_STACK_SIZE, PRI_ABOVE_NORMAL, 0, 0}; in Listen()
88 objectStubOne->args = endpoint; in Listen()
90 endpoint->identity.cookie = objectStubOne; in Listen()
92 endpoint->identity.handle = INVALID_INDEX; in Listen()
93 endpoint->identity.token = SERVICE_TYPE_NORMAL; in Listen()
95 registerEpArg->endpoint in Listen()
140 RegisterRemoteFeatures(Endpoint *endpoint) RegisterRemoteFeatures() argument
202 Endpoint *endpoint = (Endpoint *)option.args; Dispatch() local
233 Endpoint *endpoint = (Endpoint *)response->data; HandleIpc() local
279 Endpoint *endpoint = (Endpoint *)argv; OnSamgrServerExit() local
[all...]
H A Dendpoint_rpc.c15 #include "endpoint.h"
36 static int AddPolicyToRouter(const Endpoint *endpoint, const SvcIdentity *saInfo,
42 Endpoint *endpoint = SAMGR_Malloc(sizeof(Endpoint)); in SAMGR_CreateEndpoint() local
43 if (endpoint == NULL) { in SAMGR_CreateEndpoint()
46 endpoint->deadId = INVALID_INDEX; in SAMGR_CreateEndpoint()
47 endpoint->boss = NULL; in SAMGR_CreateEndpoint()
48 endpoint->routers = VECTOR_Make((VECTOR_Key)GetIServerProxy, (VECTOR_Compare)CompareIServerProxy); in SAMGR_CreateEndpoint()
49 endpoint->name = name; in SAMGR_CreateEndpoint()
50 endpoint->running = FALSE; in SAMGR_CreateEndpoint()
51 endpoint in SAMGR_CreateEndpoint()
59 SAMGR_AddRouter(Endpoint *endpoint, const SaName *saName, const Identity *id, IUnknown *proxy) SAMGR_AddRouter() argument
101 SAMGR_AddSysCap(const Endpoint *endpoint, const char *sysCap, BOOL isReg) SAMGR_AddSysCap() argument
137 SAMGR_GetSysCap(const Endpoint *endpoint, const char *sysCap, BOOL *isReg) SAMGR_GetSysCap() argument
174 SendGetAllSysCapsRequest(const Endpoint *endpoint, uint32 startIdx, IpcIo *reply, void **replyBuf) SendGetAllSysCapsRequest() argument
228 SAMGR_GetSystemCapabilities(const Endpoint *endpoint, char sysCaps[MAX_SYSCAP_NUM][MAX_SYSCAP_NAME_LEN], int32 *sysCapNum) SAMGR_GetSystemCapabilities() argument
257 SAMGR_ProcPolicy(const Endpoint *endpoint, const SaName *saName, int token) SAMGR_ProcPolicy() argument
287 AddPolicyToRouter(const Endpoint *endpoint, const SvcIdentity *saInfo, const PolicyTrans *policy, uint32 policyNum) AddPolicyToRouter() argument
[all...]
H A Dendpoint.h72 int SAMGR_AddRouter(Endpoint *endpoint, const SaName *saName, const Identity *id, IUnknown *proxy);
73 int SAMGR_ProcPolicy(const Endpoint *endpoint, const SaName *saName, int token);
74 int32 SAMGR_AddSysCap(const Endpoint *endpoint, const char *sysCap, BOOL isReg);
75 int32 SAMGR_GetSysCap(const Endpoint *endpoint, const char *sysCap, BOOL *isReg);
76 int32 SAMGR_GetSystemCapabilities(const Endpoint *endpoint,
H A Dsamgr_mini_ipc_adapter.c37 void Listen(Endpoint *endpoint, int token, const char *service, const char *feature) in Listen() argument
39 endpoint->registerEP(&endpoint->identity, token, service, feature); in Listen()
44 Endpoint *endpoint = g_remoteRegister.endpoint; in Dispatch() local
49 if (TB_CheckMessage(&endpoint->bucket) == BUCKET_BUSY) { in Dispatch()
54 Router *router = VECTOR_At(&endpoint->routers, token); in Dispatch()
56 HILOG_ERROR(HILOG_MODULE_SAMGR, "Router <%s, %u> is NULL", endpoint->name, token); in Dispatch()
60 resp.data = endpoint; in Dispatch()
81 Endpoint *endpoint in HandleIpc() local
[all...]
H A Dsamgr_ipc_adapter.h18 #include "endpoint.h"
44 Endpoint *endpoint; member
84 void Listen(Endpoint *endpoint, int token, const char *service, const char *feature);
/foundation/systemabilitymgr/samgr_lite/samgr_client/source/
H A Dremote_register.c47 int32 token = SAMGR_AddRouter(g_remoteRegister.endpoint, &saName, identity, iUnknown); in SAMGR_RegisterServiceApi()
49 if (token < 0 || !g_remoteRegister.endpoint->running) { in SAMGR_RegisterServiceApi()
52 return SAMGR_ProcPolicy(g_remoteRegister.endpoint, &saName, token); in SAMGR_RegisterServiceApi()
67 IUnknown *proxy = SAMGR_CreateIProxy(g_remoteRegister.endpoint->context, service, feature); in SAMGR_FindServiceApi()
87 return SAMGR_AddSysCap(g_remoteRegister.endpoint, sysCap, isReg); in SAMGR_RegisterSystemCapabilityApi()
94 if (SAMGR_GetSysCap(g_remoteRegister.endpoint, sysCap, &isReg) != EC_SUCCESS) { in SAMGR_QuerySystemCapabilityApi()
103 return SAMGR_GetSystemCapabilities(g_remoteRegister.endpoint, sysCaps, size); in SAMGR_GetSystemCapabilitiesApi()
108 if (g_remoteRegister.endpoint == NULL) { in ClearRegistry()
115 VECTOR_Clear(&(g_remoteRegister.endpoint->routers)); in ClearRegistry()
116 CloseLiteIpc(g_remoteRegister.endpoint in ClearRegistry()
[all...]
H A Dremote_register_rpc.c53 int32 token = SAMGR_AddRouter(g_remoteRegister.endpoint, &saName, identity, iUnknown); in SAMGR_RegisterServiceApi()
64 if (token < 0 || !g_remoteRegister.endpoint->running) { in SAMGR_RegisterServiceApi()
68 SAMGR_ProcPolicy(g_remoteRegister.endpoint, &saName, token); in SAMGR_RegisterServiceApi()
104 return SAMGR_AddSysCap(g_remoteRegister.endpoint, sysCap, isReg); in SAMGR_RegisterSystemCapabilityApi()
111 if (SAMGR_GetSysCap(g_remoteRegister.endpoint, sysCap, &isReg) != EC_SUCCESS) { in SAMGR_QuerySystemCapabilityApi()
120 return SAMGR_GetSystemCapabilities(g_remoteRegister.endpoint, sysCaps, size); in SAMGR_GetSystemCapabilitiesApi()
125 if (g_remoteRegister.endpoint == NULL) { in ClearRegistry()
132 VECTOR_Clear(&(g_remoteRegister.endpoint->routers)); in ClearRegistry()
133 SAMGR_Free(g_remoteRegister.endpoint); in ClearRegistry()
134 g_remoteRegister.endpoint in ClearRegistry()
[all...]
H A Dremote_register.h19 #include "endpoint.h"
29 Endpoint *endpoint; member
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
H A Dend_point_test.cpp142 * @tc.desc: test the SetEndpoint(std::shared_ptr<Endpoint> endpoint)
150 std::shared_ptr<EndpointMock> endpoint = nullptr; in HWTEST_F() local
151 Status status = manager.SetEndpoint(endpoint); in HWTEST_F()
157 * @tc.desc: test the SetEndpoint(std::shared_ptr<Endpoint> endpoint)
165 std::shared_ptr<EndpointMock> endpoint = std::make_shared<EndpointMock>(); in HWTEST_F() local
166 Status status = manager.SetEndpoint(endpoint); in HWTEST_F()
168 status = manager.SetEndpoint(endpoint); in HWTEST_F()
187 std::shared_ptr<EndpointMock> endpoint = std::make_shared<EndpointMock>(); in HWTEST_F() local
188 Status status = manager.SetEndpoint(endpoint); in HWTEST_F()
209 std::shared_ptr<EndpointMock> endpoint in HWTEST_F() local
[all...]
/foundation/multimedia/audio_framework/services/audio_service/server/src/
H A Daudio_service.cpp96 AUDIO_INFO_LOG("find endpoint unlink, call delay release."); in OnProcessRelease()
543 CHECK_AND_RETURN_RET_LOG(audioEndpoint != nullptr, nullptr, "no endpoint found for the process"); in GetAudioProcess()
580 CHECK_AND_RETURN_LOG(ret == SUCCESS, "Unlink process to old endpoint failed"); in ResetAudioEndpoint()
584 AUDIO_INFO_LOG("Erase endpoint %{public}s from endpointList_", endpointName.c_str()); in ResetAudioEndpoint()
591 CHECK_AND_RETURN_LOG(audioEndpoint != nullptr, "Get new endpoint failed"); in ResetAudioEndpoint()
603 void AudioService::CheckInnerCapForProcess(sptr<AudioProcessInServer> process, std::shared_ptr<AudioEndpoint> endpoint) in CheckInnerCapForProcess() argument
613 endpoint->EnableFastInnerCap(); in CheckInnerCapForProcess()
632 std::shared_ptr<AudioEndpoint> endpoint) in LinkProcessToEndpoint()
634 int32_t ret = endpoint->LinkProcessStream(process); in LinkProcessToEndpoint()
635 if (ret != SUCCESS && endpoint in LinkProcessToEndpoint()
631 LinkProcessToEndpoint(sptr<AudioProcessInServer> process, std::shared_ptr<AudioEndpoint> endpoint) LinkProcessToEndpoint() argument
657 UnlinkProcessToEndpoint(sptr<AudioProcessInServer> process, std::shared_ptr<AudioEndpoint> endpoint) UnlinkProcessToEndpoint() argument
755 std::shared_ptr<AudioEndpoint> endpoint = AudioEndpoint::CreateEndpoint(isVoipStream ? GetAudioEndpointForDevice() local
765 std::shared_ptr<AudioEndpoint> endpoint = AudioEndpoint::CreateEndpoint(AudioEndpoint::TYPE_INDEPENDENT, GetAudioEndpointForDevice() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Ddistributed_kv_data_manager.cpp189 Status DistributedKvDataManager::SetEndpoint(std::shared_ptr<Endpoint> endpoint) in SetEndpoint() argument
192 if (endpoint == nullptr) { in SetEndpoint()
209 auto communicator = std::make_shared<ProcessCommunicationImpl>(endpoint); in SetEndpoint()
217 auto systemApi = std::make_shared<ProcessSystemApiAdapterImpl>(endpoint); in SetEndpoint()
225 auto permissionCallback = [endpoint](const DistributedDB::PermissionCheckParam &param, uint8_t flag) -> bool { in SetEndpoint()
230 return endpoint->HasDataSyncPermission(params, flag); in SetEndpoint()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dprocess_communication_impl.cpp24 ProcessCommunicationImpl::ProcessCommunicationImpl(std::shared_ptr<Endpoint> endpoint) in ProcessCommunicationImpl() argument
25 : endpoint_(endpoint) in ProcessCommunicationImpl()
37 ZLOGE("endpoint Start Fail: %{public}d", errCode); in Start()
48 ZLOGE("endpoint Stop Fail: %{public}d", errCode); in Stop()
H A Dprocess_system_api_adapter_impl.cpp30 ProcessSystemApiAdapterImpl::ProcessSystemApiAdapterImpl(std::shared_ptr<Endpoint> endpoint) in ProcessSystemApiAdapterImpl() argument
31 : endpoint_(endpoint) in ProcessSystemApiAdapterImpl()
/foundation/multimedia/audio_framework/services/audio_service/server/include/
H A Daudio_service.h61 int32_t LinkProcessToEndpoint(sptr<AudioProcessInServer> process, std::shared_ptr<AudioEndpoint> endpoint);
62 int32_t UnlinkProcessToEndpoint(sptr<AudioProcessInServer> process, std::shared_ptr<AudioEndpoint> endpoint);
93 void CheckInnerCapForProcess(sptr<AudioProcessInServer> process, std::shared_ptr<AudioEndpoint> endpoint);
H A Daudio_process_in_server.h71 // override for IAudioProcessStream, used in endpoint
82 DeviceStreamInfo &serverStreamInfo, const std::shared_ptr<OHAudioBuffer> &endpoint = nullptr);
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dprocess_system_api_adapter_impl.h28 API_EXPORT explicit ProcessSystemApiAdapterImpl(std::shared_ptr<Endpoint> endpoint);
H A Dprocess_communication_impl.h32 API_EXPORT explicit ProcessCommunicationImpl(std::shared_ptr<Endpoint> endpoint);
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Ddistributed_kv_data_manager.h160 * @brief set endpoint for client sync.
161 * @param endpoint The pointer of endpoint.
164 API_EXPORT Status SetEndpoint(std::shared_ptr<Endpoint> endpoint);

Completed in 8 milliseconds