diff options
author | Benji Dial <benji@benjidial.net> | 2024-06-07 11:27:40 -0400 |
---|---|---|
committer | Benji Dial <benji@benjidial.net> | 2024-06-07 11:27:40 -0400 |
commit | 84bfb2d3617e981605267bdd8b114ed3bba3a500 (patch) | |
tree | 7aa32228860b8c0368e7fba983b313679795bbfa /tabulator-mpi/source.cpp | |
parent | 9778e5c1298c8888214725f968badcbab516ea82 (diff) | |
download | lib94-84bfb2d3617e981605267bdd8b114ed3bba3a500.tar.gz |
new tabulator, remove evolver
Diffstat (limited to 'tabulator-mpi/source.cpp')
-rw-r--r-- | tabulator-mpi/source.cpp | 214 |
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; - -} |