• file
• latest
• revisions
• annotate
• diff
• comparison
• raw

scheduler.py@4cdc9c1f6b28 (annotated)

scheduler.py

Thu, 18 Jan 2018 23:01:16 +0000

author

Tuomo Valkonen <tuomov@iki.fi>

date

Thu, 18 Jan 2018 23:01:16 +0000

changeset 1

4cdc9c1f6b28

child 7

e189d4a6cb8c

permissions

-rw-r--r--

basic scheduler structure draft, etc.

1 4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	1	#
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	2	# Borgend scheduler
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	3	#
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	4
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	5	from Queue import Queue
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	6	from runborg import BorgInstance
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	7	import sched
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	8	import ui
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	9
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	10	def scheduler(sched):
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	11	timeout=???
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	12	q=sched.eventqueue
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	13	while True:
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	14	timeout, timerevent=next_timed_event(sched);
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	15	t=Timer(timeout, lambda: q.put(timerevent));
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	16	event=sq.get(True):
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	17	# Decide what to do
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	18
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	19	class Scheduler:
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	20
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	21	def __init__(self, backups):
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	22	self.backups=backups
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	23	self.eventqueue=Queue()
4cdc9c1f6b28 basic scheduler structure draft, etc. Tuomo Valkonen <tuomov@iki.fi> parents: diff changeset	24	self.t=Thread(target=scheduler, args=self)