[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [ooni-probe/master] Delete measurements module
commit ca24885eeea83c023e79eecedb139db21cbc1cd9
Author: Arturo Filastò <art@xxxxxxxxx>
Date: Sat Jan 12 18:30:50 2013 +0100
Delete measurements module
---
ooni/measurements.py | 161 --------------------------------------------------
1 files changed, 0 insertions(+), 161 deletions(-)
diff --git a/ooni/measurements.py b/ooni/measurements.py
deleted file mode 100644
index 86d6f84..0000000
--- a/ooni/measurements.py
+++ /dev/null
@@ -1,161 +0,0 @@
-from .tasks import TaskWithTimeout
-from inspect import getmembers
-from ooni.nettest import NetTestCase
-from ooni.ratelimiting import StaticRateLimiter
-from twisted.python.reflect import prefixedMethodNames
-from twisted.trial.runner import filenameToModule
-from StringIO import StringIO
-from os.path import isfile
-
-class Measurement(TaskWithTimeout):
- def __init__(self, test_class, test_method, test_input, net_test):
- """
- test_class:
- is the class, subclass of NetTestCase, of the test to be run
-
- test_method:
- is a string representing the test method to be called to perform
- this measurement
-
- test_input:
- is the input to the test
- """
- self.test_instance = test_class()
- self.test_instance.input = test_input
- self.test_instance.report = {}
- self.test_instance._start_time = time.time()
- self.test_instance._setUp()
- self.test_instance.setUp()
- self.test = getattr(self.test_instance, test_method)
-
- def succeeded(self):
- self.net_test.measurementSuccess()
-
- def failed(self):
- self.net_test.measurementFailed()
-
- def timedOut(self):
- self.net_test.measurementTimeOut()
-
- def run(self):
- d = defer.maybeDeferred(self.test)
- d.addCallback(self.succeeded)
- d.addErrback(self.failed)
- return d
-
-class NetTest(object):
- director = None
- method_prefix = 'test'
-
- def __init__(self, net_test_file, inputs, options, report):
- """
- net_test_file:
- is a file object containing the test to be run.
-
- inputs:
- is a generator containing the inputs to the net test.
-
- options:
- is a dict containing the options to be passed to the net test.
- """
- self.test_cases = self.loadNetTest(net_test_file)
- self.inputs = inputs
- self.options = options
-
- def loadNetTest(self, net_test_object):
- """
- Creates all the necessary test_cases (a list of tuples containing the
- NetTestCase (test_class, test_method))
-
- example:
- [(test_classA, test_method1),
- (test_classA, test_method2),
- (test_classA, test_method3),
- (test_classA, test_method4),
- (test_classA, test_method5),
-
- (test_classB, test_method1),
- (test_classB, test_method2)]
-
- Note: the inputs must be valid for test_classA and test_classB.
-
- net_test_object:
- is a file like object that will be used to generate the test_cases.
- """
- try:
- if isfile(net_test_object):
- return self._loadNetTestFile(net_test_object)
- except TypeError:
- if isinstance(net_test_object, StringIO) or \
- isinstance(net_test_object, str):
- return self._loadNetTestString(net_test_object)
-
- def _loadNetTestString(self, net_test_string):
- """
- Load NetTest from a string
- """
- ns = {}
- test_cases = []
- exec net_test_string.read() in ns
- for item in ns.itervalues():
- test_cases.extend(self._get_test_methods(item))
- return test_cases
-
- def _loadNetTestFile(self, net_test_file):
- """
- Load NetTest from a file
- """
- test_cases = []
- module = filenameToModule(net_test_file)
- for __, item in getmembers(module):
- test_cases.extend(self._get_test_methods(item))
- return test_cases
-
- def _get_test_methods(self, item):
- """
- Look for test_ methods in subclasses of NetTestCase
- """
- test_cases = []
- try:
- assert issubclass(item, NetTestCase)
- methods = prefixedMethodNames(item, self.method_prefix)
- for method in methods:
- test_cases.append((item, self.method_prefix + method))
- except (TypeError, AssertionError):
- pass
- return test_cases
-
- def timedOut(self, measurement):
- """
- This gets called when a measurement has timed out. This may or may not
- trigger a retry inside of MeasurementsTracker.
- """
- self.director.measurementTimedOut(measurement)
-
- def failed(self, measurement, failure):
- """
- This gets called when a measurement has failed in the sense that all
- the retries have failed at successfully running the test.
- This means that it's a definitive failure and we will no longer make
- any attempts at re-running the measurement.
- """
- self.director.measurementFailed(measurement, failure)
-
- def succeeded(self, measurement):
- """
- This gets called when a measurement has failed.
- """
- self.report.write(measurement)
-
- def generateMeasurements(self):
- """
- This is a generator that yields measurements and sets their timeout
- value and their netTest attribute.
- """
- for test_input in self.inputs:
- for test_class, test_method in self.test_cases:
- measurement = Measurement(test_class, test_method, test_input)
- measurement.netTest = self
- measurement.timeout = self.rateLimiter.timeout
- yield measurement
-
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits