Skip to content

File shard_proxy_queue.c

FileList > broker > shard_proxy_queue.c

Go to the source code of this file

  • #include <stdio.h>
  • #include <stdlib.h>
  • #include <assert.h>
  • #include "cas_common.h"
  • #include "shard_proxy_common.h"
  • #include "shard_proxy_queue.h"

Public Functions

Type Name
void * shard_cqueue_dequeue (T_SHARD_CQUEUE * q)
void shard_cqueue_destroy (T_SHARD_CQUEUE * q)
int shard_cqueue_enqueue (T_SHARD_CQUEUE * q, void * e)
int shard_cqueue_initialize (T_SHARD_CQUEUE * q, int size)
void * shard_queue_dequeue (T_SHARD_QUEUE * q)
void shard_queue_destroy (T_SHARD_QUEUE * q)
int shard_queue_enqueue (T_SHARD_QUEUE * q, void * v)
int shard_queue_initialize (T_SHARD_QUEUE * q)
int shard_queue_ordered_enqueue (T_SHARD_QUEUE * q, void * v, SHARD_COMP_FN comp_fn)
void * shard_queue_peek_value (T_SHARD_QUEUE * q)

Public Static Functions

Type Name
bool shard_cqueue_is_empty (T_SHARD_CQUEUE * q)
bool shard_cqueue_is_full (T_SHARD_CQUEUE * q)
void shard_queue_insert_after (T_SHARD_QUEUE * q, T_SHARD_QUEUE_ENT * prev, T_SHARD_QUEUE_ENT * curr)

Public Functions Documentation

function shard_cqueue_dequeue

void * shard_cqueue_dequeue (
    T_SHARD_CQUEUE * q
) 

function shard_cqueue_destroy

void shard_cqueue_destroy (
    T_SHARD_CQUEUE * q
) 

function shard_cqueue_enqueue

int shard_cqueue_enqueue (
    T_SHARD_CQUEUE * q,
    void * e
) 

function shard_cqueue_initialize

int shard_cqueue_initialize (
    T_SHARD_CQUEUE * q,
    int size
) 

function shard_queue_dequeue

void * shard_queue_dequeue (
    T_SHARD_QUEUE * q
) 

function shard_queue_destroy

void shard_queue_destroy (
    T_SHARD_QUEUE * q
) 

function shard_queue_enqueue

int shard_queue_enqueue (
    T_SHARD_QUEUE * q,
    void * v
) 

function shard_queue_initialize

int shard_queue_initialize (
    T_SHARD_QUEUE * q
) 

function shard_queue_ordered_enqueue

int shard_queue_ordered_enqueue (
    T_SHARD_QUEUE * q,
    void * v,
    SHARD_COMP_FN comp_fn
) 

function shard_queue_peek_value

void * shard_queue_peek_value (
    T_SHARD_QUEUE * q
) 

Public Static Functions Documentation

function shard_cqueue_is_empty

static bool shard_cqueue_is_empty (
    T_SHARD_CQUEUE * q
) 

function shard_cqueue_is_full

static bool shard_cqueue_is_full (
    T_SHARD_CQUEUE * q
) 

function shard_queue_insert_after

static void shard_queue_insert_after (
    T_SHARD_QUEUE * q,
    T_SHARD_QUEUE_ENT * prev,
    T_SHARD_QUEUE_ENT * curr
) 


The documentation for this class was generated from the following file cubrid/src/broker/shard_proxy_queue.c