Skip to content

Commit

Permalink
linux/daemon_cl: CLEANUP() macro added (SCA daemon_cl clean up fixes)
Browse files Browse the repository at this point in the history
Static code analysis fixes _005/_007..._011/_014..._016/_047

Issues: Avnu#41 Avnu#42 Avnu#43 Avnu#44 Avnu#45 Avnu#46 Avnu#48 Avnu#49 Avnu#50 Avnu#71

Minor main() refactoring and macro for deleting all objects created
during start up - limits memory leaks.
  • Loading branch information
PawelModrzejewski committed Jan 19, 2021
1 parent a9f9f50 commit b75220e
Showing 1 changed file with 36 additions and 18 deletions.
54 changes: 36 additions & 18 deletions linux/src/daemon_cl.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,24 @@
#define PHY_DELAY_MB_TX_I20 1044//100M delay
#define PHY_DELAY_MB_RX_I20 2133//100M delay

#define CLEANUP()\
do { \
delete pPort; \
delete pClock; \
delete ifname; \
delete timestamper; \
delete ipc; \
delete condition_factory; \
delete timer_factory; \
delete lock_factory; \
delete timerq_factory; \
delete default_factory; \
delete thread_factory; \
delete watchdog; \
GPTP_LOG_INFO("Clean up"); \
GPTP_LOG_UNREGISTER(); \
} while(0)

void gPTPPersistWriteCB(char *bufPtr, uint32_t bufSize);

void print_usage( char *arg0 ) {
Expand Down Expand Up @@ -108,7 +126,7 @@ int main(int argc, char **argv)
PortInit_t portInit;

sigset_t set;
InterfaceName *ifname;
InterfaceName *ifname = NULL;
int sig;

bool syntonize = false;
Expand Down Expand Up @@ -183,19 +201,26 @@ int main(int argc, char **argv)
portInit.neighborPropDelayThreshold =
CommonPort::NEIGHBOR_PROP_DELAY_THRESH;

LinuxNetworkInterfaceFactory *default_factory =
new LinuxNetworkInterfaceFactory;
LinuxNetworkInterfaceFactory *default_factory = new LinuxNetworkInterfaceFactory;
OSNetworkInterfaceFactory::registerFactory
(factory_name_t("default"), default_factory);
LinuxTimerQueueFactory *timerq_factory = new LinuxTimerQueueFactory();
LinuxLockFactory *lock_factory = new LinuxLockFactory();
LinuxTimerFactory *timer_factory = new LinuxTimerFactory();
LinuxConditionFactory *condition_factory = new LinuxConditionFactory();
LinuxSharedMemoryIPC *ipc = new LinuxSharedMemoryIPC();

#ifdef ARCH_INTELCE
EtherTimestamper *timestamper = new LinuxTimestamperIntelCE();
#else
EtherTimestamper *timestamper = new LinuxTimestamperGeneric();
#endif

/* Create Low level network interface object */
if( argc < 2 ) {
printf( "Interface name required\n" );
GPTP_LOG_ERROR( "Interface name required" );
print_usage( argv[0] );
CLEANUP();
return -1;
}
ifname = new InterfaceName( argv[1], strlen(argv[1]) );
Expand Down Expand Up @@ -241,7 +266,7 @@ int main(int argc, char **argv)
}
else if( strcmp(argv[i] + 1, "H") == 0 ) {
print_usage( argv[0] );
GPTP_LOG_UNREGISTER();
CLEANUP();
return 0;
}
else if( strcmp(argv[i] + 1, "R") == 0 ) {
Expand Down Expand Up @@ -269,7 +294,7 @@ int main(int argc, char **argv)
{
printf("Too many values\n");
print_usage( argv[0] );
GPTP_LOG_UNREGISTER();
CLEANUP();
return 0;
}
phy_delay[delay_count]=atoi(cli_inp_delay);
Expand All @@ -280,7 +305,7 @@ int main(int argc, char **argv)
{
printf("All four delay values must be specified\n");
print_usage( argv[0] );
GPTP_LOG_UNREGISTER();
CLEANUP();
return 0;
}
ether_phy_delay[LINKSPEED_1G].set_delay
Expand Down Expand Up @@ -348,11 +373,6 @@ int main(int argc, char **argv)
restoredataptr = (char *)restoredata;
}

#ifdef ARCH_INTELCE
EtherTimestamper *timestamper = new LinuxTimestamperIntelCE();
#else
EtherTimestamper *timestamper = new LinuxTimestamperGeneric();
#endif

sigemptyset(&set);
sigaddset(&set, SIGINT);
Expand All @@ -361,7 +381,7 @@ int main(int argc, char **argv)
sigaddset(&set, SIGUSR2);
if (pthread_sigmask(SIG_BLOCK, &set, NULL) != 0) {
perror("pthread_sigmask()");
GPTP_LOG_UNREGISTER();
CLEANUP();
return -1;
}

Expand Down Expand Up @@ -431,7 +451,7 @@ int main(int argc, char **argv)

if (!pPort->init_port()) {
GPTP_LOG_ERROR("failed to initialize port");
GPTP_LOG_UNREGISTER();
CLEANUP();
return -1;
}

Expand Down Expand Up @@ -484,7 +504,7 @@ int main(int argc, char **argv)

if (sigwait(&set, &sig) != 0) {
perror("sigwait()");
GPTP_LOG_UNREGISTER();
CLEANUP();
return -1;
}

Expand Down Expand Up @@ -522,9 +542,7 @@ int main(int argc, char **argv)
pPort->joinLinkWatchThread(linkExitCode);
GPTP_LOG_INFO("All threads terminated");

if( ipc ) delete ipc;

GPTP_LOG_UNREGISTER();
CLEANUP();
return 0;
}

Expand Down

0 comments on commit b75220e

Please sign in to comment.