potrSendQueue.h

Go to the documentation of this file.

 
#ifndef POTR_SEND_QUEUE_H
#define POTR_SEND_QUEUE_H
 
#include <stddef.h>
 
#include <porter_const.h>
#include <porter_type.h>
 
#ifndef _WIN32
    #include <pthread.h>
    typedef pthread_mutex_t PotrMutex;
    typedef pthread_cond_t  PotrCondVar;
#else /* _WIN32 */
    #include <winsock2.h>
    #include <windows.h>
    typedef CRITICAL_SECTION   PotrMutex;
    typedef CONDITION_VARIABLE PotrCondVar;
#endif /* _WIN32 */

typedef struct
{
    PotrPeerId peer_id;     
    uint16_t  flags;        
    uint16_t  payload_len;  
    uint8_t  *payload;      
} PotrPayloadElem;

typedef struct
{
    PotrPayloadElem *entries;      
    uint8_t         *payload_pool; 
    size_t           depth;        
    size_t           head;         
    size_t           tail;         
    size_t           count;        
    size_t           inflight;     
    PotrMutex        mutex;        
    PotrCondVar      not_empty;    
    PotrCondVar      not_full;     
    PotrCondVar      drained;      
} PotrSendQueue;
 
#ifdef __cplusplus
extern "C"
{
#endif /* __cplusplus */
 
    extern int  potr_send_queue_init(PotrSendQueue *q, size_t depth, uint16_t max_payload);
    extern void potr_send_queue_destroy(PotrSendQueue *q);
    extern int  potr_send_queue_push(PotrSendQueue *q, PotrPeerId peer_id,
                                     uint16_t flags,
                                     const void *payload, uint16_t payload_len);      /* 満杯時は即時 POTR_ERROR */
    extern int  potr_send_queue_push_wait(PotrSendQueue *q, PotrPeerId peer_id,
                                          uint16_t flags,
                                          const void *payload, uint16_t payload_len,
                                          volatile int *running);                      /* 満杯時は空きを待機 */
    extern int  potr_send_queue_pop(PotrSendQueue *q, PotrPayloadElem *out,
                                    volatile int *running);
    extern int  potr_send_queue_peek(PotrSendQueue *q, PotrPayloadElem *out);
    extern int  potr_send_queue_peek_timed(PotrSendQueue *q, PotrPayloadElem *out,
                                           uint32_t timeout_ms);
    extern int  potr_send_queue_try_pop(PotrSendQueue *q, PotrPayloadElem *out);
    extern void potr_send_queue_complete(PotrSendQueue *q);
    extern void potr_send_queue_wait_drained(PotrSendQueue *q);
    extern void potr_send_queue_shutdown(PotrSendQueue *q);
 
#ifdef __cplusplus
}
#endif /* __cplusplus */
 
#endif /* POTR_SEND_QUEUE_H */