Работа с разделяемой памятью

#include <stdio.h>
#include <unistd.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <semaphore.h>
 
// int proc_no = 1;
 
int N, k1, k2, t;
 
int main()
{
  pid_t pid;
  sem_t *sem_rd, *sem_wr;
  int shmid, *data;
 
  N = 128;
  k1 = 30;
  k2 = 50;
  t = 10;
 
  shmid = shmget( IPC_PRIVATE, N * sizeof(int), IPC_CREAT | S_IRUSR | S_IWUSR );
  if( shmid < 0 )
  {
    perror("shmget");
    return 1;
  }
 
  sem_wr = sem_open( "mysem_wr", O_CREAT, 0644, 0 );
  sem_unlink( "mysem_wr" );
 
  sem_rd = sem_open( "mysem_rd", O_CREAT, 0644, 0 );
  sem_unlink( "mysem_rd" );
 
  pid = fork();
  if( pid < 0 )
  {
    perror( "fork" );
    return 1;
  }
  else if( pid )        // main process
  {
    int numbers_in_mem = 0, wr_ptr = 0, number = 0;
 
    data = (int*)shmat( shmid, 0, 0 );
    if( (int*)-1 == data )
    {
      perror("p1.shmat");
      return 1;
    }
 
    for(;;)
    {
      if( N - numbers_in_mem > k1 )
      {
        int i;
 
        printf( "p1: free space %d, writing %d numbers...", N - numbers_in_mem, k1 );
 
        for( i = 0; i < k1; i++ )
        {
          data[wr_ptr++] = number++;
          if( wr_ptr >= N )     wr_ptr = 0;
        }
        numbers_in_mem += k1;
        sem_post( sem_wr );
 
        printf( "done\np1: sleep %d sec\n", t );
        sleep(t);
      }
      else
      {
        printf( "p1: free space %d, waiting space for %d numbers...", N - numbers_in_mem, k1 );
        sem_wait( sem_rd );
        numbers_in_mem -= k2;
        printf( "done\n" );
      }
    }
  }
  else                  // child process
  {
    int numbers_in_mem = 0, rd_ptr = 0;
 
    data = (int*)shmat( shmid, 0, 0 );
    if( (int*)-1 == data )
    {
      perror("p2.shmat");
      return 1;
    }
 
    for(;;)
    {
      if( numbers_in_mem >= k2 )
      {
        int i;
 
        printf( "p2: numbers in memory %d, reading %d numbers:\n", numbers_in_mem, k2 );
 
        for( i = 0; i < k2; i++ )
        {
          printf( "%d ", data[rd_ptr++] );
          if( rd_ptr >= N )     rd_ptr = 0;
        }
        numbers_in_mem -= k2;
        sem_post( sem_rd );
 
        printf( "\np2: sleep %d sec\n", t );
        sleep(t);
      }
      else
      {
        printf( "p2: numbers in memory %d, waiting for %d numbers.\n", numbers_in_mem, k2 );
        sem_wait( sem_wr );
        numbers_in_mem += k1;
      }
    }
  }
 
  return 0;
}

for(;;)