summaryrefslogtreecommitdiff
path: root/src/daemon/dlt-daemon.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/daemon/dlt-daemon.c')
-rw-r--r--src/daemon/dlt-daemon.c121
1 files changed, 95 insertions, 26 deletions
diff --git a/src/daemon/dlt-daemon.c b/src/daemon/dlt-daemon.c
index b5d572d..7b80ef1 100644
--- a/src/daemon/dlt-daemon.c
+++ b/src/daemon/dlt-daemon.c
@@ -185,8 +185,9 @@ int option_handling(DltDaemonLocal *daemon_local, int argc, char *argv[])
fprintf (stderr, "Invalid option, this should never occur!\n");
return -1;
}
- } /* switch() */
+ }
+ /* switch() */
#ifndef DLT_USE_UNIX_SOCKET_IPC
snprintf(daemon_local->flags.userPipesDir, DLT_PATH_MAX,
@@ -262,6 +263,7 @@ int option_file_parser(DltDaemonLocal *daemon_local)
daemon_local->flags.contextLogLevel = DLT_LOG_INFO;
daemon_local->flags.contextTraceStatus = DLT_TRACE_STATUS_OFF;
daemon_local->flags.enforceContextLLAndTS = 0; /* default is off */
+ daemon_local->flags.ipNodes = NULL;
/* open configuration file */
if (daemon_local->flags.cvalue[0])
@@ -564,6 +566,50 @@ int option_file_parser(DltDaemonLocal *daemon_local)
intval);
}
}
+ else if (strcmp(token, "BindAddress") == 0)
+ {
+ DltBindAddress_t *newNode = NULL;
+ DltBindAddress_t *temp = NULL;
+
+ char *tok = strtok(value, ",;");
+
+ if (tok != NULL) {
+ daemon_local->flags.ipNodes = calloc(1, sizeof(DltBindAddress_t));
+
+ if (daemon_local->flags.ipNodes == NULL) {
+ dlt_vlog(LOG_ERR, "Could not allocate for IP list\n");
+ return -1;
+ }
+ else {
+ strncpy(daemon_local->flags.ipNodes->ip,
+ tok,
+ sizeof(daemon_local->flags.ipNodes->ip) - 1);
+ daemon_local->flags.ipNodes->next = NULL;
+ temp = daemon_local->flags.ipNodes;
+
+ tok = strtok(NULL, ",;");
+
+ while (tok != NULL) {
+ newNode = calloc(1, sizeof(DltBindAddress_t));
+
+ if (newNode == NULL) {
+ dlt_vlog(LOG_ERR, "Could not allocate for IP list\n");
+ return -1;
+ }
+ else {
+ strncpy(newNode->ip, tok, sizeof(newNode->ip) - 1);
+ }
+
+ temp->next = newNode;
+ temp = temp->next;
+ tok = strtok(NULL, ",;");
+ }
+ }
+ }
+ else {
+ dlt_vlog(LOG_WARNING, "BindAddress option is empty\n");
+ }
+ }
else {
fprintf(stderr, "Unknown option: %s=%s\n", token, value);
}
@@ -706,7 +752,7 @@ int main(int argc, char *argv[])
/* --- Daemon init phase 2 end --- */
- if (daemon_local.flags.offlineLogstorageDirPath[0]) {
+ if (daemon_local.flags.offlineLogstorageDirPath[0])
if (dlt_daemon_logstorage_setup_internal_storage(
&daemon,
&daemon_local,
@@ -714,7 +760,6 @@ int main(int argc, char *argv[])
daemon_local.flags.vflag) == -1)
dlt_log(LOG_INFO,
"Setting up internal offline log storage failed!\n");
- }
/* create fd for watchdog */
#ifdef DLT_SYSTEMD_WATCHDOG_ENABLE
@@ -1081,6 +1126,7 @@ int dlt_daemon_local_connection_init(DltDaemon *daemon,
{
int fd = -1;
int mask = 0;
+ DltBindAddress_t *head = daemon_local->flags.ipNodes;
PRINT_FUNCTION_VERBOSE(verbose);
@@ -1124,19 +1170,43 @@ int dlt_daemon_local_connection_init(DltDaemon *daemon,
/* create and open socket to receive incoming connections from client */
daemon_local->client_connections = 0;
- if (dlt_daemon_socket_open(&fd, daemon_local->flags.port) == DLT_RETURN_OK) {
- if (dlt_connection_create(daemon_local,
- &daemon_local->pEvent,
- fd,
- POLLIN,
- DLT_CONNECTION_CLIENT_CONNECT)) {
+ if (head == NULL) { /* no IP set in BindAddress option, will use "0.0.0.0" as default */
+
+ if (dlt_daemon_socket_open(&fd, daemon_local->flags.port, "0.0.0.0") == DLT_RETURN_OK) {
+ if (dlt_connection_create(daemon_local,
+ &daemon_local->pEvent,
+ fd,
+ POLLIN,
+ DLT_CONNECTION_CLIENT_CONNECT)) {
+ dlt_log(LOG_ERR, "Could not initialize main socket.\n");
+ return DLT_RETURN_ERROR;
+ }
+ }
+ else {
dlt_log(LOG_ERR, "Could not initialize main socket.\n");
return DLT_RETURN_ERROR;
}
}
else {
- dlt_log(LOG_ERR, "Could not initialize main socket.\n");
- return DLT_RETURN_ERROR;
+ while (head != NULL) { /* open socket for each IP in the bindAddress list */
+
+ if (dlt_daemon_socket_open(&fd, daemon_local->flags.port, head->ip) == DLT_RETURN_OK) {
+ if (dlt_connection_create(daemon_local,
+ &daemon_local->pEvent,
+ fd,
+ POLLIN,
+ DLT_CONNECTION_CLIENT_CONNECT)) {
+ dlt_log(LOG_ERR, "Could not initialize main socket.\n");
+ return DLT_RETURN_ERROR;
+ }
+ }
+ else {
+ dlt_log(LOG_ERR, "Could not initialize main socket.\n");
+ return DLT_RETURN_ERROR;
+ }
+
+ head = head->next;
+ }
}
/* create and open unix socket to receive incoming connections from
@@ -1293,6 +1363,8 @@ void dlt_daemon_local_cleanup(DltDaemon *daemon, DltDaemonLocal *daemon_local, i
unlink(daemon_local->flags.ctrlSockPath);
+ /* free IP list */
+ free(daemon_local->flags.ipNodes);
}
void dlt_daemon_exit_trigger()
@@ -1480,17 +1552,15 @@ int dlt_daemon_log_internal(DltDaemon *daemon, DltDaemonLocal *daemon_local, cha
}
/* look if TCP connection to client is available */
- if ((daemon->mode == DLT_USER_MODE_EXTERNAL) || (daemon->mode == DLT_USER_MODE_BOTH)) {
+ if ((daemon->mode == DLT_USER_MODE_EXTERNAL) || (daemon->mode == DLT_USER_MODE_BOTH))
if ((ret =
dlt_daemon_client_send(DLT_DAEMON_SEND_TO_ALL, daemon, daemon_local, msg.headerbuffer,
sizeof(DltStorageHeader), msg.headerbuffer + sizeof(DltStorageHeader),
msg.headersize - sizeof(DltStorageHeader),
- msg.databuffer, msg.datasize, verbose))) {
+ msg.databuffer, msg.datasize, verbose)))
if (ret == DLT_DAEMON_ERROR_BUFFER_FULL)
daemon->overflow_counter++;
- }
- }
}
free(msg.databuffer);
@@ -2295,9 +2365,8 @@ int dlt_daemon_process_user_message_register_context(DltDaemon *daemon,
}
/* Set log level */
- if (userctxt.log_level == DLT_USER_LOG_LEVEL_NOT_SET) {
+ if (userctxt.log_level == DLT_USER_LOG_LEVEL_NOT_SET)
userctxt.log_level = DLT_LOG_DEFAULT;
- }
else
/* Plausibility check */
if ((userctxt.log_level < DLT_LOG_DEFAULT) ||
@@ -2305,9 +2374,8 @@ int dlt_daemon_process_user_message_register_context(DltDaemon *daemon,
return -1;
/* Set trace status */
- if (userctxt.trace_status == DLT_USER_TRACE_STATUS_NOT_SET) {
+ if (userctxt.trace_status == DLT_USER_TRACE_STATUS_NOT_SET)
userctxt.trace_status = DLT_TRACE_STATUS_DEFAULT;
- }
else
/* Plausibility check */
if ((userctxt.trace_status < DLT_TRACE_STATUS_DEFAULT) ||
@@ -2647,7 +2715,8 @@ int dlt_daemon_process_user_message_log(DltDaemon *daemon,
return DLT_DAEMON_ERROR_UNKNOWN;
}
}
- else if (dlt_set_storageheader(daemon_local->msg.storageheader, daemon->ecuid) == DLT_RETURN_ERROR) {
+ else if (dlt_set_storageheader(daemon_local->msg.storageheader, daemon->ecuid) == DLT_RETURN_ERROR)
+ {
dlt_log(LOG_WARNING, "Can't set storage header in process user message log\n");
return DLT_DAEMON_ERROR_UNKNOWN;
}
@@ -2686,10 +2755,9 @@ int dlt_daemon_process_user_message_log(DltDaemon *daemon,
sizeof(DltStorageHeader),
daemon_local->msg.headerbuffer + sizeof(DltStorageHeader),
daemon_local->msg.headersize - sizeof(DltStorageHeader),
- daemon_local->msg.databuffer, daemon_local->msg.datasize, verbose))) {
+ daemon_local->msg.databuffer, daemon_local->msg.datasize, verbose)))
if (ret == DLT_DAEMON_ERROR_BUFFER_FULL)
daemon->overflow_counter++;
- }
}
/* keep not read data in buffer */
@@ -2785,7 +2853,8 @@ int dlt_daemon_process_user_message_log_shm(DltDaemon *daemon,
return -1;
}
}
- else if (dlt_set_storageheader(daemon_local->msg.storageheader, daemon->ecuid) == -1) {
+ else if (dlt_set_storageheader(daemon_local->msg.storageheader, daemon->ecuid) == -1)
+ {
dlt_log(LOG_WARNING, "Can't set storage header in process user message log\n");
dlt_shm_remove(&(daemon_local->dlt_shm));
return -1;
@@ -3081,14 +3150,14 @@ int create_timer_fd(DltDaemonLocal *daemon_local,
return -1;
}
- if (period_sec <= 0 || starts_in <= 0 ) {
+ if ((period_sec <= 0) || (starts_in <= 0)) {
/* timer not activated via the service file */
dlt_vlog(LOG_INFO, "<%s> not set: period=0\n", timer_name);
local_fd = -1;
}
+
#ifdef linux
- else
- {
+ else {
struct itimerspec l_timer_spec;
local_fd = timerfd_create(CLOCK_MONOTONIC, 0);
View Lorry Controller Status