mirror of
https://github.com/openvswitch/ovs
synced 2025-08-31 14:25:26 +00:00
python: Fix several pep8 whitespace errors.
Fix the following pep8 errors: E201 whitespace after '(' E203 whitespace before ',' E222 multiple spaces after operator E225 missing whitespace around operator E226 missing whitespace around arithmetic operator E231 missing whitespace after ':' E241 multiple spaces after ':' E251 unexpected spaces around keyword / parameter equals E261 at least two spaces before inline comment E262 inline comment should start with '# ' E265 block comment should start with '# ' E271 multiple spaces after keyword Signed-off-by: Russell Bryant <russell@ovn.org> Acked-by: Ben Pfaff <blp@ovn.org>
This commit is contained in:
@@ -22,7 +22,6 @@ import time
|
||||
|
||||
import ovs.dirs
|
||||
import ovs.fatal_signal
|
||||
#import ovs.lockfile
|
||||
import ovs.process
|
||||
import ovs.socket_util
|
||||
import ovs.timeval
|
||||
@@ -254,7 +253,6 @@ def _fork_and_wait_for_startup():
|
||||
# Running in parent process.
|
||||
os.close(rfd)
|
||||
ovs.timeval.postfork()
|
||||
#ovs.lockfile.postfork()
|
||||
|
||||
global _daemonize_fd
|
||||
_daemonize_fd = wfd
|
||||
|
@@ -1089,7 +1089,7 @@ class Transaction(object):
|
||||
self._inc_column = column
|
||||
|
||||
def _fetch(self, row, column_name):
|
||||
self._fetch_requests.append({"row":row, "column_name":column_name})
|
||||
self._fetch_requests.append({"row": row, "column_name": column_name})
|
||||
|
||||
def _write(self, row, column, datum):
|
||||
assert row._changes is not None
|
||||
|
@@ -1,4 +1,10 @@
|
||||
# The @variables@ in this file are replaced by default directories for
|
||||
# use in python/ovs/dirs.py in the source directory and replaced by the
|
||||
# configured directories for use in the installed python/ovs/dirs.py.
|
||||
#
|
||||
import os
|
||||
|
||||
# Note that the use of """ is to aid in dealing with paths with quotes in them.
|
||||
PKGDATADIR = os.environ.get("OVS_PKGDATADIR", """/usr/local/share/openvswitch""")
|
||||
RUNDIR = os.environ.get("OVS_RUNDIR", """/var/run""")
|
||||
LOGDIR = os.environ.get("OVS_LOGDIR", """/usr/local/var/log""")
|
||||
|
@@ -1,8 +1,10 @@
|
||||
## The @variables@ in this file are replaced by default directories for
|
||||
## use in python/ovs/dirs.py in the source directory and replaced by the
|
||||
## configured directories for use in the installed python/ovs/dirs.py.
|
||||
##
|
||||
# The @variables@ in this file are replaced by default directories for
|
||||
# use in python/ovs/dirs.py in the source directory and replaced by the
|
||||
# configured directories for use in the installed python/ovs/dirs.py.
|
||||
#
|
||||
import os
|
||||
|
||||
# Note that the use of """ is to aid in dealing with paths with quotes in them.
|
||||
PKGDATADIR = os.environ.get("OVS_PKGDATADIR", """@pkgdatadir@""")
|
||||
RUNDIR = os.environ.get("OVS_RUNDIR", """@RUNDIR@""")
|
||||
LOGDIR = os.environ.get("OVS_LOGDIR", """@LOGDIR@""")
|
||||
|
@@ -153,7 +153,7 @@ def from_string(s):
|
||||
|
||||
|
||||
class Parser(object):
|
||||
## Maximum height of parsing stack. ##
|
||||
# Maximum height of parsing stack. #
|
||||
MAX_HEIGHT = 1000
|
||||
|
||||
def __init__(self, check_trailer=False):
|
||||
|
@@ -92,9 +92,9 @@ class Message(object):
|
||||
return "\"params\" must be JSON array"
|
||||
|
||||
pattern = {Message.T_REQUEST: 0x11001,
|
||||
Message.T_NOTIFY: 0x11000,
|
||||
Message.T_REPLY: 0x00101,
|
||||
Message.T_ERROR: 0x00011}.get(self.type)
|
||||
Message.T_NOTIFY: 0x11000,
|
||||
Message.T_REPLY: 0x00101,
|
||||
Message.T_ERROR: 0x00011}.get(self.type)
|
||||
if pattern is None:
|
||||
return "invalid JSON-RPC message type %s" % self.type
|
||||
|
||||
|
@@ -350,8 +350,8 @@ class UnixStream(Stream):
|
||||
@staticmethod
|
||||
def _open(suffix, dscp):
|
||||
connect_path = suffix
|
||||
return ovs.socket_util.make_unix_socket(socket.SOCK_STREAM,
|
||||
True, None, connect_path)
|
||||
return ovs.socket_util.make_unix_socket(socket.SOCK_STREAM,
|
||||
True, None, connect_path)
|
||||
Stream.register_method("unix", UnixStream)
|
||||
|
||||
|
||||
|
@@ -130,7 +130,7 @@ class Vlog:
|
||||
matches = formatting.match(match)
|
||||
# Do we need to apply padding?
|
||||
if not matches.group(1) and replace != "":
|
||||
replace = replace.center(len(replace)+2)
|
||||
replace = replace.center(len(replace) + 2)
|
||||
# Does the field have a minimum width
|
||||
if matches.group(2):
|
||||
min_width = int(matches.group(2))
|
||||
|
@@ -60,7 +60,7 @@ class UdpSender(DatagramProtocol):
|
||||
def startProtocol(self):
|
||||
self.looper = LoopingCall(self.sendData)
|
||||
period = self.duration / float(self.count)
|
||||
self.looper.start(period , now = False)
|
||||
self.looper.start(period, now=False)
|
||||
|
||||
def stopProtocol(self):
|
||||
if (self.looper is not None):
|
||||
|
@@ -43,7 +43,7 @@ def get_interface_mtu(iface):
|
||||
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
||||
indata = iface + ('\0' * (32 - len(iface)))
|
||||
try:
|
||||
outdata = fcntl.ioctl(s.fileno(), 0x8921, indata) # socket.SIOCGIFMTU
|
||||
outdata = fcntl.ioctl(s.fileno(), 0x8921, indata) # socket.SIOCGIFMTU
|
||||
mtu = struct.unpack("16si12x", outdata)[1]
|
||||
except:
|
||||
return 0
|
||||
@@ -60,7 +60,7 @@ def get_interface(address):
|
||||
names = array.array('B', '\0' * bytes)
|
||||
outbytes = struct.unpack('iL', fcntl.ioctl(
|
||||
s.fileno(),
|
||||
0x8912, # SIOCGIFCONF
|
||||
0x8912, # SIOCGIFCONF
|
||||
struct.pack('iL', bytes, names.buffer_info()[0])
|
||||
))[0]
|
||||
namestr = names.tostring()
|
||||
@@ -80,9 +80,9 @@ def uname():
|
||||
def start_process(args):
|
||||
try:
|
||||
p = subprocess.Popen(args,
|
||||
stdin = subprocess.PIPE,
|
||||
stdout = subprocess.PIPE,
|
||||
stderr = subprocess.PIPE)
|
||||
stdin=subprocess.PIPE,
|
||||
stdout=subprocess.PIPE,
|
||||
stderr=subprocess.PIPE)
|
||||
out, err = p.communicate()
|
||||
return (p.returncode, out, err)
|
||||
except exceptions.OSError:
|
||||
@@ -186,7 +186,7 @@ def start_local_server(port):
|
||||
p = subprocess.Popen(["ovs-test", "-s", str(port)],
|
||||
stdout=subprocess.PIPE, stderr=subprocess.PIPE,
|
||||
preexec_fn=sigint_intercept)
|
||||
fcntl.fcntl( p.stdout.fileno(),fcntl.F_SETFL,
|
||||
fcntl.fcntl(p.stdout.fileno(), fcntl.F_SETFL,
|
||||
fcntl.fcntl(p.stdout.fileno(), fcntl.F_GETFL) | os.O_NONBLOCK)
|
||||
|
||||
while p.poll() is None:
|
||||
|
Reference in New Issue
Block a user