plazza.cpp

#include "plazza.h"
#include <stdio.h>
#include <errno.h>
#include <cstring> // strerror

Plazza::Plazza(int _multiplier, int _cooks, int _time)
{
  this->multiplier = _multiplier;
  this->cooks = _cooks;
  this->time = _time;
  this->num = 0;
  this->pid = getpid();
}

void	Plazza::assign_to_kitchen(std::string &pizza)
{
  std::list<Fifo>::iterator	itin;
  std::list<Fifo>::iterator	itout;
  std::string res;
  int	_pid;

  itin = this->fifosin.begin();
  itout = this->fifosout.begin();
  while (itin != this->fifosin.end())
    {
      *itout << pizza;
      *itin >> res;
      if (res.compare(0, 4, "succ") == 0)
	break ;
      itin++;
      itout++;
    }
  this->num = this->num + 1;
  if (getpid() == this->pid)
    { 
      Fifo  fifoin(this->num, 0);
      Fifo  fifoout(this->num, 1);
      this->fifosin.push_back(fifoin);
      this->fifosout.push_back(fifoout);
      if ((_pid = fork()) < 0)
	throw cerrExcept("fork fail");
      if(_pid == 0)
	{
	  Kitchen	kitchen(this->multiplier, this->cooks, this->time);
	  kitchen.work(fifoout, fifoin);
	}
      else
	{
	  fifoout << pizza;
	  fifoin >> res;
	  std::cout << res << "  res" << std::endl;
	}
    }
}

void	Plazza::reception()
{
  std::string	msg;
  Parse parse;

  if (this->pid = getpid())
    {
      while (1)
	{
	  std::cout << " > Enter the commands :" << std::endl;
	  getline(std::cin, msg);
	  if (msg.compare(0, 4, "quit") == 0)
	    return ;
    if (msg.compare(0, 4, "exit") == 0)
      return ;
	  parse.getinfo(msg);
	  while (parse.get_count())
	    {
	      assign_to_kitchen(parse.get_order_one_pizza());
	      parse.order_pop();
	    }
	}
    }
}

Plazza::~Plazza()
{
  std::string         error;
  std::ostringstream  fifo;
  std::string         dir("./fifos/");

  for (int i = 0; i != this->num; ++i)
  {
    fifo << dir << (i + 1) << "a";
    if (remove(fifo.str().c_str()) != 0)
    {
      error.append("cleanfifo: ").append(strerror(errno));
      throw cerrExcept(error);
    }
    fifo.str(""); // clean fifo stream
    fifo << dir << (i + 1) << "b";
    if (remove(fifo.str().c_str()) != 0)
    {
      error.append("cleanfifo: ").append(strerror(errno));
      throw cerrExcept(error);
    }    
  }
}