Fixed bug where stopwatch wouldn't reset when an error occurs

kairosdb · Apr 8, 2019 · 2534fac · 2534fac
1 parent d58e025
commit 2534fac
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/pom.xml b/pom.xml
@@ -4,7 +4,7 @@
 
 	<groupId>org.kairosdb</groupId>
 	<artifactId>kairos-remote</artifactId>
-	<version>1.1</version>
+	<version>1.1.1</version>
 	<packaging>jar</packaging>
 
 	<name>kairos-remote</name>

diff --git a/src/main/java/org/kairosdb/plugin/remote/RemoteListener.java b/src/main/java/org/kairosdb/plugin/remote/RemoteListener.java
@@ -76,7 +76,6 @@ public class RemoteListener
 	private String m_dataFileName;
 	private volatile boolean m_firstDataPoint = true;
 	private int m_dataPointCounter;
-	private Stopwatch m_sendTimer = Stopwatch.createUnstarted();
 
 	private volatile Multimap<DataPointKey, DataPoint> m_dataPointMultimap;
 	private final Object m_mapLock = new Object();  //Lock for the above map
@@ -447,14 +446,13 @@ void sendData() throws IOException
 		{
 
 			long now = System.currentTimeMillis();
-			m_sendTimer.start();
+			Stopwatch sendTimer = Stopwatch.createStarted();
+			long timeToSend = 0L;
 
 			rollAndZipFile(now, false);
-
 			sendAllZipfiles();
 
-			long timeToSend = m_sendTimer.elapsed(TimeUnit.MILLISECONDS);
-			m_sendTimer.reset();
+			timeToSend = sendTimer.elapsed(TimeUnit.MILLISECONDS);
 
 			try
 			{