mqtt/src/mqttd.c - diff

Return to mqttd.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

Diff for /mqtt/src/mqttd.c between versions 1.2.2.8 and 1.3

version 1.2.2.8, 2012/05/22 14:15:04	version 1.3, 2012/07/03 09:02:50
Line 43 sigHand(int sig)	Line 43 sigHand(int sig)
}	}

ioLIBERR(cfg);	ioLIBERR(cfg);
	case SIGINT:
case SIGTERM:	case SIGTERM:
ioDEBUG(1, "Terminate MQTT service in progress");	ioDEBUG(1, "Terminate MQTT service in progress");
Kill++;	Kill++;
Line 97 main(int argc, char **argv)	Line 98 main(int argc, char **argv)
for (i = 0; i < 3; i++)	for (i = 0; i < 3; i++)
if (!mqttLoadRTLM(&cfg, i)) {	if (!mqttLoadRTLM(&cfg, i)) {
printf("Error:: Can't load RTL module\n");	printf("Error:: Can't load RTL module\n");
while (i--)	mqttUnloadRTLM(acc);
mqttUnloadRTLM(i);	mqttUnloadRTLM(pub);
	mqttUnloadRTLM(logg);
cfgUnloadConfig(&cfg);	cfgUnloadConfig(&cfg);
closelog();	closelog();
return 2;	return 2;
Line 119 main(int argc, char **argv)	Line 121 main(int argc, char **argv)
goto end;	goto end;
}	}


if (mqttMkDir(&cfg)) {	if (mqttMkDir(&cfg)) {
printf("Error:: in statedir #%d - %s\n", errno, strerror(errno));	printf("Error:: in statedir #%d - %s\n", errno, strerror(errno));
ret = 3;	ret = 3;
Line 156 main(int argc, char **argv)	Line 159 main(int argc, char **argv)
sigemptyset(&sa.sa_mask);	sigemptyset(&sa.sa_mask);
sa.sa_handler = sigHand;	sa.sa_handler = sigHand;
sigaction(SIGHUP, &sa, NULL);	sigaction(SIGHUP, &sa, NULL);
	sigaction(SIGINT, &sa, NULL);
sigaction(SIGTERM, &sa, NULL);	sigaction(SIGTERM, &sa, NULL);
sigaction(SIGCHLD, &sa, NULL);	sigaction(SIGCHLD, &sa, NULL);
sigaction(SIGPIPE, &sa, NULL);	sigaction(SIGPIPE, &sa, NULL);
Line 190 end: /* free all resources */	Line 194 end: /* free all resources */
call.CloseLOG(logg);	call.CloseLOG(logg);
call.ClosePUB(pub);	call.ClosePUB(pub);
call.CloseACC(acc);	call.CloseACC(acc);
for (i = 0; i < 3; i++)	mqttUnloadRTLM(acc);
mqttUnloadRTLM(i);	mqttUnloadRTLM(pub);
closelog();	mqttUnloadRTLM(logg);
cfgUnloadConfig(&cfg);	cfgUnloadConfig(&cfg);
	closelog();
return ret;	return ret;
}	}

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.2.2.8
changed lines
	Added in v.1.3