You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
146 lines
4.7 KiB
146 lines
4.7 KiB
/*
|
|
* graphite.c
|
|
*
|
|
* Created on: Jan 19, 2015
|
|
* Author: fmetz
|
|
*/
|
|
#include <sys/types.h>
|
|
#include <sys/socket.h>
|
|
#include <netinet/in.h>
|
|
#include <arpa/inet.h>
|
|
#include <unistd.h>
|
|
|
|
#include "log.h"
|
|
#include "call.h"
|
|
|
|
static int graphite_sock=-1;
|
|
static u_int32_t graphite_ipaddress;
|
|
static int graphite_port=0;
|
|
static struct callmaster* cm=0;
|
|
//struct totalstats totalstats_prev;
|
|
static time_t g_now, next_run;
|
|
|
|
int connect_to_graphite_server(u_int32_t ipaddress, int port) {
|
|
|
|
graphite_sock=-1;
|
|
//int reconnect=0;
|
|
int rc=0;
|
|
struct sockaddr_in sin;
|
|
memset(&sin,0,sizeof(sin));
|
|
int val=1;
|
|
|
|
graphite_ipaddress = ipaddress;
|
|
graphite_port = port;
|
|
|
|
rc = graphite_sock = socket(AF_INET, SOCK_STREAM,0);
|
|
if(rc<0) {
|
|
ilog(LOG_ERROR,"Couldn't make socket for connecting to graphite.");
|
|
return -1;
|
|
}
|
|
|
|
sin.sin_family=AF_INET;
|
|
sin.sin_addr.s_addr=graphite_ipaddress;
|
|
sin.sin_port=htons(graphite_port);
|
|
|
|
rc = setsockopt(graphite_sock,SOL_SOCKET,SO_REUSEADDR, &val,sizeof(val));
|
|
if(rc<0) {
|
|
ilog(LOG_ERROR,"Couldn't set sockopt for graphite descriptor.");
|
|
goto error;
|
|
}
|
|
|
|
struct in_addr ip;
|
|
ip.s_addr = graphite_ipaddress;
|
|
ilog(LOG_INFO, "Connecting to graphite server %s at port:%i with fd:%i",inet_ntoa(ip),graphite_port,graphite_sock);
|
|
rc = connect(graphite_sock, (struct sockaddr *)&sin, sizeof(sin));
|
|
if (rc==-1) {
|
|
ilog(LOG_ERROR, "Connection could not be established. Trying again next time of graphite-interval.");
|
|
goto error;
|
|
}
|
|
|
|
ilog(LOG_INFO, "Graphite server connected.");
|
|
|
|
return graphite_sock;
|
|
|
|
error:
|
|
close(graphite_sock);
|
|
graphite_sock = -1;
|
|
return -1;
|
|
}
|
|
|
|
int send_graphite_data() {
|
|
|
|
int rc=0;
|
|
|
|
if (graphite_sock < 0) {
|
|
ilog(LOG_ERROR,"Graphite socket is not connected.");
|
|
return -1;
|
|
}
|
|
|
|
// format hostname "." totals.subkey SPACE value SPACE timestamp
|
|
char hostname[256]; memset(&hostname,0,256);
|
|
rc = gethostname(hostname,256);
|
|
if (rc<0) {
|
|
ilog(LOG_ERROR, "Could not retrieve host name information.");
|
|
goto error;
|
|
}
|
|
|
|
char data_to_send[8192]; memset(&data_to_send,0,8192);
|
|
char* ptr = data_to_send;
|
|
|
|
mutex_lock(&cm->totalstats_lock);
|
|
|
|
rc = sprintf(ptr,"%s.totals.average_call_dur.tv_sec %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_average_call_dur.tv_sec,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.average_call_dur.tv_usec %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_average_call_dur.tv_usec,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.forced_term_sess %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_forced_term_sess,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.managed_sess %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_managed_sess,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.nopacket_relayed_sess %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_nopacket_relayed_sess,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.oneway_stream_sess %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_oneway_stream_sess,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.regular_term_sess %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_regular_term_sess,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.relayed_errors %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_relayed_errors,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.relayed_packets %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_relayed_packets,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.silent_timeout_sess %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_silent_timeout_sess,(unsigned long long)g_now); ptr += rc;
|
|
rc = sprintf(ptr,"%s.totals.timeout_sess %llu %llu\n",hostname, (unsigned long long) cm->totalstats_interval.total_timeout_sess,(unsigned long long)g_now); ptr += rc;
|
|
|
|
ZERO(cm->totalstats_interval);
|
|
|
|
mutex_unlock(&cm->totalstats_lock);
|
|
|
|
rc = write(graphite_sock, data_to_send, strlen(data_to_send));
|
|
if (rc<0) {
|
|
ilog(LOG_ERROR,"Could not write to graphite socket. Disconnecting graphite server.");
|
|
goto error;
|
|
}
|
|
return 0;
|
|
|
|
error:
|
|
close(graphite_sock); graphite_sock=-1;
|
|
return -1;
|
|
}
|
|
|
|
void graphite_loop_run(struct callmaster* callmaster, int seconds) {
|
|
|
|
int rc=0;
|
|
|
|
g_now = time(NULL);
|
|
if (g_now < next_run)
|
|
goto sleep;
|
|
|
|
next_run = g_now + seconds;
|
|
|
|
if (!cm)
|
|
cm = callmaster;
|
|
|
|
if (graphite_sock < 0) {
|
|
rc = connect_to_graphite_server(graphite_ipaddress, graphite_port);
|
|
}
|
|
|
|
if (rc>=0) {
|
|
rc = send_graphite_data();
|
|
if (rc<0) {
|
|
ilog(LOG_ERROR,"Sending graphite data failed.");
|
|
}
|
|
}
|
|
|
|
sleep:
|
|
usleep(100000);
|
|
}
|