Skip to content

Commit

Permalink
Real time simulation
Browse files Browse the repository at this point in the history 
simulate_rt was created
  • Loading branch information
@OscarFdezS
OscarFdezS committed Dec 19, 2022
1 parent 143541d commit 56ca6c3
Show file tree
Hide file tree
Showing 2 changed files with 182 additions and 160 deletions.
316 changes: 159 additions & 157 deletions xdevs/examples/basic/basic.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,180 +10,182 @@


class Job:
def __init__(self, name):
self.name = name
self.time = 0
def __init__(self, name):
self.name = name
self.time = 0


class Generator(Atomic):

def __init__(self, name, period):
super().__init__(name)
self.i_start = Port(Job, "i_start")
self.i_stop = Port(Job, "i_stop")
self.o_out = Port(Job, "o_out")
self.add_in_port(self.i_start)
self.add_in_port(self.i_stop)
self.add_out_port(self.o_out)
self.period = period
self.job_counter = 1
def initialize(self):
self.hold_in(PHASE_ACTIVE, self.period)
def exit(self):
pass
def deltint(self):
self.job_counter += 1
self.hold_in(PHASE_ACTIVE, self.period)
def deltext(self, e):
self.passivate()
def lambdaf(self):
self.o_out.add(Job(str(self.job_counter)))
def __init__(self, name, period):
super().__init__(name)
self.i_start = Port(Job, "i_start")
self.i_stop = Port(Job, "i_stop")
self.o_out = Port(Job, "o_out")

self.add_in_port(self.i_start)
self.add_in_port(self.i_stop)
self.add_out_port(self.o_out)

self.period = period
self.job_counter = 1

def initialize(self):
self.hold_in(PHASE_ACTIVE, self.period)

def exit(self):
pass

def deltint(self):
self.job_counter += 1
self.hold_in(PHASE_ACTIVE, self.period)

def deltext(self, e):
self.passivate()

def lambdaf(self):
self.o_out.add(Job(str(self.job_counter)))


class Processor(Atomic):
def __init__(self, name, proc_time):
super().__init__(name)
self.i_in = Port(Job, "i_in")
self.o_out = Port(Job, "o_out")
self.add_in_port(self.i_in)
self.add_out_port(self.o_out)

self.current_job = None
self.proc_time = proc_time
def initialize(self):
self.passivate()
def exit(self):
pass
def deltint(self):
self.passivate()
def deltext(self, e):
if self.phase == PHASE_PASSIVE:
self.current_job = self.i_in.get()
self.hold_in(PHASE_ACTIVE, self.proc_time)
self.continuef(e)
def lambdaf(self):
self.o_out.add(self.current_job)

def __init__(self, name, proc_time):
super().__init__(name)

self.i_in = Port(Job, "i_in")
self.o_out = Port(Job, "o_out")

self.add_in_port(self.i_in)
self.add_out_port(self.o_out)

self.current_job = None
self.proc_time = proc_time

def initialize(self):
self.passivate()

def exit(self):
pass

def deltint(self):
self.passivate()

def deltext(self, e):
if self.phase == PHASE_PASSIVE:
self.current_job = self.i_in.get()
self.hold_in(PHASE_ACTIVE, self.proc_time)
self.continuef(e)

def lambdaf(self):
self.o_out.add(self.current_job)


class Transducer(Atomic):

def __init__(self, name, obs_time):
super().__init__(name)
self.i_arrived = Port(Job, "i_arrived")
self.i_solved = Port(Job, "i_solved")
self.o_out = Port(Job, "o_out")
self.add_in_port(self.i_arrived)
self.add_in_port(self.i_solved)
self.add_out_port(self.o_out)
self.jobs_arrived = []
self.jobs_solved = []
self.total_ta = 0
self.clock = 0
self.obs_time = obs_time
def initialize(self):
self.hold_in(PHASE_ACTIVE, self.obs_time)
def exit(self):
pass
def deltint(self):
self.clock += self.sigma
if self.phase == PHASE_ACTIVE:
if self.jobs_solved:
avg_ta = self.total_ta / len(self.jobs_solved)
throughput = len(self.jobs_solved) / self.clock if self.clock > 0 else 0
else:
avg_ta = 0
throughput = 0
logger.info("End time: %f" % self.clock)
logger.info("Jobs arrived: %d" % len(self.jobs_arrived))
logger.info("Jobs solved: %d" % len(self.jobs_solved))
logger.info("Average TA: %f" % avg_ta)
logger.info("Throughput: %f\n" % throughput)
self.hold_in(PHASE_DONE, 0)
else:
self.passivate()
def deltext(self, e):
self.clock += e
if self.phase == PHASE_ACTIVE:
if self.i_arrived:
job = self.i_arrived.get()
logger.info("Starting job %s @ t = %d" % (job.name, self.clock))
job.time = self.clock
self.jobs_arrived.append(job)
if self.i_solved:
job = self.i_solved.get()
logger.info("Job %s finished @ t = %d" % (job.name, self.clock))
self.total_ta += self.clock - job.time
self.jobs_solved.append(job)

