MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

IDEA-CR-19207 distinct error message to simplify debug

Browse Source
This commit is contained in:
Vladimir Krivosheev
2017-03-13 15:11:35 +01:00
parent 4e1baa5177
commit 2dc564c2e4
1 changed files with 42 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/script-debugger/debugger-ui/src/RemoteVmConnection.kt
+42 -41
View File
@@ -50,52 +50,53 @@ abstract class RemoteVmConnection : VmConnection<Vm>() {
port = address.port
setState(ConnectionStatus.WAITING_FOR_CONNECTION, "Connecting to ${address.hostString}:${address.port}")
val result = AsyncPromise<Vm>()
var attemptNumber = 0
fun attempt() {
connectCancelHandler.set { result.setError("Closed explicitly") }
val connectionPromise = AsyncPromise<Any?>()
connectionPromise.rejected { result.setError(it) }
result
.done {
vm = it!!
setState(ConnectionStatus.CONNECTED, "Connected to ${connectedAddressToPresentation(address, it)}")
startProcessing()
}
.rejected {
if (it !is ConnectException) {
LOG.errorIfNotMessage(it)
}
setState(ConnectionStatus.CONNECTION_FAILED, it.message)
}
.processed { connectCancelHandler.set(null) }
createBootstrap(address, result)
.connect(address, connectionPromise,
maxAttemptCount = if (stopCondition == null) NettyUtil.DEFAULT_CONNECT_ATTEMPT_COUNT else -1,
stopCondition = stopCondition)
?.closeFuture()?.addListener {
if (result.isFulfilled) {
close("Process disconnected unexpectedly", ConnectionStatus.DISCONNECTED)
}
else {
if (++attemptNumber > 10 || (stopCondition?.value(null) ?: false)) {
result.setError("Cannot establish connection - promptly closed after open")
}
else {
sleep(result, 300)
attempt()
}
}
}
}
val future = ApplicationManager.getApplication().executeOnPooledThread {
if (Thread.interrupted()) {
return@executeOnPooledThread
}
var attemptNumber = 0
fun attempt() {
connectCancelHandler.set { result.setError("Closed explicitly") }
val connectionPromise = AsyncPromise<Any?>()
connectionPromise.rejected { result.setError(it) }
result
.done {
vm = it!!
setState(ConnectionStatus.CONNECTED, "Connected to ${connectedAddressToPresentation(address, it)}")
startProcessing()
}
.rejected {
if (it !is ConnectException) {
LOG.errorIfNotMessage(it)
}
setState(ConnectionStatus.CONNECTION_FAILED, it.message)
}
.processed { connectCancelHandler.set(null) }
createBootstrap(address, result)
.connect(address, connectionPromise,
maxAttemptCount = if (stopCondition == null) NettyUtil.DEFAULT_CONNECT_ATTEMPT_COUNT else -1,
stopCondition = stopCondition)
?.closeFuture()?.addListener {
if (result.isFulfilled) {
close("Process disconnected unexpectedly", ConnectionStatus.DISCONNECTED)
}
else {
if (++attemptNumber > 10 || (stopCondition?.value(null) ?: false)) {
result.setError("Process disconnected unexpectedly")
}
else {
sleep(result, 300)
attempt()
}
}
}
}
attempt()
}