# HG changeset patch # User Sandro Knauß # Date 1327196305 -3600 # Node ID 48f2b8adc7da62f114bbba6806e325a49b8732f6 # Parent 1d93f1ddfd1642e1bd9b93c2563735ef6486adac eigenständiger client datei für den xmlrpc test diff -r 1d93f1ddfd16 -r 48f2b8adc7da tests/xmlrpc.py --- a/tests/xmlrpc.py Sun Jan 22 02:37:31 2012 +0100 +++ b/tests/xmlrpc.py Sun Jan 22 02:38:25 2012 +0100 @@ -1,8 +1,6 @@ -from multiprocessing import Process, Pool +from multiprocessing import Process from sqlalchemy import create_engine -from time import sleep - from tempfile import mkdtemp import shutil @@ -19,13 +17,15 @@ self.password="test" return self.password +from twisted.python import log import logging -logging.basicConfig(level=logging.DEBUG, format='%(asctime)s %(name)s(%(processName)s)-%(levelname)s: %(message)s') - +logging.basicConfig(level=logging.INFO, format='%(asctime)s %(name)s(%(processName)s)-%(levelname)s: %(message)s') +#observer = log.PythonLoggingObserver() +#observer.start() def xxxxx(userid): import xmlrpclib - return xmlrpclib.ServerProxy('http://localhost:7080/RPC2').status(userid) + return xmlrpclib.ServerProxy('http://localhost:7080/RPC2').listMethods() def main(): from twisted.internet import reactor @@ -59,8 +59,9 @@ @dbdefer def getuser(userhash, session): - session.execute("SELECT SLEEP(10)") + #session.execute("SELECT SLEEP(10)") return imuser._getuser(userhash = userhash, session=session) + imuser.dbdefer=dbdefer imuser._getuser=imuser.getuser imuser.getuser=getuser @@ -72,9 +73,6 @@ session.add(User(name='test',apikey='abcdef123456789')) p = Process(target=main) p.start() - sleep(1) - pool=Pool(5) - print pool.map(xxxxx, ('abcdef123456789',)*25) p.join() finally: s.stop() diff -r 1d93f1ddfd16 -r 48f2b8adc7da tests/xmlrpc_client.py --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/tests/xmlrpc_client.py Sun Jan 22 02:38:25 2012 +0100 @@ -0,0 +1,12 @@ +from multiprocessing.pool import ThreadPool +import xmlrpclib +import timeit + + +def x(i): + xmlrpclib.ServerProxy('http://192.168.56.101:7080/RPC2').status('abcdef123456789') + +pool=ThreadPool(50) + +print min(timeit.repeat(lambda:pool.map(x,range(51)),number=1,repeat=1)) +