Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
rename S4U::Channel to S4U::Mailbox. It was not a good idea
[simgrid.git] / src / s4u / s4u_process.cpp
1 /* Copyright (c) 2006-2014. The SimGrid Team.
2  * All rights reserved.                                                     */
3
4 /* This program is free software; you can redistribute it and/or modify it
5  * under the terms of the license (GNU LGPL) which comes with this package. */
6
7 #include "../../include/simgrid/s4u/mailbox.hpp"
8 #include "xbt/log.h"
9 #include "msg/msg_private.h"
10 #include "msg/msg_mailbox.h"
11
12 #include "simgrid/s4u/host.hpp"
13 #include "simgrid/s4u/process.hpp"
14
15 XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_process,"S4U processes");
16
17 /* C main function of a process, running this->main */
18 static int s4u_process_runner(int argc, char **argv) {
19
20         smx_process_t smx_proc = SIMIX_process_self();
21         simgrid::s4u::Process *proc = (simgrid::s4u::Process*) SIMIX_process_self_get_data(smx_proc);
22         int res= proc->main(argc,argv);
23         return res;
24 }
25
26
27
28 using namespace simgrid;
29
30 s4u::Process::Process(const char *procname, s4u::Host *host, int argc, char **argv)
31     : s4u::Process::Process(procname,host, argc,argv, -1) {
32 }
33 s4u::Process::Process(const char *procname, s4u::Host *host, int argc, char **argv, double killTime) {
34         p_smx_process = simcall_process_create(procname, s4u_process_runner, this, host->getName(), killTime, argc, argv, NULL/*properties*/,0);
35
36         xbt_assert(p_smx_process,"Cannot create the process");
37 //      TRACE_msg_process_create(procname, simcall_process_get_PID(p_smx_process), host->getInferior());
38 //      simcall_process_on_exit(p_smx_process,(int_f_pvoid_pvoid_t)TRACE_msg_process_kill,p_smx_process);
39 }
40
41 s4u::Process *s4u::Process::current() {
42         smx_process_t smx_proc = SIMIX_process_self();
43         return (simgrid::s4u::Process*) SIMIX_process_self_get_data(smx_proc);
44 }
45 s4u::Process *s4u::Process::byPid(int pid) {
46         return (simgrid::s4u::Process*) SIMIX_process_self_get_data(SIMIX_process_from_PID(pid));
47 }
48
49 void s4u::Process::setAutoRestart(bool autorestart) {
50         simcall_process_auto_restart_set(p_smx_process,autorestart);
51 }
52
53 s4u::Host *s4u::Process::getHost() {
54         return s4u::Host::byName(sg_host_name(simcall_process_get_host(p_smx_process)));
55 }
56 const char* s4u::Process::getName() {
57         return simcall_process_get_name(p_smx_process);
58 }
59 int s4u::Process::getPid(){
60         return simcall_process_get_PID(p_smx_process);
61 }
62
63 void s4u::Process::setKillTime(double time) {
64         simcall_process_set_kill_time(p_smx_process,time);
65 }
66 double s4u::Process::getKillTime() {
67         return simcall_process_get_kill_time(p_smx_process);
68 }
69 void s4u::Process::killAll() {
70         simcall_process_killall(1);
71 }
72 void s4u::Process::kill() {
73         simcall_process_kill(p_smx_process);
74 }
75
76 void s4u::Process::sleep(double duration) {
77         simcall_process_sleep(duration);
78 }
79
80 void s4u::Process::execute(double flops) {
81         simcall_process_execute(NULL,flops,1.0/*priority*/,0./*bound*/, 0L/*affinity*/);
82 }
83
84 char *s4u::Process::recvstr(Mailbox &chan) {
85         char *res=NULL;
86         size_t res_size=sizeof(res);
87
88         simcall_comm_recv(chan.getInferior(),&res,&res_size,NULL,NULL,NULL,-1 /* timeout */,-1 /*rate*/);
89
90     return res;
91 }
92 void s4u::Process::sendstr(Mailbox &chan, const char*msg) {
93         char *msg_cpy=xbt_strdup(msg);
94         smx_synchro_t comm = simcall_comm_isend(p_smx_process, chan.getInferior(), strlen(msg),
95                         -1/*rate*/, msg_cpy, sizeof(void *),
96                         NULL, NULL, NULL,NULL/*data*/, 0);
97         simcall_comm_wait(comm, -1/*timeout*/);
98 }
99