Changeset 3663

Timestamp:

Aug 14, 2007, 9:09:04 AM (16 years ago)

Author:

Nicklas Nordborg

Message:

Measure performance for reporter migration.

Location:

trunk/src

Files:

• clients/migrate/net/sf/basedb/clients/migrate/ReporterTransfer.java (modified) (4 diffs)
• core/net/sf/basedb/util/timer/PerformanceTimer.java (added)

trunk/src/clients/migrate/net/sf/basedb/clients/migrate/ReporterTransfer.java

@@ -34 +34 @@
 import net.sf.basedb.core.query.Hql;
 import net.sf.basedb.core.query.Orders;
+import net.sf.basedb.util.timer.PerformanceTimer;
 
 import java.sql.PreparedStatement;
@@ -146 +147 @@
         query.setFirstResult(start);
         cleanUpMemory();
+        log.info("Mapping reporter #" + start + " to #"+(start+batchSize));
         mapMigratedReporters(dc, query);
         start += batchSize;
       }
       cleanUpMemory();
+      log.info("Mapping duplicate reporters");
       mapDuplicateReporters();
     }
@@ -214 +217 @@
   {
     DataResultIterator<ReporterData> result = null;
+    PerformanceTimer timer = new PerformanceTimer(
+      "iterate()", "hasNext()", "next()", "HashMap.get()", "HashMap.put()", "other");
     try
     {
+      timer.start(0);
       result = query.iterate(dc);
+      timer.stopStart(0, 1);
       while (result.hasNext())
       {
+        timer.stopStart(1, 2);
         ReporterData reporter = result.next();
+        timer.stopStart(2, 3);
         Integer base1Id = externalIdMap.get(reporter.getExternalId());
+        timer.stopStart(3, 4);
         reporterMap.put(base1Id, new ReporterProxy(reporter));
+        timer.stopStart(4, 5);
         progress.increase();
         if (log.isDebugEnabled())
@@ -228 +239 @@
             " has been mapped to BASE 1 ID="+base1Id);
         }
+        timer.stopStart(5, 1);
+      }
+      timer.stopAll();
+      if (log.isInfoEnabled())
+      {
+        log.info("\n"+timer.toString());
       }
     }