Parcourir la source

Rename file from serve_mixin.py to socketserver.py, and rename the class name from ServeMixin NoPollMixIn.

git-svn-id: svn://bind10.isc.org/svn/bind10/branches/trac352@3347 e5f2f494-b856-4b98-b285-d166d9295462
Likun Zhang il y a 14 ans
Parent
commit
d2a4492d47

+ 3 - 3
src/bin/cmdctl/cmdctl.py.in

@@ -45,7 +45,7 @@ from isc.config import ccsession
 import isc.utils.process
 from optparse import OptionParser, OptionValueError
 from hashlib import sha1
-from isc.utils import serve_mixin
+from isc.utils import socketserver_mixin
 
 try:
     import threading
@@ -441,7 +441,7 @@ class CommandControl():
 
         return (keyfile, certfile, accountsfile)
 
-class SecureHTTPServer(serve_mixin.ServeMixIn,
+class SecureHTTPServer(socketserver_mixin.NoPollMixIn,
                        socketserver.ThreadingMixIn,
                        http.server.HTTPServer):
     '''Make the server address can be reused.'''
@@ -451,7 +451,7 @@ class SecureHTTPServer(serve_mixin.ServeMixIn,
                  CommandControlClass,
                  idle_timeout = 1200, verbose = False):
         '''idle_timeout: the max idle time for login'''
-        serve_mixin.ServeMixIn.__init__(self)
+        socketserver_mixin.NoPollMixIn.__init__(self)
         try:
             http.server.HTTPServer.__init__(self, server_address, RequestHandlerClass)
         except socket.error as err:

+ 4 - 4
src/bin/xfrout/xfrout.py.in

@@ -34,7 +34,7 @@ import socket
 import select
 import errno
 from optparse import OptionParser, OptionValueError
-from isc.utils import serve_mixin
+from isc.utils import socketserver_mixin
 
 try:
     from libxfr_python import *
@@ -291,13 +291,13 @@ class XfroutSession(BaseRequestHandler):
 
         self._send_message_with_last_soa(msg, sock, rrset_soa, message_upper_len)
 
-class UnixSockServer(serve_mixin.ServeMixIn, ThreadingUnixStreamServer):
+class UnixSockServer(socketserver_mixin.NoPollMixIn, ThreadingUnixStreamServer):
     '''The unix domain socket server which accept xfr query sent from auth server.'''
 
     def __init__(self, sock_file, handle_class, shutdown_event, config_data, cc, log):
         self._remove_unused_sock_file(sock_file)
         self._sock_file = sock_file
-        serve_mixin.ServeMixIn.__init__(self)
+        socketserver_mixin.NoPollMixIn.__init__(self)
         ThreadingUnixStreamServer.__init__(self, sock_file, handle_class)
         self._lock = threading.Lock()
         self._transfers_counter = 0
@@ -342,7 +342,7 @@ class UnixSockServer(serve_mixin.ServeMixIn, ThreadingUnixStreamServer):
             return True 
 
     def shutdown(self):
-        super().shutdown() # call the shutdown() of class serve_mixin.ServeMinIn
+        super().shutdown() # call the shutdown() of class socketserver_mixin.NoPollMixIn
         try:
             os.unlink(self._sock_file)
         except Exception as e:

+ 1 - 1
src/lib/python/isc/utils/Makefile.am

@@ -1,5 +1,5 @@
 SUBDIRS = tests
 
-python_PYTHON = __init__.py process.py serve_mixin.py
+python_PYTHON = __init__.py process.py socketserver_mixin.py
 
 pythondir = $(pyexecdir)/isc/utils

+ 1 - 1
src/lib/python/isc/utils/__init__.py

@@ -1 +1 @@
-from isc.utils.serve_mixin import *
+from isc.utils.socketserver_mixin import *

+ 1 - 1
src/lib/python/isc/utils/serve_mixin.py

@@ -18,7 +18,7 @@ import socket
 import select
 
 SOCK_DATA = b'somedata'
-class ServeMixIn:
+class NoPollMixIn:
     '''This is a mix-in class to override the function serve_forever()
     and shutdown() in class socketserver.BaseServer.
 

+ 4 - 4
src/lib/python/isc/utils/tests/serve_mixin_test.py

@@ -14,7 +14,7 @@
 # WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 
 import unittest
-from isc.utils.serve_mixin import ServeMixIn
+from isc.utils.socketserver_mixin import NoPollMixIn
 import socketserver
 import threading
 import socket
@@ -25,12 +25,12 @@ class MyHandler(socketserver.BaseRequestHandler):
         data = self.request.recv(20)
         self.request.send(data)
 
-class MyServer(ServeMixIn, 
+class MyServer(NoPollMixIn, 
                socketserver.ThreadingMixIn,
                socketserver.TCPServer):
 
     def __init__(self, server_addr, handler_class):
-        ServeMixIn.__init__(self)
+        NoPollMixIn.__init__(self)
         socketserver.TCPServer.__init__(self, server_addr, handler_class)
 
 def send_and_get_reply(ip, port, msg):
@@ -41,7 +41,7 @@ def send_and_get_reply(ip, port, msg):
     sock.close()
     return response
 
-class TestServeMixIn(unittest.TestCase):
+class TestNoPollMixIn(unittest.TestCase):
     def test_serve_forever(self):
         # use port 0 to select an arbitrary unused port.
         server = MyServer(('127.0.0.1', 0), MyHandler)