Change in vdsm[master]: stomp: add a getter for the stomp reactor

ykaplan at redhat.com ykaplan at redhat.com
Mon Mar 9 16:00:17 UTC 2015


Yeela Kaplan has uploaded a new change for review.

Change subject: stomp: add a getter for the stomp reactor
......................................................................

stomp: add a getter for the stomp reactor

Change-Id: I5ad4c79130c0ca1c4a5bd01343eafd3d8bf36231
Signed-off-by: Yeela Kaplan <ykaplan at redhat.com>
---
M lib/yajsonrpc/stompReactor.py
M vdsm/clientIF.py
M vdsm/protocoldetector.py
3 files changed, 14 insertions(+), 0 deletions(-)


  git pull ssh://gerrit.ovirt.org:29418/vdsm refs/changes/91/38491/1

diff --git a/lib/yajsonrpc/stompReactor.py b/lib/yajsonrpc/stompReactor.py
index 3aa85e8..26a7ea3 100644
--- a/lib/yajsonrpc/stompReactor.py
+++ b/lib/yajsonrpc/stompReactor.py
@@ -330,6 +330,9 @@
         self.json_binding = json_binding
         self._reactor = self.json_binding.createStompReactor()
 
+    def get_reactor(self):
+        return self._reactor
+
     def detect(self, data):
         return data.startswith(stomp.COMMANDS)
 
diff --git a/vdsm/clientIF.py b/vdsm/clientIF.py
index d29f8c2..615e7c9 100644
--- a/vdsm/clientIF.py
+++ b/vdsm/clientIF.py
@@ -175,6 +175,9 @@
                                 protocol=protocol)
         return sslctx
 
+    def getReactor(self, type=None):
+        return self._acceptor.get_reactor(type)
+
     def _prepareXMLRPCBinding(self):
         if config.getboolean('vars', 'xmlrpc_enable'):
             try:
diff --git a/vdsm/protocoldetector.py b/vdsm/protocoldetector.py
index 6d74c8b..3778d10 100644
--- a/vdsm/protocoldetector.py
+++ b/vdsm/protocoldetector.py
@@ -278,6 +278,14 @@
         server_socket.setblocking(0)
         return server_socket
 
+    def get_reactor(self, type):
+        if type == "stomp":
+            for handler in self._handlers:
+                if handler.NAME == "stomp":
+                    return handler.get_reactor()
+        else:
+            return self._reactor
+
 
 class _CannotDetectProtocol(Exception):
     pass


-- 
To view, visit https://gerrit.ovirt.org/38491
To unsubscribe, visit https://gerrit.ovirt.org/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: I5ad4c79130c0ca1c4a5bd01343eafd3d8bf36231
Gerrit-PatchSet: 1
Gerrit-Project: vdsm
Gerrit-Branch: master
Gerrit-Owner: Yeela Kaplan <ykaplan at redhat.com>


More information about the vdsm-patches mailing list