+++ /dev/null
-require "simgrid"
--- Splay global modules
-rpc = {}
-log = {}
-job = {}
-event = {}
-os = {}
-start = {}
--- Splay global variables
-job.me ={}
-job.nodes = {}
-job.list_type = "random"
-
---Init nodes tables
-function init_nodes()
- for i= 1,simgrid.Host.number() do
- job.nodes[i] = simgrid.Host.getPropValue(simgrid.Host.at(i),"ip")..":"..simgrid.Host.getPropValue(simgrid.Host.at(i),"port");
- end
-end
-
-function init_jobs()
- init_nodes()
-end
-
--- Job methods
-function job.me.ip()
- return simgrid.Host.getPropValue(simgrid.Host.self(),"ip");
-end
-
-function job.me.port()
- return simgrid.Host.getPropValue(simgrid.Host.self(),"port");
-end
-
-function job.position()
- return simgrid.Host.getPropValue(simgrid.Host.self(),"position");
-end
-
--- log Methods
-function log:print(msg)
- simgrid.info(msg);
-end
-
--- rpc Methods
-function rpc.call(node,call)
- --init_nodes();
- func = "empty"
- arg = "empty"
- mailbox = node
-
- if type(call) == "table" then
- func = call[1]
- arg = call[2]
- end
- task_call = simgrid.Task.new("splay_task",10000,10000);
- task_call['func_call_name'] = func;
- task_call['func_call_arg'] = arg;
- --log:print("Sending Task to mailbox "..mailbox.." to call "..func.." with arg "..arg);
- simgrid.Task.iSend(task_call,mailbox);
- call_function(func,arg)
-end
-
--- event Methods
-function event.sleep(time)
- my_mailbox = job.me.ip()..":"..job.me.port()
- task = simgrid.Task.splay_recv(my_mailbox, time)
-end
-
--- main func for each process, this is equivalent to the Deploiment file
-function event.thread(main_func)
- dofile("platform_script.lua");
- init_jobs()
-end
-
--- OS methods
-function os.exit()
- simgrid.Host.destroy(simgrid.Host.self());
-end
-
--- Start Methods
-function start.loop()
- simgrid.run()
- simgrid.clean()
-end
--- useful functions
-function call_function(fct,arg)
- _G[fct](arg)
-end
-
-function SPLAYschool()
- simgrid.info("Calling me...")
-end
