change driver_cloud_swap.

src/driver/driver_cloud_swap_client/grpcclient.cpp

@@ -164,6 +164,8 @@ void grpcclient::threadrecv(std::shared_ptr<::grpc::ClientReaderWriter<iv::Cloud
         std::cout<<" reply nres: "<<reply.xdata_size()<<std::endl;
 //        nfail = 0;
 //        std::cout << "接收到回复：" << reply.remsg()<<"--\n" << std::endl;
+        std::cout<<" node latency:  "<<reply.flatency_innode()<<" objnode latency: "<<reply.flatency_inobjnode()
+                <<" server latency: "<<reply.flatency_inserver()<<" objnode store latency: "<<reply.flatencyinstore_obj()<<std::endl;
         if(reply.nres() > 0)
         {
             int i;

src/driver/driver_cloud_swap_server/swapunit.cpp

@@ -81,6 +81,7 @@ void swapunit::threadsend(::grpc::ServerReaderWriter<iv::CloudSwapReplyStream, i
         }
         iv::CloudSwapReplyStream xreply;
         xreply.set_nres(xvectorsendmsgbuf.size());
+        double fpinginobj;
         if(xvectorsendmsgbuf.size() == 0)
         {
             xreply.set_flatency_inserver(0.0);
@@ -90,16 +91,17 @@ void swapunit::threadsend(::grpc::ServerReaderWriter<iv::CloudSwapReplyStream, i
         {
             int64_t nlatinserver = (xNow - xvectorsendmsgbuf[0].nRecvTime);
             double flatinserver = nlatinserver;
-            flatinserver = flatinserver/1000000000.0;
+            flatinserver = flatinserver/1000000.0;  //ms
             xreply.set_flatency_inserver(flatinserver);
+            fpinginobj = xvectorsendmsgbuf[0].pingavg;
         }
         for(i=0;i<nsize;i++)
         {
             std::cout<<" add reply data. "<<std::endl;
             xreply.add_xdata(xvectorsendmsgbuf[i].pdata_ptr.get(),xvectorsendmsgbuf[i].ndatasize);
         }
-        xreply.set_flatency_innode(0);
-        xreply.set_flatency_inobjnode(0);
+        xreply.set_flatency_innode(mfpingavg);
+        xreply.set_flatency_inobjnode(fpinginobj);
         xreply.set_nmsgservertime(xNow);
  //       xreply.set_nres(1);
         std::cout<<mstrnodeid<<" reply data size : "<<xreply.xdata_size()<<std::endl;