+ xbt_free(type);
+ xbt_free(p);
+ xbt_free(bs);
+ return str;
+}
+
+unsigned int MC_request_testany_fail(smx_simcall_t req)
+{
+ unsigned int cursor;
+ smx_action_t action;
+
+ xbt_dynar_foreach(simcall_comm_testany__get__comms(req), cursor, action){
+ if(action->comm.src_proc && action->comm.dst_proc)
+ return FALSE;
+ }
+
+ return TRUE;
+}
+
+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_MC_RANDOM
+ || req->call == SIMCALL_MC_SNAPSHOT
+ || req->call == SIMCALL_MC_COMPARE_SNAPSHOTS;
+}
+
+int MC_request_is_enabled(smx_simcall_t req)
+{
+ unsigned int index = 0;
+ smx_action_t act;
+
+ switch (req->call) {
+
+ 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(simcall_comm_wait__get__timeout(req) >= 0){
+ if(_sg_mc_timeout == 1){
+ return TRUE;
+ }else{
+ act = simcall_comm_wait__get__comm(req);
+ return (act->comm.src_proc && act->comm.dst_proc);
+ }
+ }else{
+ act = simcall_comm_wait__get__comm(req);
+ if(act->comm.detached && act->comm.src_proc == NULL && act->comm.type == SIMIX_COMM_READY)
+ return (act->comm.dst_proc != NULL);
+ 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;
+
+ default:
+ /* The rest of the request are always enabled */
+ return TRUE;
+ }
+}
+
+int MC_request_is_enabled_by_idx(smx_simcall_t req, unsigned int idx)
+{
+ smx_action_t act;
+
+ switch (req->call) {
+
+ 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(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(simcall_comm_testany__get__comms(req), idx, smx_action_t);
+ return (act->comm.src_proc && act->comm.dst_proc);
+ break;
+
+ default:
+ return TRUE;
+ }
+}
+
+int MC_process_is_enabled(smx_process_t process)
+{
+ if (process->simcall.call != SIMCALL_NONE && MC_request_is_enabled(&process->simcall))
+ return TRUE;
+
+ 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);