Update for PM changing from Date to Long

kgrgreer · Sep 28, 2020 · 595c7c9 · 595c7c9
1 parent da0b1e4
commit 595c7c9
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/src/foam/box/socket/SocketConnectionBox.js b/src/foam/box/socket/SocketConnectionBox.js
@@ -215,7 +215,7 @@ foam.CLASS({
           try {
             long sent = in_.readLong();
             PM p = PM.create(getX(), this.getClass().getSimpleName(), getHost()+":"+getPort()+":network");
-            p.setStartTime(new java.util.Date(sent));
+            p.setStartTime(sent);
             p.log(x);
 
             pm = PM.create(x, pmKey, pmName);

diff --git a/src/foam/box/socket/SocketServerProcessor.java b/src/foam/box/socket/SocketServerProcessor.java
@@ -78,7 +78,7 @@ public void execute(X x) {
         try {
           long sent = in_.readLong();
           PM p = PM.create(x, pmKey, pmName+":network");
-          p.setStartTime(new java.util.Date(sent));
+          p.setStartTime(sent);
           p.log(x);
 
           pm = PM.create(x, pmKey, pmName+":execute");

diff --git a/src/foam/nanos/medusa/ClusterCommand.js b/src/foam/nanos/medusa/ClusterCommand.js
@@ -115,7 +115,7 @@ foam.CLASS({
         // set destination on previous hop
         ClusterCommandHop hop = existing[existing.length -1];
         PM pm = hop.getPm();
-        pm.setEndTime(new java.util.Date());
+        pm.setEndTime(System.currentTimeMillis());
         pm.setName(PM.combine(pm.getName(), support.getConfigId()));
         // start next hop
         ClusterCommandHop[] hops = new ClusterCommandHop[existing.length + 1];

diff --git a/src/foam/nanos/medusa/ClusterConfigMonitorAgent.js b/src/foam/nanos/medusa/ClusterConfigMonitorAgent.js
@@ -132,7 +132,7 @@ foam.CLASS({
             ClusterConfig cfg = (ClusterConfig) client.find_(x, config.getId());
             pm.log(x);
             if ( cfg != null ) {
-              cfg.setPingTime(pm.getEndTime().getTime() - pm.getStartTime().getTime());
+              cfg.setPingTime(pm.getEndTime() - pm.getStartTime());
               getDao().put_(x, cfg);
             } else {
               getLogger().warning("client,find", cfg.getId(), "null");