main_p.c

/* Archivo: main_p.c
 * Proceso maestro.
 * Autores: Victor De Ponte
 *          Isaac Lopez
 */
#include "main_p.h"

#ifndef STD
#define STD
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#define TRUE 1
#define FALSE 0
#define TAMAX 10
#endif

#ifndef ALM
#define ALM
#include "almacenamiento.h"
#endif

#ifndef COMMON
#define COMMON
#include "reinascommon.h"
#endif

#ifndef USEPROC
#define USEPROC
#include <unistd.h>
#endif

#ifndef USETIME
#define USETIME
#include <time.h>
#endif

#ifndef USO
#define USO "\nreinas_p: Resuelve el problema de las 8 reinas usando Procesos hijos.\n\nDesarrollado por:\n\tVictor De Ponte, Carnet 05-38087\n\tIsaac Lopez, Carnet 07-41120\n\nUSO:\n\n\tSintaxis:\n\n\t\treinas_p [-n <num_trabajadores>] [-i {1|0}]\n\n\tOpciones:\n\n\t\t-n\tNumero de hijos a resolver el problema. El valor por\n\t\t\tdefecto es 8.\n\t\t-i\tOpcion de impresión. Debe ir seguido de un 1 si se desea\n\t\t\tque cada hijo imprima su resultado, o 0 en caso contra-\n\t\t\trio. El valor por defecto es 0.\n\n"
#endif

/*INICIO Funciones y procedimientos referentes al manejo de respuestas*/

void lectura(Trie *answers, int nJobs) {
  int max = answers->maxChildren;
  char mensaje[60];
  FILE *answer;
  char *fileName = (char *) malloc(19 * sizeof(char));
  int tmp[max];
  double time = 0.0;
  int i;
  for (i = 1; i <= nJobs; i++) {
    sprintf(fileName,"./salidas/salida%d",i);
    answer = fopen(fileName,"r");
    if (errno) {
      sprintf(mensaje, "Problema abriendo la salida del proceso %d!!!:\n\tArchivo: %s\n", i, fileName);
      perror(mensaje);
      exit(1);
    }
    
    if (fscanf(answer, "%d %d %d %d %d %d %d %d %d", &tmp[0], &tmp[1], &tmp[2], &tmp[3], &tmp[4], &tmp[5], &tmp[6], &tmp[7], &time) == EOF) {
      sprintf(mensaje, "Problema leyendo la salida del proceso %d!\n", i);
      perror(mensaje);
      exit(1);
    }
    
    T_insert(answers,tmp,max,time);
  }
  free(fileName);
  fileName = NULL;
}

/*FIN Funciones y procedimientos referentes al manejo de respuestas*/
/*----------------------------------------------------------------------------*/

void main(int argc, char **argv){
  int nJobs = 8;
  int flagPrint = 0;
  int espera;
  
  procesarArgumentos(argc, argv, &nJobs, &flagPrint, USO);
  
  /* pid_t crea; */
  /* 	if((crea = fork()) == 0){ */
  /* 	execlp("/bin/mkdir", "mkdir", "./salidas", NULL); */
  /* 	} */
  /* wait(&espera); */

  pid_t trabajadores[nJobs];
  int h;
  for (h = 0; h < nJobs; h++){
    if ((trabajadores[h]=fork())==0){
      char* argumento1 = malloc(sizeof(char*));
      sprintf(argumento1, "%d",h%8);
      char* argumento2 = malloc(sizeof(char*));
      sprintf(argumento2, "%d",h/8);
      char* argumento3 = malloc(sizeof(char*));
      sprintf(argumento3, "%d",flagPrint);
      execl("./reinas", "./reinas", argumento1, argumento2, argumento3, NULL);
    }
  }
	
  for (h = 0; h < nJobs; h++){
    wait(&espera);
  }
  
  Trie *respuestas = newTrie(8);
  lectura(respuestas, nJobs);
  traversal(respuestas);
  t_free(respuestas);
  respuestas = NULL;
  /* execl("/bin/rm", "/bin/rm", "-r", "./salidas/", (char *) NULL); */
	
}