benji/lib94
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

move tabulator-mpi's parameters into separate file for easier changing

Browse source
This commit is contained in:
Benji Dial 2023-05-30 21:49:05 -04:00
parent 6b2cbe6c00
commit 1a0a068b87
3 changed files with 13 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
tabulator-mpi/constants.hpp Normal file
View file

@ -0,0 +1,3 @@
#define STEPS_TO_TIE 1000000
#define ROUNDS_PER_CHUNK 100
#define CHUNKS_PER_PAIR 10

9
tabulator-mpi/head.cpp
View file

@ -2,6 +2,8 @@
#include <cstdio> #include <cstdio>
#include <mpi.h> #include <mpi.h>
#include "constants.hpp"
static int **score_results; static int **score_results;
static int get_result() { static int get_result() {
@ -26,11 +28,12 @@ void head_main(int comm_size, int warrior_count, const lib94::warrior *const *wa
for (int i = 0; i < warrior_count; ++i) for (int i = 0; i < warrior_count; ++i)
for (int j = i + 1; j < warrior_count; ++j) { for (int j = i + 1; j < warrior_count; ++j) {
fprintf(stderr, "%s vs %s\n", warriors[i]->name.c_str(), warriors[j]->name.c_str()); fprintf(stderr, "%s vs %s\n", warriors[i]->name.c_str(), warriors[j]->name.c_str());
for (int x = 0; x < 10; ++x) { for (int x = 0; x < CHUNKS_PER_PAIR; ++x) {
int rank = get_result(); int rank = get_result();
int message[3] = {i, j, x * 100}; int message[3] = {i, j, x * ROUNDS_PER_CHUNK};
MPI_Send(message, 2, MPI_INT, rank, 0, MPI_COMM_WORLD); MPI_Send(message, 2, MPI_INT, rank, 0, MPI_COMM_WORLD);
fprintf(stderr, "sent rounds %d through %d to worker %d\n", x * 100 + 1, x * 100 + 100, rank); fprintf(stderr, "sent rounds %d through %d to worker %d\n",
x * ROUNDS_PER_CHUNK + 1, x * ROUNDS_PER_CHUNK + ROUNDS_PER_CHUNK, rank);
} }
fputc('\n', stderr); fputc('\n', stderr);
} }

6
tabulator-mpi/worker.cpp
View file

@ -1,6 +1,8 @@
#include <lib94/lib94.hpp> #include <lib94/lib94.hpp>
#include <mpi.h> #include <mpi.h>
#include "constants.hpp"
static int do_round(const lib94::warrior *w1, const lib94::warrior *w2) { static int do_round(const lib94::warrior *w1, const lib94::warrior *w2) {
const lib94::warrior *ws[2] = {w1, w2}; const lib94::warrior *ws[2] = {w1, w2};
@ -14,7 +16,7 @@ static int do_round(const lib94::warrior *w1, const lib94::warrior *w2) {
lib94::init_round(ws, 2); lib94::init_round(ws, 2);
for (int i = 0; i < 1000000; ++i) { for (int i = 0; i < STEPS_TO_TIE; ++i) {
const lib94::warrior *result = lib94::single_step<false>(); const lib94::warrior *result = lib94::single_step<false>();
if (result == w1) if (result == w1)
return -1; return -1;
@ -37,7 +39,7 @@ void worker_main(const lib94::warrior *const *warriors) {
buffer[2] = 0; buffer[2] = 0;
for (int i = 0; i < 100; ++i) for (int i = 0; i < ROUNDS_PER_CHUNK; ++i)
buffer[2] += do_round(warriors[buffer[0]], warriors[buffer[1]]); buffer[2] += do_round(warriors[buffer[0]], warriors[buffer[1]]);
} }
} }