Skip to content
Snippets Groups Projects
Commit f51a8439 authored by Peter W. Draper's avatar Peter W. Draper
Browse files

Merge branch 'scaled-size' of gitlab:swift/swiftmpistepsim into scaled-size

parents aaf2412a fecc69fb
No related branches found
No related tags found
1 merge request!7Add a scale factor for messages
......@@ -130,6 +130,7 @@ static void *inject_thread(void *arg) {
/* Differences to SWIFT: MPI_BYTE not the MPI_Type. */
int err = 0;
if (log->type == task_type_send) {
log->data = calloc(log->size, 1);
err = MPI_Isend(log->data, log->size, MPI_BYTE, log->otherrank, log->tag,
subtypeMPI_comms[log->subtype], &log->req);
......@@ -139,6 +140,7 @@ static void *inject_thread(void *arg) {
atomic_inc(&todo_send);
} else {
log->data = calloc(log->size, 1);
err = MPI_Irecv(log->data, log->size, MPI_BYTE, log->otherrank, log->tag,
subtypeMPI_comms[log->subtype], &log->req);
......@@ -328,7 +330,7 @@ static void pick_logs(void) {
nlogs, sizeof(struct mpiuse_log_entry *));
nr_reqs = 0;
sends_queue = (struct mpiuse_log_entry **)calloc(
nlogs, sizeof(struct mpiuse_log_entry *) * nlogs);
nlogs, sizeof(struct mpiuse_log_entry *));
nr_sends = 0;
recvs_queue = (struct mpiuse_log_entry **)calloc(
nlogs, sizeof(struct mpiuse_log_entry *));
......@@ -346,6 +348,7 @@ static void pick_logs(void) {
log->data = calloc(log->size, 1);
/* And keep this log. */
log->data = NULL;
reqs_queue[nr_reqs] = log;
nr_reqs++;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment