summaryrefslogtreecommitdiff
path: root/tabulator-mpi/source.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tabulator-mpi/source.cpp')
-rw-r--r--tabulator-mpi/source.cpp214
1 files changed, 0 insertions, 214 deletions
diff --git a/tabulator-mpi/source.cpp b/tabulator-mpi/source.cpp
deleted file mode 100644
index f7fe54f..0000000
--- a/tabulator-mpi/source.cpp
+++ /dev/null
@@ -1,214 +0,0 @@
-#include <lib94/lib94.hpp>
-#include <iostream>
-#include <fstream>
-#include <sstream>
-#include <cstdio>
-#include <vector>
-#include <mpi.h>
-
-const int default_rounds_per_chunk = 250;
-const int steps_to_tie = 1000000;
-
-int error(std::string msg, int rank) {
- if (rank == 0) {
- std::cerr << msg << std::endl;
- return 1;
- }
- return 0;
-}
-
-int main(int argc, char **argv) {
-
- MPI_Init(&argc, &argv);
-
- int rank;
- int size;
-
- MPI_Comm_rank(MPI_COMM_WORLD, &rank);
- MPI_Comm_size(MPI_COMM_WORLD, &size);
-
- if (size < 2)
- return error("this must be run under mpi with at least two processes.", rank);
-
- std::vector<std::string> filenames = {};
- int rounds_per_chunk = default_rounds_per_chunk;
-
- for (int i = 1; i < argc; ++i) {
- if (atoi(argv[i]) > 0)
- rounds_per_chunk = atoi(argv[i]);
- else
- filenames.push_back(argv[i]);
- }
-
- if (filenames.size() == 0)
- return error("no files specified.", rank);
- if (filenames.size() == 1)
- return error("only one file specified.", rank);
-
- int count = filenames.size();
- lib94::warrior **warriors = new lib94::warrior *[count];
- for (int i = 0; i < count; ++i) {
- std::ifstream file(filenames[i]);
- if (!file)
- return error("could not open " + filenames[i] + ".", rank);
- std::stringstream stream;
- stream << file.rdbuf();
- try {
- warriors[i] = lib94::compile_warrior(stream.str());
- }
- catch (const lib94::compiler_exception &ex) {
- return error("could not compile " + filenames[i] + ": " + ex.message + " on line " + std::to_string(ex.source_line_number) + ".", rank);
- }
- }
-
- //w1 * count + w2
- int *placements = new int[count * count];
- for (int i = 0; i < count; ++i)
- for (int j = 0; j < count; ++j) {
- int p = LIB94_CORE_SIZE - warriors[i]->instructions.size() - warriors[j]->instructions.size() + 1;
- if (p <= 0)
- return error(filenames[i] + " and " + filenames[j] + " do not fit in core together.", rank);
- placements[i * count + j] = p;
- }
-
- if (rank == 0) {
-
- std::cerr << "\x1b""7\x1b[?47h\x1b[2J" << std::flush;
-
- //w1 * count + w2
- int *wins_array = new int[count * count];
- for (int i = 0; i < count * count; ++i)
- wins_array[i] = 0;
-
- for (int i = 0; i < count; ++i)
- for (int j = 0; j < count; ++j) {
- if (i == j)
- continue;
- int rounds = placements[i * count + j];
- for (int r = 0; r < rounds; r += rounds_per_chunk) {
- int e = std::min(r + rounds_per_chunk, rounds);
-
- MPI_Status status;
- int buffer[4];
- MPI_Recv(buffer, 4, MPI_INT, MPI_ANY_SOURCE, 1, MPI_COMM_WORLD, &status);
- int source = status.MPI_SOURCE;
-
- wins_array[buffer[0] * count + buffer[1]] += buffer[2];
- wins_array[buffer[1] * count + buffer[0]] += buffer[3];
-
- buffer[0] = i;
- buffer[1] = j;
- buffer[2] = r;
- buffer[3] = e;
- MPI_Send(buffer, 4, MPI_INT, source, 0, MPI_COMM_WORLD);
-
- std::cerr << "\x1b[" << source << ";1Hworker " << source << ": " << warriors[i]->name << " vs " << warriors[j]->name << " rounds " << r + 1 << " to " << e << " of " << rounds << ".\x1b[0K" << std::flush;
- }
- }
-
- for (int i = 1; i < size; ++i) {
- MPI_Status status;
- int buffer[4];
- MPI_Recv(buffer, 4, MPI_INT, MPI_ANY_SOURCE, 1, MPI_COMM_WORLD, &status);
- int source = status.MPI_SOURCE;
-
- wins_array[buffer[0] * count + buffer[1]] += buffer[2];
- wins_array[buffer[1] * count + buffer[0]] += buffer[3];
-
- buffer[3] = 0;
- MPI_Send(buffer, 4, MPI_INT, source, 0, MPI_COMM_WORLD);
- std::cerr << "\x1b[" << source << ";1Hworker " << source << ": complete.\x1b[0K" << std::flush;
- }
-
- std::cerr << "\x1b[?47l\x1b""8";
-
- int col_width = 13;
- for (int i = 0; i < count; ++i)
- if ((int)warriors[i]->name.size() > col_width)
- col_width = (int)warriors[i]->name.size();
-
- printf(" %*s", col_width, "");
- for (int i = 0; i < count; ++i)
- printf(" | %*s", col_width, warriors[i]->name.c_str());
- putchar('\n');
- for (int k = 0; k < col_width + 2; ++k)
- putchar('-');
- for (int i = 0; i < count; ++i) {
- putchar('+');
- for (int k = 0; k < col_width + 2; ++k)
- putchar('-');
- }
- putchar('\n');
- for (int j = 0; j < count; ++j) {
- printf(" %*s", col_width, warriors[j]->name.c_str());
- for (int i = 0; i < count; ++i)
- if (i == j)
- printf(" | %*s", col_width, "");
- else
- printf(" | %5d / %5d%*s", wins_array[i * count + j], placements[i * count + j] * 2, col_width - 13, "");
- putchar('\n');
- }
-
- }
-
- else {
-
- lib94::instruction core_background = {
- .op = lib94::DAT,
- .mod = lib94::F,
- .amode = lib94::DIRECT,
- .bmode = lib94::DIRECT,
- .anumber = 0,
- .bnumber = 0
- };
-
- int buffer[4] = { 0, 0, 0, 0 };
- MPI_Send(buffer, 4, MPI_INT, 0, 1, MPI_COMM_WORLD);
-
- while (true) {
-
- MPI_Recv(buffer, 4, MPI_INT, 0, 0, MPI_COMM_WORLD, 0);
- if (buffer[3] == 0)
- break;
-
- auto w1 = warriors[buffer[0]];
- auto w2 = warriors[buffer[1]];
- int start_offset = w1->instructions.size();
- int w1_wins = 0;
- int w2_wins = 0;
-
- const lib94::warrior *const wlist[2] = { w1, w2 };
- int offsets[2] = {};
-
- for (int round = buffer[2]; round < buffer[3]; ++round) {
-
- offsets[1] = start_offset + round;
- lib94::clear_core(core_background);
- lib94::init_round(wlist, 2, offsets, false);
-
- for (int step = 0; step < steps_to_tie; ++step) {
- auto lost = lib94::single_step<false>();
- if (lost == w1) {
- ++w2_wins;
- break;
- }
- if (lost == w2) {
- ++w1_wins;
- break;
- }
- }
-
- }
-
- buffer[2] = w1_wins;
- buffer[3] = w2_wins;
- MPI_Send(buffer, 4, MPI_INT, 0, 1, MPI_COMM_WORLD);
-
- }
-
- }
-
- MPI_Finalize();
- return 0;
-
-}
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-21 21:30:39 +0000