Advertisement
Guest User

look

a guest
Sep 30th, 2014
205
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
C 1.00 KB | None | 0 0
  1. if(0 == rank){
  2.  
  3.         /* Show the number of processors */
  4.         printf("Number of processors is %d\n", size);
  5.         /* Ask size of message */
  6.         printf("Please give an input size in bytes: \n");
  7.         fflush(NULL);
  8.         /* Read the message size */
  9.         scanf("%d", &messageSize);
  10.  
  11.         if (messageSize > MAXSIZE) {
  12.             printf("Sorry, that's too much memory!\n\n");
  13.             messageSize = 0;
  14.         }
  15.  
  16.         printf("Message size is %d\n", messageSize);
  17.  
  18.         for(int i=1;i<size;i++){
  19.             err = MPI_Send(&messageSize,messageSize,MPI_INT,i,tag,MPI_COMM_WORLD);
  20.              if (err != MPI_SUCCESS) {
  21.                 printf("Process 0: Error in MPI_Send!\n");
  22.                 exit(1);
  23.             }
  24.         }
  25.     } else {
  26.         err = MPI_Recv(&messageSize, messageSize, MPI_INT, 0, tag, MPI_COMM_WORLD, &status);
  27.          if (err != MPI_SUCCESS) {
  28.             printf("Error in MPI_Recv!\n");
  29.             exit(1);
  30.         }          /* Receive a message from any sender */
  31.         source_id = status.MPI_SOURCE;
  32.         printf("Message received from %d size message",source_id,messageSize);
  33.     }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement