--- 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()
--- /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))
+