Masanobu Yasui authored on 2014/12/09 20:14:26
Showing 2 changed files
... ...
@@ -979,7 +979,7 @@ int mexec_status(mcomm *c, int n)
979 979
   cprintf(0, c, "recv op : %d\n", count);
980 980
   for(m=mftop[MFRECV];m;m=m->next){
981 981
     t = localtime(&(m->lastrecv.tv_sec));
982
-    cprintf(0, c, "  %s %s %02d:%02d:%02d %s (%d/%d) mark=%d rid=%d\n",
982
+    cprintf(0, c, "  %s %s %02d:%02d:%02d %s (%d/%d) mark=%d rid=%d ip=%s\n",
983 983
       stropcode(&(m->mdata)), 
984 984
       strrstate(m->mdata.head.nstate), 
985 985
       t->tm_hour, t->tm_min, t->tm_sec, 
... ...
@@ -987,7 +987,8 @@ int mexec_status(mcomm *c, int n)
987 987
       m->recvcount,
988 988
       m->seqnomax, 
989 989
       m->markcount,
990
-      m->mdata.head.reqid); 
990
+      m->mdata.head.reqid,
991
+      inet_ntoa(m->addr.sin_addr)); 
991 992
   }
992 993
   return(0);
993 994
 }
... ...
@@ -1288,6 +1288,7 @@ static void mrecv_req_del_data(mdata *data, struct sockaddr_in *addr)
1288 1288
   m->mdata.head.reqid  = data->head.reqid;
1289 1289
   m->mdata.head.nstate = MAKUO_RECVSTATE_OPEN;
1290 1290
   memcpy(&(m->addr), addr, sizeof(m->addr));
1291
+  mtimeget(&(m->lastrecv));
1291 1292
   if(data->head.flags & MAKUO_FLAG_DRYRUN){
1292 1293
     m->dryrun = 1;
1293 1294
   }