File libsrc/bpo_queue.c

Included Files

#include <stdio.h>

#include <errno.h>

#include <sys/types.h>

#include <sys/time.h>

#include <sys/stat.h>

#include <sys/mman.h>

#include <sys/ipc.h>

#include <sys/shm.h>

#include <unistd.h>

#include <signal.h>

#include <fcntl.h>

#include <string.h>

#include <memory.h>

#include <stdlib.h>

#include <mplib1/mplib1_config.h>

#include <mplib1/safe_string.h>

#include <mplib1/dl_list.h>

#include <mplib1/cfg_file.h>

#include <mplib1/pid_check.h>

#include <mplib1/fprintfile.h>
- #include <mplib1/timestamp.h>

#include "include/bpo_q_internal.h"
- #include <mplib1/bpo_lock.h>
- #include <mplib1/bpo_list.h>
- #include <mplib1/bpo_init.h>
- #include <mplib1/bpo_alloc.h>
- #include <mplib1/bpo_proc.h>
- #include <mplib1/bpo_queue.h>

Type struct q_work

struct q_work
- {
- int notify;
- int rv;
- int errno;
- const char* q_name;
- void* r_ptr;
- struct bpo_Q* qp;
- }

Local Variables

bpo_queue_debug
static int bpo_queue_debug

Used in:

Get_Q_pid()
add_q_item()
add_this_q_item()
cache_queues()
do_a_reply()
get_Q_resource()
maybe_add_queue()
mpCheckQ()
mpCreateQ()
mpFindQ()
mpGetMsg()
mpPostMsg()
mpPutMsg()
mpReplyMsg()
mpWaitQ()
rem_q_item()
rem_this_q_item()
sole_reuse()

queue_debug_str
static char queue_debug_str[]

Used in:

cache_queues()
mpCheckQ()
mpCreateQ()
mpFindQ()
mpGetMsg()
mpPostMsg()
mpPutMsg()
mpReplyMsg()
mpWaitQ()

q_res_name
static char q_res_name[]

Used in:

get_Q_resource()

segments
static List segments

Used in:

cache_queues()
seginit()

seg_init
static int seg_init

Used in:

cache_queues()
seginit()

Global Function cache_queues()

struct cache_queue_list* cache_queues ( struct Q_Head* qh, const char* q_name )

Prototyped in:

include/bpo_q_internal.h

Calls:

Called by:

References Functions:

cache_q_list() : libsrc/bpo_queue.c

References Variables:

Global Function free_q_stuff()

void free_q_stuff ( struct bpo_Q* qp )

Prototyped in:

include/bpo_q_internal.h

Calls:

Called by:

Global Function free_this_private_q()

void free_this_private_q ( struct bpo_private_q* pqp )

Prototyped in:

include/bpo_q_internal.h

Calls:

Called by:

do_del_queues() : libsrc/bpo_val_q.c

Global Function get_Q_resource()

struct Q_Head* get_Q_resource ( const void* hint )

Prototyped in:

include/bpo_q_internal.h

Calls:

Called by:

References Variables:

Global Function mpCheckQ()

int mpCheckQ ( const char* q_name, const void* hint )

Prototyped in:

mplib1/bpo_queue.h

Calls:

References Variables:

Global Function mpCreateQ()

struct bpo_Q* mpCreateQ ( const void* hint, const char* q_name, int q_max, int q_flags, int q_mech )

Prototyped in:

mplib1/bpo_queue.h

Calls:

References Functions:

maybe_add_queue() : libsrc/bpo_queue.c

References Variables:

Global Function mpFindQ()

void* mpFindQ ( const char* q_name, const void* hint )

Prototyped in:

mplib1/bpo_queue.h

Calls:

References Variables:

Global Function mpGetMsg()

void* mpGetMsg ( const char* q_name, const void* hint )

Prototyped in:

mplib1/bpo_queue.h

Calls:

Called by:

bpo_send_and_get() : libsrc/bpo_msg.c

References Functions:

rem_q_item() : libsrc/bpo_queue.c

References Variables:

Global Function mpPostMsg()

int mpPostMsg ( const char* q_name, struct bpo_Q_Mesg* mesp, struct bpo_Q* reply_q )

Prototyped in:

mplib1/bpo_queue.h

Calls:

Called by:

bpo_send_and_get() : libsrc/bpo_msg.c

References Variables:

Global Function mpPutMsg()

int mpPutMsg ( const char* q_name, bpo_Node* q_node )

Prototyped in:

mplib1/bpo_queue.h

Calls:

Called by:

mpPostMsg() : libsrc/bpo_queue.c

References Functions:

add_q_item() : libsrc/bpo_queue.c

References Variables:

Global Function mpReplyMsg()

int mpReplyMsg ( struct bpo_Q_Mesg* mesp )

Prototyped in:

mplib1/bpo_queue.h

Calls:

References Functions:

do_a_reply() : libsrc/bpo_queue.c

References Variables:

Global Function mpWaitQ()

int mpWaitQ ( const char* name, const void* hint )

Prototyped in:

mplib1/bpo_queue.h

Calls:

Called by:

bpo_send_and_get() : libsrc/bpo_msg.c

References Variables:

Local Function Get_Q_pid()

static void Get_Q_pid ( struct bpo_Q* qp )

Calls:

Called by:

New_Q() : libsrc/bpo_queue.c

References Variables:

bpo_queue_debug : libsrc/bpo_queue.c

Local Function New_Q()

static struct bpo_Q* New_Q ( const void* hint, const char* q_name, int q_max, int q_flags, int q_mech )

Calls:

Called by:

mpCreateQ() : libsrc/bpo_queue.c

Local Function add_q_item()

