diff options
Diffstat (limited to 'src/daemon/dlt-daemon.c')
| -rw-r--r-- | src/daemon/dlt-daemon.c | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/src/daemon/dlt-daemon.c b/src/daemon/dlt-daemon.c index 6d58bb4..f075b09 100644 --- a/src/daemon/dlt-daemon.c +++ b/src/daemon/dlt-daemon.c @@ -231,6 +231,7 @@ int option_file_parser(DltDaemonLocal *daemon_local) daemon_local->RingbufferMinSize = DLT_DAEMON_RINGBUFFER_MIN_SIZE; daemon_local->RingbufferMaxSize = DLT_DAEMON_RINGBUFFER_MAX_SIZE; daemon_local->RingbufferStepSize = DLT_DAEMON_RINGBUFFER_STEP_SIZE; + daemon_local->daemonFifoSize = 0; daemon_local->flags.sendECUSoftwareVersion = 0; memset(daemon_local->flags.pathToECUSoftwareVersion, 0, sizeof(daemon_local->flags.pathToECUSoftwareVersion)); daemon_local->flags.sendTimezone = 0; @@ -396,6 +397,10 @@ int option_file_parser(DltDaemonLocal *daemon_local) { sscanf(value,"%lu",&(daemon_local->RingbufferStepSize)); } + else if(strcmp(token,"DaemonFIFOSize")==0) + { + sscanf(value,"%lu",&(daemon_local->daemonFifoSize)); + } else if(strcmp(token,"SharedMemorySize")==0) { daemon_local->flags.sharedMemorySize = atoi(value); @@ -972,6 +977,7 @@ static int dlt_daemon_init_fifo(DltDaemonLocal *daemon_local) { int ret; int fd = -1; + int fifo_size; char local_str[DLT_DAEMON_TEXTBUFSIZE]; /* open named pipe(FIFO) to receive DLT messages from users */ @@ -1005,6 +1011,28 @@ static int dlt_daemon_init_fifo(DltDaemonLocal *daemon_local) return -1; } /* if */ + if (daemon_local->daemonFifoSize != 0) + { + /* Set Daemon FIFO size */ + if (fcntl(fd, F_SETPIPE_SZ , daemon_local->daemonFifoSize) == -1) + { + snprintf(str,DLT_DAEMON_TEXTBUFSIZE,"set FIFO size error: %s\n",strerror(errno)); + dlt_log(LOG_ERR, str); + } + } + + /* Get Daemon FIFO size */ + if ((fifo_size = fcntl(fd, F_GETPIPE_SZ , 0)) == -1) + { + snprintf(str,DLT_DAEMON_TEXTBUFSIZE,"get FIFO size error: %s\n",strerror(errno)); + dlt_log(LOG_ERR, str); + } + else + { + snprintf(str,DLT_DAEMON_TEXTBUFSIZE,"FIFO size: %d\n",fifo_size); + dlt_log(LOG_INFO, str); + } + /* Early init, to be able to catch client (app) connections * as soon as possible. This registration is automatically ignored * during next execution. |