mq.h

Go to the documentation of this file.

 
/******************************************************************************
*                                                                             *
* License Agreement                                                           *
* Copyright (c) Ricardo L. Cayssials                                          *
* All rights reserved.                                                        *
*                                                                             *
******************************************************************************/
 
// Check https://stackoverflow.com/questions/1154709/how-can-i-hide-the-declaration-of-a-struct-in-c
 
#ifndef MQ_H_
#define MQ_H_
 
 
 
struct T_QUEUE_RESOURCE {
    void          *MQ_PBuffer;              
    INT32         MQ_Count_deliver;         
    INT32         MQ_consumer_count;        
    INT32         MQ_Buffer_Length;         
    INT32         MQ_msg_Length;            
    INT32         MQ_priority_send;         
    INT32         MQ_priority_consume;      
    INT32         MQ_msg_seq;               
    struct gs_tcb *MQ_CUR_TCB ;            
};
 
//*************************************************************************************************
 
struct queue_buffer {         
    INT32   BUFFER_status;                
    void    *BUFFER_pbuffer;              
    INT32   BUFFER_buffer_length;         
    INT32   BUFFER_current_byte_index;    
    INT32   BUFFER_msg_seq;               
    TIMEPRIORITY BUFFER_priority;         
    TIMEPRIORITY BUFFER_timeout;          
};
 
#define BUFFER_status_READ                  1u     
#define BUFFER_status_NOT_READ              2u     
 
G_RCB  *gu_queue_create(void *pbuffer, INT32 buffer_length);
GS_ECB  *gu_queue_consume(G_RCB  *presource, void *pbuffer, INT32 buffer_length, gt_time timeout);
INT32 gk_check_consume(GS_ECB * pbuffer);
INT32 gk_MQ_move_to_consumer(GS_RRDS *pbuffer_consumer, INT32 start_byte_id, INT32 bytes_count);
INT32 gu_MQ_consumer_mark_read(GS_ECB * pevent);
INT32 gk_MQ_Read_Sender(void);
INT32 gk_MQ_send(G_RCB  *prcb, void *pmsg, INT32 msg_length, gt_time timeout);
INT32 gu_MQ_receive(GS_ECB  *pevent);
INT32 gk_timeout_ECB_MQ_consume(GS_ECB *peventime);
INT32 gk_timeout_ECB_MQ_send(GS_ECB *peventime);
INT32 gk_QUEUE_granted_kill(GS_ECB *pevent);
 
 
 
#endif /* MQ_H__H_ */