svn commit: r1292528 - in /incubator/tashi/branches/stroucki-dropthrift/src/tashi: ./ agents/ client/ messaging/ nodemanager/vmcontrol/ thrift/

[st...@apache.org]

Author: stroucki
Date: Wed Feb 22 21:42:49 2012
New Revision: 1292528

URL: http://svn.apache.org/viewvc?rev=1292528&view=rev
Log:
remove thrift-needing code

Removed:
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/agents/locality-server.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/client/client.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/client/test.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/messaging/messageBroker.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/messaging/messaging.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/messaging/soapmessaging.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/messaging/tashimessaging.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/messaging/threadpool.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/messaging/thriftmessaging.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/thrift/
Modified:
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/nodemanager/vmcontrol/xenpv.py
    incubator/tashi/branches/stroucki-dropthrift/src/tashi/util.py

Modified: incubator/tashi/branches/stroucki-dropthrift/src/tashi/nodemanager/vmcontrol/xenpv.py
URL: http://svn.apache.org/viewvc/incubator/tashi/branches/stroucki-dropthrift/src/tashi/nodemanager/vmcontrol/xenpv.py?rev=1292528&r1=1292527&r2=1292528&view=diff
==============================================================================
--- incubator/tashi/branches/stroucki-dropthrift/src/tashi/nodemanager/vmcontrol/xenpv.py (original)
+++ incubator/tashi/branches/stroucki-dropthrift/src/tashi/nodemanager/vmcontrol/xenpv.py Wed Feb 22 21:42:49 2012
@@ -28,7 +28,7 @@ from vmcontrolinterface import VmControl
 from tashi.rpycservices.rpyctypes import Errors, InstanceState, TashiException
 from tashi.rpycservices.rpyctypes import Instance, Host
 from tashi import boolean, convertExceptions, ConnectionManager, version
-from tashi.util import isolatedRPC, broken
+from tashi.util import broken
 
 import tashi.parallel
 from tashi.parallel import synchronized, synchronizedmethod

Modified: incubator/tashi/branches/stroucki-dropthrift/src/tashi/util.py
URL: http://svn.apache.org/viewvc/incubator/tashi/branches/stroucki-dropthrift/src/tashi/util.py?rev=1292528&r1=1292527&r2=1292528&view=diff
==============================================================================
--- incubator/tashi/branches/stroucki-dropthrift/src/tashi/util.py (original)
+++ incubator/tashi/branches/stroucki-dropthrift/src/tashi/util.py Wed Feb 22 21:42:49 2012
@@ -148,14 +148,6 @@ class reference(object):
 	def __delattr__(self, name):
 		return delattr(self.__dict__['__real_obj__'], name)
 
-def isolatedRPC(client, method, *args, **kw):
-	"""Opens and closes a thrift transport for a single RPC call"""
-	if (not client._iprot.trans.isOpen()):
-		client._iprot.trans.open()
-	res = getattr(client, method)(*args, **kw)
-	client._iprot.trans.close()
-	return res
-
 def signalHandler(signalNumber):
 	"""Used to denote a particular function as the signal handler for a 
 	   specific signal"""
@@ -192,7 +184,7 @@ def instantiateImplementation(className,
 
 def convertExceptions(oldFunc):
 	"""This converts any exception type into a TashiException so that 
-	   it can be passed over a Thrift RPC"""
+	   it can be passed over an RPC"""
 	def newFunc(*args, **kw):
 		try:
 			return oldFunc(*args, **kw)