#########################################################
# The object (file object.py)

class myObject:
    def __init__(self):
        # a global counter
        self.globalNumCalls = 0
    def method1(self, string):
        self.globalNumCalls += 1
        return len(string)
    def method2(self, number):
        self.globalNumCalls += 1
        return number*number
    def getGlobalNumCalls(self):
        return self.globalNumCalls

def remote_objects():
	return { 'sampleObject': myObject() }
#########################################################
#########################################################


#########################################################
# The Pyro server, with a wrapper for object.myobject 
# and thread local storage (file server.py)

import sys
import Pyro.core
import Pyro.naming

import object


class SampleObject(Pyro.core.ObjBase, object.myObject):
    def __init__(self):
        Pyro.core.ObjBase.__init__(self)
        object.myObject.__init__(self)
        
    def method2localcount(self, number):
        # increment the thread-local counter
        self.getLocalStorage().numSquareCalls += 1
        # call the "standard" function (this will increment the global counter)
        return self.method2(number)
    
    def getNumLocalSquareCalls(self):
        return self.getLocalStorage().numSquareCalls

def initTLS(tls):
        print "Init TLS:",tls
        print "Setting a counter, numSquareCalls, for this TLS to 0."
        tls.numSquareCalls=0
                

if __name__ == "__main__":
    Pyro.core.initServer()
    daemon=Pyro.core.Daemon()
    daemon.useNameServer(Pyro.naming.NameServerLocator().getNS())
    daemon.setInitTLS(initTLS)
    uri=daemon.connect(SampleObject(), "sampleObject")
    print "sample object is running."
    daemon.setTimeout(5)
    daemon.requestLoop()
#########################################################
#########################################################


#########################################################
# The cherrypy server definition file (file testXmlRpc.cpy)

def initProgram():
    import Pyro.core

def initThread(threadIndex):
    time.sleep(threadIndex * 0.2)
    # dispatch a pyro object to each thread via "request" reserved variable
    Pyro.core.initClient()
    request.x=Pyro.core.getProxyForURI("PYRONAME://sampleObject")
    request.x._setTimeout(5)
    request.x._release()
    
CherryClass Xml_rpc:

view:
    def lenString(self, a) xmlrpc:
        # Return the length of its input string
        return request.x.method1(a)
    def squareNumber(self, a) xmlrpc:
        # Return the square of its input number
        return request.x.method2(a)
    def squareNumberLocalCount(self, a) xmlrpc:
        # Return the square of its input number, incrementing a thread local counter, too.
        return request.x.method2localcount(a)
    def noglobalcalls(self) xmlrpc:
        # Return the number of global calls
        return request.x.getGlobalNumCalls()
    def nosquarelocalcalls(self) xmlrpc:
        # Return the number of thread-local calls
        return request.x.getNumLocalSquareCalls()
#########################################################
#########################################################


#########################################################
# The cherrypy configuration file (file testXmlRpcServer.cfg)
[server]
typeOfRequests=xmlRpc,web
threadPool=3
#########################################################
#########################################################


#########################################################
# A sample test program (file testXmlRpcClient.py)

import xmlrpclib, time
testsvr = xmlrpclib.Server("http://localhost:8000")

sttime = time.time()
    
for i in xrange(1000):
    assert len("I love cherry pie") == testsvr.xml.rpc.lenString("I love cherry pie")
    assert testsvr.xml.rpc.squareNumber(12) == 144
    print "# global calls:", testsvr.xml.rpc.noglobalcalls()
    assert testsvr.xml.rpc.squareNumberLocalCount(6) == 36
    print "# thread-local calls: ", testsvr.xml.rpc.nosquarelocalcalls()
print time.time() - sttime
#########################################################
#########################################################