@@ -80,7 +80,7 @@ int mfdirchk(mfile *d){

   if(d->mdata.head.flags & MAKUO_FLAG_ACK){

     return(1);

   }

-  for(m=mftop[0];m;m=m->next){

+  for(m=mftop[MFSEND];m;m=m->next){

     if(m == d){

       continue;

     }

@@ -276,7 +276,7 @@ int do_accept(mcomm *c, fd_set *fds)

   }

   c[i].addrlen = sizeof(c[i].addr);

   c[i].fd[0] = accept(s, (struct sockaddr *)(&c[i].addr), &(c[i].addrlen));

-  lprintf(1, "%s: accept from %s i=%d fd=%d\n", __func__, inet_ntoa(c[i].addr.sin_addr), i, c[i].fd[0]);

+  lprintf(1, "%s: socket[%d] from %s\n", __func__, i, inet_ntoa(c[i].addr.sin_addr));

   c[i].working = 1;

   return(0);

 }

@@ -313,9 +313,9 @@ void mloop()

       do_pong();

       do_recv();

       do_send();

-      do_exechk(moption.comm);

       do_accept(moption.comm, &rfds);

       do_comexe(moption.comm, &rfds);

+      do_exechk(moption.comm);

     }

   }

 }

@@ -5,21 +5,21 @@

 #include "makuosan.h"

-char *command_list[]={"quit",     /*  */

-                      "exit",     /*  */

-                      "bye",      /*  */

-                      "send",     /*  */

-                      "sync",     /*  */

-                      "dsync",    /*  */

-                      "members",  /*  */

-                      "status",   /*  */

-                      "md5",      /*  */

-                      "check",    /*  */

-                      "echo",     /*  */

-                      "exclude",  /*  */

-                      "loglevel", /*  */

-                      "help",     /*  */

-                      NULL};      /*  */

+char *command_list[]={"quit",

+                      "exit",

+                      "bye",

+                      "send",

+                      "sync",

+                      "dsync",

+                      "members",

+                      "status",

+                      "md5",

+                      "check",

+                      "echo",

+                      "exclude",

+                      "loglevel",

+                      "help",

+                      NULL};

 mfile *mexec_with_dsync(mcomm *c, char *fn, int dryrun, int recurs, mhost *t)

 {

@@ -254,11 +254,22 @@ int mexec_scan(mcomm *c, char *fn, mhost *h, int mode, gid_t gid)

 int mexec_close(mcomm *c, int n)

 {

+  int i;

   mfile *m;

-  lprintf(1 + n * 7, "%s: fd=%d n=%d\n", __func__, c->fd[n], n);

-  if(c->fd[n] != -1)

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

     close(c->fd[n]);

+    for(i=0;i<MAX_COMM;i++){

+      if(c == &(moption.comm[i])){

+        break;

+      }

+    }

+    if(n){

+      lprintf(8, "%s: socket[%d] (backend)\n", __func__, i);

+    }else{

+      lprintf(1, "%s: socket[%d]\n", __func__, i);

+    }

+  }

   c->fd[n]  = -1;

   c->size[n] = 0;

   if(!n){

@@ -274,7 +285,7 @@ int mexec_close(mcomm *c, int n)

     for(m=mftop[MFSEND];m;m=m->next){

       if(m->comm == c){

         m->comm = NULL;

-        lprintf(3, "%s: cancel %s\n", __func__, m->fn);

+        lprintf(3, "%s: cancel> %s\n", __func__, m->cmdline);

       }

     }

   }

@@ -831,7 +842,13 @@ int mexec_status(mcomm *c, int n)

   mfile  *m;

   struct tm *t;

+  /*----- pid -----*/

+  cprintf(0, c, "process: %d\n", getpid());

+

+  /*----- version -----*/

   cprintf(0,c,"version: %s\n", PACKAGE_VERSION);

+

+  /*----- basedir -----*/

   if(moption.chroot){

     cprintf(0, c, "chroot : %s/\n", moption.real_dir);

   }else{