diff --git a/common/source/java/ch/systemsx/cisd/common/evaluator/Evaluator.java b/common/source/java/ch/systemsx/cisd/common/evaluator/Evaluator.java
index df230def7a49efb5332e3dc0729913a23ca811f2..499e168601b71654f38ae65f8e9f37fcfdb493d7 100644
--- a/common/source/java/ch/systemsx/cisd/common/evaluator/Evaluator.java
+++ b/common/source/java/ch/systemsx/cisd/common/evaluator/Evaluator.java
@@ -39,6 +39,8 @@ import org.python.core.PyStringMap;
import org.python.core.PySystemState;
import org.python.util.PythonInterpreter;
+import ch.systemsx.cisd.common.utilities.PythonUtils;
+
/**
* A class for evaluating expressions, based on Jython.
* <p>
@@ -122,7 +124,7 @@ public final class Evaluator
{
throw new EvaluatorException("Expression '" + expression + "' contains line breaks");
}
- this.interpreter = new PythonInterpreter();
+ this.interpreter = PythonUtils.createIsolatedPythonInterpreter();
// Security: do not allow file access.
try
diff --git a/common/source/java/ch/systemsx/cisd/common/utilities/PythonUtils.java b/common/source/java/ch/systemsx/cisd/common/utilities/PythonUtils.java
new file mode 100644
index 0000000000000000000000000000000000000000..99a0d61dd35014f881aaa29d7ee064c2f0187720
--- /dev/null
+++ b/common/source/java/ch/systemsx/cisd/common/utilities/PythonUtils.java
@@ -0,0 +1,39 @@
+/*
+ * Copyright 2012 ETH Zuerich, CISD
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package ch.systemsx.cisd.common.utilities;
+
+import org.python.core.PySystemState;
+import org.python.util.PythonInterpreter;
+
+/**
+ * Utility functions for Jython.
+ *
+ * @author Bernd Rinn
+ */
+public class PythonUtils
+{
+
+ /**
+ * Creates a new Jython interpreter with a fully isolated system state (i.e. interpreters in
+ * different threads don't influence each other.
+ */
+ public static PythonInterpreter createIsolatedPythonInterpreter()
+ {
+ return new PythonInterpreter(null, new PySystemState());
+ }
+
+}
diff --git a/datastore_server/source/java/ch/systemsx/cisd/etlserver/registrator/JythonTopLevelDataSetHandler.java b/datastore_server/source/java/ch/systemsx/cisd/etlserver/registrator/JythonTopLevelDataSetHandler.java
index a5971fc0d908542277f637a184812f0d9070271a..99d9930c7c08166578be451bc572740c68567abf 100644
--- a/datastore_server/source/java/ch/systemsx/cisd/etlserver/registrator/JythonTopLevelDataSetHandler.java
+++ b/datastore_server/source/java/ch/systemsx/cisd/etlserver/registrator/JythonTopLevelDataSetHandler.java
@@ -30,6 +30,7 @@ import ch.systemsx.cisd.common.exceptions.ConfigurationFailureException;
import ch.systemsx.cisd.common.filesystem.FileUtilities;
import ch.systemsx.cisd.common.utilities.IDelegatedActionWithResult;
import ch.systemsx.cisd.common.utilities.PropertyUtils;
+import ch.systemsx.cisd.common.utilities.PythonUtils;
import ch.systemsx.cisd.etlserver.ITopLevelDataSetRegistratorDelegate;
import ch.systemsx.cisd.etlserver.TopLevelDataSetRegistratorGlobalState;
import ch.systemsx.cisd.etlserver.registrator.api.v1.SecondaryTransactionFailure;
@@ -198,7 +199,7 @@ public class JythonTopLevelDataSetHandler<T extends DataSetInformation> extends
{
return createJythonDataSetRegistrationService(incomingDataSetFile,
callerDataSetInformationOrNull, cleanAfterwardsAction, delegate,
- new PythonInterpreter(), getGlobalState());
+ PythonUtils.createIsolatedPythonInterpreter(), getGlobalState());
}
/**
diff --git a/datastore_server/source/java/ch/systemsx/cisd/etlserver/registrator/api/v2/JythonTopLevelDataSetHandlerV2.java b/datastore_server/source/java/ch/systemsx/cisd/etlserver/registrator/api/v2/JythonTopLevelDataSetHandlerV2.java
index 024d94d4a530e5ef85f57ff4d9b9d1c708da943d..7278192638caf05aa9fce67636fb4a904bbca072 100644
--- a/datastore_server/source/java/ch/systemsx/cisd/etlserver/registrator/api/v2/JythonTopLevelDataSetHandlerV2.java
+++ b/datastore_server/source/java/ch/systemsx/cisd/etlserver/registrator/api/v2/JythonTopLevelDataSetHandlerV2.java
@@ -21,6 +21,7 @@ import java.io.File;
import org.python.util.PythonInterpreter;
import ch.systemsx.cisd.common.utilities.IDelegatedActionWithResult;
+import ch.systemsx.cisd.common.utilities.PythonUtils;
import ch.systemsx.cisd.etlserver.ITopLevelDataSetRegistratorDelegate;
import ch.systemsx.cisd.etlserver.TopLevelDataSetRegistratorGlobalState;
import ch.systemsx.cisd.etlserver.registrator.DataSetFile;
@@ -60,7 +61,7 @@ public class JythonTopLevelDataSetHandlerV2<T extends DataSetInformation> extend
{
return createJythonDataSetRegistrationServiceV2(incomingDataSetFile,
callerDataSetInformationOrNull, cleanAfterwardsAction, delegate,
- new PythonInterpreter(), getGlobalState());
+ PythonUtils.createIsolatedPythonInterpreter(), getGlobalState());
}
/**
diff --git a/datastore_server/source/java/ch/systemsx/cisd/openbis/dss/generic/shared/api/v1/validation/ValidationScriptRunner.java b/datastore_server/source/java/ch/systemsx/cisd/openbis/dss/generic/shared/api/v1/validation/ValidationScriptRunner.java
index 80503292525d76fcd2480fe45f249a6925df3fd2..92503c0467a4560e96da384254327daf857496f2 100644
--- a/datastore_server/source/java/ch/systemsx/cisd/openbis/dss/generic/shared/api/v1/validation/ValidationScriptRunner.java
+++ b/datastore_server/source/java/ch/systemsx/cisd/openbis/dss/generic/shared/api/v1/validation/ValidationScriptRunner.java
@@ -32,6 +32,7 @@ import org.python.core.PyObject;
import org.python.util.PythonInterpreter;
import ch.systemsx.cisd.common.utilities.JythonUtils;
+import ch.systemsx.cisd.common.utilities.PythonUtils;
/**
* @author Chandrasekhar Ramakrishnan
@@ -76,7 +77,7 @@ public class ValidationScriptRunner
private ValidationScriptRunner(String scriptString)
{
- this.interpreter = new PythonInterpreter();
+ this.interpreter = PythonUtils.createIsolatedPythonInterpreter();
// Load the script
this.scriptString = scriptString;
diff --git a/openbis/source/java/ch/systemsx/cisd/openbis/generic/server/jython/api/v1/impl/MasterDataRegistrationScriptRunner.java b/openbis/source/java/ch/systemsx/cisd/openbis/generic/server/jython/api/v1/impl/MasterDataRegistrationScriptRunner.java
index 8c6f1b1fa9a3cf0c229d6654db29690232dfd774..7fac147a409070d979959a35b140113d3d04f022 100644
--- a/openbis/source/java/ch/systemsx/cisd/openbis/generic/server/jython/api/v1/impl/MasterDataRegistrationScriptRunner.java
+++ b/openbis/source/java/ch/systemsx/cisd/openbis/generic/server/jython/api/v1/impl/MasterDataRegistrationScriptRunner.java
@@ -21,6 +21,7 @@ import java.io.File;
import org.python.util.PythonInterpreter;
import ch.systemsx.cisd.common.filesystem.FileUtilities;
+import ch.systemsx.cisd.common.utilities.PythonUtils;
/**
* A class for running python scripts that register master data.
@@ -51,7 +52,7 @@ public class MasterDataRegistrationScriptRunner implements IMasterDataScriptRegi
MasterDataRegistrationService service = new MasterDataRegistrationService(commonServer);
// Configure the evaluator
- PythonInterpreter interpreter = new PythonInterpreter();
+ PythonInterpreter interpreter = PythonUtils.createIsolatedPythonInterpreter();
interpreter.set(SERVICE_VARIABLE_NAME, service);
// Invoke the evaluator
diff --git a/screening/source/java/ch/systemsx/cisd/openbis/dss/etl/jython/JythonPlateDataSetHandler.java b/screening/source/java/ch/systemsx/cisd/openbis/dss/etl/jython/JythonPlateDataSetHandler.java
index 51b0910ee50e7368e9d8b5265cb1af967af471ff..c210e3d49e1a9de5b21816a377f413e6e5b1f16b 100644
--- a/screening/source/java/ch/systemsx/cisd/openbis/dss/etl/jython/JythonPlateDataSetHandler.java
+++ b/screening/source/java/ch/systemsx/cisd/openbis/dss/etl/jython/JythonPlateDataSetHandler.java
@@ -21,6 +21,7 @@ import ch.systemsx.cisd.common.filesystem.FileUtilities;
import ch.systemsx.cisd.common.io.FileBasedContentNode;
import ch.systemsx.cisd.common.utilities.IDelegatedActionWithResult;
import ch.systemsx.cisd.common.utilities.PropertyUtils;
+import ch.systemsx.cisd.common.utilities.PythonUtils;
import ch.systemsx.cisd.etlserver.ITopLevelDataSetRegistratorDelegate;
import ch.systemsx.cisd.etlserver.TopLevelDataSetRegistratorGlobalState;
import ch.systemsx.cisd.etlserver.registrator.AbstractDataSetRegistrationDetailsFactory;
@@ -346,7 +347,7 @@ public class JythonPlateDataSetHandler extends JythonTopLevelDataSetHandler<Data
{
return new JythonDataSetRegistrationService<DataSetInformation>(this, incomingDataSetFile,
callerDataSetInformationOrNull, cleanAfterwardsAction, delegate,
- new PythonInterpreter(), getGlobalState())
+ PythonUtils.createIsolatedPythonInterpreter(), getGlobalState())
{
@SuppressWarnings("unchecked")
@Override