fifo_iface.h File Reference

#include "message_queue_iface.h"

Include dependency graph for fifo_iface.h:

Classes
struct	Fifo
struct	InOutChannel

Typedefs
typedef struct Fifo	Fifo
typedef struct InOutChannel	InOutChannel

Functions
static void *	fifo_claim_continuous_space_for_push (Fifo *queue, int len)
static void	fifo_commit_peek (Fifo *queue, int len)
static void	fifo_commit_push (Fifo *queue, int len)
static Fifo *	fifo_create (void *buffer, int size, unsigned flags)
static void	fifo_dispose (Fifo *queue)
static int	fifo_is_empty (Fifo *queue)
static int	fifo_is_full (Fifo *queue, int len)
static int	fifo_is_ready (Fifo *queue)
static int	fifo_peek_continuous_buf (Fifo *queue, void **ptr)
static int	fifo_pop (Fifo *queue, char *message, int bufLen)
static int	fifo_push (Fifo *queue, const char *message, int len)
static InOutChannel *	inout_channel_create (Fifo *in, Fifo *out)
static InOutChannel *	inout_channel_create_on_heap (int in_size, int out_size, int flags)
static void	inout_channel_dispose (InOutChannel *ch)

Typedef Documentation

typedef struct Fifo Fifo

typedef struct InOutChannel InOutChannel

Function Documentation

static void* fifo_claim_continuous_space_for_push ( Fifo *  queue, int  len  )

inlinestatic

References atom_read, Fifo::buffer, fifo_is_ready(), Fifo::flags, LOG_FATAL, MQF_WRITE_LOCK, Fifo::sh, Fifo::size, and unlikely().

static void fifo_commit_peek ( Fifo *  queue, int  len  )

inlinestatic

References atom_read, atom_set, MB, Fifo::sh, and Fifo::size.

static void fifo_commit_push ( Fifo *  queue, int  len  )

inlinestatic

References atom_read, atom_set, MB, Fifo::sh, and Fifo::size.

static Fifo* fifo_create ( void *  buffer, int  size, unsigned  flags  )

static

References atom_read, atom_set, Fifo::buffer, Fifo::flags, halt(), init(), Fifo::lock, LOG_FATAL, MALLOC, MB, MEMSET, MQ_ALIGNTO_CACHELINE, MQ_CACHELINE_ALIGN_SIZE, MQD_MAGIC, MQF_ALLOC_ON_HEAP, MQF_ALWAYS_REINIT, MQF_INITIATOR_SIDE, MQF_THIS_SIDE_CONNECTED, Fifo::sh, Fifo::size, SPINLOCK_INIT, and USE_SPINLOCK.

Referenced by inout_channel_create_on_heap().

static void fifo_dispose ( Fifo *  queue )

static

References Fifo::buffer, Fifo::flags, FREE, Fifo::lock, MQF_ALLOC_ON_HEAP, SPINLOCK_FINI, and USE_SPINLOCK.

Referenced by inout_channel_dispose().

static int fifo_is_empty ( Fifo *  queue )

inlinestatic

References atom_read, fifo_is_ready(), and Fifo::sh.

static int fifo_is_full ( Fifo *  queue, int  len  )

inlinestatic

References atom_read, fifo_is_ready(), Fifo::flags, Fifo::lock, MQF_WRITE_LOCK, Fifo::sh, Fifo::size, SPIN_LOCK, SPIN_UNLOCK, and unlikely().

static int fifo_is_ready ( Fifo *  queue )

inlinestatic

References atom_read, Fifo::flags, likely(), MQD_MAGIC, MQF_THIS_SIDE_CONNECTED, Fifo::sh, and Fifo::size.

Referenced by fifo_claim_continuous_space_for_push(), fifo_is_empty(), fifo_is_full(), fifo_peek_continuous_buf(), fifo_pop(), and fifo_push().

static int fifo_peek_continuous_buf ( Fifo *  queue, void **  ptr  )

inlinestatic

References atom_read, Fifo::buffer, fifo_is_ready(), Fifo::flags, LOG_FATAL, MQF_READ_LOCK, Fifo::sh, Fifo::size, and unlikely().

static int fifo_pop ( Fifo *  queue, char *  message, int  bufLen  )

inlinestatic

References atom_read, atom_set, Fifo::buffer, fifo_is_ready(), Fifo::flags, Fifo::lock, MB, MEMCPY, MQF_READ_LOCK, Fifo::sh, Fifo::size, SPIN_LOCK, SPIN_UNLOCK, and unlikely().

static int fifo_push ( Fifo *  queue, const char *  message, int  len  )

inlinestatic

References atom_read, atom_set, Fifo::buffer, fifo_is_ready(), Fifo::flags, Fifo::lock, MB, MEMCPY, MQF_WRITE_LOCK, Fifo::sh, Fifo::size, SPIN_LOCK, SPIN_UNLOCK, and unlikely().

static InOutChannel* inout_channel_create ( Fifo *  in, Fifo *  out  )

static

References InOutChannel::in, MALLOC, MEMSET, and InOutChannel::out.

static InOutChannel* inout_channel_create_on_heap ( int  in_size, int  out_size, int  flags  )

static

References fifo_create(), InOutChannel::in, MALLOC, MEMSET, MQF_ALLOC_ON_HEAP, and InOutChannel::out.

static void inout_channel_dispose ( InOutChannel *  ch )

static

References fifo_dispose(), FREE, InOutChannel::in, and InOutChannel::out.