*/
int SIMIX_process_has_pending_comms(smx_actor_t process) {
- return xbt_fifo_size(process->comms) > 0;
+ return process->comms.size() > 0;
}
/**
xbt_os_mutex_acquire(simix_global->mutex);
/* cancel non-blocking communications */
- smx_activity_t synchro = static_cast<smx_activity_t>(xbt_fifo_pop(process->comms));
- while (synchro != nullptr) {
+ smx_activity_t synchro = static_cast<smx_activity_t>(process->comms.front());
+ while (!process->comms.empty()) {
simgrid::kernel::activity::Comm *comm = static_cast<simgrid::kernel::activity::Comm*>(synchro);
/* make sure no one will finish the comm after this process is destroyed,
if (comm->detached && comm->src_proc != nullptr) {
/* the comm will be freed right now, remove it from the sender */
- xbt_fifo_remove(comm->src_proc->comms, comm);
+ comm->src_proc->comms.remove(comm);
}
comm->unref();
} else {
xbt_die("Communication synchro %p is in my list but I'm not the sender nor the receiver", synchro);
}
- synchro = static_cast<smx_activity_t>(xbt_fifo_pop(process->comms));
+ process->comms.pop_front();
+ synchro = static_cast<smx_activity_t>(process->comms.front());
}
XBT_DEBUG("%p should not be run anymore",process);
delete this->context;
if (this->properties)
xbt_dict_free(&this->properties);
- if (this->comms != nullptr)
- xbt_fifo_free(this->comms);
if (this->on_exit)
xbt_dynar_free(&this->on_exit);
}
exec->unref();
} else if (comm != nullptr) {
- xbt_fifo_remove(process->comms, process->waiting_synchro);
+ process->comms.remove(process->waiting_synchro);
comm->cancel();
// Remove first occurrence of &process->simcall:
simgrid::kernel::activity::Comm *comm = dynamic_cast<simgrid::kernel::activity::Comm*>(process->waiting_synchro);
if (comm != nullptr) {
- xbt_fifo_remove(process->comms, comm);
+ process->comms.remove(comm);
comm->cancel();
}
#include "simgrid/s4u/Actor.hpp"
#include "src/simix/popping_private.h"
-#include "xbt/fifo.h"
#include "xbt/swag.h"
+#include<list>
typedef struct s_smx_process_exit_fun {
int_f_pvoid_pvoid_t fun;
sg_host_t new_host = nullptr; /* if not null, the host on which the process must migrate to */
smx_activity_t waiting_synchro = nullptr; /* the current blocking synchro if any */
- xbt_fifo_t comms = xbt_fifo_new(); /* the current non-blocking communication synchros */
+ std::list<smx_activity_t> comms ; /* the current non-blocking communication synchros */
xbt_dict_t properties = nullptr;
s_smx_simcall_t simcall;
void *data = nullptr; /* kept for compatibility, it should be replaced with moddata */
other_comm->type = SIMIX_COMM_READY;
}
- xbt_fifo_push(src_proc->comms, other_synchro);
+ src_proc->comms.push_back(other_synchro);
if (detached) {
other_comm->state = SIMIX_READY;
other_comm->type = SIMIX_COMM_READY;
}
- xbt_fifo_push(dst_proc->comms, other_synchro);
+ dst_proc->comms.push_back(other_synchro);
}
/* Setup communication synchro */
}
simcall->issuer->waiting_synchro = nullptr;
- xbt_fifo_remove(simcall->issuer->comms, synchro);
+ simcall->issuer->comms.remove(synchro);
if(comm->detached){
if(simcall->issuer == comm->src_proc){
if(comm->dst_proc)
- xbt_fifo_remove(comm->dst_proc->comms, synchro);
+ comm->dst_proc->comms.remove(synchro);
}
else if(simcall->issuer == comm->dst_proc){
if(comm->src_proc)
- xbt_fifo_remove(comm->src_proc->comms, synchro);
+ comm->src_proc->comms.remove(synchro);
//in case of a detached comm we have an extra ref to remove, as the sender won't do it
destroy_count++;
}
else{
- xbt_fifo_remove(comm->dst_proc->comms, synchro);
- xbt_fifo_remove(comm->src_proc->comms, synchro);
+ comm->dst_proc->comms.remove(synchro);
+ comm->src_proc->comms.remove(synchro);
}
}