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

Jupyter Vars View env tests

Browse Source 
GitOrigin-RevId: 5d8f85798caba1055d3bd31baa8a6009c841ccfd
This commit is contained in:
Elizaveta Shashkova
2019-05-20 17:10:43 +03:00
committed by intellij-monorepo-bot
parent 2c80149799
commit e274a57fb9
1 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/testSrc/com/jetbrains/env/python/debug/PyBaseDebuggerTask.java
Vendored
+14 -6
View File
@@ -51,6 +51,7 @@ import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
/**
* @author traff
@@ -186,26 +187,33 @@ public abstract class PyBaseDebuggerTask extends PyExecutionFixtureTestTask {
return convertToList(myDebugProcess.loadFrame());
}
protected String computeValueAsync(List<PyDebugValue> debugValues, String name) throws PyDebuggerException {
protected String computeValueAsync(List<PyDebugValue> debugValues, String name) throws PyDebuggerException, InterruptedException {
final PyDebugValue debugValue = findDebugValueByName(debugValues, name);
assert debugValue != null;
Semaphore variableSemaphore = new Semaphore(0);
final ArrayList<PyFrameAccessor.PyAsyncValue<String>> valuesForEvaluation = createAsyncValue(debugValue, variableSemaphore);
myDebugProcess.loadAsyncVariablesValues(valuesForEvaluation);
if (!variableSemaphore.tryAcquire(NORMAL_TIMEOUT, TimeUnit.MILLISECONDS)) {
throw new PyDebuggerException("Timeout exceeded, failed to load variable: " + debugValue.getName());
}
return debugValue.getValue();
}
public static ArrayList<PyFrameAccessor.PyAsyncValue<String>> createAsyncValue(PyDebugValue debugValue, Semaphore semaphore) {
ArrayList<PyFrameAccessor.PyAsyncValue<String>> valuesForEvaluation = new ArrayList<>();
valuesForEvaluation.add(new PyFrameAccessor.PyAsyncValue<>(debugValue, new PyDebugCallback<String>() {
@Override
public void ok(String value) {
debugValue.setValue(value);
variableSemaphore.release();
semaphore.release();
}
@Override
public void error(PyDebuggerException exception) {
variableSemaphore.release();
semaphore.release();
}
}));
myDebugProcess.loadAsyncVariablesValues(valuesForEvaluation);
XDebuggerTestUtil.waitFor(variableSemaphore, NORMAL_TIMEOUT);
return debugValue.getValue();
return valuesForEvaluation;
}
public static List<PyDebugValue> convertToList(XValueChildrenList childrenList) {