Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
more verbose checks
[simgrid.git] / src / kernel / activity / SynchroExec.cpp
1 /* Copyright (c) 2007-2016. The SimGrid Team. All rights reserved.          */
2
3 /* This program is free software; you can redistribute it and/or modify it
4  * under the terms of the license (GNU LGPL) which comes with this package. */
5
6 #include <simgrid/s4u/host.hpp>
7
8 #include "src/kernel/activity/SynchroExec.hpp"
9 #include "src/surf/surf_interface.hpp"
10 #include "src/simix/smx_host_private.h"
11
12 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix_process);
13
14 simgrid::kernel::activity::Exec::Exec(const char*name, sg_host_t hostarg)
15 {
16   if (name)
17     this->name = name;
18   this->state = SIMIX_RUNNING;
19   this->host = hostarg;
20 }
21
22 simgrid::kernel::activity::Exec::~Exec()
23 {
24   if (surf_exec)
25     surf_exec->unref();
26   if (timeoutDetector)
27     timeoutDetector->unref();
28 }
29 void simgrid::kernel::activity::Exec::suspend()
30 {
31   XBT_VERB("This exec is suspended (remain: %f)", surf_exec->getRemains());
32   if (surf_exec)
33     surf_exec->suspend();
34 }
35
36 void simgrid::kernel::activity::Exec::resume()
37 {
38   XBT_VERB("This exec is resumed (remain: %f)", surf_exec->getRemains());
39   if (surf_exec)
40     surf_exec->resume();
41 }
42
43 double simgrid::kernel::activity::Exec::remains()
44 {
45   if (state == SIMIX_RUNNING)
46     return surf_exec->getRemains();
47
48   return 0;
49 }
50
51 void simgrid::kernel::activity::Exec::post()
52 {
53   if (host && host->isOff()) {/* FIMXE: handle resource failure for parallel tasks too */
54     /* If the host running the synchro failed, notice it. This way, the asking
55      * process can be killed if it runs on that host itself */
56     state = SIMIX_FAILED;
57   } else if (surf_exec->getState() == simgrid::surf::Action::State::failed) {
58     /* If the host running the synchro didn't fail, then the synchro was canceled */
59     state = SIMIX_CANCELED;
60   } else if (timeoutDetector && timeoutDetector->getState() == simgrid::surf::Action::State::done) {
61     state = SIMIX_TIMEOUT;
62   } else {
63     state = SIMIX_DONE;
64   }
65
66   if (surf_exec) {
67     surf_exec->unref();
68     surf_exec = nullptr;
69   }
70   if (timeoutDetector) {
71     timeoutDetector->unref();
72     timeoutDetector = nullptr;
73   }
74
75   /* If there are simcalls associated with the synchro, then answer them */
76   if (!simcalls.empty())
77     SIMIX_execution_finish(this);
78 }