X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9f2dfd25486ba89c4adaa54d774092c0b9756361:/examples/python/operation-io/operation-io.py..1b211507e0c2abe5f2b7fbe56988af46d3189b51:/examples/python/task-io/task-io.py diff --git a/examples/python/operation-io/operation-io.py b/examples/python/task-io/task-io.py similarity index 56% rename from examples/python/operation-io/operation-io.py rename to examples/python/task-io/task-io.py index 59a07afaad..18a4cb2aac 100644 --- a/examples/python/operation-io/operation-io.py +++ b/examples/python/task-io/task-io.py @@ -5,7 +5,7 @@ from argparse import ArgumentParser import sys -from simgrid import Engine, Operation, ExecOp, IoOp, IoOpType +from simgrid import Engine, Task, ExecTask, IoTask, IoOpType def parse(): parser = ArgumentParser() @@ -17,34 +17,34 @@ def parse(): ) return parser.parse_args() -def callback(op): - print(f'[{Engine.clock}] Operation {op} finished ({op.count})') +def callback( t): + print(f'[{Engine.clock}] { t} finished ({ t.count})') if __name__ == '__main__': args = parse() e = Engine(sys.argv) e.load_platform(args.platform) - Operation.init() + Task.init() # Retrieve hosts bob = e.host_by_name('bob') carl = e.host_by_name('carl') - # Create operations - exec1 = ExecOp.init("exec1", 1e9, bob) - exec2 = ExecOp.init("exec2", 1e9, carl) - write = IoOp.init("write", 1e7, bob.disks[0], IoOpType.WRITE) - read = IoOp.init("read", 1e7, carl.disks[0], IoOpType.READ) + # Create tasks + exec1 = ExecTask.init("exec1", 1e9, bob) + exec2 = ExecTask.init("exec2", 1e9, carl) + write = IoTask.init("write", 1e7, bob.disks[0], IoOpType.WRITE) + read = IoTask.init("read", 1e7, carl.disks[0], IoOpType.READ) - # Create the graph by defining dependencies between operations + # Create the graph by defining dependencies between tasks exec1.add_successor(write) write.add_successor(read) read.add_successor(exec2) - # Add a function to be called when operations end for log purpose - Operation.on_end_cb(callback) + # Add a function to be called when tasks end for log purpose + Task.on_end_cb(callback) - # Enqueue two executions for operation exec1 + # Enqueue two executions for task exec1 exec1.enqueue_execs(2) # runs the simulation