{
saveState(_dumpErrorFile);
}
- _trace.close();
+ {
+ YACS::BASES::AutoLocker<YACS::BASES::Mutex> alck(&_mutexForTrace);
+ _trace.close();
+ }
DEBTRACE("End of RunB thread");
}
DEBTRACE("before _semForMaxThreads.wait " << _semThreadCnt);
if(_semThreadCnt == 0)
{
+ // --- Critical section
+ YACS::BASES::AutoLocker<YACS::BASES::Mutex> alck(&_mutexForSchedulerUpdate);
//check if we have enough threads to run
std::set<Task*> tmpSet=_runningTasks;
std::set<Task*>::iterator it = tmpSet.begin();
std::cerr << "WARNING: maybe you need more threads to run your schema (current value="<< _maxThreads << ")" << std::endl;
std::cerr << "If it is the case, set the YACS_MAX_THREADS environment variable to a bigger value (export YACS_MAX_THREADS=xxx)" << std::endl;
}
+ // --- End of critical section
}
_semForMaxThreads.wait();
OutputPyPort::OutputPyPort(const OutputPyPort& other, Node *newHelder):OutputPort(other,newHelder),DataPort(other,newHelder),Port(other,newHelder),
_data(Py_None)
{
+ Py_INCREF(_data);
}
void OutputPyPort::put(const void *data) throw(ConversionException)
export PYTHONPATH=@CMAKE_CURRENT_SOURCE_DIR@:$PYTHONPATH
export PYTHONPATH=@CMAKE_SOURCE_DIR@/src/yacsloader/Test:$PYTHONPATH
-chmod +x @CMAKE_CURRENT_SOURCE_DIR@/testExec.py
python @CMAKE_CURRENT_SOURCE_DIR@/testExec.py
ret0=$?
if [ $ret0 -gt 0 ]; then
exit $ret0
fi
-chmod +x @CMAKE_CURRENT_SOURCE_DIR@/testResume.py
python @CMAKE_CURRENT_SOURCE_DIR@/testResume.py
ret1=$?
if [ $ret1 -gt 0 ]; then
exit $ret1
fi
-chmod +x @CMAKE_CURRENT_SOURCE_DIR@/testLoader.py
python @CMAKE_CURRENT_SOURCE_DIR@/testLoader.py
ret2=$?
if [ $ret2 -gt 0 ]; then
exit $ret2
fi
-chmod +x @CMAKE_CURRENT_SOURCE_DIR@/testEdit.py
python @CMAKE_CURRENT_SOURCE_DIR@/testEdit.py
ret3=$?
if [ $ret3 -gt 0 ]; then
exit $ret3
fi
-chmod +x @CMAKE_CURRENT_SOURCE_DIR@/testSave.py
python @CMAKE_CURRENT_SOURCE_DIR@/testSave.py
ret4=$?
if [ $ret4 -gt 0 ]; then
exit $ret4
fi
-chmod +x @CMAKE_CURRENT_SOURCE_DIR@/testRefcount.py
python @CMAKE_CURRENT_SOURCE_DIR@/testRefcount.py
ret5=$?
if [ $ret5 -gt 0 ]; then
exit $ret5
fi
-chmod +x @CMAKE_CURRENT_SOURCE_DIR@/testSaveLoadRun.py
python @CMAKE_CURRENT_SOURCE_DIR@/testSaveLoadRun.py
ret6=$?
if [ $ret6 -gt 0 ]; then