From 71a7aae2c7e3451293ad7e96b07efa5329e12b86 Mon Sep 17 00:00:00 2001 From: Alexander Wenzel Date: Tue, 4 Oct 2011 17:34:25 +0200 Subject: First version of DLT system mamager. --- src/system/dlt-system.c | 370 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 370 insertions(+) create mode 100755 src/system/dlt-system.c (limited to 'src/system/dlt-system.c') diff --git a/src/system/dlt-system.c b/src/system/dlt-system.c new file mode 100755 index 0000000..ab9c2d9 --- /dev/null +++ b/src/system/dlt-system.c @@ -0,0 +1,370 @@ +/* + * Dlt system manager to Dlt + * @licence app begin@ + * + * Copyright (C) 2011, BMW AG - Alexander Wenzel + * + * This program is free software; you can redistribute it and/or modify it under the terms of the + * GNU Lesser General Public License, version 2.1, as published by the Free Software Foundation. + * This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even + * the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General + * Public License, version 2.1, for more details. + * + * You should have received a copy of the GNU Lesser General Public License, version 2.1, along + * with this program; if not, see . + * + * Note that the copyright holders assume that the GNU Lesser General Public License, version 2.1, may + * also be applicable to programs even in cases in which the program is not a library in the technical sense. + * + * Linking DLT statically or dynamically with other modules is making a combined work based on DLT. You may + * license such other modules under the GNU Lesser General Public License, version 2.1. If you do not want to + * license your linked modules under the GNU Lesser General Public License, version 2.1, you + * may use the program under the following exception. + * + * As a special exception, the copyright holders of DLT give you permission to combine DLT + * with software programs or libraries that are released under any license unless such a combination is not + * permitted by the license of such a software program or library. You may copy and distribute such a + * system following the terms of the GNU Lesser General Public License, version 2.1, including this + * special exception, for DLT and the licenses of the other code concerned. + * + * Note that people who make modified versions of DLT are not obligated to grant this special exception + * for their modified versions; it is their choice whether to do so. The GNU Lesser General Public License, + * version 2.1, gives permission to release a modified version without this exception; this exception + * also makes it possible to release a modified version which carries forward this exception. + * + * @licence end@ + */ + +/******************************************************************************* +** ** +** SRC-MODULE: dlt-system.c ** +** ** +** TARGET : linux ** +** ** +** PROJECT : DLT ** +** ** +** AUTHOR : Alexander Wenzel Alexander.AW.Wenzel@bmw.de ** +** ** +** PURPOSE : ** +** ** +** REMARKS : ** +** ** +** PLATFORM DEPENDANT [yes/no]: yes ** +** ** +** TO BE CHANGED BY USER [yes/no]: no ** +** ** +*******************************************************************************/ + +/******************************************************************************* +** Author Identity ** +******************************************************************************** +** ** +** Initials Name Company ** +** -------- ------------------------- ---------------------------------- ** +** aw Alexander Wenzel BMW ** +** mk Markus Klein Fraunhofer ESK ** +*******************************************************************************/ + +/******************************************************************************* +** Revision Control History ** +*******************************************************************************/ + +/* + * $LastChangedRevision: 1670 $ + * $LastChangedDate: 2011-04-08 15:12:06 +0200 (Fr, 08. Apr 2011) $ + * $LastChangedBy$ + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include "dlt_common.h" +#include "dlt_user.h" + +#include "dlt-system.h" +#include "dlt-system_cfg.h" +#include "dlt-system-log.h" + +/* Port number, to which the syslogd-ng sends its log messages */ +#define MAXSTRLEN 1024 + +DLT_DECLARE_CONTEXT(syslogContext); +DLT_DECLARE_CONTEXT(kernelVersionContext); + +void dlt_system_init_options(DltSystemOptions *options) +{ + strncpy(options->ConfigurationFile,DEFAULT_CONFIGURATION_FILE,sizeof(options->ConfigurationFile)); + strncpy(options->ApplicationId,DEFAULT_APPLICATION_ID,sizeof(options->ApplicationId)); + strncpy(options->SyslogContextId,DEFAULT_SYSLOG_CONTEXT_ID,sizeof(options->SyslogContextId)); + options->SyslogPort = DEFAULT_SYSLOG_PORT; + options->KernelVersionMode = DEFAULT_KERNEL_VERSION_MODE; + strncpy(options->KernelVersionContextId,DEFAULT_KERNEL_VERSION_CONTEXT_ID,sizeof(options->KernelVersionContextId)); +} + +int dlt_system_parse_options(DltSystemOptions *options,int argc, char* argv[]) +{ + int opt; + char version[255]; + + while ((opt = getopt(argc, argv, "c:h")) != -1) + { + switch (opt) + { + case 'c': + { + strncpy(options->ConfigurationFile,optarg,sizeof(options->ConfigurationFile)); + break; + } + case 'h': + { + dlt_get_version(version); + + printf("Usage: dlt-system [options]\n"); + printf("System information manager and forwarder to DLT daemon.\n"); + printf("%s \n", version); + printf("Options:\n"); + printf("-c filename - Set configuration file (default: /etc/dlt-system.conf)\n"); + printf("-h - This help\n"); + return -1; + break; + } + default: /* '?' */ + { + fprintf(stderr, "Unknown option '%c'\n", optopt); + return -1; + } + } + } + + return 0; +} + +int dlt_system_parse_configuration(DltSystemOptions *options) +{ + FILE * pFile; + char line[1024]; + char token[1024]; + char value[1024]; + char *pch; + + /* open configuration file */ + pFile = fopen (options->ConfigurationFile,"r"); + + if (pFile!=NULL) + { + while(1) + { + /* fetch line from configuration file */ + if ( fgets (line , 1024 , pFile) != NULL ) + { + //printf("Line: %s\n",line); + pch = strtok (line," =\r\n"); + token[0]=0; + value[0]=0; + + while (pch != NULL) + { + if(strcmp(pch,"#")==0) + break; + + if(token[0]==0) + { + strncpy(token,pch,sizeof(token)); + } + else + { + strncpy(value,pch,sizeof(value)); + break; + } + + pch = strtok (NULL, " =\r\n"); + } + + if(token[0] && value[0]) + { + /* parse arguments here */ + if(strcmp(token,"ApplicationId")==0) + { + strncpy(options->ApplicationId,value,sizeof(options->ApplicationId)); + printf("Option: %s=%s\n",token,value); + } + else if(strcmp(token,"SyslogContextId")==0) + { + strncpy(options->SyslogContextId,value,sizeof(options->SyslogContextId)); + printf("Option: %s=%s\n",token,value); + } + else if(strcmp(token,"SyslogPort")==0) + { + options->SyslogPort = atoi(value); + printf("Option: %s=%s\n",token,value); + } + else if(strcmp(token,"KernelVersionMode")==0) + { + options->KernelVersionMode = atoi(value); + printf("Option: %s=%s\n",token,value); + } + else if(strcmp(token,"KernelVersionContextId")==0) + { + strncpy(options->KernelVersionContextId,value,sizeof(options->KernelVersionContextId)); + printf("Option: %s=%s\n",token,value); + } + else + { + fprintf(stderr, "Unknown option: %s=%s\n",token,value); + } + } + + } + else + { + break; + } + } + fclose (pFile); + } + else + { + fprintf(stderr, "Cannot open configuration file: %s\n",options->ConfigurationFile); + return -1; + } + + return 0; +} + +int main(int argc, char* argv[]) +{ + int sock; + int bytes_read; + socklen_t addr_len; + char recv_data[MAXSTRLEN]; + struct sockaddr_in client_addr, server_addr; + fd_set rfds; + struct timeval tv; + int retval; + uint32_t lasttime; + int firsttime = 1; + + DltSystemOptions options; + + /* init options */ + dlt_system_init_options(&options); + + /* parse command line options */ + if(dlt_system_parse_options(&options,argc,argv)) { + return -1; + } + + /* parse configuration file */ + if(dlt_system_parse_configuration(&options)) { + return -1; + } + + /* register application and contexts */ + DLT_REGISTER_APP(options.ApplicationId,"DLT System Manager"); + + DLT_REGISTER_CONTEXT(syslogContext,options.SyslogContextId,"SYSLOG Adapter"); + + if(options.KernelVersionMode != DLT_SYSTEM_MODE_OFF) + DLT_REGISTER_CONTEXT(kernelVersionContext,options.KernelVersionContextId,"Log Kernel version"); + + /* create systemd socket */ + if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) + { + perror("Socket"); + exit(1); + } + server_addr.sin_family = AF_INET; + server_addr.sin_port = htons(options.SyslogPort); + server_addr.sin_addr.s_addr = INADDR_ANY; + bzero(&(server_addr.sin_zero), 8); + if (bind(sock, (struct sockaddr *)&server_addr, + sizeof(struct sockaddr)) == -1) + { + perror("Bind"); + return -1; + } + addr_len = sizeof(struct sockaddr); + + /* Watch sockets to see when it has input. */ + FD_ZERO(&rfds); + FD_SET(sock, &rfds); + + lasttime = dlt_uptime(); + + while (1) + { + /* Wait up to one second. */ + tv.tv_sec = 0; + tv.tv_usec = (dlt_uptime()-lasttime+10000)*100; + + /* wait data to be received, or wait min time */ + retval = select(1, &rfds, NULL, NULL, &tv); + /* Don't rely on the value of tv now! */ + + if (retval == -1) + perror("select()"); + else if (retval) + printf("Data is available now.\n"); + //else + // printf("No data within one seconds.\n"); + + if((dlt_uptime()-lasttime) >= 10000) + { + /* one second elapsed */ + lasttime = dlt_uptime(); + + if(((options.KernelVersionMode == DLT_SYSTEM_MODE_STARTUP) && firsttime) || + (options.KernelVersionMode == DLT_SYSTEM_MODE_REGULAR) ) { + dlt_system_log_kernel_version(&kernelVersionContext); + } + + firsttime = 0; + } + + /* check syslog adapter socket */ + if(FD_ISSET(sock, &rfds)) + { + bytes_read = 0; + + bytes_read = recvfrom(sock, recv_data, MAXSTRLEN, 0, + (struct sockaddr *)&client_addr, &addr_len); + + if (bytes_read == -1) + { + if (errno == EINTR) + { + continue; + } + else + { + DLT_UNREGISTER_CONTEXT(syslogContext); + DLT_UNREGISTER_CONTEXT(syslogContext); + DLT_UNREGISTER_APP(); + exit(1); + } + } + + recv_data[bytes_read] = '\0'; + + if (bytes_read != 0) + { + DLT_LOG(syslogContext, DLT_LOG_INFO, DLT_STRING(recv_data)); + } + } + } + + if(options.KernelVersionMode != DLT_SYSTEM_MODE_OFF) + DLT_UNREGISTER_CONTEXT(kernelVersionContext); + + DLT_UNREGISTER_CONTEXT(syslogContext); + DLT_UNREGISTER_APP(); + + return 0; +} -- cgit v1.2.1