#include "xdasd_mqueue.h"
#include "xdasd_thread.h"
#include <stdio.h>
#include <string.h>
#include <malloc.h>
Go to the source code of this file.
Data Structures | |
| struct | mqueue_tag |
| Internal message queue structure. More... | |
Typedefs | |
| typedef struct mqueue_tag | mqueue_t |
| Internal message queue structure. | |
Functions | |
| static void * | bg_proc (void *data) |
| The message queue background processor thread procedure. | |
| int | xdasd_mqueue_append (MsgQueue mq, void *msg) |
| Append data to a queue, signal background thread to process. | |
| MsgQueue | xdasd_mqueue_create (MsgPut_t *put, MsgGet_t *get, MsgProc_t *proc) |
| Initialize the message queue sub-system. | |
| void | xdasd_mqueue_destroy (MsgQueue mq) |
| Cleanup a message queue object. | |
This module implements a generic thread-safe background processing message queue. Messages are added to the queue by direct call, and removed from the queue by a background thread that submits them to the specified processor in serialized fashion.
Definition in file xdasd_mqueue.c.
1.5.6