#include "config.h"
#include <errno.h>
#include <string.h>
#include <stdio.h>
#include <time.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/queue.h>
#include <sys/socket.h>
#include "vmbuf.h"
#include "plog.h"
#include "misc.h"
#include "admin.h"
#include "gcmalloc.h"
#include "evt.h"
#ifdef ENABLE_ADMINPORT
struct evtlist evtlist = TAILQ_HEAD_INITIALIZER(evtlist);
int evtlist_len = 0;
void
evt_push(src, dst, type, optdata)
struct sockaddr *src;
struct sockaddr *dst;
int type;
vchar_t *optdata;
{
struct evtdump *evtdump;
struct evt *evt;
size_t len;
if (adminsock_path == NULL)
return;
if (evtlist_len > EVTLIST_MAX) {
plog(LLV_DEBUG, LOCATION, NULL,
"Cannot record event: event queue overflowed\n");
return;
}
if (evtlist_len == EVTLIST_MAX) {
plog(LLV_ERROR, LOCATION, NULL,
"Cannot record event: event queue overflow\n");
src = NULL;
dst = NULL;
type = EVTT_OVERFLOW;
optdata = NULL;
}
len = sizeof(*evtdump);
if (optdata)
len += optdata->l;
if ((evtdump = racoon_malloc(len)) == NULL) {
plog(LLV_ERROR, LOCATION, NULL, "Cannot record event: %s\n",
strerror(errno));
return;
}
if ((evt = racoon_malloc(sizeof(*evt))) == NULL) {
plog(LLV_ERROR, LOCATION, NULL, "Cannot record event: %s\n",
strerror(errno));
racoon_free(evtdump);
return;
}
if (src)
memcpy(&evtdump->src, src, sysdep_sa_len(src));
if (dst)
memcpy(&evtdump->dst, dst, sysdep_sa_len(dst));
evtdump->len = len;
evtdump->type = type;
time(&evtdump->timestamp);
if (optdata)
memcpy(evtdump + 1, optdata->v, optdata->l);
evt->dump = evtdump;
TAILQ_INSERT_TAIL(&evtlist, evt, next);
evtlist_len++;
return;
}
struct evtdump *
evt_pop(void) {
struct evtdump *evtdump;
struct evt *evt;
if ((evt = TAILQ_FIRST(&evtlist)) == NULL)
return NULL;
evtdump = evt->dump;
TAILQ_REMOVE(&evtlist, evt, next);
racoon_free(evt);
evtlist_len--;
return evtdump;
}
vchar_t *
evt_dump(void) {
struct evtdump *evtdump;
vchar_t *buf = NULL;
if ((evtdump = evt_pop()) != NULL) {
if ((buf = vmalloc(evtdump->len)) == NULL) {
plog(LLV_ERROR, LOCATION, NULL,
"evt_dump failed: %s\n", strerror(errno));
return NULL;
}
memcpy(buf->v, evtdump, evtdump->len);
racoon_free(evtdump);
}
return buf;
}
#endif