Administrace komentářů

#define jmeno 1234
#define SEM_NAMEa "/mysema"
typedef struct counter
{
  int count; 
} COUNTER;

int processedEvent(sem_t *semId, FILE* soubor, int shmid, COUNTER *sharedStuff);
int main()
{ 
  pid_t pid;
  pid_t children[3];
  sem_t *semIdA;
  
  int retCode = 0;
  int shmid = 0;
  int i = 0;
  int stepsNumber = 0;
  void *sharedMemory = (void *) 0;
  struct counter *sharedStuff;

  // Zpracovani parametru programu;
  stepsNumber = 3;
  if (stepsNumber == -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  } 
  // Prace se souborem
  FILE *fw;
  fw = fopen("out.txt", "w");
  if (fw == NULL)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  // Vytvoreni sdilene pameti;
  shmid = shmget((key_t)jmeno, 3 *sizeof(int), 0666 | IPC_CREAT);
  if (shmid == -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  // Zpristupneni sdilene pameti programu;
  sharedMemory = shmat(shmid, (void *) 0, 0);
  if (sharedMemory == (void *) -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  
  sharedStuff = (struct counter *) sharedMemory;
  sharedStuff->count=0;
  printf("Pocet: %d\n", sharedStuff->count);
  
  // Odpojeni sdilene pameti;
  retCode = shmdt(sharedMemory);
  if (retCode == -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  // Vytvoreni semaforu;
  semIdA = sem_open(SEM_NAMEa, O_CREAT, 0666, 0);
  if (semIdA == SEM_FAILED)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  // Vytvoreni podprocesu;
  for (; i<3; i++)
  {
    pid = fork();
    switch (pid)
    {
      case -1:
	// Uvolneni prostredku;
	fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
	break;
      case 0:
	while (stepsNumber != 0)
	{
	  processedEvent(semIdA, fw, shmid, sharedStuff);
	  stepsNumber--;
	}
	// Uzavreni souboru
	retCode = fclose(fw);
	if (retCode == EOF)
	{
	  fprintf(stderr, "Failed...\n");
	  exit(EXIT_FAILURE);
	}
	exit(EXIT_SUCCESS);
	break;
      default:
	children[i] = pid;
	break;
    }
  } 
  // Ukonceni potomknu;
  for (i = 0; i<3; i++)
  {
    retCode = waitpid(children[i], NULL, 0);
    if (retCode < 0)
    {
      retCode = kill(children[i], SIGTERM);
      if (retCode == -1)
      {
	fprintf(stderr, "Failed...\n");
	exit(EXIT_FAILURE);
      }
    }
  }
  // Zavreni semaforu;
  retCode = sem_close(semIdA);
  if (retCode == -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  // Uvolneni porstredku semaforu;
  retCode = sem_unlink(SEM_NAMEa);
  if (retCode == -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  // Zpristupneni sdilene pameti programu;
  sharedMemory = shmat(shmid, (void *) 0, 0);
  if (sharedMemory == (void *) -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  
  printf("Pocet: %d\n", sharedStuff->count);
  
  // Odpojeni sdilene pameti;
  retCode = shmdt(sharedMemory);
  if (retCode == -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  }
  // Smazani sdilene pameti;
  retCode = shmctl(shmid, IPC_RMID, 0);
  if (retCode == -1)
  {
    fprintf(stderr, "Failed...\n");
    exit(EXIT_FAILURE);
  } 
  
  exit(EXIT_SUCCESS);
}

int processedEvent(sem_t *semId, FILE* soubor, int shmid, COUNTER *sharedStuff)
{
  int retCode = 0;
  void *sharedMemory = (void *) 0;
  // Zpristupneni sdilene pameti programu
  sharedMemory = shmat(shmid, (void *) 0, 0);
  if (sharedMemory == (void *) -1)
  {
    return -1;
  }
  // Zablokovani semaforu
  retCode = sem_wait(semId);
  if (retCode == -1)
  {
    return -1;
  }
  //*****KS*****
  sharedStuff = (struct counter *) sharedMemory;
  sharedStuff->count ++;
  fprintf(soubor, "%d\n", sharedStuff->count);
  //*****KS*****
  // Odblokovani semaforu
  retCode = sem_post(semId);
  if (retCode == -1)
  {
    return -1;
  }
  // Zavreni semaforu
  retCode = sem_close(semId);
  if (retCode == -1)
  {
    return -1;
  }
  // Odpojeni sdilene pameti
  retCode = shmdt(sharedMemory);
  if (retCode == -1)
  {
    return -1;
  }
  return 0;
}