Signed-off-by: Guido Trotter <[email protected]>
---
 daemons/ganeti-confd |   14 +++++++-------
 1 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/daemons/ganeti-confd b/daemons/ganeti-confd
index 22e1637..2fc5737 100755
--- a/daemons/ganeti-confd
+++ b/daemons/ganeti-confd
@@ -37,13 +37,13 @@ import errno
 
 from optparse import OptionParser
 
+from ganeti import asyncnotifier
+from ganeti import confd
+from ganeti.confd import server as confd_server
 from ganeti import constants
 from ganeti import errors
 from ganeti import daemon
 from ganeti import ssconf
-from ganeti.asyncnotifier import AsyncNotifier
-from ganeti.confd.server import ConfdProcessor
-from ganeti.confd import PackMagic, UnpackMagic
 
 
 class ConfdAsyncUDPServer(daemon.AsyncUDPSocket):
@@ -71,7 +71,7 @@ class ConfdAsyncUDPServer(daemon.AsyncUDPSocket):
   # this method is overriding a daemon.AsyncUDPSocket method
   def handle_datagram(self, payload_in, ip, port):
     try:
-      query = UnpackMagic(payload_in)
+      query = confd.UnpackMagic(payload_in)
     except errors.ConfdMagicError, err:
       logging.debug(err)
       return
@@ -79,7 +79,7 @@ class ConfdAsyncUDPServer(daemon.AsyncUDPSocket):
     answer =  self.processor.ExecQuery(query, ip, port)
     if answer is not None:
       try:
-        self.enqueue_send(ip, port, PackMagic(answer))
+        self.enqueue_send(ip, port, confd.PackMagic(answer))
       except errors.UdpDataSizeError:
         logging.error("Reply too big to fit in an udp packet.")
 
@@ -199,7 +199,7 @@ class ConfdConfigurationReloader(object):
     # Asyncronous inotify handler for config changes
     self.wm = pyinotify.WatchManager()
     self.inotify_handler = ConfdInotifyEventHandler(self.wm, self.OnInotify)
-    self.notifier = AsyncNotifier(self.wm, self.inotify_handler)
+    self.notifier = asyncnotifier.AsyncNotifier(self.wm, self.inotify_handler)
 
     self.timer_handle = None
     self._EnableTimer()
@@ -336,7 +336,7 @@ def ExecConfd(options, args):
   mainloop = daemon.Mainloop()
 
   # Asyncronous confd UDP server
-  processor = ConfdProcessor()
+  processor = confd_server.ConfdProcessor()
   try:
     processor.Enable()
   except errors.ConfigurationError:
-- 
1.5.6.5

Reply via email to