examples/PIPS/opencproducerconsumerex/inc/commanheader.h

#ifndef COMMANHEADER_H
#define COMMANHEADER_H

/* INCLUDE FILES */
#include <semaphore.h>

#define MAX_CLIENTS     10
#define KPortNum                2222
#define KMSGQKEY                1000
#define KMAXSENDMSG     100

#define IN_SET_LOOPBACK_ADDR(a) \
        { (a)->sin_addr.s_addr  = 0x0100007F; (a)->sin_family = AF_INET; }


/* Structure used for sending details to the Producer and Consumers */
typedef struct 
{
        int   noOfItems;
        int   noOfConsumers;
        sem_t itemLock;
} ThreadParam;

/* Structure defining Items to be Produced */
typedef struct 
{
        int    itemNum;
        char   itemName[50];
} ProducedItem;



void* ProducerThreadEntryPoint( void* aParam );

void* ConsumerThreadEntryPoint( void* aParam );

#ifdef __cplusplus
extern "C" 
{
#endif

void CreateObserverThread( int aNoOfMsg );

void PushOntoStack( ProducedItem* aItem );

ProducedItem* PopFromStack();

void FreeItem(ProducedItem* aItem);

#ifdef __cplusplus
}
#endif


#endif /*COMMANHEADER_H*/

/*  End of File */

---