Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
64b588b21b1f8aca617aca4b483f4b65b6cd230f
[simgrid.git] / src / simix / smx_smurf.c
1 /* Copyright (c) 2010-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 "smx_private.h"
8 #include "xbt/fifo.h"
9 #include "xbt/xbt_os_thread.h"
10 #ifdef HAVE_MC
11 #include "mc/mc_private.h"
12 #endif
13
14 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_smurf, simix,
15                                 "Logging specific to SIMIX (SMURF)");
16
17 XBT_INLINE smx_simcall_t SIMIX_simcall_mine()
18 {
19   smx_process_t issuer = SIMIX_process_self();
20   return &issuer->simcall;
21 }
22
23 /**
24  * \brief Makes the current process do a simcall to the kernel and yields
25  * until completion. If the current thread is maestro, we don't yield and
26  * execute the simcall directly.
27  * \param self the current process
28  */
29 void SIMIX_simcall_push(smx_process_t self)
30 {
31   if (self != simix_global->maestro_process) {
32     XBT_DEBUG("Yield process '%s' on simcall %s (%d)", self->name,
33               SIMIX_simcall_name(self->simcall.call), (int)self->simcall.call);
34     SIMIX_process_yield(self);
35   } else {
36     XBT_DEBUG("I'm the maestro, execute the simcall directly");
37     SIMIX_simcall_enter(&self->simcall, 0);
38   }
39 }
40
41 void SIMIX_simcall_answer(smx_simcall_t simcall)
42 {
43   if (simcall->issuer != simix_global->maestro_process){
44     XBT_DEBUG("Answer simcall %s (%d) issued by %s (%p)", SIMIX_simcall_name(simcall->call), (int)simcall->call,
45         simcall->issuer->name, simcall->issuer);
46     simcall->issuer->simcall.call = SIMCALL_NONE;
47 /*    This check should be useless and slows everyone. Reactivate if you see something
48  *    weird in process scheduling.
49  */
50 /*    if(!xbt_dynar_member(simix_global->process_to_run, &(simcall->issuer))) */
51     xbt_dynar_push_as(simix_global->process_to_run, smx_process_t, simcall->issuer);
52 /*    else DIE_IMPOSSIBLE; */
53   }
54 }
55
56 void SIMIX_simcall_exit(smx_action_t action)
57 {
58   switch (action->type) {
59
60     case SIMIX_ACTION_EXECUTE:
61     case SIMIX_ACTION_PARALLEL_EXECUTE:
62       SIMIX_post_host_execute(action);
63       break;
64
65     case SIMIX_ACTION_COMMUNICATE:
66       SIMIX_post_comm(action);
67       break;
68
69     case SIMIX_ACTION_SLEEP:
70       SIMIX_post_process_sleep(action);
71       break;
72
73     case SIMIX_ACTION_JOIN:
74       SIMIX_post_process_sleep(action);
75       break;
76
77     case SIMIX_ACTION_SYNCHRO:
78       SIMIX_post_synchro(action);
79       break;
80
81     case SIMIX_ACTION_IO:
82       SIMIX_post_io(action);
83       break;
84   }
85 }