# The runner is a pool of threads used to parallelize
# execution of tasks
- nthreads = int(os.environ.get("NEPI_NTHREADS", "3"))
+ nthreads = int(os.environ.get("NEPI_NTHREADS", "20"))
self._runner = ParallelRun(maxthreads = nthreads)
# Event processing thread
"""
return self._logger
+ @property
+ def failure_level(self):
+ """ Returns the level of FAILURE of th experiment
+
+ """
+
+ return self._fm._failure_level
+
@property
def ecstate(self):
""" Returns the state of the Experiment Controller
# Author: Alina Quereilhac <alina.quereilhac@inria.fr>
import logging
-import netns
import time
import os
import sys
import uuid
+try:
+ import netns
+except ImportError:
+ pass
+
class NetNSWrapper(object):
def __init__(self, loglevel = logging.INFO, enable_dump = False):
super(NetNSWrapper, self).__init__()