X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/272ccad1b68b6d9c17069f3c934886925bb15b5d..9788cd051f72b982ec571c96e84577e9749188b1:/src/mc/mc_request.c diff --git a/src/mc/mc_request.c b/src/mc/mc_request.c index 9a5f74aa40..5b7ce40864 100644 --- a/src/mc/mc_request.c +++ b/src/mc/mc_request.c @@ -1,4 +1,5 @@ -/* Copyright (c) 2008-2012 Da SimGrid Team. All rights reserved. */ +/* Copyright (c) 2008-2013. The 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. */ @@ -11,14 +12,12 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_request, mc, static char* pointer_to_string(void* pointer); static char* buff_size_to_string(size_t size); -int MC_request_depend(smx_simcall_t r1, smx_simcall_t r2) -{ - if(_surf_do_model_check == 2) +int MC_request_depend(smx_simcall_t r1, smx_simcall_t r2) { + if(mc_reduce_kind == e_mc_reduce_none) return TRUE; - if (r1->issuer == r2->issuer) - return FALSE; + return FALSE; if(r1->call == SIMCALL_COMM_ISEND && r2->call == SIMCALL_COMM_IRECV) return FALSE; @@ -26,130 +25,134 @@ int MC_request_depend(smx_simcall_t r1, smx_simcall_t r2) if(r1->call == SIMCALL_COMM_IRECV && r2->call == SIMCALL_COMM_ISEND) return FALSE; - if( (r1->call == SIMCALL_COMM_ISEND || r1->call == SIMCALL_COMM_IRECV) - && r2->call == SIMCALL_COMM_WAIT){ + if((r1->call == SIMCALL_COMM_ISEND || r1->call == SIMCALL_COMM_IRECV) + && r2->call == SIMCALL_COMM_WAIT){ - if(r2->comm_wait.comm->comm.rdv == NULL) - return FALSE; + smx_rdv_t rdv = r1->call == SIMCALL_COMM_ISEND ? simcall_comm_isend__get__rdv(r1) : simcall_comm_irecv__get__rdv(r1); - smx_rdv_t rdv = r1->call == SIMCALL_COMM_ISEND ? r1->comm_isend.rdv : r1->comm_irecv.rdv; + if(rdv != simcall_comm_wait__get__comm(r2)->comm.rdv_cpy && simcall_comm_wait__get__timeout(r2) <= 0) + return FALSE; - if(r2->comm_wait.comm->comm.rdv != rdv) + if((r1->issuer != simcall_comm_wait__get__comm(r2)->comm.src_proc) && (r1->issuer != simcall_comm_wait__get__comm(r2)->comm.dst_proc) && simcall_comm_wait__get__timeout(r2) <= 0) return FALSE; - if(r2->comm_wait.comm->comm.type == SIMIX_COMM_SEND && r1->call == SIMCALL_COMM_ISEND) + if((r1->call == SIMCALL_COMM_ISEND) && (simcall_comm_wait__get__comm(r2)->comm.type == SIMIX_COMM_SEND) + && (simcall_comm_wait__get__comm(r2)->comm.src_buff != simcall_comm_isend__get__src_buff(r1)) && simcall_comm_wait__get__timeout(r2) <= 0) return FALSE; - if(r2->comm_wait.comm->comm.type == SIMIX_COMM_RECEIVE && r1->call == SIMCALL_COMM_IRECV) + if((r1->call == SIMCALL_COMM_IRECV) && (simcall_comm_wait__get__comm(r2)->comm.type == SIMIX_COMM_RECEIVE) + && (simcall_comm_wait__get__comm(r2)->comm.dst_buff != simcall_comm_irecv__get__dst_buff(r1)) && simcall_comm_wait__get__timeout(r2) <= 0) return FALSE; } - if( (r2->call == SIMCALL_COMM_ISEND || r2->call == SIMCALL_COMM_IRECV) - && r1->call == SIMCALL_COMM_WAIT){ + if((r2->call == SIMCALL_COMM_ISEND || r2->call == SIMCALL_COMM_IRECV) + && r1->call == SIMCALL_COMM_WAIT){ - if(r1->comm_wait.comm->comm.rdv != NULL) - return FALSE; + smx_rdv_t rdv = r2->call == SIMCALL_COMM_ISEND ? simcall_comm_isend__get__rdv(r2) : simcall_comm_irecv__get__rdv(r2); - smx_rdv_t rdv = r2->call == SIMCALL_COMM_ISEND ? r2->comm_isend.rdv : r2->comm_irecv.rdv; - - if(r1->comm_wait.comm->comm.rdv != rdv) + if(rdv != simcall_comm_wait__get__comm(r1)->comm.rdv_cpy && simcall_comm_wait__get__timeout(r1) <= 0) return FALSE; - if(r1->comm_wait.comm->comm.type == SIMIX_COMM_SEND && r2->call == SIMCALL_COMM_ISEND) + if((r2->issuer != simcall_comm_wait__get__comm(r1)->comm.src_proc) && (r2->issuer != simcall_comm_wait__get__comm(r1)->comm.dst_proc) && simcall_comm_wait__get__timeout(r1) <= 0) + return FALSE; + + if((r2->call == SIMCALL_COMM_ISEND) && (simcall_comm_wait__get__comm(r1)->comm.type == SIMIX_COMM_SEND) + && (simcall_comm_wait__get__comm(r1)->comm.src_buff != simcall_comm_isend__get__src_buff(r2)) && simcall_comm_wait__get__timeout(r1) <= 0) return FALSE; - if(r1->comm_wait.comm->comm.type == SIMIX_COMM_RECEIVE && r2->call == SIMCALL_COMM_IRECV) + if((r2->call == SIMCALL_COMM_IRECV) && (simcall_comm_wait__get__comm(r1)->comm.type == SIMIX_COMM_RECEIVE) + && (simcall_comm_wait__get__comm(r1)->comm.dst_buff != simcall_comm_irecv__get__dst_buff(r2)) && simcall_comm_wait__get__timeout(r1) <= 0) return FALSE; } /* FIXME: the following rule assumes that the result of the * isend/irecv call is not stored in a buffer used in the * test call. */ - if( (r1->call == SIMCALL_COMM_ISEND || r1->call == SIMCALL_COMM_IRECV) - && r2->call == SIMCALL_COMM_TEST) - return FALSE; + /*if( (r1->call == SIMCALL_COMM_ISEND || r1->call == SIMCALL_COMM_IRECV) + && r2->call == SIMCALL_COMM_TEST) + return FALSE;*/ /* FIXME: the following rule assumes that the result of the * isend/irecv call is not stored in a buffer used in the * test call.*/ - if( (r2->call == SIMCALL_COMM_ISEND || r2->call == SIMCALL_COMM_IRECV) - && r1->call == SIMCALL_COMM_TEST) - return FALSE; + /*if( (r2->call == SIMCALL_COMM_ISEND || r2->call == SIMCALL_COMM_IRECV) + && r1->call == SIMCALL_COMM_TEST) + return FALSE;*/ if(r1->call == SIMCALL_COMM_ISEND && r2->call == SIMCALL_COMM_ISEND - && r1->comm_isend.rdv != r2->comm_isend.rdv) + && simcall_comm_isend__get__rdv(r1) != simcall_comm_isend__get__rdv(r2)) return FALSE; if(r1->call == SIMCALL_COMM_IRECV && r2->call == SIMCALL_COMM_IRECV - && r1->comm_irecv.rdv != r2->comm_irecv.rdv) + && simcall_comm_irecv__get__rdv(r1) != simcall_comm_irecv__get__rdv(r2)) return FALSE; if(r1->call == SIMCALL_COMM_WAIT && (r2->call == SIMCALL_COMM_WAIT || r2->call == SIMCALL_COMM_TEST) - && (r1->comm_wait.comm->comm.src_proc == NULL - || r1->comm_wait.comm->comm.dst_proc == NULL)) + && (simcall_comm_wait__get__comm(r1)->comm.src_proc == NULL + || simcall_comm_wait__get__comm(r1)->comm.dst_proc == NULL)) return FALSE; if(r2->call == SIMCALL_COMM_WAIT && (r1->call == SIMCALL_COMM_WAIT || r1->call == SIMCALL_COMM_TEST) - && (r2->comm_wait.comm->comm.src_proc == NULL - || r2->comm_wait.comm->comm.dst_proc == NULL)) + && (simcall_comm_wait__get__comm(r2)->comm.src_proc == NULL + || simcall_comm_wait__get__comm(r2)->comm.dst_proc == NULL)) return FALSE; if(r1->call == SIMCALL_COMM_WAIT && r2->call == SIMCALL_COMM_WAIT - && r1->comm_wait.comm->comm.src_buff == r2->comm_wait.comm->comm.src_buff - && r1->comm_wait.comm->comm.dst_buff == r2->comm_wait.comm->comm.dst_buff) + && simcall_comm_wait__get__comm(r1)->comm.src_buff == simcall_comm_wait__get__comm(r2)->comm.src_buff + && simcall_comm_wait__get__comm(r1)->comm.dst_buff == simcall_comm_wait__get__comm(r2)->comm.dst_buff) return FALSE; if (r1->call == SIMCALL_COMM_WAIT && r2->call == SIMCALL_COMM_WAIT - && r1->comm_wait.comm->comm.src_buff != NULL - && r1->comm_wait.comm->comm.dst_buff != NULL - && r2->comm_wait.comm->comm.src_buff != NULL - && r2->comm_wait.comm->comm.dst_buff != NULL - && r1->comm_wait.comm->comm.dst_buff != r2->comm_wait.comm->comm.src_buff - && r1->comm_wait.comm->comm.dst_buff != r2->comm_wait.comm->comm.dst_buff - && r2->comm_wait.comm->comm.dst_buff != r1->comm_wait.comm->comm.src_buff) + && simcall_comm_wait__get__comm(r1)->comm.src_buff != NULL + && simcall_comm_wait__get__comm(r1)->comm.dst_buff != NULL + && simcall_comm_wait__get__comm(r2)->comm.src_buff != NULL + && simcall_comm_wait__get__comm(r2)->comm.dst_buff != NULL + && simcall_comm_wait__get__comm(r1)->comm.dst_buff != simcall_comm_wait__get__comm(r2)->comm.src_buff + && simcall_comm_wait__get__comm(r1)->comm.dst_buff != simcall_comm_wait__get__comm(r2)->comm.dst_buff + && simcall_comm_wait__get__comm(r2)->comm.dst_buff != simcall_comm_wait__get__comm(r1)->comm.src_buff) return FALSE; if(r1->call == SIMCALL_COMM_TEST && - (r1->comm_test.comm == NULL - || r1->comm_test.comm->comm.src_buff == NULL - || r1->comm_test.comm->comm.dst_buff == NULL)) + (simcall_comm_test__get__comm(r1) == NULL + || simcall_comm_test__get__comm(r1)->comm.src_buff == NULL + || simcall_comm_test__get__comm(r1)->comm.dst_buff == NULL)) return FALSE; if(r2->call == SIMCALL_COMM_TEST && - (r2->comm_test.comm == NULL - || r2->comm_test.comm->comm.src_buff == NULL - || r2->comm_test.comm->comm.dst_buff == NULL)) + (simcall_comm_test__get__comm(r2) == NULL + || simcall_comm_test__get__comm(r2)->comm.src_buff == NULL + || simcall_comm_test__get__comm(r2)->comm.dst_buff == NULL)) return FALSE; if(r1->call == SIMCALL_COMM_TEST && r2->call == SIMCALL_COMM_WAIT - && r1->comm_test.comm->comm.src_buff == r2->comm_wait.comm->comm.src_buff - && r1->comm_test.comm->comm.dst_buff == r2->comm_wait.comm->comm.dst_buff) + && simcall_comm_test__get__comm(r1)->comm.src_buff == simcall_comm_wait__get__comm(r2)->comm.src_buff + && simcall_comm_test__get__comm(r1)->comm.dst_buff == simcall_comm_wait__get__comm(r2)->comm.dst_buff) return FALSE; if(r1->call == SIMCALL_COMM_WAIT && r2->call == SIMCALL_COMM_TEST - && r1->comm_wait.comm->comm.src_buff == r2->comm_test.comm->comm.src_buff - && r1->comm_wait.comm->comm.dst_buff == r2->comm_test.comm->comm.dst_buff) + && simcall_comm_wait__get__comm(r1)->comm.src_buff == simcall_comm_test__get__comm(r2)->comm.src_buff + && simcall_comm_wait__get__comm(r1)->comm.dst_buff == simcall_comm_test__get__comm(r2)->comm.dst_buff) return FALSE; if (r1->call == SIMCALL_COMM_WAIT && r2->call == SIMCALL_COMM_TEST - && r1->comm_wait.comm->comm.src_buff != NULL - && r1->comm_wait.comm->comm.dst_buff != NULL - && r2->comm_test.comm->comm.src_buff != NULL - && r2->comm_test.comm->comm.dst_buff != NULL - && r1->comm_wait.comm->comm.dst_buff != r2->comm_test.comm->comm.src_buff - && r1->comm_wait.comm->comm.dst_buff != r2->comm_test.comm->comm.dst_buff - && r2->comm_test.comm->comm.dst_buff != r1->comm_wait.comm->comm.src_buff) + && simcall_comm_wait__get__comm(r1)->comm.src_buff != NULL + && simcall_comm_wait__get__comm(r1)->comm.dst_buff != NULL + && simcall_comm_test__get__comm(r2)->comm.src_buff != NULL + && simcall_comm_test__get__comm(r2)->comm.dst_buff != NULL + && simcall_comm_wait__get__comm(r1)->comm.dst_buff != simcall_comm_test__get__comm(r2)->comm.src_buff + && simcall_comm_wait__get__comm(r1)->comm.dst_buff != simcall_comm_test__get__comm(r2)->comm.dst_buff + && simcall_comm_test__get__comm(r2)->comm.dst_buff != simcall_comm_wait__get__comm(r1)->comm.src_buff) return FALSE; if (r1->call == SIMCALL_COMM_TEST && r2->call == SIMCALL_COMM_WAIT - && r1->comm_test.comm->comm.src_buff != NULL - && r1->comm_test.comm->comm.dst_buff != NULL - && r2->comm_wait.comm->comm.src_buff != NULL - && r2->comm_wait.comm->comm.dst_buff != NULL - && r1->comm_test.comm->comm.dst_buff != r2->comm_wait.comm->comm.src_buff - && r1->comm_test.comm->comm.dst_buff != r2->comm_wait.comm->comm.dst_buff - && r2->comm_wait.comm->comm.dst_buff != r1->comm_test.comm->comm.src_buff) - return FALSE; + && simcall_comm_test__get__comm(r1)->comm.src_buff != NULL + && simcall_comm_test__get__comm(r1)->comm.dst_buff != NULL + && simcall_comm_wait__get__comm(r2)->comm.src_buff != NULL + && simcall_comm_wait__get__comm(r2)->comm.dst_buff != NULL + && simcall_comm_test__get__comm(r1)->comm.dst_buff != simcall_comm_wait__get__comm(r2)->comm.src_buff + && simcall_comm_test__get__comm(r1)->comm.dst_buff != simcall_comm_wait__get__comm(r2)->comm.dst_buff + && simcall_comm_wait__get__comm(r2)->comm.dst_buff != simcall_comm_test__get__comm(r1)->comm.src_buff) + return FALSE; return TRUE; @@ -180,73 +183,105 @@ char *MC_request_to_string(smx_simcall_t req, int value) switch(req->call){ case SIMCALL_COMM_ISEND: - type = xbt_strdup("iSend"); - p = pointer_to_string(req->comm_isend.src_buff); - bs = buff_size_to_string(req->comm_isend.src_buff_size); - args = bprintf("src=%s, buff=%s, size=%s", req->issuer->name, p, bs); - break; - case SIMCALL_COMM_IRECV: - size = req->comm_irecv.dst_buff_size ? *req->comm_irecv.dst_buff_size : 0; - type = xbt_strdup("iRecv"); - p = pointer_to_string(req->comm_irecv.dst_buff); - bs = buff_size_to_string(size); - args = bprintf("dst=%s, buff=%s, size=%s", req->issuer->name, p, bs); - break; - case SIMCALL_COMM_WAIT: - act = req->comm_wait.comm; - if(value == -1){ - type = xbt_strdup("WaitTimeout"); - p = pointer_to_string(act); - args = bprintf("comm=%p", p); - }else{ - type = xbt_strdup("Wait"); - p = pointer_to_string(act); - args = bprintf("comm=%s [(%lu)%s -> (%lu)%s]", p, - act->comm.src_proc ? act->comm.src_proc->pid : 0, - act->comm.src_proc ? act->comm.src_proc->name : "", - act->comm.dst_proc ? act->comm.dst_proc->pid : 0, - act->comm.dst_proc ? act->comm.dst_proc->name : ""); - } - break; - case SIMCALL_COMM_TEST: - act = req->comm_test.comm; - if(act->comm.src_proc == NULL || act->comm.dst_proc == NULL){ - type = xbt_strdup("Test FALSE"); - p = pointer_to_string(act); - args = bprintf("comm=%s", p); - }else{ - type = xbt_strdup("Test TRUE"); - p = pointer_to_string(act); - args = bprintf("comm=%s [(%lu)%s -> (%lu)%s]", p, - act->comm.src_proc->pid, act->comm.src_proc->name, - act->comm.dst_proc->pid, act->comm.dst_proc->name); - } - break; - - case SIMCALL_COMM_WAITANY: - type = xbt_strdup("WaitAny"); - p = pointer_to_string(xbt_dynar_get_as(req->comm_waitany.comms, value, smx_action_t)); - args = bprintf("comm=%s (%d of %lu)", p, - value+1, xbt_dynar_length(req->comm_waitany.comms)); - break; - - case SIMCALL_COMM_TESTANY: - if(value == -1){ - type = xbt_strdup("TestAny FALSE"); - args = xbt_strdup("-"); - }else{ - type = xbt_strdup("TestAny"); - args = bprintf("(%d of %lu)", value+1, xbt_dynar_length(req->comm_testany.comms)); - } - break; + type = xbt_strdup("iSend"); + p = pointer_to_string(simcall_comm_isend__get__src_buff(req)); + bs = buff_size_to_string(simcall_comm_isend__get__src_buff_size(req)); + if(req->issuer->smx_host) + args = bprintf("src=(%lu)%s (%s), buff=%s, size=%s", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host), req->issuer->name, p, bs); + else + args = bprintf("src=(%lu)%s, buff=%s, size=%s", req->issuer->pid, req->issuer->name, p, bs); + break; + case SIMCALL_COMM_IRECV: + size = simcall_comm_irecv__get__dst_buff_size(req) ? *simcall_comm_irecv__get__dst_buff_size(req) : 0; + type = xbt_strdup("iRecv"); + p = pointer_to_string(simcall_comm_irecv__get__dst_buff(req)); + bs = buff_size_to_string(size); + if(req->issuer->smx_host) + args = bprintf("dst=(%lu)%s (%s), buff=%s, size=%s", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host), req->issuer->name, p, bs); + else + args = bprintf("dst=(%lu)%s, buff=%s, size=%s", req->issuer->pid, req->issuer->name, p, bs); + break; + case SIMCALL_COMM_WAIT: + act = simcall_comm_wait__get__comm(req); + if(value == -1){ + type = xbt_strdup("WaitTimeout"); + p = pointer_to_string(act); + args = bprintf("comm=%s", p); + }else{ + type = xbt_strdup("Wait"); + p = pointer_to_string(act); + args = bprintf("comm=%s [(%lu)%s (%s)-> (%lu)%s (%s)]", p, + act->comm.src_proc ? act->comm.src_proc->pid : 0, + act->comm.src_proc ? MSG_host_get_name(act->comm.src_proc->smx_host) : "", + act->comm.src_proc ? act->comm.src_proc->name : "", + act->comm.dst_proc ? act->comm.dst_proc->pid : 0, + act->comm.dst_proc ? MSG_host_get_name(act->comm.dst_proc->smx_host) : "", + act->comm.dst_proc ? act->comm.dst_proc->name : ""); + } + break; + case SIMCALL_COMM_TEST: + act = simcall_comm_test__get__comm(req); + if(act->comm.src_proc == NULL || act->comm.dst_proc == NULL){ + type = xbt_strdup("Test FALSE"); + p = pointer_to_string(act); + args = bprintf("comm=%s", p); + }else{ + type = xbt_strdup("Test TRUE"); + p = pointer_to_string(act); + args = bprintf("comm=%s [(%lu)%s (%s) -> (%lu)%s (%s)]", p, + act->comm.src_proc->pid, act->comm.src_proc->name, MSG_host_get_name(act->comm.src_proc->smx_host), + act->comm.dst_proc->pid, act->comm.dst_proc->name, MSG_host_get_name(act->comm.dst_proc->smx_host)); + } + break; + + case SIMCALL_COMM_WAITANY: + type = xbt_strdup("WaitAny"); + if(!xbt_dynar_is_empty(simcall_comm_waitany__get__comms(req))){ + p = pointer_to_string(xbt_dynar_get_as(simcall_comm_waitany__get__comms(req), value, smx_action_t)); + args = bprintf("comm=%s (%d of %lu)", p, + value+1, xbt_dynar_length(simcall_comm_waitany__get__comms(req))); + }else{ + args = bprintf("comm at idx %d", value); + } + break; + + case SIMCALL_COMM_TESTANY: + if(value == -1){ + type = xbt_strdup("TestAny FALSE"); + args = xbt_strdup("-"); + }else{ + type = xbt_strdup("TestAny"); + args = bprintf("(%d of %lu)", value+1, xbt_dynar_length(simcall_comm_testany__get__comms(req))); + } + break; + + case SIMCALL_MC_SNAPSHOT: + type = xbt_strdup("MC_SNAPSHOT"); + args = '\0'; + break; + + case SIMCALL_MC_COMPARE_SNAPSHOTS: + type = xbt_strdup("MC_COMPARE_SNAPSHOTS"); + args = '\0'; + break; + + case SIMCALL_MC_RANDOM: + type = xbt_strdup("MC_RANDOM"); + args = bprintf("%d", value); + break; + + default: + THROW_UNIMPLEMENTED; + } - default: - THROW_UNIMPLEMENTED; + if(args != NULL){ + str = bprintf("[(%lu)%s (%s)] %s(%s) (%d)", req->issuer->pid , MSG_host_get_name(req->issuer->smx_host), req->issuer->name, type, args, req->call); + }else{ + str = bprintf("[(%lu)%s (%s)] %s (%d) ", req->issuer->pid , MSG_host_get_name(req->issuer->smx_host), req->issuer->name, type, req->call); } - str = bprintf("[(%lu)%s] %s (%s)", req->issuer->pid ,req->issuer->name, type, args); - xbt_free(type); xbt_free(args); + xbt_free(type); xbt_free(p); xbt_free(bs); return str; @@ -257,7 +292,7 @@ unsigned int MC_request_testany_fail(smx_simcall_t req) unsigned int cursor; smx_action_t action; - xbt_dynar_foreach(req->comm_testany.comms, cursor, action){ + xbt_dynar_foreach(simcall_comm_testany__get__comms(req), cursor, action){ if(action->comm.src_proc && action->comm.dst_proc) return FALSE; } @@ -268,11 +303,14 @@ unsigned int MC_request_testany_fail(smx_simcall_t req) int MC_request_is_visible(smx_simcall_t req) { return req->call == SIMCALL_COMM_ISEND - || req->call == SIMCALL_COMM_IRECV - || req->call == SIMCALL_COMM_WAIT - || req->call == SIMCALL_COMM_WAITANY - || req->call == SIMCALL_COMM_TEST - || req->call == SIMCALL_COMM_TESTANY; + || req->call == SIMCALL_COMM_IRECV + || req->call == SIMCALL_COMM_WAIT + || req->call == SIMCALL_COMM_WAITANY + || req->call == SIMCALL_COMM_TEST + || req->call == SIMCALL_COMM_TESTANY + || req->call == SIMCALL_MC_RANDOM + || req->call == SIMCALL_MC_SNAPSHOT + || req->call == SIMCALL_MC_COMPARE_SNAPSHOTS; } int MC_request_is_enabled(smx_simcall_t req) @@ -282,33 +320,38 @@ int MC_request_is_enabled(smx_simcall_t req) switch (req->call) { - case SIMCALL_COMM_WAIT: - /* FIXME: check also that src and dst processes are not suspended */ + case SIMCALL_COMM_WAIT: + /* FIXME: check also that src and dst processes are not suspended */ - /* If it has a timeout it will be always be enabled, because even if the - * communication is not ready, it can timeout and won't block. - * On the other hand if it hasn't a timeout, check if the comm is ready.*/ - if(req->comm_wait.timeout >= 0){ + /* If it has a timeout it will be always be enabled, because even if the + * communication is not ready, it can timeout and won't block. + * On the other hand if it hasn't a timeout, check if the comm is ready.*/ + if(simcall_comm_wait__get__timeout(req) >= 0){ + if(_sg_mc_timeout == 1){ return TRUE; }else{ - act = req->comm_wait.comm; + act = simcall_comm_wait__get__comm(req); return (act->comm.src_proc && act->comm.dst_proc); } - break; - - case SIMCALL_COMM_WAITANY: - /* Check if it has at least one communication ready */ - xbt_dynar_foreach(req->comm_waitany.comms, index, act) { - if (act->comm.src_proc && act->comm.dst_proc){ - return TRUE; - } + }else{ + act = simcall_comm_wait__get__comm(req); + return (act->comm.src_proc && act->comm.dst_proc); + } + break; + + case SIMCALL_COMM_WAITANY: + /* Check if it has at least one communication ready */ + xbt_dynar_foreach(simcall_comm_waitany__get__comms(req), index, act) { + if (act->comm.src_proc && act->comm.dst_proc){ + return TRUE; } - return FALSE; - break; + } + return FALSE; + break; - default: - /* The rest of the request are always enabled */ - return TRUE; + default: + /* The rest of the request are always enabled */ + return TRUE; } } @@ -318,24 +361,24 @@ int MC_request_is_enabled_by_idx(smx_simcall_t req, unsigned int idx) switch (req->call) { - case SIMCALL_COMM_WAIT: - /* FIXME: check also that src and dst processes are not suspended */ - act = req->comm_wait.comm; - return (act->comm.src_proc && act->comm.dst_proc); - break; + case SIMCALL_COMM_WAIT: + /* FIXME: check also that src and dst processes are not suspended */ + act = simcall_comm_wait__get__comm(req); + return (act->comm.src_proc && act->comm.dst_proc); + break; - case SIMCALL_COMM_WAITANY: - act = xbt_dynar_get_as(req->comm_waitany.comms, idx, smx_action_t); - return (act->comm.src_proc && act->comm.dst_proc); - break; + case SIMCALL_COMM_WAITANY: + act = xbt_dynar_get_as(simcall_comm_waitany__get__comms(req), idx, smx_action_t); + return (act->comm.src_proc && act->comm.dst_proc); + break; - case SIMCALL_COMM_TESTANY: - act = xbt_dynar_get_as(req->comm_testany.comms, idx, smx_action_t); - return (act->comm.src_proc && act->comm.dst_proc); - break; + case SIMCALL_COMM_TESTANY: + act = xbt_dynar_get_as(simcall_comm_testany__get__comms(req), idx, smx_action_t); + return (act->comm.src_proc && act->comm.dst_proc); + break; - default: - return TRUE; + default: + return TRUE; } } @@ -346,3 +389,105 @@ int MC_process_is_enabled(smx_process_t process) return FALSE; } + +char *MC_request_get_dot_output(smx_simcall_t req, int value){ + + char *str = NULL, *label = NULL; + smx_action_t act = NULL; + + switch(req->call){ + case SIMCALL_COMM_ISEND: + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] iSend", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host)); + else + label = bprintf("[(%lu)] iSend", req->issuer->pid); + break; + + case SIMCALL_COMM_IRECV: + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] iRecv", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host)); + else + label = bprintf("[(%lu)] iRecv", req->issuer->pid); + break; + + case SIMCALL_COMM_WAIT: + act = simcall_comm_wait__get__comm(req); + if(value == -1){ + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] WaitTimeout", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host)); + else + label = bprintf("[(%lu)] WaitTimeout", req->issuer->pid); + }else{ + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] Wait [(%lu)->(%lu)]", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host), act->comm.src_proc ? act->comm.src_proc->pid : 0, act->comm.dst_proc ? act->comm.dst_proc->pid : 0); + else + label = bprintf("[(%lu)] Wait [(%lu)->(%lu)]", req->issuer->pid, act->comm.src_proc ? act->comm.src_proc->pid : 0, act->comm.dst_proc ? act->comm.dst_proc->pid : 0); + } + break; + + case SIMCALL_COMM_TEST: + act = simcall_comm_test__get__comm(req); + if(act->comm.src_proc == NULL || act->comm.dst_proc == NULL){ + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] Test FALSE", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host)); + else + label = bprintf("[(%lu)] Test FALSE", req->issuer->pid); + }else{ + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] Test TRUE", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host)); + else + label = bprintf("[(%lu)] Test TRUE", req->issuer->pid); + } + break; + + case SIMCALL_COMM_WAITANY: + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] WaitAny [%d of %lu]", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host), value+1, xbt_dynar_length(simcall_comm_waitany__get__comms(req))); + else + label = bprintf("[(%lu)] WaitAny [%d of %lu]", req->issuer->pid, value+1, xbt_dynar_length(simcall_comm_waitany__get__comms(req))); + break; + + case SIMCALL_COMM_TESTANY: + if(value == -1){ + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] TestAny FALSE", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host)); + else + label = bprintf("[(%lu)] TestAny FALSE", req->issuer->pid); + }else{ + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] TestAny TRUE [%d of %lu]", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host), value+1, xbt_dynar_length(simcall_comm_testany__get__comms(req))); + else + label = bprintf("[(%lu)] TestAny TRUE [%d of %lu]", req->issuer->pid, value+1, xbt_dynar_length(simcall_comm_testany__get__comms(req))); + } + break; + + case SIMCALL_MC_RANDOM: + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] MC_RANDOM (%d)", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host), value); + else + label = bprintf("[(%lu)] MC_RANDOM (%d)", req->issuer->pid, value); + break; + + case SIMCALL_MC_SNAPSHOT: + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] MC_SNAPSHOT", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host)); + else + label = bprintf("[(%lu)] MC_SNAPSHOT", req->issuer->pid); + break; + + case SIMCALL_MC_COMPARE_SNAPSHOTS: + if(req->issuer->smx_host) + label = bprintf("[(%lu)%s] MC_COMPARE_SNAPSHOTS", req->issuer->pid, MSG_host_get_name(req->issuer->smx_host)); + else + label = bprintf("[(%lu)] MC_COMPARE_SNAPSHOTS", req->issuer->pid); + break; + + default: + THROW_UNIMPLEMENTED; + } + + str = bprintf("label = \"%s\", color = %s, fontcolor = %s", label, colors[req->issuer->pid-1], colors[req->issuer->pid-1]); + xbt_free(label); + return str; + +}