Cleaned up exceptions
This commit is contained in:
parent
41ea4872be
commit
82fb4c4151
|
@ -16,11 +16,11 @@
|
||||||
|
|
||||||
package dorkbox.network.aeron
|
package dorkbox.network.aeron
|
||||||
|
|
||||||
|
import dorkbox.network.connection.ListenerManager
|
||||||
import dorkbox.network.exceptions.ClientTimedOutException
|
import dorkbox.network.exceptions.ClientTimedOutException
|
||||||
import io.aeron.ChannelUriStringBuilder
|
import io.aeron.ChannelUriStringBuilder
|
||||||
import kotlinx.coroutines.delay
|
import kotlinx.coroutines.delay
|
||||||
import mu.KLogger
|
import mu.KLogger
|
||||||
import java.lang.Thread.sleep
|
|
||||||
import java.util.concurrent.*
|
import java.util.concurrent.*
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -81,13 +81,15 @@ internal open class IpcMediaDriverConnection(streamId: Int,
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
delay(500L) // not delay? maybe coroutines?
|
delay(500L)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
if (!success) {
|
if (!success) {
|
||||||
subscription.close()
|
subscription.close()
|
||||||
throw ClientTimedOutException("Creating subscription connection to aeron")
|
val clientTimedOutException = ClientTimedOutException("Creating subscription connection to aeron")
|
||||||
|
ListenerManager.cleanStackTraceInternal(clientTimedOutException)
|
||||||
|
throw clientTimedOutException
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -101,13 +103,16 @@ internal open class IpcMediaDriverConnection(streamId: Int,
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
delay(500L) // not delay? maybe coroutines?
|
delay(500L)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!success) {
|
if (!success) {
|
||||||
subscription.close()
|
subscription.close()
|
||||||
publication.close()
|
publication.close()
|
||||||
throw ClientTimedOutException("Creating publication connection to aeron")
|
|
||||||
|
val clientTimedOutException = ClientTimedOutException("Creating publication connection to aeron")
|
||||||
|
ListenerManager.cleanStackTraceInternal(clientTimedOutException)
|
||||||
|
throw clientTimedOutException
|
||||||
}
|
}
|
||||||
|
|
||||||
this.success = true
|
this.success = true
|
||||||
|
|
|
@ -124,7 +124,7 @@ internal class UdpMediaDriverClientConnection(val address: InetAddress,
|
||||||
if (!success) {
|
if (!success) {
|
||||||
subscription.close()
|
subscription.close()
|
||||||
val ex = ClientTimedOutException("Cannot create subscription: $ip ${subscriptionUri.build()} in ${timoutInNanos}ms")
|
val ex = ClientTimedOutException("Cannot create subscription: $ip ${subscriptionUri.build()} in ${timoutInNanos}ms")
|
||||||
ListenerManager.cleanStackTrace(ex)
|
ListenerManager.cleanStackTraceInternal(ex)
|
||||||
throw ex
|
throw ex
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user