static int add_q_item ( struct bpo_List* blp, struct bpo_Node* q_node, struct q_work* other )

Calls:

Used in:

mpPutMsg() : libsrc/bpo_queue.c

References Functions:

add_this_q_item() : libsrc/bpo_queue.c

References Variables:

bpo_queue_debug : libsrc/bpo_queue.c

Local Function add_q_to_cache()

static int add_q_to_cache ( struct bpo_Q* qp, struct cache_queue_list* qpl )

Calls:

Used in:

cache_q_list() : libsrc/bpo_queue.c

References Functions:

pid_transfer() : libsrc/bpo_queue.c

Local Function add_this_q_item()

static int add_this_q_item ( struct bpo_List* blp, struct bpo_Node* q_node, struct q_work* other )

Calls:

Used in:

References Variables:

bpo_queue_debug : libsrc/bpo_queue.c

Local Function alloc_private_q()

static struct bpo_private_q* alloc_private_q ( struct bpo_Q* qp )

Calls:

Called by:

add_q_to_cache() : libsrc/bpo_queue.c

Local Function cache_q_list()

static int cache_q_list ( struct bpo_List* blp, struct cache_queue_list* qpl, char* q_name )

Calls:

Used in:

cache_queues() : libsrc/bpo_queue.c

References Functions:

add_q_to_cache() : libsrc/bpo_queue.c

Local Function do_a_reply()

static int do_a_reply ( struct bpo_List* blp, struct bpo_Node* q_node, struct q_work* other )

Calls:

Used in:

mpReplyMsg() : libsrc/bpo_queue.c

References Functions:

add_this_q_item() : libsrc/bpo_queue.c

References Variables:

bpo_queue_debug : libsrc/bpo_queue.c

Local Function free_all_pids()

static void free_all_pids ( struct bpo_private_q* pqp )

Calls:

Walk_List() : libsrc/dl_l_014.c

Called by:

free_this_private_q() : libsrc/bpo_queue.c

Used in:

old_cleanup() : libsrc/bpo_queue.c

References Functions:

free_private_pid() : libsrc/bpo_queue.c

Local Function free_old_pids()

static void free_old_pids ( struct bpo_private_q* pqp )

Calls:

Walk_List() : libsrc/dl_l_014.c

Used in:

old_cleanup() : libsrc/bpo_queue.c

References Functions:

free_private_pid() : libsrc/bpo_queue.c

Local Function free_private_pid()

static void free_private_pid ( struct bpo_private_pid* ppp )

Calls:

Remove_Node() : libsrc/dl_l_002.c
free()

Used in:

Local Function free_private_q()

static void free_private_q ( struct bpo_private_q* pqp )

Calls:

Remove_Node() : libsrc/dl_l_002.c
free()

Called by:

free_this_private_q() : libsrc/bpo_queue.c

Used in:

old_cleanup() : libsrc/bpo_queue.c

Local Function get_pids()

static void get_pids ( struct bpo_Q_pid* qpp, struct bpo_private_q* pqp )

Calls:

Used in:

pid_transfer() : libsrc/bpo_queue.c

Local Function inform_a_queue()

static int inform_a_queue ( struct Q_Head* qh, const char* q_name )

Calls:

Called by:

References Functions:

inform_this_pid() : libsrc/bpo_queue.c

Local Function inform_this_pid()

static void inform_this_pid ( struct bpo_private_pid* ppp, const void* hint )

Calls:

Inform_Process_Str() : libsrc/bpo_proc.c

Used in:

inform_a_queue() : libsrc/bpo_queue.c

Local Function maybe_add_queue()

static int maybe_add_queue ( struct bpo_List* blp, struct bpo_Q* nqp, struct bpo_Q** rv )

Calls:

Used in:

mpCreateQ() : libsrc/bpo_queue.c

References Functions:

sole_reuse() : libsrc/bpo_queue.c

References Variables:

bpo_queue_debug : libsrc/bpo_queue.c

Local Function mpCheckQ_Internal()

static int mpCheckQ_Internal ( const char* q_name, struct Q_Head* qh )

Calls:

Called by:

Local Function old_cleanup()

static void old_cleanup ( struct cache_queue_list* qpl )

Calls:

Walk_List() : libsrc/dl_l_014.c

Called by:

cache_queues() : libsrc/bpo_queue.c

References Functions:

Local Function pid_transfer()

static int pid_transfer ( struct bpo_List* blp, struct bpo_private_q* pqp )

Calls:

Used in:

add_q_to_cache() : libsrc/bpo_queue.c

References Functions:

get_pids() : libsrc/bpo_queue.c

Local Function rem_q_item()

static int rem_q_item ( struct bpo_List* blp, struct q_work* other )

Calls:

Used in:

mpGetMsg() : libsrc/bpo_queue.c

References Functions:

rem_this_q_item() : libsrc/bpo_queue.c

References Variables:

bpo_queue_debug : libsrc/bpo_queue.c

Local Function rem_this_q_item()

static int rem_this_q_item ( struct bpo_List* blp, struct bpo_Q* qp, struct q_work* other )

Calls:

Used in:

rem_q_item() : libsrc/bpo_queue.c

References Variables:

bpo_queue_debug : libsrc/bpo_queue.c

Local Function seginit()

static void seginit ( void )

Calls:

Init_List() : libsrc/dl_l_001.c

Called by:

cache_queues() : libsrc/bpo_queue.c

References Variables:

Local Function sole_reuse()

static int sole_reuse ( struct bpo_List* blp, struct bpo_Q* qp, struct bpo_Q* nqp )

Calls:

Used in:

maybe_add_queue() : libsrc/bpo_queue.c

References Variables:

bpo_queue_debug : libsrc/bpo_queue.c