378 lines
13 KiB
C
378 lines
13 KiB
C
#include "denm.h"
|
|
#include "facilities.h"
|
|
|
|
#include <unistd.h>
|
|
#include <syslog.h>
|
|
|
|
#define syslog_info(msg, ...) syslog(LOG_INFO, msg, ##__VA_ARGS__)
|
|
#define syslog_emerg(msg, ...) syslog(LOG_EMERG, "%s:%d [" msg "]", __func__, __LINE__, ##__VA_ARGS__)
|
|
#define syslog_err(msg, ...) syslog(LOG_ERR, "%s:%d [" msg "]", __func__, __LINE__, ##__VA_ARGS__)
|
|
|
|
#ifndef NDEBUG
|
|
#define syslog_debug(msg, ...) syslog(LOG_DEBUG, "%s:%d " msg "", __func__, __LINE__, ##__VA_ARGS__)
|
|
#else
|
|
#define syslog_debug(msg, ...)
|
|
#endif
|
|
|
|
static enum EVENT_CHECK_RESULT event_check(den_t *den, DENM_t *denm) {
|
|
int rv = 0;
|
|
|
|
uint64_t e_detection_time, e_reference_time;
|
|
asn_INTEGER2ulong((INTEGER_t*) &denm->denm.management.detectionTime, &e_detection_time);
|
|
asn_INTEGER2ulong((INTEGER_t*) &denm->denm.management.referenceTime, &e_reference_time);
|
|
|
|
if (denm->denm.situation == NULL) {
|
|
return EVENT_INVALID; // Ignore situationless events
|
|
}
|
|
|
|
if (e_detection_time > e_reference_time) {
|
|
return EVENT_INVALID;
|
|
}
|
|
|
|
struct timespec systemtime;
|
|
clock_gettime(CLOCK_REALTIME, &systemtime);
|
|
long now = (long) (systemtime.tv_sec * 1000 + systemtime.tv_nsec / 1E6);
|
|
now = now - 1072915200000; // Convert EPOCH to 2004/01/01 00:00:000
|
|
|
|
uint32_t e_validity_duration;
|
|
if (denm->denm.management.validityDuration != NULL) {
|
|
e_validity_duration = *(uint32_t *) denm->denm.management.validityDuration * 1000; // validityDuration comes in seconds
|
|
} else {
|
|
e_validity_duration = 30000;
|
|
}
|
|
|
|
if (e_detection_time + e_validity_duration < now) {
|
|
return EVENT_PASSED;
|
|
}
|
|
|
|
bool is_new = true;
|
|
bool is_update = false;
|
|
bool exists_vacancy = false;
|
|
|
|
pthread_mutex_lock(&den->lock);
|
|
|
|
for (int i = 0; i < den->no_max_events; ++i) {
|
|
if (den->events[i]->enabled) {
|
|
if (den->events[i]->station_id == denm->denm.management.actionID.originatingStationID &&
|
|
den->events[i]->sn == denm->denm.management.actionID.sequenceNumber) {
|
|
|
|
is_new = false;
|
|
if (den->events[i]->reference_time < e_reference_time ||
|
|
den->events[i]->detection_time < e_detection_time) {
|
|
is_update = true;
|
|
}
|
|
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (is_new) {
|
|
for (int i = 0; i < den->no_max_events; ++i) {
|
|
if (!den->events[i]->enabled) {
|
|
exists_vacancy = true;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
pthread_mutex_unlock(&den->lock);
|
|
|
|
if (denm->denm.management.termination != NULL) {
|
|
if (*denm->denm.management.termination == 0) {
|
|
return EVENT_CANCELLATION;
|
|
} else if (*denm->denm.management.termination == 1) {
|
|
return EVENT_NEGATION;
|
|
}
|
|
}
|
|
|
|
if (is_update) {
|
|
return EVENT_UPDATE;
|
|
}
|
|
|
|
if (!is_new) {
|
|
return EVENT_REPEATED;
|
|
}
|
|
|
|
if (!exists_vacancy) {
|
|
return EVENT_NUMBER_EXCEEDED;
|
|
}
|
|
|
|
return EVENT_NEW;
|
|
}
|
|
|
|
static int event_add(den_t *den, DENM_t *denm) {
|
|
|
|
struct timespec systemtime;
|
|
clock_gettime(CLOCK_REALTIME, &systemtime);
|
|
long now = (long) (systemtime.tv_sec * 1000 + systemtime.tv_nsec / 1E6);
|
|
now = now - 1072915200000; // Convert EPOCH to 2004/01/01 00:00:000
|
|
|
|
uint64_t e_detection_time, e_reference_time;
|
|
asn_INTEGER2ulong((INTEGER_t*) &denm->denm.management.detectionTime, &e_detection_time);
|
|
asn_INTEGER2ulong((INTEGER_t*) &denm->denm.management.referenceTime, &e_reference_time);
|
|
|
|
uint32_t e_validity_duration;
|
|
if (denm->denm.management.validityDuration != NULL) {
|
|
e_validity_duration = *(uint32_t *) denm->denm.management.validityDuration * 1000; // validityDuration comes in seconds
|
|
} else {
|
|
e_validity_duration = 30000;
|
|
}
|
|
|
|
pthread_mutex_lock(&den->lock);
|
|
|
|
int index = -1;
|
|
for (int i = 0; i < den->no_max_events; ++i) {
|
|
if (!den->events[i]->enabled) {
|
|
index = i;
|
|
break;
|
|
}
|
|
}
|
|
|
|
uint8_t state = EVENT_ACTIVE;
|
|
if (denm->denm.management.termination != NULL) {
|
|
if (*(denm->denm.management.termination) == 0) {
|
|
state = EVENT_CANCELLED;
|
|
} else if (*(denm->denm.management.termination) == 1) {
|
|
state = EVENT_NEGATION;
|
|
}
|
|
}
|
|
|
|
switch (state) {
|
|
case EVENT_ACTIVE:
|
|
++den->no_active_events;
|
|
break;
|
|
case EVENT_CANCELLED:
|
|
++den->no_cancelled_events;
|
|
break;
|
|
case EVENT_NEGATED:
|
|
++den->no_negated_events;
|
|
break;
|
|
}
|
|
|
|
if (index != -1) {
|
|
den->events[index]->enabled = true;
|
|
den->events[index]->state = state;
|
|
den->events[index]->station_id = denm->denm.management.actionID.originatingStationID;
|
|
den->events[index]->sn = denm->denm.management.actionID.sequenceNumber;
|
|
den->events[index]->cause = denm->denm.situation->eventType.causeCode;
|
|
den->events[index]->subcause = denm->denm.situation->eventType.subCauseCode;
|
|
den->events[index]->detection_time = e_detection_time;
|
|
den->events[index]->reference_time = e_reference_time;
|
|
den->events[index]->expiration_time = e_detection_time + e_validity_duration;
|
|
den->events[index]->latitude = denm->denm.management.eventPosition.latitude;
|
|
den->events[index]->longitude = denm->denm.management.eventPosition.longitude;
|
|
den->events[index]->denm = denm;
|
|
|
|
if (denm->denm.management.actionID.sequenceNumber > den->sn) {
|
|
den->sn = denm->denm.management.actionID.sequenceNumber;
|
|
}
|
|
}
|
|
|
|
pthread_mutex_unlock(&den->lock);
|
|
|
|
if (index == -1) return 1; // Max events reached
|
|
else return 0; // Event added to db
|
|
}
|
|
|
|
static int event_update(den_t *den, DENM_t *denm) {
|
|
|
|
struct timespec systemtime;
|
|
clock_gettime(CLOCK_REALTIME, &systemtime);
|
|
long now = (long) (systemtime.tv_sec * 1000 + systemtime.tv_nsec / 1E6);
|
|
now = now - 1072915200000; // Convert EPOCH to 2004/01/01 00:00:000
|
|
|
|
uint64_t e_detection_time, e_reference_time;
|
|
asn_INTEGER2ulong((INTEGER_t*) &denm->denm.management.detectionTime, &e_detection_time);
|
|
asn_INTEGER2ulong((INTEGER_t*) &denm->denm.management.referenceTime, &e_reference_time);
|
|
|
|
uint8_t state = EVENT_ACTIVE;
|
|
if (denm->denm.management.termination != NULL) {
|
|
if (*(denm->denm.management.termination) == 0) {
|
|
state = EVENT_CANCELLED;
|
|
} else if (*(denm->denm.management.termination) == 1) {
|
|
state = EVENT_NEGATION;
|
|
}
|
|
}
|
|
|
|
int index = -1;
|
|
pthread_mutex_lock(&den->lock);
|
|
|
|
for (int i = 0; i < den->no_max_events; ++i) {
|
|
if (den->events[i]->enabled) {
|
|
if (den->events[i]->station_id == denm->denm.management.actionID.originatingStationID &&
|
|
den->events[i]->sn == denm->denm.management.actionID.sequenceNumber) {
|
|
index = i;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
switch (den->events[index]->state) {
|
|
case EVENT_ACTIVE:
|
|
--den->no_active_events;
|
|
break;
|
|
case EVENT_CANCELLED:
|
|
--den->no_cancelled_events;
|
|
break;
|
|
case EVENT_NEGATED:
|
|
--den->no_negated_events;
|
|
break;
|
|
}
|
|
|
|
switch (state) {
|
|
case EVENT_ACTIVE:
|
|
++den->no_active_events;
|
|
break;
|
|
case EVENT_CANCELLED:
|
|
++den->no_cancelled_events;
|
|
break;
|
|
case EVENT_NEGATED:
|
|
++den->no_negated_events;
|
|
break;
|
|
}
|
|
|
|
if (index != -1) {
|
|
den->events[index]->state = state;
|
|
den->events[index]->detection_time = e_detection_time;
|
|
den->events[index]->cause = denm->denm.situation->eventType.causeCode;
|
|
den->events[index]->subcause = denm->denm.situation->eventType.subCauseCode;
|
|
den->events[index]->reference_time = e_reference_time;
|
|
|
|
if (denm->denm.management.validityDuration != NULL) {
|
|
den->events[index]->expiration_time = e_detection_time + *(uint32_t *) denm->denm.management.validityDuration * 1000;
|
|
}
|
|
|
|
den->events[index]->latitude = denm->denm.management.eventPosition.latitude;
|
|
den->events[index]->longitude = denm->denm.management.eventPosition.longitude;
|
|
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, den->events[index]->denm);
|
|
den->events[index]->denm = denm;
|
|
}
|
|
|
|
pthread_mutex_unlock(&den->lock);
|
|
|
|
if (index == -1) return 1; // Event not found
|
|
else return 0; // Event updated
|
|
}
|
|
|
|
int event_manage(den_t *den, DENM_t *denm) {
|
|
int rv = 0;
|
|
switch (event_check(den, denm)) {
|
|
case EVENT_NEW:
|
|
rv = event_add(den, denm);
|
|
syslog_debug("[facilities] [den] new event received");
|
|
if (rv) {
|
|
syslog_debug("[facilities] [den] failed adding event, max events reached");
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, denm);
|
|
rv = 1;
|
|
}
|
|
break;
|
|
case EVENT_INVALID:
|
|
syslog_debug("[facilities] [den] invalid event received, ignoring");
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, denm);
|
|
break;
|
|
case EVENT_PASSED:
|
|
syslog_debug("[facilities] [den] old event received, ignoring");
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, denm);
|
|
break;
|
|
case EVENT_CANCELLATION:
|
|
syslog_debug("[facilities] [den] event cancellation received");
|
|
rv = event_update(den, denm);
|
|
if (rv) {
|
|
syslog_debug("[facilities] [den] failed cancelling event, event not found");
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, denm);
|
|
rv = 1;
|
|
}
|
|
break;
|
|
case EVENT_NEGATION:
|
|
syslog_debug("[facilities] [den] event negation received");
|
|
rv = event_update(den, denm);
|
|
if (rv) {
|
|
syslog_debug("[facilities] [den] failed negating event, event not found");
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, denm);
|
|
rv = 1;
|
|
}
|
|
break;
|
|
case EVENT_UPDATE:
|
|
syslog_debug("[facilities] [den] event update received");
|
|
rv = event_update(den, denm);
|
|
if (rv) {
|
|
syslog_debug("[facilities] [den] failed updating event, event not found");
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, denm);
|
|
}
|
|
break;
|
|
case EVENT_REPEATED:
|
|
syslog_debug("[facilities] [den] repeated event received, ignoring");
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, denm);
|
|
break;
|
|
case EVENT_NUMBER_EXCEEDED:
|
|
syslog_debug("[facilities] [den] max events reached, ignoring");
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, denm);
|
|
break;
|
|
}
|
|
return rv;
|
|
}
|
|
|
|
void* den_service(void *fc) {
|
|
facilities_t *facilities = (facilities_t *) fc;
|
|
|
|
struct timespec systemtime;
|
|
uint64_t now;
|
|
|
|
den_t *den = facilities->den;
|
|
pthread_mutex_init(&den->lock, NULL);
|
|
|
|
den->no_max_events = 32;
|
|
|
|
den->events = malloc(den->no_max_events * sizeof(void*));
|
|
for (int i = 0; i < den->no_max_events; ++i) {
|
|
den->events[i] = calloc(1, sizeof(event_t));
|
|
}
|
|
|
|
while (!facilities->exit) {
|
|
clock_gettime(CLOCK_REALTIME, &systemtime);
|
|
now = (long)(systemtime.tv_sec * 1000 + systemtime.tv_nsec / 1E6);
|
|
now = now - 1072915200000; // Convert EPOCH to 2004/01/01 00:00:000
|
|
|
|
pthread_mutex_lock(&den->lock);
|
|
for (int i = 0; i < den->no_max_events; ++i) {
|
|
if (den->events[i]->enabled) {
|
|
if (now >= den->events[i]->expiration_time) { // Remove event
|
|
den->events[i]->enabled = false;
|
|
ASN_STRUCT_FREE(asn_DEF_DENM, den->events[i]->denm);
|
|
switch (den->events[i]->state) {
|
|
case EVENT_ACTIVE:
|
|
--den->no_active_events;
|
|
break;
|
|
case EVENT_CANCELLED:
|
|
--den->no_cancelled_events;
|
|
break;
|
|
case EVENT_NEGATED:
|
|
--den->no_negated_events;
|
|
break;
|
|
}
|
|
} else {
|
|
switch (den->events[i]->state) {
|
|
case EVENT_ACTIVE:
|
|
syslog_debug("[facilities] [den] event %d expiring in %ld second(s)", i, (den->events[i]->expiration_time - now)/1000);
|
|
break;
|
|
case EVENT_CANCELLED:
|
|
break;
|
|
case EVENT_NEGATED:
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
syslog_info("[facilities] [den] events :: [ %d active | %d cancelled | %d negated ]", den->no_active_events, den->no_cancelled_events, den->no_negated_events);
|
|
|
|
pthread_mutex_unlock(&den->lock);
|
|
|
|
usleep(1000000);
|
|
}
|
|
|
|
return NULL;
|
|
}
|