*/
typedef struct sock_t {
int fd;
- u_int16_t port;
+ uint16_t port;
} sock_t;
/**
ObjectEntryHID *objectEntryHID;
void *attributes; //atributes of object
Boolean appMOM;
- Boolean private; //object created by me self app
+ Boolean privateCreated; //object created by me self app
HTimFncUserNode expirationPurgeTimer;
//only for private CSTPublication,CSTSubscription
void *instance; //data stream
pthread_rwlock_t objRootLock;
ul_htim_queue_t htimRoot; //root of tree htimers
pthread_rwlock_t htimRootLock;
- sem_t htimSendSem; //for wake up
+ pthread_cond_t htimSendCond; //for wake up
+ pthread_mutex_t htimSendMutex;
+ int htimSendCondValue;
Boolean htimNeedWakeUp;
};
GUID_RTPS guid;
gavl_cust_root_field_t csChangeForReader;
- int csChangesCounter;
+ unsigned int csChangesCounter;
//comm states
StateMachineHB commStateHB;
CSTWriterParams params;
ul_list_head_t csChanges;
- int csChangesCounter;
+ unsigned int csChangesCounter;
gavl_cust_root_field_t cstRemoteReader;
- int cstRemoteReaderCounter;
+ unsigned int cstRemoteReaderCounter;
pthread_rwlock_t lock;
HTimFncUserNode refreshPeriodTimer;
//only for CSTPublications
unsigned int strictReliableCounter;
unsigned int bestEffortsCounter;
- sem_t semCSChangeDestroyed;
+ pthread_cond_t condCSChangeDestroyed; //for wake up
+ pthread_mutex_t mutexCSChangeDestroyed;
+ int condValueCSChangeDestroyed;
};
/**
GUID_RTPS guid;
gavl_cust_root_field_t csChangeFromWriter;
- int csChangesCounter;
+ unsigned int csChangesCounter;
SequenceNumber sn;
SequenceNumber firstSN;
HTimFncUserNode delayResponceTimer;
HTimFncUserNode repeatActiveQueryTimer;
- int ACKRetriesCounter;
+ unsigned int ACKRetriesCounter;
} CSTRemoteWriter;
typedef struct CSTSubscriptions CSTSubscriptions;
ul_list_head_t csChanges;
gavl_cust_root_field_t cstRemoteWriter;
- int cstRemoteWriterCounter;
+ unsigned int cstRemoteWriterCounter;
pthread_rwlock_t lock;
//ser./deser. function
struct CSTPublications {
gavl_cust_root_field_t cstWriter;
pthread_rwlock_t lock;
- u_int32_t counter;
+ uint32_t counter;
};
/**
struct CSTSubscriptions {
gavl_cust_root_field_t cstReader;
pthread_rwlock_t lock;
- u_int32_t counter;
+ uint32_t counter;
};
/**
* struct ORTEDomain -
*/
struct ORTEDomain {
- u_int32_t domain; //domain value
+ uint32_t domain; //domain value
GUID_RTPS guid; //guid of self application
AppParams *appParams; //self parameters (share from objectEntry)
ObjectEntryOID *objectEntryOID;//entry point for self OID