ekg2
|
#include "ekg2-config.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <dirent.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include "debug.h"
#include "dynstuff.h"
#include "commands.h"
#include "msgqueue.h"
#include "protocol.h"
#include "sessions.h"
#include "stuff.h"
#include "xmalloc.h"
#include "dynstuff_inline.h"
Funkcje | |
static | LIST_FREE_ITEM (list_msg_queue_free, msg_queue_t *) |
DYNSTUFF_LIST_DECLARE (msgs_queue, msg_queue_t, list_msg_queue_free, __DYNSTUFF_LIST_ADD, __DYNSTUFF_LIST_REMOVE_ITER, __DYNSTUFF_LIST_DESTROY) | |
int | msg_queue_remove_uid (const char *uid) |
int | msg_queue_remove_seq (const char *seq) |
int | msg_queue_flush (const char *session) |
int | msg_queue_count_session (const char *uid) |
int | msg_queue_write () |
int | msg_queue_read () |
Zmienne | |
msg_queue_t * | msgs_queue = NULL |
DYNSTUFF_LIST_DECLARE | ( | msgs_queue | , |
msg_queue_t | , | ||
list_msg_queue_free | , | ||
__DYNSTUFF_LIST_ADD | , | ||
__DYNSTUFF_LIST_REMOVE_ITER | , | ||
__DYNSTUFF_LIST_DESTROY | |||
) |
|
static |
int msg_queue_count_session | ( | const char * | uid | ) |
int msg_queue_flush | ( | const char * | session | ) |
int msg_queue_read | ( | ) |
Read msgqueue of not sended messages.
msgqueue is subdir ("queue") in ekg2 config directory.
int msg_queue_remove_seq | ( | const char * | seq | ) |
int msg_queue_remove_uid | ( | const char * | uid | ) |
int msg_queue_write | ( | ) |
msg_queue_t* msgs_queue = NULL |