eigenständiger client datei für den xmlrpc test devel
authorSandro Knauß <knauss@netzguerilla.net>
Sun, 22 Jan 2012 02:38:25 +0100
branchdevel
changeset 105 48f2b8adc7da
parent 104 1d93f1ddfd16
child 106 d2992f011930
eigenständiger client datei für den xmlrpc test
tests/xmlrpc.py
tests/xmlrpc_client.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()
--- /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))
+