First version of DLT system mamager.

1 files changed, 370 insertions, 0 deletions

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 <alexander.wenzel@bmw.de>
+ * 
+ * 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 <http://www.gnu.org/licenses/lgpl-2.1.html>.
+ * 
+ * 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 <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <signal.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <errno.h>
+
+#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;
+}