import tools
+# When this variable is true, start after any ensure_created
+startingup = False
+
# shell path -> account class association
shell_acct_class = {}
# account type -> account class association
finally: self._create_sem.release()
if not isinstance(self._acct, next_class): self._acct = next_class(rec)
else: self._acct.configure(rec)
- if next_class != curr_class: self._acct.start()
+ if next_class != curr_class || startingup:
+ self._acct.start()
def ensure_destroyed(self): self._q.put((self._ensure_destroyed,))
def _ensure_destroyed(self): self._destroy(self._get_class())
database.db.deliver_record(rec)
if fullupdate: database.db.set_min_timestamp(data['timestamp'])
database.db.sync()
-
- # handle requested startup
- global start_requested
- if start_requested:
- start_requested = False
- cumulative_delay = 0
- for name in database.db.iterkeys():
- accounts.get(name).start(delay=cumulative_delay)
- cumulative_delay += 3
+ accounts.startingup = False
def deliver_ticket(data): return GetSlivers(data, fullupdate=False)
accounts.register_class(sliver_vs.Sliver_VS)
accounts.register_class(delegate.Delegate)
- global start_requested
- start_requested = options.startup
+ accounts.startingup = options.startup
database.start()
api.deliver_ticket = deliver_ticket
api.start()