Searched refs:dispatcherId (Results 1 – 11 of 11) sorted by relevance
40 DispatcherId dispatcherId; member76 if (dispatcherId >= MESSAGE_ENGINE_MAX_DISPATCHER) { in RefDispatcherInner()90 if (g_dispatchers[dispatcherId] == NULL) { in RefDispatcherInner()94 if (g_dispatchers[dispatcherId]->Ref == NULL) { in RefDispatcherInner()97 result = g_dispatchers[dispatcherId]->Ref(g_dispatchers[dispatcherId]); in RefDispatcherInner()113 if (dispatcherId >= MESSAGE_ENGINE_MAX_DISPATCHER) { in RegDispatcher()130 if (g_dispatchers[dispatcherId] != NULL) { in RegDispatcher()134 g_dispatchers[dispatcherId] = dispatcher; in RegDispatcher()267 g_servicesIndex[remoteService->serviceId].dispatcherId = dispatcherId; in DoRegistService()387 …sIndex[serviceId].nodeIndex != nodeId || g_servicesIndex[serviceId].dispatcherId != dispatcherId) { in UnregistServiceInner()[all …]
24 DispatcherId dispatcherId; member220 errCode = UnregistLocalService(data->dispatcherId, data->serviceId); in DestroyService()263 privateData->dispatcherId = cfg->dispatcherId; in InitService()267 errCode = RegistLocalService(cfg->dispatcherId, def); in InitService()
38 ErrorCode RegistLocalService(const DispatcherId dispatcherId, struct ServiceDef *mapper);40 ErrorCode UnregistLocalService(const DispatcherId dispatcherId, ServiceId serviceId);
52 DispatcherId dispatcherId; member
61 void DestroyDispatcherInner(const NodeId nodeId, const DispatcherId dispatcherId);
85 DispatcherId dispatcherId; member
91 .dispatcherId = CUSTOM_DISPATCHER_ID, in StartEnv()100 .dispatcherId = DEFAULT_DISPATCHER_ID in StartEnv()108 .dispatcherId = CUSTOM_DISPATCHER_ID in StartEnv()143 .dispatcherId = CUSTOM_DISPATCHER_ID in MessageSingleNodeTest001()
387 .dispatcherId = DEFAULT_DISPATCHER_ID in P2pInit()
540 .dispatcherId = DEFAULT_DISPATCHER_ID in ApInit()
641 .dispatcherId = DEFAULT_DISPATCHER_ID in StaInit()
1792 ServiceCfg cfg = {.dispatcherId = DEFAULT_DISPATCHER_ID}; in BaseInit()