From 26cd2c9ae16be61499b8c28a46a31ce7d97a862e Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: Mon, 5 Dec 2022 15:39:03 -0500
Subject: [PATCH] Nedela

---
 dn5/Makefile   |  2 +-
 dn5/server.c   | 70 +++++++++++++++++++++++++++++++++++++
 dn5/server.c_b | 95 --------------------------------------------------
 3 files changed, 71 insertions(+), 96 deletions(-)
 create mode 100644 dn5/server.c
 delete mode 100644 dn5/server.c_b

diff --git a/dn5/Makefile b/dn5/Makefile
index b8db7d8..5d37328 100644
--- a/dn5/Makefile
+++ b/dn5/Makefile
@@ -15,4 +15,4 @@ push:
 
 run_remote:
 	 ssh nsc 'cd $(DESTINATION); make clean;module load OpenMPI/4.0.5-GCC-10.2.0; make server;'	
-	 ssh nsc 'srun --mpi=pmix --reservation=fri -n2 $(DESTINATION)/server'
+	 ssh nsc 'module load OpenMPI/4.0.5-GCC-10.2.0; mpirun  -N 2 $(DESTINATION)/server'
diff --git a/dn5/server.c b/dn5/server.c
new file mode 100644
index 0000000..74a3518
--- /dev/null
+++ b/dn5/server.c
@@ -0,0 +1,70 @@
+#include <stdlib.h>
+#include <stdio.h>
+#include <mpi.h>
+
+#define buffsize 650
+
+int main(int argc, char* argv[])
+{
+	int taskid, ntasks;
+	int *buff;
+	double inittime, totaltime;
+
+	MPI_Init(&argc, &argv);
+
+	MPI_Comm_rank(MPI_COMM_WORLD, &taskid);
+	MPI_Comm_size(MPI_COMM_WORLD, &ntasks);
+
+	buff = (int *)malloc(sizeof(int)*buffsize);
+	for (int i=0; i<buffsize; i++)
+		buff[i] = i;
+	MPI_Barrier(MPI_COMM_WORLD);
+	
+	printf("Task %d has started, ntasks = %d\n", taskid, ntasks);
+	fflush(stdout);
+	
+	inittime = MPI_Wtime();
+
+	if(taskid == 0) {
+		buff[0] = 0;
+		buff[1] = -1;
+		printf("Task %d has started sending message, ntasks = %d\n", taskid, ntasks);
+		fflush(stdout);
+		MPI_Send(buff, buffsize, MPI_INT, 1, 0, MPI_COMM_WORLD);
+	}
+
+	MPI_Recv(buff, buffsize, MPI_INT, taskid, 0, MPI_COMM_WORLD, NULL);
+	printf("Task %d has recieved the message, ntasks = %d\n", taskid, ntasks);
+	fflush(stdout);
+
+	if (taskid != 0) {
+		for (int j = 0; j < buffsize; j++) {
+			if(buff[j] == -1) {
+				buff[j] = taskid;
+				buff[j + 1] = -1;
+				break;
+			}
+		}
+
+		if (taskid != ntasks - 1) {
+			MPI_Send(buff, buffsize, MPI_INT, 0, 0, MPI_COMM_WORLD);
+		}
+		MPI_Send(buff, buffsize, MPI_INT, taskid + 1, 0, MPI_COMM_WORLD);
+	}
+
+	totaltime = MPI_Wtime() - inittime;
+	
+	if (taskid == 0) {
+		printf("Cas prenosa: %f s, buffsize: %ld\n", totaltime, sizeof(int)*buffsize);
+		for(int i = 0; i < buffsize; i++) {
+			if(buff[i] == -1) {
+				break;
+			}
+			printf("%d ", buff[i]);
+		}
+	}
+
+	free(buff);
+	MPI_Finalize();
+	return 0;
+}
diff --git a/dn5/server.c_b b/dn5/server.c_b
deleted file mode 100644
index 3106179..0000000
--- a/dn5/server.c_b
+++ /dev/null
@@ -1,95 +0,0 @@
-#include <stdlib.h>
-#include <stdio.h>
-#include <mpi.h>
-
-#define buffsize 650
-
-int main(int argc, char* argv[])
-{
-	int				taskid, ntasks;
-	int				i;
-	int				*buff;
-	double			inittime, totaltime;
-	MPI_Request		sendrequest, recvrequest;
-	int				done;
-
-	MPI_Init(&argc, &argv);
-
-	MPI_Comm_rank(MPI_COMM_WORLD, &taskid);
-	MPI_Comm_size(MPI_COMM_WORLD, &ntasks);
-
-
-	buff = (int *)malloc(sizeof(int)*buffsize);
-	for (i=0; i<buffsize; i++)
-		buff[i] = i;
-	MPI_Barrier(MPI_COMM_WORLD);
-	
-	printf("Task %d has started, ntasks = %d\n", taskid, ntasks);
-	fflush(stdout);
-	
-	inittime = MPI_Wtime();
-
-	int size;
-
-	if(taskid == 0) {
-		buff[0] = 0;
-		buff[1] = -1;
-		printf("Sending master\n");
-		MPI_Isend(buff, buffsize, MPI_INT, 1, 0, MPI_COMM_WORLD, &sendrequest);
-	}
-
-	for(int i = 1; i < ntasks; i++)
-	{
-		if(taskid == i)
-		{	
-			printf("Recieving %d\n", taskid);
-			fflush(stdout);
-			MPI_Irecv(buff, buffsize, MPI_INT, 0, 0, MPI_COMM_WORLD,&recvrequest);
-			MPI_Wait(&sendrequest, MPI_STATUS_IGNORE);
-			MPI_Wait(&recvrequest, MPI_STATUS_IGNORE);
-			printf("Recieved\n");
-			fflush(stdout);
-			for (int j = 0; j < buffsize; j++)
-			{
-				if(buff[j] == -1)
-				{
-					buff[j] = taskid;
-					buff[j + 1] = -1;
-					break;
-				}
-			}
-			printf("Sending\n");
-			fflush(stdout);
-			MPI_Send(buff, buffsize, MPI_INT, i+1, 0, MPI_COMM_WORLD);
-			printf("Sent\n");
-			fflush(stdout);
-		}
-	}
-	
-
-	if(taskid == 0) {
-		printf("Done rec");
-		fflush(stdout);
-		MPI_Recv(buff, buffsize, MPI_INT, ntasks, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE);
-		printf("Done rec1");
-		fflush(stdout);
-	}
-
-	totaltime = MPI_Wtime() - inittime;
-
-	if (taskid == 0) {
-		printf("Cas prenosa: %f s, buffsize: %ld\n", totaltime, sizeof(int)*buffsize);
-		for(int i = 0; i < buffsize; i++) {
-			if(buff[i] == -1) {
-				break;
-			}
-			printf("%d ", buff[i]);
-		}
-	}
-
-	free(buff);
-
-	MPI_Finalize();
-
-	return 0;
-}