145 lines
4.9 KiB
C++
145 lines
4.9 KiB
C++
/*
|
|
* Copyright (c) 2016-2017 Wind River Systems, Inc.
|
|
*
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*
|
|
*/
|
|
|
|
/**
|
|
* @file
|
|
* Wind River Titanium Cloud Maintenance Alarm Manager Daemon Handler
|
|
*/
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <iostream>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <errno.h>
|
|
#include <unistd.h> /* for close and usleep */
|
|
#include <json-c/json.h> /* for ... json-c json string parsing */
|
|
|
|
using namespace std;
|
|
|
|
#define __MODULE_PRIVATE__
|
|
|
|
#include "alarm.h" /* module header */
|
|
#include "jsonUtil.h" /* for ... jsonUtil_ utiltiies */
|
|
#include "nodeTimers.h" /* for ... maintenance timers */
|
|
#include "daemon_common.h" /* for UNUSED() */
|
|
|
|
void daemon_sigchld_hdlr ( void ) { ; }
|
|
|
|
/*****************************************************************************
|
|
*
|
|
* Name : _fm_timestamp
|
|
*
|
|
* Purpose : Get a microsecond timestamp of the current time.
|
|
*
|
|
* Description: Used to record the time the alarm/log was requested
|
|
*
|
|
* Uses : FMTimeT from fmAPI.h
|
|
*
|
|
****************************************************************************/
|
|
|
|
FMTimeT _fm_timestamp ( void )
|
|
{
|
|
struct timespec ts;
|
|
clock_gettime(CLOCK_REALTIME, &ts);
|
|
return ( ts.tv_sec*1000000 + ts.tv_nsec/1000 );
|
|
}
|
|
|
|
/** Daemon timer handler */
|
|
void _timer_handler ( int sig, siginfo_t *si, void *uc)
|
|
{
|
|
timer_t * tid_ptr = (void**)si->si_value.sival_ptr ;
|
|
UNUSED(sig);
|
|
UNUSED(uc);
|
|
if ( !(*tid_ptr) )
|
|
{
|
|
return ;
|
|
}
|
|
else
|
|
{
|
|
mtcTimer_stop_tid_int_safe (tid_ptr);
|
|
}
|
|
}
|
|
|
|
int alarmHdlr_request_handler ( char * msg_ptr )
|
|
{
|
|
int rc = FAIL_JSON_PARSE ;
|
|
struct json_object *raw_obj = json_tokener_parse( msg_ptr );
|
|
jlog ("Alarm Request: %s\n", msg_ptr );
|
|
if ( raw_obj )
|
|
{
|
|
int elements ;
|
|
|
|
/* Check response sanity */
|
|
rc = jsonUtil_array_elements ( msg_ptr, MTCALARM_REQ_LABEL, elements );
|
|
if ( elements )
|
|
{
|
|
#define PARSE_FAILURE ((const char *)"failed to parse value for key")
|
|
queue_entry_type entry ;
|
|
string alarm_req = "" ;
|
|
string operation = "" ;
|
|
string severity = "" ;
|
|
for ( int i = 0 ; i < elements ; i++ )
|
|
{
|
|
if ( ( rc = jsonUtil_get_array_idx ( msg_ptr, MTCALARM_REQ_LABEL, i, alarm_req ) ) == PASS )
|
|
{
|
|
if (( rc = jsonUtil_get_key_val ( (char*)alarm_req.data(), MTCALARM_REQ_KEY__ALARMID, entry.alarmid )) != PASS )
|
|
{
|
|
elog ("%s '%s'\n", PARSE_FAILURE, MTCALARM_REQ_KEY__ALARMID);
|
|
}
|
|
else if (( rc = jsonUtil_get_key_val ( (char*)alarm_req.data(), MTCALARM_REQ_KEY__HOSTNAME, entry.hostname )) != PASS )
|
|
{
|
|
elog ("%s '%s'\n", PARSE_FAILURE, MTCALARM_REQ_KEY__HOSTNAME);
|
|
}
|
|
else if (( rc = jsonUtil_get_key_val ( (char*)alarm_req.data(), MTCALARM_REQ_KEY__OPERATION, operation )) != PASS )
|
|
{
|
|
elog ("%s '%s'\n", PARSE_FAILURE, MTCALARM_REQ_KEY__OPERATION);
|
|
}
|
|
else if (( rc = jsonUtil_get_key_val ( (char*)alarm_req.data(), MTCALARM_REQ_KEY__SEVERITY, severity)) != PASS )
|
|
{
|
|
elog ("%s '%s'\n", PARSE_FAILURE, MTCALARM_REQ_KEY__SEVERITY);
|
|
}
|
|
else if (( rc = jsonUtil_get_key_val ( (char*)alarm_req.data(), MTCALARM_REQ_KEY__ENTITY, entry.entity )) != PASS )
|
|
{
|
|
elog ("%s '%s'\n", PARSE_FAILURE, MTCALARM_REQ_KEY__ENTITY);
|
|
}
|
|
else if (( rc = jsonUtil_get_key_val ( (char*)alarm_req.data(), MTCALARM_REQ_KEY__PREFIX, entry.prefix)) != PASS )
|
|
{
|
|
elog ("%s '%s'\n", PARSE_FAILURE, MTCALARM_REQ_KEY__PREFIX);
|
|
}
|
|
else
|
|
{ entry.timestamp = _fm_timestamp ();
|
|
entry.operation = tolowercase(operation);
|
|
entry.severity = tolowercase(severity);
|
|
alarmMgr_queue_alarm (entry);
|
|
}
|
|
if ( rc ) break ;
|
|
}
|
|
else
|
|
{
|
|
wlog ("failed to get index '%d of %d' from alarm request", i, elements);
|
|
}
|
|
} /* for loop */
|
|
}
|
|
else
|
|
{
|
|
elog ("failed to find '%s' label in json object\n", MTCALARM_REQ_LABEL );
|
|
elog (" ... %s\n", msg_ptr );
|
|
rc = FAIL_JSON_OBJECT ;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
elog ("failed to parse json request\n");
|
|
elog (" ... %s\n", msg_ptr );
|
|
rc = FAIL_JSON_OBJECT ;
|
|
}
|
|
if (raw_obj) json_object_put(raw_obj);
|
|
return (rc);
|
|
}
|