From 73f8412b422e84c53de832b4985ade17c61c2cb8 Mon Sep 17 00:00:00 2001
From: Peter Johnson <johnson.peter@gmail.com>
Date: Thu, 5 Oct 2017 23:13:31 -0700
Subject: [PATCH] Correctly handle negative waitForXQueue timeouts in Java.

---
 .../networktables/NetworkTableInstance.java   | 24 +++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

diff --git a/src/main/java/edu/wpi/first/networktables/NetworkTableInstance.java b/src/main/java/edu/wpi/first/networktables/NetworkTableInstance.java
index 4d53f67fba..5c8f296196 100644
--- a/src/main/java/edu/wpi/first/networktables/NetworkTableInstance.java
+++ b/src/main/java/edu/wpi/first/networktables/NetworkTableInstance.java
@@ -345,7 +345,11 @@ public final class NetworkTableInstance {
         NetworkTablesJNI.cancelPollEntryListener(m_entryListenerPoller);
         while (m_entryListenerWaitQueue) {
           try {
-            return m_entryListenerWaitQueueCond.await((long) (timeout * 1e9), TimeUnit.NANOSECONDS);
+            if (timeout < 0) {
+              m_entryListenerWaitQueueCond.await();
+            } else {
+              return m_entryListenerWaitQueueCond.await((long) (timeout * 1e9), TimeUnit.NANOSECONDS);
+            }
           } catch (InterruptedException ex) {
             Thread.currentThread().interrupt();
             return true;
@@ -475,7 +479,11 @@ public final class NetworkTableInstance {
         NetworkTablesJNI.cancelPollConnectionListener(m_connectionListenerPoller);
         while (m_connectionListenerWaitQueue) {
           try {
-            return m_connectionListenerWaitQueueCond.await((long) (timeout * 1e9), TimeUnit.NANOSECONDS);
+            if (timeout < 0) {
+              m_connectionListenerWaitQueueCond.await();
+            } else {
+              return m_connectionListenerWaitQueueCond.await((long) (timeout * 1e9), TimeUnit.NANOSECONDS);
+            }
           } catch (InterruptedException ex) {
             Thread.currentThread().interrupt();
             return true;
@@ -597,7 +605,11 @@ public final class NetworkTableInstance {
         NetworkTablesJNI.cancelPollRpc(m_rpcCallPoller);
         while (m_rpcCallWaitQueue) {
           try {
-            return m_rpcCallWaitQueueCond.await((long) (timeout * 1e9), TimeUnit.NANOSECONDS);
+            if (timeout < 0) {
+              m_rpcCallWaitQueueCond.await();
+            } else {
+              return m_rpcCallWaitQueueCond.await((long) (timeout * 1e9), TimeUnit.NANOSECONDS);
+            }
           } catch (InterruptedException ex) {
             Thread.currentThread().interrupt();
             return true;
@@ -1070,7 +1082,11 @@ public final class NetworkTableInstance {
         NetworkTablesJNI.cancelPollLogger(m_loggerPoller);
         while (m_loggerWaitQueue) {
           try {
-            return m_loggerWaitQueueCond.await((long) (timeout * 1e9), TimeUnit.NANOSECONDS);
+            if (timeout < 0) {
+              m_loggerWaitQueueCond.await();
+            } else {
+              return m_loggerWaitQueueCond.await((long) (timeout * 1e9), TimeUnit.NANOSECONDS);
+            }
           } catch (InterruptedException ex) {
             Thread.currentThread().interrupt();
             return true;