#include <stdio.h>
#include <malloc.h>
#include <mpi.h>
#define QUOTA 10; // Build 10 Cars/Run 
#define COMPONENTS 7; // 7 parts to build each car

int main(int argc, char **argv)
{
 int myid,numprocs;
 int i,c;
 int build = 10;
 int components = 7;
 char car[7][32];
 char colors[5][6] = {"Red", "Green", "Blue", "Black", "White"};
 char color[8];
 // message tags
 int chassis     = 0;
 int drive_train = 1;
 int wheels      = 2;
 int engine      = 3;
 int seats       = 4;
 int body        = 5;
 int paint       = 6;
 MPI_Status status;

 MPI_Init(&argc, &argv);
 MPI_Comm_size(MPI_COMM_WORLD,&numprocs);
 MPI_Comm_rank(MPI_COMM_WORLD,&myid); 
 
 if (numprocs == 8)
  {
   if (myid == 0)
    {
     for (i=0; i<build; i++)
      {
       sprintf(car[myid],"Chassis %d",i);
       //printf("Chassis created for car %d\n",i+1);
       MPI_Send(car,7*32,MPI_CHAR,1,chassis,MPI_COMM_WORLD);
      }
    }
   else
    {
     for (i=0; i<build; i++)
      {
       switch (myid)
        {
         case 1: MPI_Recv(car,7*32,MPI_CHAR,0,chassis,MPI_COMM_WORLD,&status);
                 sprintf(car[myid],"Drive Train %d",i);
                 //printf("drive train added to car %d\n",i+1);
                 MPI_Send(car,7*32,MPI_CHAR,2,drive_train,MPI_COMM_WORLD); 
                 break;
         case 2: MPI_Recv(car,7*32,MPI_CHAR,1,drive_train,MPI_COMM_WORLD,&status);
                 sprintf(car[myid],"Wheels %d",i);
                 //printf("wheels added to car %d\n",i+1); 
                 MPI_Send(car,7*32,MPI_CHAR,3,wheels,MPI_COMM_WORLD);
                 break;
         case 3: MPI_Recv(car,7*32,MPI_CHAR,2,wheels,MPI_COMM_WORLD,&status);
                 sprintf(car[myid],"Engine %d",i);
                 //printf("engine added to car %d\n",i+1); 
                 MPI_Send(car,7*32,MPI_CHAR,4,engine,MPI_COMM_WORLD);
                 break;
         case 4: MPI_Recv(car,7*32,MPI_CHAR,3,engine,MPI_COMM_WORLD,&status);
                 sprintf(car[myid],"Seats %d",i);
                 //printf("seats added to car %d\n",i+1); 
                 MPI_Send(car,7*32,MPI_CHAR,5,seats,MPI_COMM_WORLD);
                 break;
         case 5: MPI_Recv(car,7*32,MPI_CHAR,4,seats,MPI_COMM_WORLD,&status);
                 sprintf(car[myid],"Body %d",i);
                 //printf("body added to car %d\n",i+1); 
                 MPI_Send(car,7*32,MPI_CHAR,6,body,MPI_COMM_WORLD);
                 break;
         case 6: MPI_Recv(car,7*32,MPI_CHAR,5,body,MPI_COMM_WORLD,&status);
                 sprintf(color,"%s",colors[i % 5]);
                 sprintf(car[myid],"%s Paint %d",color,i);
                 //printf("%s paint added to car %d\n",color,i+1); 
                 MPI_Send(car,7*32,MPI_CHAR,7,paint,MPI_COMM_WORLD);
                 break;
         case 7: MPI_Recv(car,7*32,MPI_CHAR,6,paint,MPI_COMM_WORLD,&status);
                 for (c=0; c<7; c++) { printf("Car %d> %s\n",i,car[c]); }  
                 break;
        }
      }
    }
  }
 else
  {
   if (myid == 0) printf("This assembly line needs 8 workers\n");
  }
 MPI_Finalize();
 return 0;
}