Still debugging, not yet done

bucket_sort.c

@@ -14,27 +14,42 @@ int main(int argc, char** argv){
 		int i;
 		int n;
 		srand(time(NULL));
-		n = rand() % 10 + 1;
+		//n = rand() % 10 + 1;
+		n=1;
 		printf("%d number of elements\n", n);
-		int input[n], result[n];
+		int input[n];
 		
 		int c;
 		for (c = 0; c < n; c++) {
 			input[c] = abs(rand() % 100);
+			printf("%d. %d\n", c, input[c]);
 		}
 		
-		int* bucketsNEff = malloc (sizeof(int) * numtasks);
+		int min = input[0];
+		int max = input[0];
+		for (c = 0; c < n; c++) {
+			if(input[c] < min) {
+				min = input[i];
+			}
+			if(input[c] > max) {
+				max = input[i];
+			}
+		}
+		
+		int bucketsNEff[numtasks];
 		
 		int j;
-		for(j=0; j<numtasks; j++){
+		for(j=1; j<numtasks; j++){
 			bucketsNEff[j] = 0;
 		}
 		
 		for(i=0; i<n; i++){
-			int inc = 100/(numtasks-1);
+			int inc = max/(numtasks-1);
+			printf("Inc: %d\n", inc);
 			int iteration = 1;
-			int k, p = 0;
-			for(k=inc; k<100; k+=inc){
+			int k;
+			int p = 0; //false
+			for(k=inc; k<=max; k+=inc){
 				if(input[i] <= k){
 					bucketsNEff[iteration]++;
 					p = 1;
@@ -42,20 +57,23 @@ int main(int argc, char** argv){
 				}
 				iteration++;
 			}
-			if(!p){
+			if(!p){ 
 				bucketsNEff[iteration-1]++;
 			}
 		}
 		
 		for(i=0; i<numtasks; i++){
+			printf("Bucket-%d: %d\n", i, bucketsNEff[i]);
 			MPI_Send(&input[i], 1, MPI_INT, i, 1, MPI_COMM_WORLD); 
 		}
 		
+		printf("After send\n");
+		
 		for(i=0; i<n; i++){
-			int inc = 100/(numtasks-1);
+			int inc = max/(numtasks-1);
 			int iteration = 1;
 			int k, p = 0;
-			for(k=inc; k<100; k+=inc){
+			for(k=inc; k<=max; k+=inc){
 				if(input[i] <= k){
 					MPI_Send(&input[i], 1, MPI_INT, iteration, 2, MPI_COMM_WORLD); 
 					p = 1;
@@ -68,11 +86,14 @@ int main(int argc, char** argv){
 			}
 		}
 		
+		printf("After send 2\n");
+		
+		
 		int lastIndex = 0;
 		int indexi = 0;
-		printf("A\n");
-		
+		printf("A");
 		for(i=1; i<numtasks; i++){
+			printf("Terima\n");
 			int receiver[bucketsNEff[i]];
 			MPI_Recv(&receiver[0], bucketsNEff[i], MPI_INT, i, 3, MPI_COMM_WORLD, &stat);
 			if(lastIndex = 0){
@@ -84,6 +105,9 @@ int main(int argc, char** argv){
 				indexi++;
 			}
 		}
+		for(i=0; i<n; i++){
+			printf("%d ", input[i]);
+		}
 		printf("A\n");
 		
 	} else {
@@ -113,8 +137,6 @@ int main(int argc, char** argv){
 		MPI_Send(arr, bucketNEff, MPI_INT, 0, 3, MPI_COMM_WORLD);
 	}
 
-	
-
 	MPI_Finalize();
 		
 	return 0;