mqtt/src/daemon.c - diff

Return to daemon.c CVS log

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

version 1.2.2.6, 2012/04/11 16:37:17	version 1.2.2.7, 2012/04/15 22:06:10
Line 421 Run(int sock)	Line 421 Run(int sock)

ioTRACE(1);	ioTRACE(1);

	/* start alternative thread for scheduler */
if (pthread_create(&tid, NULL, thrSched, NULL)) {	if (pthread_create(&tid, NULL, thrSched, NULL)) {
ioSYSERR(0);	ioSYSERR(0);
return -1;	return -1;
Line 442 Run(int sock)	Line 443 Run(int sock)
}	}
v = io_allocVar();	v = io_allocVar();
if (!v) {	if (!v) {
ioLIBERR(mqtt);	ioLIBERR(io);
break;	break;
} else {	} else {
memset(str, 0, sizeof str);	memset(str, 0, sizeof str);
snprintf(str, sizeof str, "%s:%hu", io_n2addr(&sa, v), io_n2port(&sa));	snprintf(str, sizeof str, "%s:%hu", io_n2addr(&sa, v), io_n2port(&sa));
	AIT_FREE_VAL(v);
AIT_SET_STR(v, str);	AIT_SET_STR(v, str);
}	}
ioDEBUG(1, "Connected client with socket=%d from %s", cli, AIT_GET_STR(v));	ioDEBUG(1, "Connected client with socket=%d from %s", cli, AIT_GET_STR(v));