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¶
function shard_cqueue_destroy¶
function shard_cqueue_enqueue¶
function shard_cqueue_initialize¶
function shard_queue_dequeue¶
function shard_queue_destroy¶
function shard_queue_enqueue¶
function shard_queue_initialize¶
function shard_queue_ordered_enqueue¶
function shard_queue_peek_value¶
Public Static Functions Documentation¶
function shard_cqueue_is_empty¶
function shard_cqueue_is_full¶
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