Major overhaul of oftest command interface
Added tests/oft as top level executable
Support command line options for many config params
Use logging module for output
Got rid of oft_config.py; consolidate configuration in
oft (top level script) and pass around as a dictionary
Add oft_assert.py (the one useful piece of oft_config that
remained).
diff --git a/tests/oft b/tests/oft
new file mode 100755
index 0000000..1faa8a1
--- /dev/null
+++ b/tests/oft
@@ -0,0 +1,251 @@
+#!/usr/bin/env python
+"""
+@package oft
+
+OpenFlow test framework top level script
+
+This script is the entry point for running OpenFlow tests
+using the OFT framework.
+
+The global configuration is passed around in a dictionary
+ygenerally called config. The keys have the following
+significance.
+
+ platform : String identifying the target platform
+ controller_host : Host on which test controller is running (for sockets)
+ controller_port : Port on which test controller listens for switch cxn
+ port_count : (Optional) Number of ports in dataplane
+ base_of_port : (Optional) Base OpenFlow port number in dataplane
+ base_if_index : (Optional) Base OS network interface for dataplane
+ test_spec : (TBD) Specification of test(s) to run
+ log_file : Filename for test logging
+ debug : String giving debug level (info, warning, error...)
+ dbg_level : logging module value of debug level
+ port_map : Map of dataplane OpenFlow port to OS interface names
+
+See config_defaults below for the default values.
+
+To add configuration to the system, first add an entry to config_default
+below. If you want this to be a command line parameter, edit config_setup
+to add the option and default value to the parser. Then edit config_get
+to make sure the option value gets copied into the configuration
+structure (which then gets passed to everyone else).
+
+By convention, oft attempts to import the contents of a file by the
+name of $platform.py into the local namespace.
+
+IMPORTANT: That file should define a function platform_config_update which
+takes a configuration dictionary as an argument and updates it for the
+current run. In particular, it should set up config["port_map"] with
+the proper map from OF port numbers to OF interface names.
+
+You can add your own platform, say gp104, by adding a file gp104.py
+that defines the function platform_config_update and then use the
+parameter --platform=gp104 on the command line.
+
+If platform_config_update does not set config["port_map"], an attempt
+is made to generate a default map via the function default_port_map_setup.
+This will use "local" and "remote" for platform names if available
+and generate a sequential map based on the values of base_of_port and
+base_if_index in the configuration structure.
+
+@todo Determine and implement conventions for test_spec.
+
+The current model for test sets is basic.py. The current convention is
+that the test set should implement a function test_set_init which takes
+an oft configuration dictionary and returns a unittest.TestSuite object.
+Future test sets should do the same thing.
+
+"""
+
+import sys
+from optparse import OptionParser
+import logging
+import unittest
+
+# Import test files
+import basic
+
+##@var DEBUG_LEVELS
+# Map from strings to debugging levels
+DEBUG_LEVELS = {
+ 'debug' : logging.DEBUG,
+ 'verbose' : logging.DEBUG,
+ 'info' : logging.INFO,
+ 'warning' : logging.WARNING,
+ 'warn' : logging.WARNING,
+ 'error' : logging.ERROR,
+ 'critical' : logging.CRITICAL
+}
+
+_debug_default = "warning"
+_debug_level_default = DEBUG_LEVELS[_debug_default]
+
+##@var config_default
+# The default configuration dictionary for OFT
+config_default = {
+ "platform" : "local",
+ "controller_host" : "127.0.0.1",
+ "controller_port" : 6633,
+ "port_count" : 4,
+ "base_of_port" : 1,
+ "base_if_index" : 1,
+ "test_spec" : "basic",
+ "log_file" : "oft.log",
+ "debug" : _debug_default,
+ "dbg_level" : _debug_level_default,
+ "port_map" : {}
+}
+
+# Map options to config structure
+def config_get(opts):
+ "Convert options class to OFT configuration dictionary"
+ cfg = config_default.copy()
+ cfg["platform"] = opts.platform
+ cfg["controller_host"] = opts.controller_host
+ cfg["controller_port"] = opts.controller_port
+ cfg["test_spec"] = opts.test_spec
+ cfg["log_file"] = opts.log_file
+ if opts.debug not in DEBUG_LEVELS.keys():
+ print "Warning: Bad value specified for debug level; using default"
+ opts.debug = _debug_default
+ cfg["debug"] = opts.debug
+ cfg["dbg_level"] = DEBUG_LEVELS[cfg["debug"]]
+ cfg["base_of_port"] = opts.base_of_port
+ cfg["base_if_index"] = opts.base_if_index
+ cfg["port_count"] = opts.port_count
+ return cfg
+
+def config_setup(cfg_dflt):
+ """
+ Set up the configuration including parsing the arguments
+
+ @param cfg_dflt The default configuration dictionary
+ @return A pair (config, args) where config is an config
+ object and args is any additional arguments from the command line
+ """
+
+ parser = OptionParser(version="%prog 0.1")
+
+ # Set up default values
+ parser.set_defaults(platform=cfg_dflt["platform"])
+ parser.set_defaults(controller_host=cfg_dflt["controller_host"])
+ parser.set_defaults(controller_port=cfg_dflt["controller_port"])
+ parser.set_defaults(test_spec=cfg_dflt["test_spec"])
+ parser.set_defaults(log_file=cfg_dflt["log_file"])
+ parser.set_defaults(debug=cfg_dflt["debug"])
+ parser.set_defaults(base_of_port=cfg_dflt["base_of_port"])
+ parser.set_defaults(base_if_index=cfg_dflt["base_if_index"])
+ parser.set_defaults(port_count=cfg_dflt["port_count"])
+
+ plat_help = """Set the platform type. Valid values include:
+ local: User space virtual ethernet pair setup
+ remote: Remote embedded Broadcom based switch
+ """
+ parser.add_option("-P", "--platform", help=plat_help)
+ parser.add_option("-H", "--host", dest="controller_host",
+ help="The IP/name of the test controller host")
+ parser.add_option("-p", "--port", dest="controller_port",
+ type="int", help="Port number of the test controller")
+ parser.add_option("--test-spec", "--test-list",
+ help="Indicate tests to run (TBD)")
+ parser.add_option("--log-file",
+ help="Name of log file, empty string to log to console")
+ parser.add_option("--debug",
+ help="Debug lvl: debug, info, warning, error, critical")
+ parser.add_option("--port_count",
+ help="Number of ports to use (optional)")
+ parser.add_option("--base_of_port",
+ help="Base OpenFlow port number (optional)")
+ parser.add_option("--base_if_index",
+ help="Base interface index number (optional)")
+ # Might need this if other parsers want command line
+ # parser.allow_interspersed_args = False
+ (options, args) = parser.parse_args()
+
+ config = config_get(options)
+
+ return (config, args)
+
+def logging_setup(config):
+ """
+ Set up logging based on config
+ """
+ _format = "%(asctime)s %(name)-10s: %(levelname)-8s: %(message)s"
+ _datefmt = "%H:%M:%S"
+ if config["log_file"]:
+ logging.basicConfig(filename=config["log_file"],
+ level=config["dbg_level"],
+ format=_format, datefmt=_datefmt)
+ #@todo Handle "no log file"
+
+def default_port_map_setup(config):
+ """
+ Setup the OF port mapping based on config
+ @param config The OFT configuration structure
+ @return Port map dictionary
+ """
+ if (config["base_of_port"] is None) or not config["port_count"]:
+ return None
+ port_map = {}
+ if config["platform"] == "local":
+ # For local, use every other veth port
+ for idx in range(config["port_count"]):
+ port_map[config["base_of_port"] + idx] = "veth" + \
+ str(config["base_if_index"] + (2 * idx))
+ elif config["platform"] == "remote":
+ # For remote, use eth ports
+ for idx in range(config["port_count"]):
+ port_map[config["base_of_port"] + idx] = "eth" + \
+ str(config["base_if_index"] + idx)
+ else:
+ return None
+
+ logging.info("Built default port map")
+ return port_map
+
+#
+# Main script
+#
+
+# Get configuration, set up logging, import platform from file
+(config, args) = config_setup(config_default)
+logging_setup(config)
+logging.info("*** STARTING TEST RUN ***")
+
+of_os_port_map = None
+if config["platform"]:
+ _imp_string = "from " + config["platform"] + " import *"
+ logging.info("Importing: " + _imp_string)
+ try:
+ exec(_imp_string)
+ except:
+ logging.warn("Failed to import " + config["platform"] + " file")
+
+try:
+ platform_config_update(config)
+except:
+ logging.warn("Could not run platform host configuration")
+
+if not config["port_map"]:
+ # Try to set up default port mapping if not done by platform
+ config["port_map"] = default_port_map_setup(config)
+
+if not config["port_map"]:
+ logging.critical("Interface port map is not defined. Exiting")
+ print("Interface port map is not defined. Exiting")
+ sys.exit(1)
+
+logging.debug("Configuration: " + str(config))
+logging.info("OF port map: " + str(config["port_map"]))
+
+# Init the test sets
+#@todo Use test-spec from config to determine which tests to run
+basic_suite = basic.test_set_init(config)
+if config["dbg_level"] >= logging.WARNING: _verb = 1
+else: _verb = 2
+
+unittest.TextTestRunner(verbosity=_verb).run(basic_suite)
+
+logging.info("*** END OF TESTS ***")
+