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