require "simgrid"
-- Splay global modules
rpc = {}
log = {}
job = {}
events = {}
os = {}
start = {}
misc = {}
-- 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(node) == "table" then
  mailbox = node.ip..":"..node.port
 end

 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);
 
end 

function rpc.server(port)
 -- nothing really to do : no need to open Socket since it's a Simulation
end


-- event Methods
function events.sleep(time)
  my_mailbox = job.me.ip()..":"..job.me.port()
  tk = simgrid.Task.splay_recv(my_mailbox, time)
  
  if type(tk) == "table" then 
  	call_function(task['func_call_name'],task['func_call_arg'])
  else log:print("task type is :"..type(tk).." it must be table?!");
  end
end


-- main func for each process, this is equivalent to the Deploiment file 
function events.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

-- Misc Methods
function misc.between(a,b)
	return a
end

-- useful functions
function call_function(fct,arg)
    _G[fct](arg)
end

function SPLAYschool(arg)
 simgrid.info("Calling me..."..arg)
end