| /foundation/multimedia/camera_lite/services/server/src/ |
| D | samgr_camera.cpp | 39 Identity identity; member
48 static BOOL Initialize(Service* service, Identity identity) in Initialize() argument
51 example->identity = identity; in Initialize()
53 identity.serviceId, identity.featureId, identity.queueId); in Initialize()
|
| /foundation/graphic/wms/services/wms/ |
| D | samgr_wms.cpp | 37 Identity identity; member
46 static BOOL Initialize(Service* service, Identity identity) in Initialize() argument
49 example->identity = identity; in Initialize()
51 identity.serviceId, identity.featureId, identity.queueId); in Initialize()
|
| /foundation/multimedia/media_lite/services/player_lite/server/src/ |
| D | samgr_player_server.cpp | 38 Identity identity; member
47 static BOOL Initialize(Service* service, Identity identity) in Initialize() argument
50 example->identity = identity; in Initialize()
52 identity.serviceId, identity.featureId, identity.queueId); in Initialize()
|
| /foundation/distributedschedule/samgr_lite/samgr_server/source/ |
| D | samgr_server.c | 49 static BOOL Initialize(Service *service, Identity identity);
55 …tFeature(SamgrServer *server, const void *origin, IpcIo *req, IpcIo *reply, SvcIdentity *identity);
56 …tFeature(SamgrServer *server, const void *origin, IpcIo *req, IpcIo *reply, SvcIdentity *identity);
58 static int RegisterSamgrEndpoint(const IpcContext* context, SvcIdentity* identity);
59 static void TransmitPolicy(int ret, const SvcIdentity* identity, IpcIo *reply,
116 static BOOL Initialize(Service *service, Identity identity) in Initialize() argument
119 server->identity = identity; in Initialize()
121 SAMGR_AddRouter(server->samgr, &saName, &server->identity, GET_IUNKNOWN(*server)); in Initialize()
171 … SvcIdentity identity = {(uint32)INVALID_INDEX, (uint32)INVALID_INDEX, (uint32)INVALID_INDEX}; in ProcEndpoint() local
172 (void)GenServiceHandle(&identity, GetCallingTid(origin)); in ProcEndpoint()
[all …]
|
| D | samgr_server_rpc.c | 52 static BOOL Initialize(Service *service, Identity identity);
58 …tFeature(SamgrServer *server, const void *origin, IpcIo *req, IpcIo *reply, SvcIdentity *identity);
59 …tFeature(SamgrServer *server, const void *origin, IpcIo *req, IpcIo *reply, SvcIdentity *identity);
61 static int RegisterSamgrEndpoint(SvcIdentity* identity);
62 static void TransmitPolicy(int ret, const SvcIdentity* identity, IpcIo *reply,
198 static BOOL Initialize(Service *service, Identity identity) in Initialize() argument
202 server->identity = identity; in Initialize()
204 SAMGR_AddRouter(server->samgr, &saName, &server->identity, GET_IUNKNOWN(*server)); in Initialize()
244 int AddEndpoint(SvcIdentity identity, const char *service, const char *feature) in AddEndpoint() argument
246 return SASTORA_Save(&g_server.store, service, feature, &identity); in AddEndpoint()
[all …]
|
| /foundation/distributedschedule/samgr_lite/interfaces/kits/samgr/ |
| D | feature.h | 94 void (*OnInitialize)(Feature *feature, Service *parent, Identity identity);
107 void (*OnStop)(Feature *feature, Identity identity);
136 void (*OnInitialize)(Feature *feature, Service *parent, Identity identity); \
137 void (*OnStop)(Feature *feature, Identity identity); \
144 void (*OnInitialize)(Feature *feature, Service *parent, Identity identity); \
145 void (*OnStop)(Feature *feature, Identity identity); \
|
| /foundation/graphic/wms/services/ims/ |
| D | samgr_ims.cpp | 36 Identity identity; member
45 static BOOL Initialize(Service* service, Identity identity) in Initialize() argument
48 example->identity = identity; in Initialize()
50 identity.serviceId, identity.featureId, identity.queueId); in Initialize()
|
| /foundation/multimedia/audio_lite/services/server/src/ |
| D | audio_capturer_samgr.cpp | 33 Identity identity; member
42 static BOOL Initialize(Service *service, Identity identity) in Initialize() argument
45 capturerSvc->identity = identity; in Initialize()
46 …MEDIA_INFO_LOG("Initialize(%s)! Identity<%d, %d, %p>", AUDIO_CAPTURER_SERVICE_NAME, identity.servi… in Initialize()
47 identity.featureId, identity.queueId); in Initialize()
|
| /foundation/multimedia/media_lite/services/recorder_lite/server/src/ |
| D | recorder_samgr.cpp | 33 Identity identity; member
42 static BOOL Initialize(Service *service, Identity identity) in Initialize() argument
45 recordSvc->identity = identity; in Initialize()
46 … MEDIA_INFO_LOG("Initialize(%s)! Identity<%d, %d, %p>", RECORDER_SERVICE_NAME, identity.serviceId, in Initialize()
47 identity.featureId, identity.queueId); in Initialize()
|
| /foundation/aafwk/standard/services/common/include/ |
| D | in_process_call_wrapper.h | 23 std::string identity = IPCSkeleton::ResetCallingIdentity(); \
25 IPCSkeleton::SetCallingIdentity(identity); \
31 std::string identity = IPCSkeleton::ResetCallingIdentity(); \
33 IPCSkeleton::SetCallingIdentity(identity); \
|
| /foundation/distributedschedule/dmsfwk_lite/source/ |
| D | dmslite_feature.c | 29 static void OnInitialize(Feature *feature, Service *parent, Identity identity);
30 static void OnStop(Feature *feature, Identity identity);
39 .identity = {-1, -1, NULL},
59 static void OnInitialize(Feature *feature, Service *parent, Identity identity) in OnInitialize() argument
65 ((DmsLite*) feature)->identity = identity; in OnInitialize()
68 static void OnStop(Feature *feature, Identity identity) in OnStop() argument
|
| D | dmslite.c | 29 static BOOL Initialize(Service *service, Identity identity);
48 static BOOL Initialize(Service *service, Identity identity) in Initialize() argument
54 ((DistributedService*) service)->identity = identity; in Initialize()
|
| /foundation/distributedschedule/samgr_lite/communication/broadcast/source/ |
| D | pub_sub_feature.c | 22 static void OnInitialize(Feature *feature, Service *parent, Identity identity);
23 static void OnStop(Feature *feature, Identity identity);
56 static void OnInitialize(Feature *feature, Service *parent, Identity identity) in OnInitialize() argument
59 ((PubSubFeature *)feature)->identity = identity; in OnInitialize()
62 static void OnStop(Feature *feature, Identity identity) in OnStop() argument
65 (void)identity; in OnStop()
81 if (item->consumer->identity == NULL) { in OnMessage()
|
| D | broadcast_service.c | 23 static BOOL Initialize(Service *service, Identity identity);
45 static BOOL Initialize(Service *service, Identity identity) in Initialize() argument
47 (void)identity; in Initialize()
|
| /foundation/distributedschedule/samgr_lite/samgr/source/ |
| D | service.c | 90 void DEFAULT_MessageHandle(ServiceImpl *serviceImpl, const Identity *identity, Request *msg) in DEFAULT_MessageHandle() argument
92 if (serviceImpl->serviceId != identity->serviceId) { in DEFAULT_MessageHandle()
96 if (identity->featureId < 0) { in DEFAULT_MessageHandle()
103 if (VECTOR_Size(&serviceImpl->features) <= identity->featureId) { in DEFAULT_MessageHandle()
107 …FeatureImpl *featureImpl = (FeatureImpl *)VECTOR_At(&(serviceImpl->features), identity->featureId); in DEFAULT_MessageHandle()
146 Identity identity = {INVALID_INDEX, INVALID_INDEX, NULL}; in DEFAULT_GetFeatureId() local
148 return identity; in DEFAULT_GetFeatureId()
151 identity.serviceId = serviceImpl->serviceId; in DEFAULT_GetFeatureId()
153 identity.queueId = serviceImpl->taskPool->queueId; in DEFAULT_GetFeatureId()
159 return identity; in DEFAULT_GetFeatureId()
[all …]
|
| D | message.c | 33 int32 SAMGR_SendRequest(const Identity *identity, const Request *request, Handler handler) in SAMGR_SendRequest() argument
35 if (request == NULL || identity == NULL) { in SAMGR_SendRequest()
39 Exchange exchange = {*identity, *request, {NULL, 0}, MSG_NON, handler, NULL}; in SAMGR_SendRequest()
46 return QUEUE_Put(identity->queueId, &exchange, 0, DONT_WAIT); in SAMGR_SendRequest()
118 uint32 *SAMGR_SendSharedRequest(const Identity *identity, const Request *request, uint32 *token, Ha… in SAMGR_SendSharedRequest() argument
120 if (identity == NULL || request == NULL) { in SAMGR_SendSharedRequest()
123 Exchange exchange = {*identity, *request, {NULL, 0}, MSG_NON, handler, token}; in SAMGR_SendSharedRequest()
126 int32 err = SharedSend(identity->queueId, &exchange, 0); in SAMGR_SendSharedRequest()
|
| /foundation/distributedschedule/samgr_lite/samgr_endpoint/source/ |
| D | endpoint_rpc.c | 70 Identity identity; member
87 static int RegisterRemoteEndpoint(SvcIdentity *identity, int token, const char *service, const char…
103 endpoint->identity.handle = (uint32_t)INVALID_INDEX; in SAMGR_CreateEndpoint()
104 endpoint->identity.token = (uint32_t)INVALID_INDEX; in SAMGR_CreateEndpoint()
105 endpoint->identity.cookie = (uint32_t)INVALID_INDEX; in SAMGR_CreateEndpoint()
137 router->identity = *id; in SAMGR_AddRouter()
336 endpoint->registerEP(&endpoint->identity, index, service, feature); in Listen()
405 int ret = SAMGR_SendSharedDirectRequest(&router->identity, &request, &resp, &ref, HandleIpc); in Dispatch()
408 saNode->token, router->identity.serviceId, router->identity.featureId); in Dispatch()
483 SvcIdentity identity; in RegisterRemoteFeatures() local
[all …]
|
| D | sa_store.c | 52 …STORA_Save(SAStore *saStore, const char *service, const char *feature, const SvcIdentity *identity) in SASTORA_Save() argument
54 if (saStore == NULL || service == NULL || identity == NULL) { in SASTORA_Save()
60 saNode->token = identity->token; in SASTORA_Save()
79 fNode->token = identity->token; in SASTORA_Save()
101 curNode->info.handle = identity->handle; in SASTORA_Save()
103 curNode->info.cookie = identity->cookie; in SASTORA_Save()
217 SvcIdentity identity = {(uint32)INVALID_INDEX, (uint32)INVALID_INDEX, (uint32)INVALID_INDEX}; in SASTORA_Find() local
220 return identity; in SASTORA_Find()
223 identity.handle = curNode->info.handle; in SASTORA_Find()
225 identity.cookie = curNode->info.cookie; in SASTORA_Find()
[all …]
|
| D | endpoint.c | 60 Identity identity; member
78 static int RegisterRemoteEndpoint(const IpcContext *context, SvcIdentity *identity);
95 endpoint->identity.handle = (uint32_t)INVALID_INDEX; in SAMGR_CreateEndpoint()
96 endpoint->identity.token = (uint32_t)INVALID_INDEX; in SAMGR_CreateEndpoint()
97 endpoint->identity.cookie = (uint32_t)INVALID_INDEX; in SAMGR_CreateEndpoint()
128 router->identity = *id; in SAMGR_AddRouter()
364 ret = endpoint->registerEP(endpoint->context, &endpoint->identity); in Receive()
377 endpoint->name, endpoint->identity.handle); in Receive()
382 if (endpoint->identity.handle != SAMGR_HANDLE) { in Receive()
421 int ret = SAMGR_SendSharedDirectRequest(&router->identity, &request, &resp, &ref, HandleIpc); in Dispatch()
[all …]
|
| D | default_client_rpc.c | 77 SvcIdentity identity = QueryIdentity(service, feature); in SAMGR_CreateIProxy() local
78 if (identity.handle == INVALID_INDEX) { in SAMGR_CreateIProxy()
92 header->target = identity; in SAMGR_CreateIProxy()
95 (void)AddDeathRecipient(identity, OnServiceExit, client, &header->deadId); in SAMGR_CreateIProxy()
106 SvcIdentity identity = QueryRemoteIdentity(deviceId, service, feature); in SAMGR_CreateIRemoteProxy() local
118 header->target = identity; in SAMGR_CreateIRemoteProxy()
135 SvcIdentity identity = {INVALID_INDEX, INVALID_INDEX, INVALID_INDEX}; in SAMGR_GetRemoteIdentity() local
138 return identity; in SAMGR_GetRemoteIdentity()
142 return identity; in SAMGR_GetRemoteIdentity()
145 identity = client->header.target; in SAMGR_GetRemoteIdentity()
[all …]
|
| D | endpoint.h | 60 typedef int (*RegisterEndpoint)(const IpcContext *context, SvcIdentity *identity);
62 typedef int (*RegisterEndpoint)(SvcIdentity *identity, int token, const char *service, const char *…
74 SvcIdentity identity; member
|
| /foundation/distributedhardware/devicemanager/ext/mini/services/devicemanagerservice/src/dispatch/ |
| D | server_stub.cpp | 48 Identity identity; member
58 static BOOL Initialize(Service *service, Identity identity) in Initialize() argument
68 mgrService->identity = identity; in Initialize()
|
| /foundation/distributedhardware/devicemanager/services/devicemanagerservice/src/dispatch/ |
| D | server_stub.cpp | 42 Identity identity; member
52 static BOOL Initialize(Service *service, Identity identity) in Initialize() argument
66 mgrService->identity = identity; in Initialize()
|
| /foundation/distributedhardware/devicemanager/services/devicemanagerservice/src/ipc/lite/ |
| D | ipc_server_listener.cpp | 26 void IpcServerListener::CommonSvcToIdentity(CommonSvcId *svcId, SvcIdentity *identity) in CommonSvcToIdentity() argument
28 identity->handle = svcId->handle; in CommonSvcToIdentity()
29 identity->token = svcId->token; in CommonSvcToIdentity()
30 identity->cookie = svcId->cookie; in CommonSvcToIdentity()
32 identity->ipcContext = svcId->ipcCtx; in CommonSvcToIdentity()
|
| /foundation/aafwk/aafwk_lite/services/abilitymgr_lite/src/ |
| D | ability_mgr_slite_feature.cpp | 72 …d AbilityMgrSliteFeature::OnFeatureInitialize(Feature *feature, Service *parent, Identity identity) in OnFeatureInitialize() argument
75 (static_cast<AbilityMgrSliteFeature *>(feature))->identity_ = identity; in OnFeatureInitialize()
79 void AbilityMgrSliteFeature::OnFeatureStop(Feature *feature, Identity identity) in OnFeatureStop() argument
82 (void) identity; in OnFeatureStop()
|