@@ -208,7 +208,14 @@ void do_free()

 void do_recv()

 {

-  mrecv();

+  mhost *t = members;

+  while(mrecv()){

+    if(t){

+      t=t->next;

+    }else{

+      break;

+    }

+  }

 }

 void do_send()

@@ -274,6 +281,9 @@ int do_accept(mcomm *c, fd_set *fds)

       break;

   }

   c[i].working = 1;

+  if(fcntl(c[i].fd[0], F_SETFL , O_NONBLOCK)){

+    lprintf(0, "[error] %s: fcntl: %s\n", __func__, strerror(errno));

+  }

   return(0);

 }

@@ -200,6 +200,7 @@ typedef struct

   int authchk;

   int isalive;

   int logflag;

+  int logover;

   char cmdline[2][MAKUO_BUFFER_SIZE];

   char parse[2][8][MAKUO_BUFFER_SIZE];

   char readbuff[2][MAKUO_BUFFER_SIZE];

@@ -293,6 +293,7 @@ int mexec_close(mcomm *c, int n)

   if(!n){

     c->authchk  = 0;

     c->logflag  = 0;

+    c->logover  = 0;

     c->loglevel = 0;

     c->isalive  = 0;

     if(c->cpid){

@@ -179,19 +179,46 @@ void lprintf(int l, char *fmt, ...)

 void cprintf(int l, mcomm *c, char *fmt, ...)

 {

+  int r;

+  int n;

+  fd_set wfds;

+  struct timeval tv;

   char m[2048];

   va_list arg;

-  if(!c)

+  if(!c){

     return;

-  if(c->fd[0] == -1)

+  }

+  if(c->fd[0] == -1){

     return;

-  if(c->loglevel >= l){

-    va_start(arg, fmt);

-    vsnprintf(m, sizeof(m), fmt, arg);

-    va_end(arg);

-    m[sizeof(m) - 1] = 0;

-    write(c->fd[0], m, strlen(m));

-    fsync(c->fd[0]);

+  }

+  if(c->loglevel < l){

+    return;

+  }

+  va_start(arg, fmt);

+  vsnprintf(m, sizeof(m), fmt, arg);

+  va_end(arg);

+  m[sizeof(m) - 1] = 0;

+  FD_ZERO(&wfds);

+  FD_SET(c->fd[0], &wfds);

+  tv.tv_sec  = 0;

+  tv.tv_usec = 100000;

+  if(select(1024, NULL, &wfds, NULL, &tv) <= 0){

+    c->logover++;

+    lprintf(0, "[error] %s: client busy: %s", __func__, m);

+  }else{

+    n = strlen(m);

+    r = write(c->fd[0], m, n);

+    if(r == -1){

+      c->logover++;

+      lprintf(0, "[error] %s: write: %s fd=%d", __func__, strerror(errno), c->fd[0]);

+    }else{

+      if(r < n){

+        c->logover++;

+        lprintf(0, "[error] %s: over fllow: %s", __func__, m);

+      }else{

+        fsync(c->fd[0]);

+      }

+    }

   }

 }