self.continuef(e)
def lambdaf(self):
if self.phase == PHASE_DONE:
self.o_out.add(Job("null"))
def __init__(self, name, obs_time):
super().__init__(name)

self.i_arrived = Port(Job, "i_arrived")
self.i_solved = Port(Job, "i_solved")
self.o_out = Port(Job, "o_out")

self.add_in_port(self.i_arrived)
self.add_in_port(self.i_solved)
self.add_out_port(self.o_out)

self.jobs_arrived = []
self.jobs_solved = []

self.total_ta = 0
self.clock = 0
self.obs_time = obs_time

def initialize(self):
self.hold_in(PHASE_ACTIVE, self.obs_time)

def exit(self):
pass

def deltint(self):
self.clock += self.sigma

if self.phase == PHASE_ACTIVE:
if self.jobs_solved:
avg_ta = self.total_ta / len(self.jobs_solved)
throughput = len(self.jobs_solved) / self.clock if self.clock > 0 else 0
else:
avg_ta = 0
throughput = 0

logger.info("End time: %f" % self.clock)
logger.info("Jobs arrived: %d" % len(self.jobs_arrived))
logger.info("Jobs solved: %d" % len(self.jobs_solved))
logger.info("Average TA: %f" % avg_ta)
logger.info("Throughput: %f\n" % throughput)

self.hold_in(PHASE_DONE, 0)
else:
self.passivate()

def deltext(self, e):
self.clock += e

if self.phase == PHASE_ACTIVE:
if self.i_arrived:
job = self.i_arrived.get()
logger.info("Starting job %s @ t = %d" % (job.name, self.clock))
job.time = self.clock
self.jobs_arrived.append(job)

if self.i_solved:
job = self.i_solved.get()
logger.info("Job %s finished @ t = %d" % (job.name, self.clock))
self.total_ta += self.clock - job.time
self.jobs_solved.append(job)

self.continuef(e)

def lambdaf(self):
if self.phase == PHASE_DONE:
self.o_out.add(Job("null"))


class Gpt(Coupled):
def __init__(self, name, period, obs_time):
super().__init__(name)
def __init__(self, name, period, obs_time):
super().__init__(name)

if period < 1:
raise ValueError("period has to be greater than 0")
if period < 1:
raise ValueError("period has to be greater than 0")

if obs_time < 0:
raise ValueError("obs_time has to be greater or equal than 0")
if obs_time < 0:
raise ValueError("obs_time has to be greater or equal than 0")

gen = Generator("generator", period)
proc = Processor("processor", 3*period)
trans = Transducer("transducer", obs_time)
gen = Generator("generator", period)
proc = Processor("processor", 3 * period)
trans = Transducer("transducer", obs_time)

self.add_component(gen)
self.add_component(proc)
self.add_component(trans)
self.add_component(gen)
self.add_component(proc)
self.add_component(trans)

self.add_coupling(gen.o_out, proc.i_in)
self.add_coupling(gen.o_out, trans.i_arrived)
self.add_coupling(proc.o_out, trans.i_solved)
self.add_coupling(trans.o_out, gen.i_stop)
self.add_coupling(gen.o_out, proc.i_in)
self.add_coupling(gen.o_out, trans.i_arrived)
self.add_coupling(proc.o_out, trans.i_solved)
self.add_coupling(trans.o_out, gen.i_stop)


class Wrap(Coupled):
def __init__(self, name, period, obs_time):
super().__init__("wrap")
def __init__(self, name, period, obs_time):
super().__init__("wrap")

gpt = Gpt(name, period, obs_time)
gpt = Gpt(name, period, obs_time)

self.add_component(gpt)
self.add_component(gpt)


if __name__ == '__main__':
gpt = Gpt("gpt", 1, 100)
coord = Coordinator(gpt)
coord.initialize()
coord.simulate()
gpt = Gpt("gpt", 2, 100)
coord = Coordinator(gpt)
coord.initialize()
# coord.simulate()
coord.simulate_rt()
# coord.simulate_rt(50)
Loading

0 comments on commit 56ca6c3

Please sign in to comment.