forked from extern/alertik
73 lines
1.5 KiB
C
73 lines
1.5 KiB
C
/*
|
|
* Alertik: a tiny 'syslog' server & notification tool for Mikrotik routers.
|
|
* This is free and unencumbered software released into the public domain.
|
|
*/
|
|
|
|
#define _POSIX_C_SOURCE 200809L
|
|
#include <stdlib.h>
|
|
#include <pthread.h>
|
|
|
|
#include "events.h"
|
|
#include "env_events.h"
|
|
#include "log.h"
|
|
#include "notifiers.h"
|
|
#include "syslog.h"
|
|
|
|
/*
|
|
* Alertik
|
|
*/
|
|
|
|
static void *handle_messages(void *p)
|
|
{
|
|
((void)p);
|
|
|
|
int handled = 0;
|
|
struct log_event ev = {0};
|
|
|
|
while (syslog_pop_msg_from_fifo(&ev) >= 0) {
|
|
print_log_event(&ev);
|
|
|
|
if (!is_within_notify_threshold()) {
|
|
log_msg("ignoring, reason: too many notifications!\n");
|
|
continue;
|
|
}
|
|
|
|
handled = process_static_event(&ev);
|
|
handled += process_environment_event(&ev);
|
|
|
|
if (handled)
|
|
update_notify_last_sent();
|
|
else
|
|
log_msg("> Not handled!\n");
|
|
}
|
|
return NULL;
|
|
}
|
|
|
|
int main(void)
|
|
{
|
|
pthread_t handler;
|
|
int fd;
|
|
|
|
log_init();
|
|
|
|
log_msg(
|
|
"Alertik (" GIT_HASH ") (built at " __DATE__ " " __TIME__ ")\n");
|
|
log_msg(" (https://github.com/Theldus/alertik)\n");
|
|
log_msg("-------------------------------------------------\n");
|
|
|
|
if (!init_static_events() && !init_environment_events())
|
|
panic("No event was configured, please configure at least one\n"
|
|
"before proceeding!\n");
|
|
|
|
syslog_init_forward();
|
|
|
|
fd = syslog_create_udp_socket();
|
|
if (pthread_create(&handler, NULL, handle_messages, NULL))
|
|
panic_errno("Unable to create hanler thread!");
|
|
|
|
log_msg("Waiting for messages at :%d (UDP)...\n", SYSLOG_PORT);
|
|
|
|
while (syslog_enqueue_new_upd_msg(fd) >= 0);
|
|
return EXIT_SUCCESS;
|
|
}
|