--- mqtt/src/daemon.c	2012/04/15 22:06:10	1.2.2.7
+++ mqtt/src/daemon.c	2012/04/15 23:45:34	1.2.2.8
@@ -47,6 +47,7 @@ initSession(int sock, ait_val_t * __restrict v)
 		return NULL;
 	}
 
+	/* init server actor */
 	sess->sess_srv = mqtt_srv_Init(sock, sess->sess_buf);
 	if (!sess->sess_srv) {
 		ioDEBUG(3, "Error:: in srv_Init #%d - %s", mqtt_GetErrno(), mqtt_GetError());
@@ -284,6 +285,7 @@ startSession(sched_task_t *task)
 	assert(task);
 
 	if (!TASK_DATA(task)) {
+		/* flow from accept new clients */
 		sess = initSession(TASK_FD(task), TASK_ARG(task));
 		if (!sess) {
 			io_freeVar(TASK_ARG(task));
@@ -395,10 +397,11 @@ static void *
 thrSched(void *arg __unused)
 {
 	struct tagSession *sess;
-	struct timespec pl = { 0, 10000000 };
+	struct timespec pl = { 0, 100000000 };
 
 	ioTRACE(1);
 
+	/* start scheduler loop */
 	schedPolling(root, &pl, NULL);
 	schedRun(root, &Kill);
 
@@ -434,6 +437,7 @@ Run(int sock)
 		return -1;
 	}
 
+	/* state machine - accept new connections */
 	while (!Kill) {
 		if ((cli = accept(sock, &sa.sa, &sslen)) == -1) {
 			if (!Kill)