equal
deleted
inserted
replaced
39 return "" |
39 return "" |
40 |
40 |
41 root=getResource() |
41 root=getResource() |
42 root.putChild('debug', XMLRPCDebug()) |
42 root.putChild('debug', XMLRPCDebug()) |
43 reactor.listenTCP(7080, server.Site(root)) |
43 reactor.listenTCP(7080, server.Site(root)) |
|
44 reactor.suggestThreadPoolSize(5) |
44 reactor.run() |
45 reactor.run() |
45 |
46 |
46 if __name__ == '__main__': |
47 if __name__ == '__main__': |
47 tdir = mkdtemp(prefix='iro-mysql-') |
48 tdir = mkdtemp(prefix='iro-mysql-') |
48 try: |
49 try: |
51 s = Server('%s/my.cnf'%tdir) |
52 s = Server('%s/my.cnf'%tdir) |
52 s.create() |
53 s.create() |
53 s.start() |
54 s.start() |
54 d=SampleDatabase("test","test",'%s/my.cnf'%tdir) |
55 d=SampleDatabase("test","test",'%s/my.cnf'%tdir) |
55 d.create() |
56 d.create() |
56 db.engine = create_engine('mysql://test:test@localhost/test?unix_socket=%s/socket'%tdir, echo=True) |
57 db.engine = create_engine('mysql://test:test@localhost/test?unix_socket=%s/socket'%tdir) |
57 dbdefer = DBDefer('mysql://test:test@localhost/test?unix_socket=%s/socket'%tdir, echo=True) |
58 dbdefer = DBDefer('mysql://test:test@localhost/test?unix_socket=%s/socket'%tdir, pool_size=5) |
58 |
|
59 |
|
60 |
59 |
61 @dbdefer |
60 @dbdefer |
62 def getuser(userhash, session): |
61 def getuser(userhash, session): |
63 session.execute("SELECT SLEEP(10)") |
62 session.execute("SELECT SLEEP(10)") |
64 return imuser._getuser(userhash = userhash, session=session) |
63 return imuser._getuser(userhash = userhash, session=session) |