работа с семафорами

@coach · Регистрация: 25.03.2009

Родительский процесс создаёт семафор (сем1) и общий файл. Дочерний процесс записывает в файл по одной строке всего 3 строки вида pid_процесса ppid текущее_время (мсек). Родительский процесс читает из файла строки и выводит их по одной ,Семафор использую для разрешения, кому из процессов получить доступ к файлу,но что-то получается какая-то ерунда

C

#include <stdio.h>
# include <fcntl.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <linux/ipc.h>
#include <linux/sem.h>
 
#define size 256
 
//char *file="semaf";
 
 
int main (int argc, char *argv [])
{
    FILE *f;    
    int i,j;
    pid_t pid;
    char buf1[size],buf2[size],str1[256],str2[256],str3[256],str[2]=" ";  
    struct timeval lt;
    size_t kol,s;
    int semid;
    char pathname[] = "sem1.txt";
    key_t key;
    struct sembuf mybuf1,mybuf2;
    union semun arg;
 
 
     key = ftok(pathname,0);
     semid = semget(key, 1, 0666 | IPC_CREAT); 
 
       
     arg.val=1;
     semctl (semid,0,SETVAL,arg);
 
    mybuf1.sem_op =-1;
    mybuf1.sem_flg = 0;
    mybuf1.sem_num = 0;
     
    mybuf2.sem_op = 1;
    mybuf2.sem_flg = 0;
    mybuf2.sem_num = 0;
 
 
    
      
    pid=fork ();
    if (pid==0)
    {
         if ((f = fopen (argv[1], "w" )) == NULL)
      {
    printf ("File open error.\n");
    exit (1);
      } 
     
     
        for (i=1;i<=3;i++)
        {
 
 
       
          if (semop(semid, &mybuf1, 1)==-1)
           {perror ("semop");}
  
 
 
 
 
 
  
 
          gettimeofday(&lt,NULL);
          gcvt(lt.tv_usec/1000,10,str3);
          gcvt(getpid (),10,str1);
          gcvt(getppid (),10,str2);
          strcat (str1,str);
          strcat (str1,str2);
          strcat (str1,str);  
          strcat (str1,str3);
             
          strcpy (buf2,str1);
         
          printf ("%s \n",buf2);
          fprintf(f, "%s\n", buf2);
          //fclose (f);
 
 
 
         
          semop(semid, &mybuf2, 1);
  
 
 
 
 
 
 
 
 
 
 
        }  
         fclose (f);
        exit (0); 
        
 
   }
  
       if ((f = fopen (argv[1], "r" )) == NULL)
      {
    printf ("File open error.\n");
    exit (1);
      } 
       
        for (j=1;j<=3;j++)
       
         { 
         
           
          if (semop(semid, &mybuf1, 1)==-1)
           {perror ("semop");}
  
 
  
 
           fscanf(f, "%s", buf1);
           printf("----%s %d\n", buf1);
 
 
 
 
 
 
 
          semop(semid, &mybuf2, 1);
  
 
 
         }
   semctl (semid,0,IPC_RMID);       
     //wait (NULL);
   fclose (f);
 wait (NULL);  
    return 0;
}

Evg · 18.05.2009, 17:45

А ерунда какого рода?
Просто я в деталях не знаком с тем, какая семафорная функция и с камими параметрами что делает. Но суть примерно должна быть такая:

Взводим семафор в состояние, например, 1.
fork'аемся

child (в цикле):
ждём, до тех пор пока состояние семафора не станет равным 1.
пишем строку в файл
устанавливаем семафор на состояние 2

parent (в цикле):
ждём, пока семафор не взведётся в состояние 2
читаем файл
взводим семафор в состояние 1

@AndruL · 10.06.2009, 18:25

C++

static struct sembuf sop_lock[2] = {
    0, 0, 0,    /ожидаем обнуления семафора/
    0, 1, 0,    /затем увеличить значение семафора на 1/
    };
 
 // ну а тут делать всё что нужно 
 
static struct sembuf sop_unlock[1] = {
    0, -1, 0,   /обнулить значение семафора/
    };

Evg 21265 / 8281 / 637 Регистрация: 30.03.2009 Сообщений: 22,638 Записей в блоге: 30
	18.05.2009, 17:45	2
	А ерунда какого рода? Просто я в деталях не знаком с тем, какая семафорная функция и с камими параметрами что делает. Но суть примерно должна быть такая: Взводим семафор в состояние, например, 1. fork'аемся child (в цикле): ждём, до тех пор пока состояние семафора не станет равным 1. пишем строку в файл устанавливаем семафор на состояние 2 parent (в цикле): ждём, пока семафор не взведётся в состояние 2 читаем файл взводим семафор в состояние 1 0

Опции темы