X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/114948db2d558f1be1481dea89be75166201461f..2f4b693b1235e1d82f41a1639046c3ac66063fba:/src/simix/smx_smurf.c diff --git a/src/simix/smx_smurf.c b/src/simix/smx_smurf.c index f3ebc520f7..0f1bdfb609 100644 --- a/src/simix/smx_smurf.c +++ b/src/simix/smx_smurf.c @@ -25,6 +25,7 @@ void SIMIX_simcall_push(smx_process_t self) SIMIX_simcall_name(self->simcall.call), (int)self->simcall.call); SIMIX_process_yield(self); } else { + XBT_DEBUG("I'm the maestro, execute the simcall directly"); SIMIX_simcall_pre(&self->simcall, 0); } } @@ -197,7 +198,7 @@ void SIMIX_simcall_pre(smx_simcall_t simcall, int value) SIMIX_simcall_answer(simcall); break; - case SIMCALL_RDV_GEY_BY_NAME: + case SIMCALL_RDV_GET_BY_NAME: simcall->rdv_get_by_name.result = SIMIX_rdv_get_by_name(simcall->rdv_get_by_name.name); SIMIX_simcall_answer(simcall); @@ -271,11 +272,7 @@ void SIMIX_simcall_pre(smx_simcall_t simcall, int value) break; case SIMCALL_HOST_EXECUTE: - simcall->host_execute.result = SIMIX_host_execute( - simcall->host_execute.name, - simcall->host_execute.host, - simcall->host_execute.computation_amount, - simcall->host_execute.priority); + simcall->host_execute.result = simcall_table[simcall->call](simcall->args); SIMIX_simcall_answer(simcall); break; @@ -558,17 +555,19 @@ void SIMIX_simcall_pre(smx_simcall_t simcall, int value) SIMIX_simcall_answer(simcall); break; +#ifdef HAVE_MC case SIMCALL_MC_SNAPSHOT: - simcall->mc_snapshot.s = MC_take_snapshot_liveness(); + simcall->mc_snapshot.s = MC_take_snapshot(); SIMIX_simcall_answer(simcall); break; case SIMCALL_MC_COMPARE_SNAPSHOTS: simcall->mc_compare_snapshots.result = - snapshot_compare(simcall->mc_compare_snapshots.snapshot1, simcall->mc_compare_snapshots.snapshot2); + snapshot_compare(simcall->mc_compare_snapshots.snapshot1, simcall->mc_compare_snapshots.snapshot2, NULL, NULL); SIMIX_simcall_answer(simcall); break; - +#endif /* HAVE_MC */ + case SIMCALL_NONE: THROWF(arg_error,0,"Asked to do the noop syscall on %s@%s", SIMIX_process_get_name(simcall->issuer), @@ -618,3 +617,67 @@ void SIMIX_simcall_post(smx_action_t action) break; } } + +/* New Simcal interface */ + +/* FIXME: add types for every simcall */ +const char *simcall_types[NUM_SIMCALLS] = { [SIMCALL_HOST_EXECUTE] = "%s%p%f%f%p" }; + +simcall_handler_t simcall_table[NUM_SIMCALLS] = { +#undef SIMCALL_ENUM_ELEMENT +#define SIMCALL_ENUM_ELEMENT(x,y) &y /* generate strings from the enumeration values */ +SIMCALL_LIST +#undef SIMCALL_ENUM_ELEMENT +}; + + +void SIMIX_simcall_typecheck(const char *fmt, ...) +{ + return; +} + +void __SIMIX_simcall(e_smx_simcall_t simcall_id, u_smx_scalar_t *args) +{ + smx_process_t self = SIMIX_process_self(); + self->simcall.call = simcall_id; + self->simcall.args = args; + + if (self != simix_global->maestro_process) { + XBT_DEBUG("Yield process '%s' on simcall %s (%d)", self->name, + SIMIX_simcall_name(self->simcall.call), (int)self->simcall.call); + + SIMIX_process_yield(self); + } else { + + SIMIX_simcall_pre(&self->simcall, 0); + } +} + +/* New Simcal interface */ + +/* FIXME: add types for every simcall */ +const char *simcall_types[NUM_SIMCALLS] = { [SIMCALL_HOST_EXECUTE] = "%s%p%f%f%p" }; + +simcall_handler_t simcall_table[NUM_SIMCALLS] = {[SIMCALL_HOST_EXECUTE] = &SIMIX_host_execute}; + +void SIMIX_simcall_typecheck(const char *fmt, ...) +{ + return; +} + +void __SIMIX_simcall(e_smx_simcall_t simcall_id, u_smx_scalar_t *args) +{ + smx_process_t self = SIMIX_process_self(); + self->simcall.call = simcall_id; + self->simcall.args = args; + + if (self != simix_global->maestro_process) { + XBT_DEBUG("Yield process '%s' on simcall %s (%d)", self->name, + SIMIX_simcall_name(self->simcall.call), (int)self->simcall.call); + + SIMIX_process_yield(self); + } else { + + SIMIX_simcall_pre(&self->simcall, 0); + } +}