3 |
3 |
4 from sqlalchemy import create_engine, pool |
4 from sqlalchemy import create_engine, pool |
5 |
5 |
6 import logging |
6 import logging |
7 |
7 |
8 from .model import setEngine,startPool, POOL_SIZE |
8 from .model import setEngine, setPool |
|
9 from .controller.pool import startPool, dbPool |
9 from .view import xmlrpc |
10 from .view import xmlrpc |
10 |
11 |
11 def runReactor(reactor, engine, root): |
12 def runReactor(reactor, engine, root): |
12 setEngine(engine) |
13 setEngine(engine) |
13 startPool(reactor) |
14 startPool(reactor) |
|
15 setPool(dbPool) |
14 |
16 |
15 reactor.listenTCP(7080, server.Site(root)) |
17 reactor.listenTCP(7080, server.Site(root)) |
16 logging.info("Server is running now...") |
18 logging.info("Server is running now...") |
17 reactor.run() |
19 reactor.run() |
18 |
20 |
19 |
21 |
20 if __name__ == '__main__': |
22 if __name__ == '__main__': |
21 engine = create_engine('mysql://test:test@localhost/test', |
23 engine = create_engine('mysql://test:test@localhost/test', |
22 poolclass = pool.SingletonThreadPool, pool_size=POOL_SIZE, ) |
24 poolclass = pool.SingletonThreadPool, pool_size=dbPool.maxthreads, ) |
23 |
25 |
24 |
26 |
25 root = resource.Resource() |
27 root = resource.Resource() |
26 root = xmlrpc.appendResource(root) |
28 root = xmlrpc.appendResource(root) |
27 |
29 |