Commit ba9038e2 authored by Michal 'vorner' Vaner's avatar Michal 'vorner' Vaner
Browse files

[1454] Loop to listen

parent 0cfe92d0
......@@ -23,6 +23,7 @@ from isc.dns import *
from isc.config.ccsession import *
from import SessionError, SessionTimeout
import isc.util.process
import select
from isc.log_messages.ddns_messages import *
......@@ -131,13 +132,25 @@ class DDNSServer:
This loops waiting for events until self.shutdown() has been called.
cc_fileno = self._cc.get_socket().fileno()
listen_fileno = self._listen_socket.fileno()
while not self._shutdown:
# We do not catch any exceptions here right now, but this would
# be a good place to catch any exceptions that b10-ddns can
# recover from. We currently have no exception hierarchy to
# make such a distinction easily, but once we do, this would
# be the place to catch.
# TODO: Catch select exceptions, like EINTR
(reads, writes, exceptions) = \[cc_fileno, listen_fileno], [], [])
for fileno in reads:
if fileno == cc_fileno:
elif fileno == listen_fileno:
pass # TODO
......@@ -19,6 +19,16 @@ import unittest
import isc
import ddns
import isc.config
import select
class FakeSocket:
A fake socket. It only provides a file number.
def __init__(self, fileno):
self.__fileno = fileno
def fileno(self):
return self.__fileno
class MyCCSession(isc.config.ConfigData):
'''Fake session with minimal interface compliance'''
......@@ -32,6 +42,12 @@ class MyCCSession(isc.config.ConfigData):
'''Called by DDNSServer initialization, but not used in tests'''
self._started = True
def get_socket(self):
Used to get the file number for select.
return FakeSocket(1)
class MyDDNSServer():
'''Fake DDNS server used to test the main() function'''
def __init__(self):
......@@ -64,6 +80,9 @@ class TestDDNSServer(unittest.TestCase):
self.ddns_server = ddns.DDNSServer(cc_session)
self.__select_expected = None
self.__select_answer = None
self.__hook_called = False
def test_config_handler(self):
# Config handler does not do anything yet, but should at least
......@@ -93,6 +112,41 @@ class TestDDNSServer(unittest.TestCase):
signal_handler(None, None)
def __select(self, reads, writes, exceptions, timeout=None):
A fake select. It checks it was called with the correct parameters and
returns a preset answer.
self.assertEqual(self.__select_expected, (reads, writes, exceptions,
answer = self.__select_answer
self.__select_answer = None
self.ddns_server._shutdown = True
return answer
def __hook(self):
A hook that can be installed to any unary function and see if it was
really called.
self.__hook_called = True
def test_accept_called(self):
Test we call the accept function when a new connection comes.
self.ddns_server._listen_socket = FakeSocket(2) = self.__select
self.ddns_server.accept = self.__hook
self.__select_expected = ([1, 2], [], [], None)
self.__select_answer = ([2], [], [])
# The answer got used
self.assertTrue(self.__hook_called) =
class TestMain(unittest.TestCase):
def setUp(self):
self._server = MyDDNSServer()
......@@ -135,7 +189,6 @@ class TestMain(unittest.TestCase):
self.assertRaises(BaseException, ddns.main, self._server)
if __name__== "__main__":
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment