equal
deleted
inserted
replaced
24 import select |
24 import select |
25 import warnings |
25 import warnings |
26 from time import localtime, mktime |
26 from time import localtime, mktime |
27 |
27 |
28 from cubicweb.cwconfig import CubicWebConfiguration |
28 from cubicweb.cwconfig import CubicWebConfiguration |
|
29 from cubicweb.server.utils import TasksManager |
29 from cubicweb.server.repository import Repository |
30 from cubicweb.server.repository import Repository |
30 |
31 |
31 class Finished(Exception): |
32 class Finished(Exception): |
32 """raise to remove an event from the event loop""" |
33 """raise to remove an event from the event loop""" |
33 |
34 |
75 class RepositoryServer(object): |
76 class RepositoryServer(object): |
76 |
77 |
77 def __init__(self, config): |
78 def __init__(self, config): |
78 """make the repository available as a PyRO object""" |
79 """make the repository available as a PyRO object""" |
79 self.config = config |
80 self.config = config |
80 self.repo = Repository(config) |
81 self.repo = Repository(config, TasksManager()) |
81 self.ns = None |
82 self.ns = None |
82 self.quiting = None |
83 self.quiting = None |
83 # event queue |
84 # event queue |
84 self.events = [] |
85 self.events = [] |
85 |
86 |