removed comments and cleaned up code.

This commit is contained in:
cody burkard
2014-07-22 23:00:43 -07:00
parent 5cd6b553a5
commit 6bc9d68485
4 changed files with 18 additions and 28 deletions
+2 -1
View File
@@ -281,7 +281,8 @@ class MininetRunner( object ):
if self.options.post: if self.options.post:
CLI( mn, script=self.options.post ) CLI( mn, script=self.options.post )
mn.stop()
elapsed = float( time.time() - start ) elapsed = float( time.time() - start )
info( 'completed in %0.3f seconds\n' % elapsed ) info( 'completed in %0.3f seconds\n' % elapsed )
+14 -15
View File
@@ -89,12 +89,22 @@ class Intf( object ):
def updateMAC( self ): def updateMAC( self ):
"Return updated MAC address based on ifconfig" "Return updated MAC address based on ifconfig"
#heres where we send the unecessary ifconfigs
ifconfig = self.ifconfig() ifconfig = self.ifconfig()
macs = self._macMatchRegex.findall( ifconfig ) macs = self._macMatchRegex.findall( ifconfig )
self.mac = macs[ 0 ] if macs else None self.mac = macs[ 0 ] if macs else None
return self.mac return self.mac
def updateAddr( self ):
"""Return IP address and MAC address based on ifconfig.
instead of updating ip and mac separately,
use one ifconfig call to do it simultaneously""""
ifconfig = self.ifconfig()
ips = self._ipMatchRegex.findall( ifconfig )
macs = self._macMatchRegex.findall( ifconfig )
self.ip = ips[ 0 ] if ips else None
self.mac = macs[ 0 ] if macs else None
return self.ip, self.mac
def IP( self ): def IP( self ):
"Return IP address" "Return IP address"
return self.ip return self.ip
@@ -106,8 +116,9 @@ class Intf( object ):
def isUp( self, setUp=False ): def isUp( self, setUp=False ):
"Return whether interface is up" "Return whether interface is up"
if setUp: if setUp:
r = self.ifconfig( 'up' ) cmdOutput = self.ifconfig( 'up' )
if r: if cmdOutput:
error( "Error setting %s up: %s " % ( self.name, cmdOutput )
return False return False
else: else:
return True return True
@@ -147,15 +158,6 @@ class Intf( object ):
results[ name ] = result results[ name ] = result
return result return result
def updateAddr( self ):
"instead of updating ip and mac separately, use one ifconfig call to do it simultaneously"
ifconfig = self.ifconfig()
ips = self._ipMatchRegex.findall( ifconfig )
macs = self._macMatchRegex.findall( ifconfig )
self.ip = ips[ 0 ] if ips else None
self.mac = macs[ 0 ] if macs else None
return self.ip, self.mac
def config( self, mac=None, ip=None, ifconfig=None, def config( self, mac=None, ip=None, ifconfig=None,
up=True, **_params ): up=True, **_params ):
"""Configure Node according to (optional) parameters: """Configure Node according to (optional) parameters:
@@ -172,9 +174,6 @@ class Intf( object ):
self.setParam( r, 'setIP', ip=ip ) self.setParam( r, 'setIP', ip=ip )
self.setParam( r, 'isUp', up=up ) self.setParam( r, 'isUp', up=up )
self.setParam( r, 'ifconfig', ifconfig=ifconfig ) self.setParam( r, 'ifconfig', ifconfig=ifconfig )
#self.updateAddr()
#self.updateIP()
#self.updateMAC()
return r return r
def delete( self ): def delete( self ):
-8
View File
@@ -102,7 +102,6 @@ from mininet.link import Link, Intf
from mininet.util import quietRun, fixLimits, numCores, ensureRoot from mininet.util import quietRun, fixLimits, numCores, ensureRoot
from mininet.util import macColonHex, ipStr, ipParse, netParse, ipAdd from mininet.util import macColonHex, ipStr, ipParse, netParse, ipAdd
from mininet.term import cleanUpScreens, makeTerms from mininet.term import cleanUpScreens, makeTerms
from multiprocessing import Process
# Mininet version: should be consistent with README and LICENSE # Mininet version: should be consistent with README and LICENSE
VERSION = "2.1.0+" VERSION = "2.1.0+"
@@ -161,15 +160,12 @@ class Mininet( object ):
self.terms = [] # list of spawned xterm processes self.terms = [] # list of spawned xterm processes
#self.pool = Pool( 64 )
Mininet.init() # Initialize Mininet if necessary Mininet.init() # Initialize Mininet if necessary
self.built = False self.built = False
if topo and build: if topo and build:
self.build() self.build()
def waitConnected( self, timeout=None, delay=.5 ): def waitConnected( self, timeout=None, delay=.5 ):
"""wait for each switch to connect to a controller, """wait for each switch to connect to a controller,
up to 5 seconds up to 5 seconds
@@ -397,16 +393,12 @@ class Mininet( object ):
info( switchName + ' ' ) info( switchName + ' ' )
info( '\n*** Adding links:\n' ) info( '\n*** Adding links:\n' )
# need to 'asynchronize' this too
for srcName, dstName in topo.links(sort=True): for srcName, dstName in topo.links(sort=True):
src, dst = self.nameToNode[ srcName ], self.nameToNode[ dstName ] src, dst = self.nameToNode[ srcName ], self.nameToNode[ dstName ]
params = topo.linkInfo( srcName, dstName ) params = topo.linkInfo( srcName, dstName )
srcPort, dstPort = topo.port( srcName, dstName ) srcPort, dstPort = topo.port( srcName, dstName )
self.addLink( src, dst, srcPort, dstPort, **params ) self.addLink( src, dst, srcPort, dstPort, **params )
#self.pool.apply_async( self.addLink, ( src, dst, srcPort, dstPort, params ) )
info( '(%s, %s) ' % ( src.name, dst.name ) ) info( '(%s, %s) ' % ( src.name, dst.name ) )
#self.pool.close()
#self.pool.join()
info( '\n' ) info( '\n' )
def configureControlNetwork( self ): def configureControlNetwork( self ):
+2 -4
View File
@@ -82,8 +82,6 @@ def errRun( *cmd, **kwargs ):
poller.register( popen.stdout, POLLIN ) poller.register( popen.stdout, POLLIN )
fdtofile = { popen.stdout.fileno(): popen.stdout } fdtofile = { popen.stdout.fileno(): popen.stdout }
outDone, errDone = False, True outDone, errDone = False, True
#bookmark: rearrange this for aynch startup. shouldnt have to keep
# maybe we dont rearrange this. we really just need a method to call a command and NOT poll for output
if popen.stderr: if popen.stderr:
fdtofile[ popen.stderr.fileno() ] = popen.stderr fdtofile[ popen.stderr.fileno() ] = popen.stderr
poller.register( popen.stderr, POLLIN ) poller.register( popen.stderr, POLLIN )
@@ -191,9 +189,9 @@ def moveIntfNoRetry( intf, dstNode, srcNode=None, printError=False ):
intf = str( intf ) intf = str( intf )
cmd = 'ip link set %s netns %s' % ( intf, dstNode.pid ) cmd = 'ip link set %s netns %s' % ( intf, dstNode.pid )
if srcNode: if srcNode:
output = srcNode.cmd( cmd ) cmdOutput = srcNode.cmd( cmd )
else: else:
output = quietRun( cmd ) cmdOutput = quietRun( cmd )
if output: if output:
if printError: if printError:
error( '*** Error: moveIntf: ' + intf + error( '*** Error: moveIntf: ' + intf +