mqtt/src/daemon.c - diff

Return to daemon.c CVS log

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

version 1.2.2.20, 2012/05/03 13:39:34	version 1.2.2.22, 2012/05/03 15:05:37
Line 336 acceptClient(sched_task_t *task)	Line 336 acceptClient(sched_task_t *task)
if ((cli = accept(TASK_FD(task), &sa.sa, &sslen)) == -1)	if ((cli = accept(TASK_FD(task), &sa.sa, &sslen)) == -1)
goto end;	goto end;
else	else
fcntl(TASK_FD(task), F_SETFL, fcntl(TASK_FD(task), F_GETFL, 0) \| O_NONBLOCK);	fcntl(cli, F_SETFL, fcntl(cli, F_GETFL, 0) \| O_NONBLOCK);

v = io_allocVar();	v = io_allocVar();
if (!v) {	if (!v) {
Line 357 acceptClient(sched_task_t *task)	Line 357 acceptClient(sched_task_t *task)
ioDEBUG(1, "Terminated client with socket=%d", cli);	ioDEBUG(1, "Terminated client with socket=%d", cli);
}	}
end:	end:
if (!schedRead(TASK_ROOT(task), acceptClient, NULL, TASK_FD(task), NULL, 0))	if (!schedRead(root, acceptClient, NULL, TASK_FD(task), NULL, 0))
ioLIBERR(sched);	ioLIBERR(sched);
return NULL;	return NULL;
}	}