Commit 1fe61658 authored by Patrick Bellot's avatar Patrick Bellot
Browse files

EDP

parent 88b8e423
......@@ -29,7 +29,7 @@
extern "C" {
extern opcua::BaseClient ** the_clients ;
extern int the_nbClient ;
extern int the_nbClients ;
}
......@@ -46,7 +46,7 @@ public:
SOPC_SecureChannel_Config * pScConfig
)
{
int nbClient = 3 ; // Number of client threads
int nbClients = 3 ; // Number of client threads
int nbTry = 10 ; // Number of total loops from OpenSecureChannel to CloseSecureChannel
uint32_t channel_config_idx = 0 ;
......@@ -71,13 +71,13 @@ public:
// CREATING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_02","Building clients") ;
clients = new Client_01 *[nbClient] ;
clients = new Client_01 *[nbClients] ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i] = new Client_01(i,pScConfig,channel_config_idx,endpointUrl) ;
the_clients = (BaseClient **)clients ;
the_nbClient = nbClient ;
the_nbClients = nbClients ;
// OPEN SECURE CHANNEL
......@@ -92,14 +92,14 @@ public:
// STARTING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_01","Starting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->start() ;
debug(MAIN_LIFE_DBG,"StartClients_01","Starting clients succeeds") ;
// WAITING FOR CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_01","Waiting for clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->join() ;
debug(MAIN_LIFE_DBG,"StartClients_01","Waiting for clients succeeds") ;
......@@ -116,7 +116,7 @@ public:
// DELETING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_01","Deleting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
clients = NULL ;
......@@ -135,7 +135,7 @@ error:
debug(MAIN_LIFE_DBG,"StartClients_01","Releasing memory with error") ;
if (clients != NULL) {
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
}
......
......@@ -29,7 +29,7 @@
extern "C" {
extern opcua::BaseClient ** the_clients ;
extern int the_nbClient ;
extern int the_nbClients ;
}
......@@ -46,7 +46,7 @@ public:
SOPC_SecureChannel_Config * pScConfig
)
{
int nbClient = 5 ; // Number of client threads
int nbClients = 5 ; // Number of client threads
int nbTry = 5 ; // Number of total loops from OpenSecureChannel to CloseSecureChannel
uint32_t channel_config_idx = 0 ;
......@@ -72,13 +72,13 @@ public:
// CREATING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_02","Building clients") ;
clients = new Client_02 *[nbClient] ;
clients = new Client_02 *[nbClients] ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i] = new Client_02(i,pScConfig,channel_config_idx,endpointUrl) ;
the_clients = (BaseClient **)clients ;
the_nbClient = nbClient ;
the_nbClients = nbClients ;
// OPEN SECURE CHANNEL
......@@ -93,14 +93,14 @@ public:
// STARTING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_02","Starting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->start() ;
debug(MAIN_LIFE_DBG,"StartClients_02","Starting clients succeeds") ;
// WAITING FOR CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_02","Waiting for clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->join() ;
debug(MAIN_LIFE_DBG,"StartClients_02","Waiting for clients succeeds") ;
......@@ -116,7 +116,7 @@ public:
// DELETING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_02","Deleting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
clients = NULL ;
......@@ -135,7 +135,7 @@ error:
debug(MAIN_LIFE_DBG,"StartClients_02","Releasing memory with error") ;
if (clients != NULL) {
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
}
......
......@@ -29,7 +29,7 @@
extern "C" {
extern opcua::BaseClient ** the_clients ;
extern int the_nbClient ;
extern int the_nbClients ;
}
......@@ -46,7 +46,7 @@ public:
SOPC_SecureChannel_Config * pScConfig
)
{
int nbClient = 3 ; // Number of client threads (max is 256)
int nbClients = 3 ; // Number of client threads (max is 256)
int nbTry = 100 ; // Number of total loops from OpenSecureChannel to CloseSecureChannel
uint32_t channel_config_idx = 0 ;
......@@ -71,13 +71,13 @@ public:
// CREATING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_03","Building clients") ;
clients = new Client_03 *[nbClient] ;
clients = new Client_03 *[nbClients] ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i] = new Client_03(i,pScConfig,channel_config_idx,endpointUrl) ;
the_clients = (BaseClient **)clients ;
the_nbClient = nbClient ;
the_nbClients = nbClients ;
// OPEN SECURE CHANNEL
......@@ -92,14 +92,14 @@ public:
// STARTING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_03","Starting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->start() ;
debug(MAIN_LIFE_DBG,"StartClients_03","Starting clients succeeds") ;
// WAITING FOR CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_03","Waiting for clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->join() ;
debug(MAIN_LIFE_DBG,"StartClients_03","Waiting for clients succeeds") ;
......@@ -115,7 +115,7 @@ public:
// DELETING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_03","Deleting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
clients = NULL ;
......@@ -134,7 +134,7 @@ error:
debug(MAIN_LIFE_DBG,"StartClients_03","Releasing memory with error") ;
if (clients != NULL) {
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
}
......
......@@ -29,7 +29,7 @@
extern "C" {
extern opcua::BaseClient ** the_clients ;
extern int the_nbClient ;
extern int the_nbClients ;
}
......@@ -46,7 +46,7 @@ public:
SOPC_SecureChannel_Config * pScConfig
)
{
int nbClient = 2 ; // Number of client threads
int nbClients = 2 ; // Number of client threads
int nbTry = 1 ; // Number of total loops from OpenSecureChannel to CloseSecureChannel
uint32_t channel_config_idx = 0 ;
......@@ -70,13 +70,13 @@ public:
// CREATING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_04","Building clients") ;
clients = new Client_04 *[nbClient] ;
clients = new Client_04 *[nbClients] ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i] = new Client_04(i,pScConfig,channel_config_idx,endpointUrl) ;
the_clients = (BaseClient **)clients ;
the_nbClient = nbClient ;
the_nbClients = nbClients ;
// OPEN SECURE CHANNEL
......@@ -91,14 +91,14 @@ public:
// STARTING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_04","Starting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->start() ;
debug(MAIN_LIFE_DBG,"StartClients_04","Starting clients succeeds") ;
// WAITING FOR CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_04","Waiting for clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->join() ;
debug(MAIN_LIFE_DBG,"StartClients_04","Waiting for clients succeeds") ;
......@@ -114,7 +114,7 @@ public:
// DELETING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_04","Deleting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
clients = NULL ;
......@@ -133,7 +133,7 @@ error:
debug(MAIN_LIFE_DBG,"StartClients_04","Releasing memory with error") ;
if (clients != NULL) {
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
}
......
......@@ -29,7 +29,7 @@
extern "C" {
extern opcua::BaseClient ** the_clients ;
extern int the_nbClient ;
extern int the_nbClients ;
}
......@@ -46,7 +46,7 @@ public:
SOPC_SecureChannel_Config * pScConfig
)
{
int nbClient = 5 ; // Number of client threads
int nbClients = 5 ; // Number of client threads
int nbTry = 3 ; // Number of total loops from OpenSecureChannel to CloseSecureChannel
uint32_t channel_config_idx = 0 ;
......@@ -70,13 +70,13 @@ public:
// CREATING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_05","Building clients") ;
clients = new Client_05 *[nbClient] ;
clients = new Client_05 *[nbClients] ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i] = new Client_05(i,pScConfig,channel_config_idx,endpointUrl) ;
the_clients = (BaseClient **)clients ;
the_nbClient = nbClient ;
the_nbClients = nbClients ;
......@@ -92,14 +92,14 @@ public:
// STARTING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_05","Starting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->start() ;
debug(MAIN_LIFE_DBG,"StartClients_05","Starting clients succeeds") ;
// WAITING FOR CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_05","Waiting for clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
clients[i]->join() ;
debug(MAIN_LIFE_DBG,"StartClients_05","Waiting for clients succeeds") ;
......@@ -115,7 +115,7 @@ public:
// DELETING CLIENTS
debug(MAIN_LIFE_DBG,"StartClients_05","Deleting clients") ;
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
clients = NULL ;
......@@ -134,7 +134,7 @@ error:
debug(MAIN_LIFE_DBG,"StartClients_05","Releasing memory with error") ;
if (clients != NULL) {
for (int i = 0 ; i < nbClient ; i++)
for (int i = 0 ; i < nbClients ; i++)
delete clients[i] ;
delete[] clients ;
}
......
......@@ -41,7 +41,7 @@ extern "C" {
void ComEvent_FctClient(SOPC_App_Com_Event event, uint32_t idOrStatus, void* param, uintptr_t appContext) ;
opcua::BaseClient ** the_clients = NULL ;
int the_nbClient = 0 ;
int the_nbClients = 0 ;
int endpointOpened = 0 ; // 0=false, Managed in s2opc_server/S2OPC_StubServices.cpp
......
......@@ -24,7 +24,7 @@
extern "C" {
extern opcua::BaseClient ** the_clients ;
extern int the_nbClient ;
extern int the_nbClients ;
extern int endpointOpened ; // Managed in s2opc_server/S2OPC_StubServices.cpp
......@@ -139,8 +139,8 @@ MYDLL void Service_ServiceFault(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_ServiceFault","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_ServiceFault","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -181,8 +181,8 @@ MYDLL void Service_CreateSession(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_CreateSession","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_CreateSession","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -221,8 +221,8 @@ MYDLL void Service_ActivateSession(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_ActivateSession","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_ActivateSession","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -261,8 +261,8 @@ MYDLL void Service_CloseSession(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_CloseSession","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_CloseSession","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -302,8 +302,8 @@ MYDLL void Service_Read(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_Read","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_Read","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -344,8 +344,8 @@ MYDLL void Service_Write(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_Write","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_Write","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -386,8 +386,8 @@ MYDLL void Service_Call(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_Call","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_Call","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -428,8 +428,8 @@ MYDLL void Service_Browse(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_Browse","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_Browse","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -470,8 +470,8 @@ MYDLL void Service_RegisterNodes(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_RegisterNodes","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_RegisterNodes","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -512,8 +512,8 @@ MYDLL void Service_UnregisterNodes(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_UnregisterNodes","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_UnregisterNodes","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -554,8 +554,8 @@ MYDLL void Service_TranslateBrowsePathsToNodeIds(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_TranslateBrowsePathsToNodeIds","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_TranslateBrowsePathsToNodeIds","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -596,8 +596,8 @@ MYDLL void Service_CreateMonitoredItems(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_CreateMonitoredItems","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_CreateMonitoredItems","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -638,8 +638,8 @@ MYDLL void Service_ModifyMonitoredItems(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_ModifyMonitoredItems","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_ModifyMonitoredItems","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -681,8 +681,8 @@ MYDLL void Service_SetMonitoringMode(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_SetMonitoringMode","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_SetMonitoringMode","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -724,8 +724,8 @@ MYDLL void Service_DeleteMonitoredItems(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_DeleteMonitoredItems","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_DeleteMonitoredItems","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -767,8 +767,8 @@ MYDLL void Service_CreateSubscription(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_CreateSubscription","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_CreateSubscription","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -809,8 +809,8 @@ MYDLL void Service_ModifySubscription(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_ModifySubscription","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_ModifySubscription","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -852,8 +852,8 @@ MYDLL void Service_SetPublishingMode(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_SetPublishingMode","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_SetPublishingMode","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -895,8 +895,8 @@ MYDLL void Service_Publish(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_Publish","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_Publish","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -938,8 +938,8 @@ MYDLL void Service_Republish(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_Republish","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_Republish","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -981,8 +981,8 @@ MYDLL void Service_TransferSubscriptions(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_TransferSubscriptions","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_TransferSubscriptions","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -1024,8 +1024,8 @@ MYDLL void Service_DeleteSubscriptions(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {
debug_ii(IPCS_ERR,"Service_DeleteSubscriptions","Not a client number (<%d): client=%d",the_nbClient,client) ;
if (client > (uint32_t)the_nbClients) {
debug_ii(IPCS_ERR,"Service_DeleteSubscriptions","Not a client number (<%d): client=%d",the_nbClients,client) ;
delete r ;
return ;
}
......@@ -1066,8 +1066,8 @@ MYDLL void Service_AddNodes(
uint32_t client = r->getResponseHeader()->getRequestHandle()->get() & 0x000000FF ;
if (client > (uint32_t)the_nbClient) {