XBT_PRIVATE void TRACE_smpi_ptp_in(int rank, const char* operation, instr_extra_data extra);
XBT_PRIVATE void TRACE_smpi_ptp_out(int rank, int dst, const char* operation);
XBT_PRIVATE void TRACE_smpi_send(int rank, int src, int dst, int tag, int size);
-XBT_PRIVATE void TRACE_smpi_recv(int rank, int src, int dst, int tag);
+XBT_PRIVATE void TRACE_smpi_recv(int src, int dst, int tag);
XBT_PRIVATE void TRACE_smpi_init(int rank);
XBT_PRIVATE void TRACE_smpi_finalize(int rank);
XBT_PRIVATE char* smpi_container(int rank, char* container, int n);
/*
* Instrumentation functions to trace MSG processes (msg_process_t)
*/
-void TRACE_msg_process_change_host(msg_process_t process, msg_host_t old_host, msg_host_t new_host)
+void TRACE_msg_process_change_host(msg_process_t process, msg_host_t new_host)
{
if (TRACE_msg_process_is_enabled()){
static long long int counter = 0;
/* declaration of instrumentation functions from msg_process_instr.c */
XBT_PRIVATE char *instr_process_id (msg_process_t proc, char *str, int len);
XBT_PRIVATE char *instr_process_id_2 (const char *process_name, int process_pid, char *str, int len);
-XBT_PRIVATE void TRACE_msg_process_change_host(msg_process_t process, msg_host_t old_host, msg_host_t new_host);
+XBT_PRIVATE void TRACE_msg_process_change_host(msg_process_t process, msg_host_t new_host);
XBT_PRIVATE void TRACE_msg_process_create (const char *process_name, int process_pid, msg_host_t host);
XBT_PRIVATE void TRACE_msg_process_destroy (const char *process_name, int process_pid);
XBT_PRIVATE void TRACE_msg_process_kill(smx_process_exit_status_t status, msg_process_t process);
*/
msg_error_t MSG_process_migrate(msg_process_t process, msg_host_t host)
{
- TRACE_msg_process_change_host(process, MSG_process_get_host(process), host);
+ TRACE_msg_process_change_host(process, host);
process->migrate(host);
return MSG_OK;
}
if (status != MPI_STATUS_IGNORE) {
src_traced = comm->group()->index(status->MPI_SOURCE);
if (not TRACE_smpi_view_internals()) {
- TRACE_smpi_recv(rank, src_traced, rank, tag);
+ TRACE_smpi_recv(src_traced, rank, tag);
}
}
TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
retval = MPI_SUCCESS;
TRACE_smpi_ptp_out(rank, dst_traced, __FUNCTION__);
- TRACE_smpi_recv(rank, src_traced, rank, recvtag);
+ TRACE_smpi_recv(src_traced, rank, recvtag);
}
smpi_bench_begin();
src_traced = (status!=MPI_STATUS_IGNORE) ?
comm->group()->rank(status->MPI_SOURCE) :
src_traced;
- TRACE_smpi_recv(rank, src_traced, dst_traced, tag_traced);
+ TRACE_smpi_recv(src_traced, dst_traced, tag_traced);
}
}
src_traced = (status != MPI_STATUSES_IGNORE)
? savedvals[*index].comm->group()->rank(status->MPI_SOURCE)
: savedvals[*index].src;
- TRACE_smpi_recv(rank_traced, src_traced, dst_traced, savedvals[*index].tag);
+ TRACE_smpi_recv(src_traced, dst_traced, savedvals[*index].tag);
}
TRACE_smpi_ptp_out(rank_traced, dst_traced, __FUNCTION__);
}
if(src_traced==MPI_ANY_SOURCE)
src_traced = (status!=MPI_STATUSES_IGNORE) ?
savedvals[i].comm->group()->rank(status[i].MPI_SOURCE) : savedvals[i].src;
- TRACE_smpi_recv(rank_traced, src_traced, dst_traced,savedvals[i].tag);
+ TRACE_smpi_recv(src_traced, dst_traced,savedvals[i].tag);
}
}
}
new StartLinkEvent (SIMIX_get_clock(), PJ_container_get_root(), type, container, "PTP", key, size);
}
-void TRACE_smpi_recv(int rank, int src, int dst, int tag)
+void TRACE_smpi_recv(int src, int dst, int tag)
{
if (not TRACE_smpi_is_enabled())
return;
TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
if (not TRACE_smpi_view_internals()) {
- TRACE_smpi_recv(rank, src_traced, rank, 0);
+ TRACE_smpi_recv(src_traced, rank, 0);
}
log_timed_action (action, clock);
TRACE_smpi_ptp_out(rank, dst_traced, __FUNCTION__);
if (is_wait_for_receive)
- TRACE_smpi_recv(rank, src_traced, dst_traced, 0);
+ TRACE_smpi_recv(src_traced, dst_traced, 0);
log_timed_action (action, clock);
}
for (i=0; i<count_requests;i++){
if (recvs_snd[i]!=-100)
- TRACE_smpi_recv(rank_traced, recvs_snd[i], recvs_rcv[i],0);
+ TRACE_smpi_recv(recvs_snd[i], recvs_rcv[i],0);
}
TRACE_smpi_ptp_out(rank_traced, -1, __FUNCTION__);
}
if (TRACE_smpi_view_internals() && ((req->flags_ & RECV) != 0)){
int rank = smpi_process()->index();
int src_traced = (req->src_ == MPI_ANY_SOURCE ? req->real_src_ : req->src_);
- TRACE_smpi_recv(rank, src_traced, rank,req->tag_);
+ TRACE_smpi_recv(src_traced, rank,req->tag_);
}
if(req->detached_sender_ != nullptr){
//integrate pseudo-timing for buffering of small messages, do not bother to execute the simcall if 0