From 7fbc86d132e2e3aca4e0e293c4975da2b374f2eb Mon Sep 17 00:00:00 2001
From: nathan <nathan@dorkbox.com>
Date: Thu, 13 Aug 2020 00:50:53 +0200
Subject: [PATCH] Removed RMI debug comments

---
 src/dorkbox/network/rmi/RmiResponseStorage.kt | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/src/dorkbox/network/rmi/RmiResponseStorage.kt b/src/dorkbox/network/rmi/RmiResponseStorage.kt
index 6d3978a8..8653fbaf 100644
--- a/src/dorkbox/network/rmi/RmiResponseStorage.kt
+++ b/src/dorkbox/network/rmi/RmiResponseStorage.kt
@@ -37,7 +37,6 @@ internal data class RmiWaiter(val id: Int) {
     }
 
     suspend fun doNotify() {
-        println("notified waiter")
         try {
             channel.send(Unit)
         } catch (ignored: Exception) {
@@ -45,7 +44,6 @@ internal data class RmiWaiter(val id: Int) {
     }
 
     suspend fun doWait() {
-        println("waiting waiter")
         try {
             channel.receive()
         } catch (ignored: Exception) {
@@ -53,7 +51,6 @@ internal data class RmiWaiter(val id: Int) {
     }
 
     fun cancel() {
-        println("delay is cancelling suspending coroutine")
         try {
             channel.cancel()
         } catch (ignored: Exception) {
@@ -109,8 +106,6 @@ internal class RmiResponseStorage(private val actionDispatch: CoroutineScope) {
 
         val pendingId = RmiUtils.packShorts(objectId, responseId)
 
-        println("pending result received")
-
         val previous = pendingLock.write { pending.put(pendingId, result) }
 
         // if NULL, since either we don't exist, or it was cancelled
@@ -162,8 +157,7 @@ internal class RmiResponseStorage(private val actionDispatch: CoroutineScope) {
             // check if we have a result or not
             val maybeResult = pendingLock.read { pending[pendingId] }
             if (maybeResult is RmiWaiter) {
-                System.err.println("TIMEOUT $pendingId")
-//                maybeResult.cancel()
+                maybeResult.cancel()
             }
         }