fork download

#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>
#define RAND_DIVISOR
100000000
#define TRUE 1
/* The mutex lock */
pthread_mutex_t mutex;
/* the semaphores */
sem_t full, empty;
/* the buffer */
buffer_item buffer[BUFFER
_SIZE];
/* buffer counter */
int counter;
pthread_t tid;       //
Thread ID
pthread_attr_t attr; //
Set of thread attributes
void *producer(void *
param); /* the producer
thread */
void *consumer(void *
param); /* the consumer
thread */
void initializeData() {
   /* Create the mutex
lock */
   pthread_mutex_init(&
mutex, NULL);
   /* Create the full
semaphore and initialize
to 0 */
   sem_init(&full, 0, 0
);
   /* Create the empty
semaphore and initialize
to BUFFER_SIZE */
   sem_init(&empty, 0,
BUFFER_SIZE);
   /* Get the default
attributes */
   pthread_attr_init(&
attr);
   /* init buffer */
   counter = 0;
}
/* Producer Thread */
void *producer(void *
param) {
   buffer_item item;
   while(TRUE) {
      /* sleep for a
random period of time */
      int rNum = rand() /
 RAND_DIVISOR;
      sleep(rNum);
      /* generate a
random number */
      item = rand();
      /* acquire the
empty lock */
      sem_wait(&empty);
      /* acquire the
mutex lock */
      pthread_mutex_lock
(&mutex);
      if(insert_item(item
)) {
         fprintf(stderr,
" Producer report error
condition\n");
      }
      else {
         printf("producer
 produced %d\n", item);
      }
      /* release the
mutex lock */
      pthread_mutex_
unlock(&mutex);
      /* signal full */
      sem_post(&full);
   }
}
/* Consumer Thread */
void *consumer(void *
param) {
   buffer_item item;
   while(TRUE) {
      /* sleep for a
random period of time */
      int rNum = rand() /
 RAND_DIVISOR;
      sleep(rNum);
      /* aquire the full
lock */
      sem_wait(&full);
      /* aquire the mutex
 lock */
      pthread_mutex_lock
(&mutex);
      if(remove_item(&
item)) {
         fprintf(stderr,
"Consumer report error
condition\n");
      }
      else {
         printf("consumer
 consumed %d\n", item);
      }
      /* release the
mutex lock */
      pthread_mutex_
unlock(&mutex);
      /* signal empty */
      sem_post(&empty);
   }
}
/* Add an item to the
buffer */
int insert_item(buffer_
item item) {
   /* When the buffer is
 not full add the item
      and increment the
counter*/
   if(counter < BUFFER_
SIZE) {
      buffer[counter] =
item;
      counter++;
      return 0;
   }
   else { /* Error the
buffer is full */
      return -1;
   }
}
/* Remove an item from
the buffer */
int remove_item(buffer_
item *item) {
   /* When the buffer is
 not empty remove the
item
      and decrement the
counter */
   if(counter > 0) {
      *item = buffer[(
counter-1)];
      counter--;
      return 0;
   }
   else { /* Error buffer
 empty */
      return -1;
   }
}
int main(int argc, char
*argv[]) {
   /* Loop counter */
   int i;
   /* Verify the correct
number of arguments were
passed in */
   if(argc != 4) {
      fprintf(stderr, "
USAGE:./main.out <INT> <
INT> <INT>\n");
   }
   int mainSleepTime =
atoi(argv[1]); /* Time
in seconds for main to
sleep */
   int numProd = atoi(
argv[2]); /* Number of
producer threads */
   int numCons = atoi(
argv[3]); /* Number of
consumer threads */
   /* Initialize the app
*/
   initializeData();
   /* Create the producer
 threads */
   for(i = 0; i <
numProd; i++) {
      /* Create the
thread */
      pthread_create(&tid
,&attr,producer,NULL);
    }
   /* Create the consumer
 threads */
   for(i = 0; i <
numCons; i++) {
      /* Create the
thread */
      pthread_create(&tid
,&attr,consumer,NULL);
   }
   /* Sleep for the
specified amount of time
in milliseconds */
   sleep(mainSleepTime);
   /* Exit the program *
/
   printf("Exit the
program\n");
   exit(0);
}

prog.c:6:1: error: expected identifier or '(' before numeric constant
 100000000
 ^
prog.c:13:1: error: unknown type name 'buffer_item'
 buffer_item buffer[BUFFER
 ^
prog.c:13:20: error: 'BUFFER' undeclared here (not in a function)
 buffer_item buffer[BUFFER
                    ^
prog.c:14:1: error: expected ']' before '_SIZE'
 _SIZE];
 ^
prog.c:18:1: error: unknown type name 'Thread'
 Thread ID
 ^
prog.c:19:1: error: expected '=', ',', ';', 'asm' or '__attribute__' before 'pthread_attr_t'
 pthread_attr_t attr; //
 ^
prog.c:20:1: error: unknown type name 'Set'
 Set of thread attributes
 ^
prog.c:20:8: error: expected '=', ',', ';', 'asm' or '__attribute__' before 'thread'
 Set of thread attributes
        ^
prog.c:20:8: error: unknown type name 'thread'
prog.c: In function 'initializeData':
prog.c:31:1: error: 'mutex' undeclared (first use in this function)
 mutex, NULL);
 ^
prog.c:31:1: note: each undeclared identifier is reported only once for each function it appears in
prog.c:41:1: error: 'BUFFER_SIZE' undeclared (first use in this function)
 BUFFER_SIZE);
 ^
prog.c:45:1: error: 'attr' undeclared (first use in this function)
 attr);
 ^
prog.c: In function 'producer':
prog.c:52:4: error: unknown type name 'buffer_item'
    buffer_item item;
    ^
prog.c:57:14: error: expected expression before ';' token
  RAND_DIVISOR;
              ^
prog.c:58:7: warning: implicit declaration of function 'sleep' [-Wimplicit-function-declaration]
       sleep(rNum);
       ^
prog.c:68:3: error: 'mutex' undeclared (first use in this function)
 (&mutex);
   ^
prog.c:69:10: warning: implicit declaration of function 'insert_item' [-Wimplicit-function-declaration]
       if(insert_item(item
          ^
prog.c:72:1: warning: missing terminating " character
 " Producer report error
 ^
prog.c:72:1: error: missing terminating " character
prog.c:73:1: error: stray '\' in program
 condition\n");
 ^
prog.c:73:1: error: 'condition' undeclared (first use in this function)
prog.c:73:11: error: expected ')' before 'n'
 condition\n");
           ^
prog.c:73:12: warning: missing terminating " character
 condition\n");
            ^
prog.c:73:11: error: missing terminating " character
 condition\n");
           ^
prog.c:74:7: error: expected ';' before '}' token
       }
       ^
prog.c:76:17: warning: missing terminating " character
          printf("producer
                 ^
prog.c:76:10: error: missing terminating " character
          printf("producer
          ^
prog.c:77:2: error: 'produced' undeclared (first use in this function)
  produced %d\n", item);
  ^
prog.c:77:2: error: stray '\' in program
prog.c:77:12: error: 'd' undeclared (first use in this function)
  produced %d\n", item);
            ^
prog.c:77:14: error: expected ')' before 'n'
  produced %d\n", item);
              ^
prog.c:77:15: warning: missing terminating " character
  produced %d\n", item);
               ^
prog.c:77:14: error: missing terminating " character
  produced %d\n", item);
              ^
prog.c:78:7: error: expected ';' before '}' token
       }
       ^
prog.c:81:7: error: unknown type name 'pthread_mutex_'
       pthread_mutex_
       ^
prog.c:82:8: error: expected declaration specifiers or '...' before '&' token
 unlock(&mutex);
        ^
prog.c: In function 'consumer':
prog.c:90:4: error: unknown type name 'buffer_item'
    buffer_item item;
    ^
prog.c:95:14: error: expected expression before ';' token
  RAND_DIVISOR;
              ^
prog.c:103:3: error: 'mutex' undeclared (first use in this function)
 (&mutex);
   ^
prog.c:104:10: warning: implicit declaration of function 'remove_item' [-Wimplicit-function-declaration]
       if(remove_item(&
          ^
prog.c:107:1: warning: missing terminating " character
 "Consumer report error
 ^
prog.c:107:1: error: missing terminating " character
prog.c:108:1: error: stray '\' in program
 condition\n");
 ^
prog.c:108:1: error: 'condition' undeclared (first use in this function)
prog.c:108:11: error: expected ')' before 'n'
 condition\n");
           ^
prog.c:108:12: warning: missing terminating " character
 condition\n");
            ^
prog.c:108:11: error: missing terminating " character
 condition\n");
           ^
prog.c:109:7: error: expected ';' before '}' token
       }
       ^
prog.c:111:17: warning: missing terminating " character
          printf("consumer
                 ^
prog.c:111:10: error: missing terminating " character
          printf("consumer
          ^
prog.c:112:2: error: 'consumed' undeclared (first use in this function)
  consumed %d\n", item);
  ^
prog.c:112:2: error: stray '\' in program
prog.c:112:12: error: 'd' undeclared (first use in this function)
  consumed %d\n", item);
            ^
prog.c:112:14: error: expected ')' before 'n'
  consumed %d\n", item);
              ^
prog.c:112:15: warning: missing terminating " character
  consumed %d\n", item);
               ^
prog.c:112:14: error: missing terminating " character
  consumed %d\n", item);
              ^
prog.c:113:7: error: expected ';' before '}' token
       }
       ^
prog.c:116:7: error: unknown type name 'pthread_mutex_'
       pthread_mutex_
       ^
prog.c:117:8: error: expected declaration specifiers or '...' before '&' token
 unlock(&mutex);
        ^
prog.c: At top level:
prog.c:124:17: error: unknown type name 'buffer_'
 int insert_item(buffer_
                 ^
prog.c:144:17: error: unknown type name 'buffer_'
 int remove_item(buffer_
                 ^
prog.c: In function 'main':
prog.c:170:23: warning: missing terminating " character
       fprintf(stderr, "
                       ^
prog.c:170:7: error: missing terminating " character
       fprintf(stderr, "
       ^
prog.c:171:1: error: 'USAGE' undeclared (first use in this function)
 USAGE:./main.out <INT> <
 ^
prog.c:171:6: error: expected ')' before ':' token
 USAGE:./main.out <INT> <
      ^
prog.c:172:1: error: stray '\' in program
 INT> <INT>\n");
 ^
prog.c:172:13: warning: missing terminating " character
 INT> <INT>\n");
             ^
prog.c:172:1: error: missing terminating " character
 INT> <INT>\n");
 ^
prog.c:173:4: error: expected ';' before '}' token
    }
    ^
prog.c:194:3: error: 'attr' undeclared (first use in this function)
 ,&attr,producer,NULL);
   ^
prog.c:209:4: error: unterminated comment
    /* Exit the program *
    ^
prog.c:208:4: error: expected declaration or statement at end of input
    sleep(mainSleepTime);
    ^

Standard output is empty