#include "mq.h"
Functions | |
static int | soap_mq_init (struct soap *soap, struct soap_mq_data *data) |
static void | soap_mq_delete (struct soap *soap, struct soap_plugin *p) |
static size_t | soap_mq_recv (struct soap *soap, char *buf, size_t len) |
static int | soap_mq_serveloop (struct soap *soap) |
static void | soap_mq_set (struct soap_mq_msg *msg) |
int | soap_mq (struct soap *soap, struct soap_plugin *p, void *arg) |
struct soap_mq_queue * | soap_mq_queue (struct soap *soap) |
Create a new queue structure allocated in the current context. Will be deallocated with soap_end(soap). Use soap_mq_get() to receive a message from the current socket to add to the queue. | |
struct soap_mq_msg * | soap_mq_get (struct soap *soap, struct soap_mq_queue *mq) |
Receive message from socket and queue it at the end of the queue. | |
struct soap_mq_msg * | soap_mq_begin (struct soap_mq_queue *mq) |
Get first message in queue. Use msg->soap to invoke service from the queued message, as in soap_serve(&msg->soap). | |
struct soap_mq_msg * | soap_mq_next (struct soap_mq_msg *msg) |
Get next message in queue. Use msg->soap to invoke service from the queued message, as in soap_serve(&msg->soap). | |
void | soap_mq_del (struct soap_mq_queue *mq, struct soap_mq_msg *msg) |
Delete message from queue, e.g. after processing it. Delete entire queue when msg==NULL. Note: structures will be deallocated with deallocation with soap_end(). | |
Variables | |
const char | soap_mq_id [] = SOAP_MQ_ID |
int soap_mq | ( | struct soap * | soap, | |
struct soap_plugin * | p, | |||
void * | arg | |||
) |
plugin registry function, invoked by soap_register_plugin
struct soap_mq_msg* soap_mq_begin | ( | struct soap_mq_queue * | mq | ) | [read] |
Get first message in queue. Use msg->soap to invoke service from the queued message, as in soap_serve(&msg->soap).
mq | pointer to the message queue structure created by soap_mq_queue() |
void soap_mq_del | ( | struct soap_mq_queue * | mq, | |
struct soap_mq_msg * | msg | |||
) |
Delete message from queue, e.g. after processing it. Delete entire queue when msg==NULL. Note: structures will be deallocated with deallocation with soap_end().
mq | pointer to the queue structure | |
msg | pointer to a message in the queue, when NULL delete entire queue |
static void soap_mq_delete | ( | struct soap * | soap, | |
struct soap_plugin * | p | |||
) | [static] |
struct soap_mq_msg* soap_mq_get | ( | struct soap * | soap, | |
struct soap_mq_queue * | mq | |||
) | [read] |
Receive message from socket and queue it at the end of the queue.
soap | current context | |
mq | pointer to the message queue structure created by soap_mq_queue() |
static int soap_mq_init | ( | struct soap * | soap, | |
struct soap_mq_data * | data | |||
) | [static] |
struct soap_mq_msg* soap_mq_next | ( | struct soap_mq_msg * | msg | ) | [read] |
Get next message in queue. Use msg->soap to invoke service from the queued message, as in soap_serve(&msg->soap).
msg | pointer to current message in the queue |
struct soap_mq_queue* soap_mq_queue | ( | struct soap * | soap | ) | [read] |
Create a new queue structure allocated in the current context. Will be deallocated with soap_end(soap). Use soap_mq_get() to receive a message from the current socket to add to the queue.
soap | current context |
static size_t soap_mq_recv | ( | struct soap * | soap, | |
char * | buf, | |||
size_t | len | |||
) | [static] |
static int soap_mq_serveloop | ( | struct soap * | soap | ) | [static] |
static void soap_mq_set | ( | struct soap_mq_msg * | msg | ) | [static] |
const char soap_mq_id[] = SOAP_MQ_ID |