#include <iostream> #include "message.h" #include "teatr.h" void send(int counts[5], long long arguments, int target) { for (size_t i = 0; i < 5; ++i) { PutInt(target, counts[i]); } PutLL(target, arguments); Send(target); } long long merge(int counts[5]) { int target = Receive(-1); int remote_counts[5]; for (size_t i = 0; i < 5; ++i) { remote_counts[i] = GetInt(target); } long long arguments = GetLL(target); for (size_t i = 0; i < 4; ++i) { for (size_t j = i + 1; j < 5; ++j) { arguments += counts[i] * remote_counts[j]; } } for (size_t i = 0; i < 5; ++i) { counts[i] += remote_counts[i]; } return arguments; } int main() { int id = MyNodeId(); int numb = NumberOfNodes(); int N = GetN(); int start = N * id / numb; int end = N * (id + 1) / numb; int counts[5] = {}; long long arguments = {}; for (int i = start; i < end; ++i) { int E = GetElement(i); if (E > 5) { return 123; } counts[E - 1]++; for (int j = E; j < 5; ++j) { arguments += counts[j]; } } std::cerr << counts[0] << ":" << counts[1] << ":" << counts[2] << ":" << counts[3] << ":" << counts[4] << ":" << arguments << "\n"; int mult = 1; while (mult * 2 < numb) { if ((id / mult) % 2 == 1) { arguments += merge(counts); } else if (id + mult < numb) { send(counts, arguments, id + mult); return 0; } mult *= 2; } if (id != numb - 1) { send(counts, arguments, numb - 1); } else { arguments += merge(counts); std::cout << arguments << "\n"; } }
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 | #include <iostream> #include "message.h" #include "teatr.h" void send(int counts[5], long long arguments, int target) { for (size_t i = 0; i < 5; ++i) { PutInt(target, counts[i]); } PutLL(target, arguments); Send(target); } long long merge(int counts[5]) { int target = Receive(-1); int remote_counts[5]; for (size_t i = 0; i < 5; ++i) { remote_counts[i] = GetInt(target); } long long arguments = GetLL(target); for (size_t i = 0; i < 4; ++i) { for (size_t j = i + 1; j < 5; ++j) { arguments += counts[i] * remote_counts[j]; } } for (size_t i = 0; i < 5; ++i) { counts[i] += remote_counts[i]; } return arguments; } int main() { int id = MyNodeId(); int numb = NumberOfNodes(); int N = GetN(); int start = N * id / numb; int end = N * (id + 1) / numb; int counts[5] = {}; long long arguments = {}; for (int i = start; i < end; ++i) { int E = GetElement(i); if (E > 5) { return 123; } counts[E - 1]++; for (int j = E; j < 5; ++j) { arguments += counts[j]; } } std::cerr << counts[0] << ":" << counts[1] << ":" << counts[2] << ":" << counts[3] << ":" << counts[4] << ":" << arguments << "\n"; int mult = 1; while (mult * 2 < numb) { if ((id / mult) % 2 == 1) { arguments += merge(counts); } else if (id + mult < numb) { send(counts, arguments, id + mult); return 0; } mult *= 2; } if (id != numb - 1) { send(counts, arguments, numb - 1); } else { arguments += merge(counts); std::cout << arguments << "\n"; } } |