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

PY-21264 Simplify the code, get rid of the success variable

Browse Source
This commit is contained in:
Alexander Koshevoy
2016-11-11 16:00:11 +03:00
parent e96a30b72b
commit 6c5abe9831
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/pydevSrc/com/jetbrains/python/debugger/pydev/transport/ClientModeDebuggerTransport.java
+4 -7
View File
@@ -17,7 +17,6 @@ import java.net.ConnectException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicBoolean;
/**
* {@link DebuggerTransport} implementation that expects a debugging script to behave as a server. The main process of the debugging script
@@ -122,22 +121,21 @@ public class ClientModeDebuggerTransport extends BaseDebuggerTransport {
throw e;
}
AtomicBoolean success = new AtomicBoolean(false);
CountDownLatch beforeHandshake = new CountDownLatch(1);
Future<Void> future = ApplicationManager.getApplication().executeOnPooledThread(() -> {
Future<Boolean> future = ApplicationManager.getApplication().executeOnPooledThread(() -> {
beforeHandshake.countDown();
try {
myDebugger.handshake();
success.set(true);
return true;
}
catch (PyDebuggerException e) {
LOG.debug(String.format("[%d] Handshake failed: #%d attempt", hashCode(), attempt));
return false;
}
return null;
});
try {
beforeHandshake.await();
future.get(CHECK_CONNECTION_APPROVED_DELAY, TimeUnit.MILLISECONDS);
connected = future.get(CHECK_CONNECTION_APPROVED_DELAY, TimeUnit.MILLISECONDS);
}
catch (InterruptedException e) {
LOG.debug(String.format("[%d] Waiting for handshake interrupted: #%d attempt", hashCode(), attempt), e);
@@ -152,7 +150,6 @@ public class ClientModeDebuggerTransport extends BaseDebuggerTransport {
future.cancel(true);
}
connected = success.get();
if (!connected) {
myDebuggerReader.close();
try {