reactor & sqlalchemy threadpools aufeinander abstimmen devel
authorSandro Knauß <knauss@netzguerilla.net>
Sun, 22 Jan 2012 02:36:12 +0100
branchdevel
changeset 102 85ac86f7ffc4
parent 101 97b745751d49
child 103 0b333b0cd986
reactor & sqlalchemy threadpools aufeinander abstimmen keine prints mehr
iro/controller/database.py
iro/controller/viewinterface.py
tests/xmlrpc.py
--- a/iro/controller/database.py	Sun Jan 22 02:32:23 2012 +0100
+++ b/iro/controller/database.py	Sun Jan 22 02:36:12 2012 +0100
@@ -47,7 +47,6 @@
         def wrapper(*args, **kwargs):
             session = sessionmaker(bind=self.engine)()
             try:
-                print func,args, kwargs
                 return func(*args, session=session, **kwargs)
             except:
                 session.rollback()
--- a/iro/controller/viewinterface.py	Sun Jan 22 02:32:23 2012 +0100
+++ b/iro/controller/viewinterface.py	Sun Jan 22 02:36:12 2012 +0100
@@ -21,7 +21,6 @@
 
 
         '''
-        print user
         return str(user)
         #return user.status(id,detailed)
         return ""
--- a/tests/xmlrpc.py	Sun Jan 22 02:32:23 2012 +0100
+++ b/tests/xmlrpc.py	Sun Jan 22 02:36:12 2012 +0100
@@ -41,6 +41,7 @@
     root=getResource()
     root.putChild('debug', XMLRPCDebug())
     reactor.listenTCP(7080, server.Site(root))
+    reactor.suggestThreadPoolSize(5)
     reactor.run()
 
 if __name__ == '__main__':
@@ -53,10 +54,8 @@
         s.start()
         d=SampleDatabase("test","test",'%s/my.cnf'%tdir)
         d.create()
-        db.engine = create_engine('mysql://test:test@localhost/test?unix_socket=%s/socket'%tdir, echo=True)
-        dbdefer = DBDefer('mysql://test:test@localhost/test?unix_socket=%s/socket'%tdir, echo=True)
-
-
+        db.engine = create_engine('mysql://test:test@localhost/test?unix_socket=%s/socket'%tdir)
+        dbdefer = DBDefer('mysql://test:test@localhost/test?unix_socket=%s/socket'%tdir, pool_size=5)
 
         @dbdefer
         def getuser(userhash, session):