Move fixLimits function to util
This commit is contained in:
+1
-6
@@ -71,12 +71,11 @@ from subprocess import call, Popen, PIPE, STDOUT
|
|||||||
from time import sleep
|
from time import sleep
|
||||||
import os, re, signal, sys, select
|
import os, re, signal, sys, select
|
||||||
flush = sys.stdout.flush
|
flush = sys.stdout.flush
|
||||||
from resource import setrlimit, RLIMIT_NPROC, RLIMIT_NOFILE
|
|
||||||
|
|
||||||
from mininet.logging_mod import lg, set_loglevel
|
from mininet.logging_mod import lg, set_loglevel
|
||||||
from mininet.node import Node, Host, Controller, Switch
|
from mininet.node import Node, Host, Controller, Switch
|
||||||
from mininet.util import run, checkRun, quietRun, makeIntfPair, moveIntf
|
from mininet.util import run, checkRun, quietRun, makeIntfPair, moveIntf
|
||||||
from mininet.util import createLink
|
from mininet.util import createLink, setLimits
|
||||||
|
|
||||||
DATAPATHS = ['user', 'kernel']
|
DATAPATHS = ['user', 'kernel']
|
||||||
|
|
||||||
@@ -533,10 +532,6 @@ class Cli( object ):
|
|||||||
lg.error("cli: unknown node or command: < %s >\n" % first)
|
lg.error("cli: unknown node or command: < %s >\n" % first)
|
||||||
lg.info("*** cli: exiting\n")
|
lg.info("*** cli: exiting\n")
|
||||||
|
|
||||||
def fixLimits():
|
|
||||||
"Fix ridiculously small resource limits."
|
|
||||||
setrlimit( RLIMIT_NPROC, ( 4096, 8192 ) )
|
|
||||||
setrlimit( RLIMIT_NOFILE, ( 16384, 32768 ) )
|
|
||||||
|
|
||||||
def init():
|
def init():
|
||||||
"Initialize Mininet."
|
"Initialize Mininet."
|
||||||
|
|||||||
@@ -2,6 +2,7 @@
|
|||||||
'''Utility functions for Mininet.'''
|
'''Utility functions for Mininet.'''
|
||||||
|
|
||||||
from time import sleep
|
from time import sleep
|
||||||
|
from resource import setrlimit, RLIMIT_NPROC, RLIMIT_NOFILE
|
||||||
import select
|
import select
|
||||||
from subprocess import call, check_call, Popen, PIPE, STDOUT
|
from subprocess import call, check_call, Popen, PIPE, STDOUT
|
||||||
|
|
||||||
@@ -167,3 +168,9 @@ def createLink(node1, node2):
|
|||||||
node1.connection[intf1] = (node2, intf2)
|
node1.connection[intf1] = (node2, intf2)
|
||||||
node2.connection[intf2] = (node1, intf1)
|
node2.connection[intf2] = (node1, intf1)
|
||||||
return intf1, intf2
|
return intf1, intf2
|
||||||
|
|
||||||
|
|
||||||
|
def fixLimits():
|
||||||
|
'''Fix ridiculously small resource limits.'''
|
||||||
|
setrlimit( RLIMIT_NPROC, (4096, 8192))
|
||||||
|
setrlimit( RLIMIT_NOFILE, (16384, 32768))
|
||||||
Reference in New Issue
Block a user