@@ -2,7 +2,7 @@

  - エラーログに"[error]"という文字列を追加した

  - メンバがタイムアウトしたときの状態を詳細に出力するようにした

  - msyncのstatusオプションで、実行中のコマンドを表示するようにした

- - 応答速度が少しだけ向上した気がする

+ - レイテンシが若干向上した

  - msyncを複数同時実行したときに挙動がおかしくなる不具合を修正

  - ファイルクローズが失敗したときに異常終了することがあった不具合を修正

  - msyncにdeleteオプションを指定したときの結果表示がおかしくなる不具合を修正

@@ -10,11 +10,10 @@

 1.1.3: 2009/1/14

  - FreeBSDから msync -r ができなかった不具合を修正

- - FreeBSDでは受信はできましたが、送信できない状態でした

- - msync --membersの結果をソートするようにしました

+ - msync --membersの結果をソートするようにした

 1.1.2: 2008/12/24

- - makuosan終了時にシャットダウンメッセージを飛ばしていなかった不具合を修正

+ - 終了時にシャットダウンメッセージを飛ばしていなかった不具合を修正

 1.1.1: 2008/12/24

  - msyncコマンドに--deleteオプションを追加

@@ -22,8 +21,8 @@

  - エラーを詳細に表示するようにした

 1.0.1: 2008/11/12

- - FreeBSDとMacOSXに対応しました

- - SPECファイルと起動スクリプトを同梱しました

+ - FreeBSDとMacOSXに対応

+ - SPECファイルと起動スクリプトを同梱

 1.0.0: 2008/11/6

  - 安定版リリース

@@ -5,7 +5,7 @@

 #ifdef HAVE_CONFIG_H

 #include "config.h"

 #endif

-#define PROTOCOL_VERSION 5

+#define PROTOCOL_VERSION 6

 #define _GNU_SOURCE

 #define _FILE_OFFSET_BITS 64

 #include <stdio.h>

@@ -979,31 +979,23 @@ static int msend_req_del_stat_waitcheck(int s, mfile *m)

 static void msend_req_del_stat(int s, mfile *m)

 {

-  if(m->pid == 0){

+  if(m->pipe != -1){

+    msend_req_del_stat_read(s, m);

+  }else{

     if(msend_req_del_stat_waitcheck(s, m)){

       m->sendwait = 1;

     }else{

-      m->mdata.head.nstate = MAKUO_SENDSTATE_LAST;

-      m->initstate = 1;

-      m->sendwait  = 0;

-      ack_clear(m, -1);

-    }

-    return;

-  }

-  if(m->pipe == -1){

-    if(waitpid(m->pid, NULL, WNOHANG) == m->pid){

-      m->pid = 0;

-    }else{

-      m->sendwait = 1;

+      if(m->link){

+        msend(mkack(&(m->link->mdata), &(m->link->addr), MAKUO_RECVSTATE_CLOSE));

+      }

+      if(waitpid(m->pid, NULL, WNOHANG) != m->pid){

+        m->sendwait = 1;

+      }else{

+        m->pid = 0;

+        msend_mfdel(m);

+      }

     }

-    return;

   }

-  msend_req_del_stat_read(s, m);

-}

-

-static void msend_req_del_last(int s, mfile *m)

-{

-  msend_mfdel(m);

 }

 static void msend_req_del_break(int s, mfile *m)

@@ -1068,6 +1060,9 @@ static void msend_req_del_close(int s, mfile *m)

     msend_packet(s, &(m->mdata), &(m->addr));

     return;

   }

+  if(m->link){

+    m->link->sendwait = 0;

+  }

   m->link = NULL;

   msend_mfdel(m);

 }

@@ -1079,9 +1074,6 @@ static void msend_req_del(int s, mfile *m)

     case MAKUO_SENDSTATE_STAT:

       msend_req_del_stat(s, m);

       break;

-    case MAKUO_SENDSTATE_LAST:

-      msend_req_del_last(s, m);

-      break;

     case MAKUO_SENDSTATE_BREAK:

       msend_req_del_break(s, m);

       break;