X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c912b7d6e75473bd05731ccf77f3e2d82afb7802..e6bc6eb53997f4648bf3207348c060e9f50ee282:/src/mc/mc_state.c diff --git a/src/mc/mc_state.c b/src/mc/mc_state.c index 08d7b598d1..822d17a431 100644 --- a/src/mc/mc_state.c +++ b/src/mc/mc_state.c @@ -1,20 +1,24 @@ +/* Copyright (c) 2008-2012 Da SimGrid Team. All rights reserved. */ +/* This program is free software; you can redistribute it and/or modify it + * under the terms of the license (GNU LGPL) which comes with this package. */ -#include "../simix/private.h" +#include "../simix/smx_private.h" #include "xbt/fifo.h" -#include "private.h" +#include "mc_private.h" /** * \brief Creates a state data structure used by the exploration algorithm */ -mc_state_t MC_state_new(void) +mc_state_t MC_state_new() { mc_state_t state = NULL; state = xbt_new0(s_mc_state_t, 1); state->max_pid = simix_process_maxpid; state->proc_status = xbt_new0(s_mc_procstate_t, state->max_pid); - + state->system_state = NULL; + mc_stats->expanded_states++; return state; } @@ -63,7 +67,7 @@ int MC_state_process_is_done(mc_state_t state, smx_process_t process){ return state->proc_status[process->pid].state == MC_DONE ? TRUE : FALSE; } -void MC_state_set_executed_request(mc_state_t state, smx_req_t req, int value) +void MC_state_set_executed_request(mc_state_t state, smx_simcall_t req, int value) { state->executed_req = *req; state->req_num = value; @@ -72,16 +76,16 @@ void MC_state_set_executed_request(mc_state_t state, smx_req_t req, int value) * corresponding communication action so it can be treated later by the dependence * function. */ switch(req->call){ - case REQ_COMM_WAITANY: - state->internal_req.call = REQ_COMM_WAIT; + case SIMCALL_COMM_WAITANY: + state->internal_req.call = SIMCALL_COMM_WAIT; state->internal_req.issuer = req->issuer; state->internal_comm = *xbt_dynar_get_as(req->comm_waitany.comms, value, smx_action_t); state->internal_req.comm_wait.comm = &state->internal_comm; state->internal_req.comm_wait.timeout = 0; break; - case REQ_COMM_TESTANY: - state->internal_req.call = REQ_COMM_TEST; + case SIMCALL_COMM_TESTANY: + state->internal_req.call = SIMCALL_COMM_TEST; state->internal_req.issuer = req->issuer; if(value > 0) @@ -91,14 +95,14 @@ void MC_state_set_executed_request(mc_state_t state, smx_req_t req, int value) state->internal_req.comm_test.result = value; break; - case REQ_COMM_WAIT: + case SIMCALL_COMM_WAIT: state->internal_req = *req; state->internal_comm = *(req->comm_wait.comm); state->executed_req.comm_wait.comm = &state->internal_comm; state->internal_req.comm_wait.comm = &state->internal_comm; break; - case REQ_COMM_TEST: + case SIMCALL_COMM_TEST: state->internal_req = *req; state->internal_comm = *req->comm_test.comm; state->executed_req.comm_test.comm = &state->internal_comm; @@ -111,18 +115,18 @@ void MC_state_set_executed_request(mc_state_t state, smx_req_t req, int value) } } -smx_req_t MC_state_get_executed_request(mc_state_t state, int *value) +smx_simcall_t MC_state_get_executed_request(mc_state_t state, int *value) { *value = state->req_num; return &state->executed_req; } -smx_req_t MC_state_get_internal_request(mc_state_t state) +smx_simcall_t MC_state_get_internal_request(mc_state_t state) { return &state->internal_req; } -smx_req_t MC_state_get_request(mc_state_t state, int *value) +smx_simcall_t MC_state_get_request(mc_state_t state, int *value) { smx_process_t process = NULL; mc_procstate_t procstate = NULL; @@ -133,58 +137,58 @@ smx_req_t MC_state_get_request(mc_state_t state, int *value) if(procstate->state == MC_INTERLEAVE){ if(MC_process_is_enabled(process)){ - switch(process->request.call){ - case REQ_COMM_WAITANY: + switch(process->simcall.call){ + case SIMCALL_COMM_WAITANY: *value = -1; - while(procstate->interleave_count < xbt_dynar_length(process->request.comm_waitany.comms)){ - if(MC_request_is_enabled_by_idx(&process->request, procstate->interleave_count++)){ + while(procstate->interleave_count < xbt_dynar_length(process->simcall.comm_waitany.comms)){ + if(MC_request_is_enabled_by_idx(&process->simcall, procstate->interleave_count++)){ *value = procstate->interleave_count-1; break; } } - if(procstate->interleave_count >= xbt_dynar_length(process->request.comm_waitany.comms)) + if(procstate->interleave_count >= xbt_dynar_length(process->simcall.comm_waitany.comms)) procstate->state = MC_DONE; if(*value != -1) - return &process->request; + return &process->simcall; break; - case REQ_COMM_TESTANY: + case SIMCALL_COMM_TESTANY: start_count = procstate->interleave_count; *value = -1; - while(procstate->interleave_count < xbt_dynar_length(process->request.comm_testany.comms)){ - if(MC_request_is_enabled_by_idx(&process->request, procstate->interleave_count++)){ + while(procstate->interleave_count < xbt_dynar_length(process->simcall.comm_testany.comms)){ + if(MC_request_is_enabled_by_idx(&process->simcall, procstate->interleave_count++)){ *value = procstate->interleave_count - 1; break; } } - if(procstate->interleave_count >= xbt_dynar_length(process->request.comm_testany.comms)) + if(procstate->interleave_count >= xbt_dynar_length(process->simcall.comm_testany.comms)) procstate->state = MC_DONE; if(*value != -1 || start_count == 0) - return &process->request; + return &process->simcall; break; - case REQ_COMM_WAIT: - if(process->request.comm_wait.comm->comm.src_proc - && process->request.comm_wait.comm->comm.dst_proc){ + case SIMCALL_COMM_WAIT: + if(process->simcall.comm_wait.comm->comm.src_proc + && process->simcall.comm_wait.comm->comm.dst_proc){ *value = 0; }else{ *value = -1; } procstate->state = MC_DONE; - return &process->request; + return &process->simcall; break; default: procstate->state = MC_DONE; *value = 0; - return &process->request; + return &process->simcall; break; } }