school/csci5451
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

working: rip why is it slower

Browse source
This commit is contained in:
Michael Zhang 2023-11-25 07:07:20 +00:00
parent d477611892
commit 0619d79caa
2 changed files with 26 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
assignments/03/Makefile
View file

@ -1,10 +1,10 @@
.PHONY: run clean .PHONY: run clean
CFLAGS += -g -pg # CFLAGS += -O3
# CFLAGS += -DFMT_HEADER_ONLY -O3 CFLAGS += -DFMT_HEADER_ONLY -g
# LDFLAGS += $(shell pkg-config --libs fmt) # LDFLAGS += $(shell pkg-config --libs fmt)
lpa: lpa.cpp Makefile test.gdb lpa: lpa.cpp Makefile
mpic++ $(CFLAGS) $(LDFLAGS) -o $@ lpa.cpp mpic++ $(CFLAGS) $(LDFLAGS) -o $@ lpa.cpp
lpac: lpa.cpp lpac: lpa.cpp

37
assignments/03/lpa.cpp
View file

@ -14,8 +14,10 @@
#include <unistd.h> #include <unistd.h>
#include <utility> #include <utility>
// #include <fmt/format.h> #ifdef FMT_HEADER_ONLY
// #include <fmt/ranges.h> #include <fmt/format.h>
#include <fmt/ranges.h>
#endif
#define TAG_SEND_NUM_EDGES 1001 #define TAG_SEND_NUM_EDGES 1001
#define TAG_SEND_EDGES 1002 #define TAG_SEND_EDGES 1002
@ -163,7 +165,7 @@ int main(int argc, char **argv) {
MPI_Barrier(MPI_COMM_WORLD); MPI_Barrier(MPI_COMM_WORLD);
double step_2_start_time; double step_2_start_time;
if (rank == 0) if (rank == 0)
step_2_start_time = MPI_Wtime(); step_2_start_time = MPI_Wtime();
// Each process analyzes the non-local edges that are contained in its portion // Each process analyzes the non-local edges that are contained in its portion
// of the graph. // of the graph.
@ -225,7 +227,7 @@ int main(int argc, char **argv) {
MPI_Barrier(MPI_COMM_WORLD); MPI_Barrier(MPI_COMM_WORLD);
double step_5_start_time; double step_5_start_time;
if (rank == 0) { if (rank == 0) {
step_5_start_time = MPI_Wtime(); step_5_start_time = MPI_Wtime();
printf("STARTING STEP 5: %0.04fs\n", step_5_start_time - step_2_start_time); printf("STARTING STEP 5: %0.04fs\n", step_5_start_time - step_2_start_time);
} }
@ -291,10 +293,6 @@ int main(int argc, char **argv) {
} }
} }
// std::cout << fmt::format("[{}] Helloge {}", rank,
// fmt::join(new_labels, ", "))
// << std::endl;
// Have there been any changes in the labels? // Have there been any changes in the labels?
int num_changes = new_labels.size(); int num_changes = new_labels.size();
int total_changes; int total_changes;
@ -319,7 +317,7 @@ int main(int argc, char **argv) {
MPI_Barrier(MPI_COMM_WORLD); MPI_Barrier(MPI_COMM_WORLD);
double end_time; double end_time;
if (rank == 0) if (rank == 0)
end_time = MPI_Wtime(); end_time = MPI_Wtime();
if (rank == 0) { if (rank == 0) {
printf("2-5 Time: %0.04fs\n", end_time - step_2_start_time); printf("2-5 Time: %0.04fs\n", end_time - step_2_start_time);
@ -353,11 +351,7 @@ int main(int argc, char **argv) {
std::cout << "Done! " << label_count.size() << std::endl; std::cout << "Done! " << label_count.size() << std::endl;
} else { } else {
std::vector<int> flat_assignments; MPI_Send(node_label_assignment_vec, num_my_nodes, MPI_INT, 0,
for (int i = 0; i < num_my_nodes; ++i) {
flat_assignments.push_back(node_label_assignment_vec[i]);
}
MPI_Send(flat_assignments.data(), flat_assignments.size(), MPI_INT, 0,
TAG_SEND_FINAL_RESULT, MPI_COMM_WORLD); TAG_SEND_FINAL_RESULT, MPI_COMM_WORLD);
} }
#pragma endregion #pragma endregion
@ -428,6 +422,21 @@ int lookup_assignment(int *base_node_assignment, pair my_node_range,
int index = -1, ctr = 0; int index = -1, ctr = 0;
std::vector<int> inner(recv_map[process_from].begin(), std::vector<int> inner(recv_map[process_from].begin(),
recv_map[process_from].end()); recv_map[process_from].end());
// {
// int lo = 0, hi = count;
// while (lo < hi) {
// int mid = (lo + hi) / 2;
// int midk = inner[mid];
// if (node_number < midk)
// hi = mid;
// else if (node_number > midk)
// lo = mid;
// else {
// index = mid;
// break;
// }
// }
// }
for (int i = 0; i < count; ++i) { for (int i = 0; i < count; ++i) {
int remote_node = inner[i]; int remote_node = inner[i];
if (node_number == remote_node) { if (node_number == remote_node) {