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.1.1.1.2.14 and 1.2.2.1

version 1.1.1.1.2.14, 2011/12/29 14:13:13	version 1.2.2.1, 2012/04/11 15:08:27
Line 7	Line 7

io_enableDEBUG;	io_enableDEBUG;

sl_config cfg;	cfg_root_t cfg;
sessions_t Sessions;	sessions_t Sessions;
sched_root_task_t *root;	sched_root_task_t *root;
sqlite3 acc, pub;	sqlite3 acc, pub;
pthread_mutex_t mtx_sess;	pthread_mutex_t mtx_sess, mtx_pub;
FILE *logg;	FILE *logg;
extern char compiled[], compiledby[], compilehost[];	extern char compiled[], compiledby[], compilehost[];
static char szCfgName[MAXPATHLEN];	static char szCfgName[MAXPATHLEN];
Line 37 sigHand(int sig)	Line 37 sigHand(int sig)

switch (sig) {	switch (sig) {
case SIGHUP:	case SIGHUP:
UnloadConfig(&cfg);	cfgUnloadConfig(&cfg);
if (!LoadConfig(szCfgName, &cfg)) {	if (!cfgLoadConfig(szCfgName, &cfg)) {
ioDEBUG(1, "Config reload OK!");	ioDEBUG(1, "Config reload OK!");
break;	break;
}	}
Line 60 sigHand(int sig)	Line 60 sigHand(int sig)
int	int
main(int argc, char **argv)	main(int argc, char **argv)
{	{
char ch, batch = 0, szStr[STRSIZ];	char ch, batch = 0;
register int i;	register int i;
int sock = -1, ret = 0;	int sock = -1, ret = 0;
struct passwd *pass;	struct passwd *pass;
struct sigaction sa;	struct sigaction sa;
	ait_val_t v;

TAILQ_INIT(&Sessions);	TAILQ_INIT(&Sessions);

Line 88 main(int argc, char **argv)	Line 89 main(int argc, char **argv)
argc -= optind;	argc -= optind;
argv += optind;	argv += optind;

if (LoadConfig(szCfgName, &cfg)) {	if (cfgLoadConfig(szCfgName, &cfg)) {
printf("Error:: can't load #%d - %s\n", cfg_GetErrno(), cfg_GetError());	printf("Error:: can't load #%d - %s\n", cfg_GetErrno(), cfg_GetError());
return 1;	return 1;
}	}
pthread_mutex_init(&mtx_sess, NULL);	pthread_mutex_init(&mtx_sess, NULL);
	pthread_mutex_init(&mtx_pub, NULL);
openlog("mqttd", LOG_PID \| LOG_CONS, LOG_DAEMON);	openlog("mqttd", LOG_PID \| LOG_CONS, LOG_DAEMON);
	/* load 3 plugins */
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--)	while (i--)
mqttUnloadRTLM(i);	mqttUnloadRTLM(i);
UnloadConfig(&cfg);	cfgUnloadConfig(&cfg);
closelog();	closelog();
	pthread_mutex_destroy(&mtx_pub);
pthread_mutex_destroy(&mtx_sess);	pthread_mutex_destroy(&mtx_sess);
return 2;	return 2;
}	}
Line 167 main(int argc, char **argv)	Line 171 main(int argc, char **argv)
goto end;	goto end;
}	}

cfg_LoadAttribute(&cfg, CFG("mqttd"), CFG("user"), CFG(szStr), sizeof szStr, MQTT_USER);	cfg_loadAttribute(&cfg, "mqttd", "user", &v, MQTT_USER);
pass = getpwnam(szStr);	pass = getpwnam(AIT_GET_STR(&v));
	AIT_FREE_VAL(&v);
if (pass) {	if (pass) {
setgid(pass->pw_gid);	setgid(pass->pw_gid);
setuid(pass->pw_uid);	setuid(pass->pw_uid);
Line 192 end:	Line 197 end:
for (i = 0; i < 3; i++)	for (i = 0; i < 3; i++)
mqttUnloadRTLM(i);	mqttUnloadRTLM(i);
closelog();	closelog();
UnloadConfig(&cfg);	cfgUnloadConfig(&cfg);
	pthread_mutex_destroy(&mtx_pub);
pthread_mutex_destroy(&mtx_sess);	pthread_mutex_destroy(&mtx_sess);
return ret;	return ret;
}	}

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

Removed from v.1.1.1.1.2.14
changed lines
	Added in v.1.2.2.1