X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=python%2Fovs%2Fstream.py;h=7ea9e46e8b59c7b6d175460ef31a268d5b8f1607;hb=dd1ba5b3f4425c8eba008d1a93b044da63466812;hp=5180642dead01861504fb024e2779d28887aa5d4;hpb=26bb0f31299d3f8eb06551d6a219846929c27149;p=openvswitch diff --git a/python/ovs/stream.py b/python/ovs/stream.py index 5180642d..7ea9e46e 100644 --- a/python/ovs/stream.py +++ b/python/ovs/stream.py @@ -13,13 +13,15 @@ # limitations under the License. import errno -import logging import os import select import socket import ovs.poller import ovs.socket_util +import ovs.vlog + +vlog = ovs.vlog.Vlog("stream") class Stream(object): @@ -260,7 +262,7 @@ class PassiveStream(object): try: sock.listen(10) except socket.error, e: - logging.error("%s: listen: %s" % (name, os.strerror(e.error))) + vlog.err("%s: listen: %s" % (name, os.strerror(e.error))) sock.close() return e.error, None @@ -291,7 +293,7 @@ class PassiveStream(object): error = ovs.socket_util.get_exception_errno(e) if error != errno.EAGAIN: # XXX rate-limit - logging.debug("accept: %s" % os.strerror(error)) + vlog.dbg("accept: %s" % os.strerror(error)) return error, None def wait(self, poller): @@ -302,14 +304,10 @@ class PassiveStream(object): self.socket.close() -def usage(name, active, passive): - print - if active: - print("Active %s connection methods:" % name) - print(" unix:FILE " - "Unix domain socket named FILE") +def usage(name): + return """ +Active %s connection methods: + unix:FILE Unix domain socket named FILE - if passive: - print("Passive %s connection methods:" % name) - print(" punix:FILE " - "listen on Unix domain socket FILE") +Passive %s connection methods: + punix:FILE Listen on Unix domain socket FILE""" % (name, name)