diff options
author | Alexander Wenzel <Alexander.AW.Wenzel@bmw.de> | 2013-12-18 09:46:02 +0100 |
---|---|---|
committer | Alexander Wenzel <Alexander.AW.Wenzel@bmw.de> | 2014-01-10 07:16:12 +0100 |
commit | 8029c1387c240fcd085be13f38d9adadc97c03bf (patch) | |
tree | 68a96ca17aff21607433cef7f89a457cc73db5ee /src/daemon/dlt-daemon.c | |
parent | b7a37dc39a2a975e594bdb554e752c8ed563673e (diff) | |
download | DLT-daemon-8029c1387c240fcd085be13f38d9adadc97c03bf.tar.gz |
Moved daemon client functions to new source file.
Signed-off-by: Alexander Wenzel <Alexander.AW.Wenzel@bmw.de>
Diffstat (limited to 'src/daemon/dlt-daemon.c')
-rw-r--r-- | src/daemon/dlt-daemon.c | 1653 |
1 files changed, 32 insertions, 1621 deletions
diff --git a/src/daemon/dlt-daemon.c b/src/daemon/dlt-daemon.c index 8fc71e6..9ace6f0 100644 --- a/src/daemon/dlt-daemon.c +++ b/src/daemon/dlt-daemon.c @@ -90,6 +90,8 @@ #include "dlt_daemon_socket.h" #include "dlt_daemon_serial.h" +#include "dlt_daemon_client.h" + #if defined(DLT_SYSTEMD_WATCHDOG_ENABLE) || defined(DLT_SYSTEMD_ENABLE) #include "sd-daemon.h" #endif @@ -477,13 +479,13 @@ int main(int argc, char* argv[]) #endif // create fd for timer timing packets - create_timer_fd(&daemon_local, 1, 1, &daemon_local.timer_timingpacket, "Timing packet"); + create_timer_fd(&daemon_local, 1, 1, &daemon_local.timer_one_s, "Timing packet"); // create fd for timer ecu version if(daemon_local.flags.sendECUSoftwareVersion > 0 || daemon_local.flags.sendTimezone > 0) { //dlt_daemon_init_ecuversion(&daemon_local); - create_timer_fd(&daemon_local, 60, 60, &daemon_local.timer_ecuversion, "ECU version"); + create_timer_fd(&daemon_local, 60, 60, &daemon_local.timer_sixty_s, "ECU version"); } if(daemon_local.flags.yvalue[0]) @@ -554,32 +556,41 @@ int main(int argc, char* argv[]) } } #endif - else if (i == daemon_local.timer_timingpacket) + else if (i == daemon_local.timer_one_s) { uint64_t expir=0; - ssize_t res = read(daemon_local.timer_timingpacket, &expir, sizeof(expir)); + ssize_t res = read(daemon_local.timer_one_s, &expir, sizeof(expir)); if(res < 0) { sprintf(str,"Failed to read timer_timingpacket; %s\n", strerror(errno) ); dlt_log(LOG_WARNING, str); // Activity received on timer_wd, but unable to read the fd: // let's go on sending notification } - dlt_daemon_send_timingpacket(&daemon, &daemon_local); + if (daemon.timingpackets) + { + dlt_daemon_control_message_time(DLT_DAEMON_SEND_TO_ALL, &daemon, &daemon_local, daemon_local.flags.vflag); + } dlt_log(LOG_DEBUG, "Timer timingpacket\n"); } - else if (i == daemon_local.timer_ecuversion) + else if (i == daemon_local.timer_sixty_s) { uint64_t expir=0; - ssize_t res = read(daemon_local.timer_ecuversion, &expir, sizeof(expir)); + ssize_t res = read(daemon_local.timer_sixty_s, &expir, sizeof(expir)); if(res < 0) { sprintf(str,"Failed to read timer_ecuversion; %s\n", strerror(errno) ); dlt_log(LOG_WARNING, str); // Activity received on timer_wd, but unable to read the fd: // let's go on sending notification } - dlt_daemon_send_ecuversion(&daemon, &daemon_local); + if(daemon_local.flags.sendECUSoftwareVersion > 0) + dlt_daemon_control_get_software_version(DLT_DAEMON_SEND_TO_ALL, &daemon,&daemon_local, daemon_local.flags.vflag); + + if(daemon_local.flags.sendTimezone > 0) + { + dlt_daemon_control_message_timezone(DLT_DAEMON_SEND_TO_ALL,&daemon,&daemon_local,daemon_local.flags.vflag); + } dlt_log(LOG_DEBUG, "Timer ecuversion\n"); } @@ -766,10 +777,6 @@ int dlt_daemon_local_init_p2(DltDaemon *daemon, DltDaemonLocal *daemon_local, in int dlt_daemon_local_connection_init(DltDaemon *daemon, DltDaemonLocal *daemon_local, int verbose) { int ret; - int yes = 1; - - struct sockaddr_in servAddr; - unsigned int servPort = DLT_DAEMON_TCP_PORT; PRINT_FUNCTION_VERBOSE(verbose); @@ -819,44 +826,8 @@ int dlt_daemon_local_connection_init(DltDaemon *daemon, DltDaemonLocal *daemon_l } /* if */ /* create and open socket to receive incoming connections from client */ - if ((daemon_local->sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) - { - dlt_log(LOG_ERR, "socket() failed!\n"); - return -1; - } /* if */ - - if ( -1 == setsockopt(daemon_local->sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int))) - { - sprintf(str,"Setsockopt error in dlt_daemon_local_connection_init: %s\n",strerror(errno)); - dlt_log(LOG_ERR, str); - return -1; - } - memset(&servAddr, 0, sizeof(servAddr)); - servAddr.sin_family = AF_INET; - servAddr.sin_addr.s_addr = INADDR_ANY; - servAddr.sin_port = htons(servPort); - - if (bind(daemon_local->sock, (struct sockaddr *) &servAddr, sizeof(servAddr)) < 0) - { - dlt_log(LOG_ERR, "bind() failed!\n"); - return -1; - } /* if */ - - if (daemon_local->flags.vflag) - { - dlt_log(LOG_INFO, "Bind succesfull\n"); - } - - if (listen(daemon_local->sock, 3) < 0) - { - dlt_log(LOG_ERR, "listen() failed!\n"); - return -1; - } /* if */ - - if (daemon_local->flags.vflag) - { - dlt_log(LOG_INFO, "Listen succesfull\n"); - } + if(dlt_daemon_socket_open(&(daemon_local->sock))) + return -1; /* prepare usage of select(), add FIFO and receiving socket */ FD_ZERO(&(daemon_local->master)); @@ -1210,7 +1181,13 @@ int dlt_daemon_process_client_connect(DltDaemon *daemon, DltDaemonLocal *daemon_ // send ecu version string if(daemon_local->flags.sendECUSoftwareVersion > 0) { - dlt_daemon_send_ecuversion(daemon,daemon_local); + if(daemon_local->flags.sendECUSoftwareVersion > 0) + dlt_daemon_control_get_software_version(DLT_DAEMON_SEND_TO_ALL, daemon,daemon_local, daemon_local->flags.vflag); + + if(daemon_local->flags.sendTimezone > 0) + { + dlt_daemon_control_message_timezone(DLT_DAEMON_SEND_TO_ALL,daemon,daemon_local,daemon_local->flags.vflag); + } } if (daemon_local->client_connections==1) @@ -1260,7 +1237,7 @@ int dlt_daemon_process_client_messages(DltDaemon *daemon, DltDaemonLocal *daemon /* Check for control message */ if ( 0 < daemon_local->receiverSock.fd && DLT_MSG_IS_CONTROL_REQUEST(&(daemon_local->msg)) ) { - dlt_daemon_control_process_control(daemon_local->receiverSock.fd, daemon,daemon_local, &(daemon_local->msg), daemon_local->flags.vflag); + dlt_daemon_client_process_control(daemon_local->receiverSock.fd, daemon,daemon_local, &(daemon_local->msg), daemon_local->flags.vflag); } bytes_to_be_removed = daemon_local->msg.headersize+daemon_local->msg.datasize-sizeof(DltStorageHeader); @@ -1315,7 +1292,7 @@ int dlt_daemon_process_client_messages_serial(DltDaemon *daemon, DltDaemonLocal /* Check for control message */ if (DLT_MSG_IS_CONTROL_REQUEST(&(daemon_local->msg))) { - if (dlt_daemon_control_process_control(daemon_local->receiverSerial.fd, daemon,daemon_local, &(daemon_local->msg), daemon_local->flags.vflag)==-1) + if (dlt_daemon_client_process_control(daemon_local->receiverSerial.fd, daemon,daemon_local, &(daemon_local->msg), daemon_local->flags.vflag)==-1) { dlt_log(LOG_ERR,"Can't process control messages\n"); return -1; @@ -2367,65 +2344,6 @@ int dlt_daemon_send_ringbuffer_to_client(DltDaemon *daemon, DltDaemonLocal *daem return 0; } -int dlt_daemon_make_periodic (unsigned int period, DltDaemonPeriodicData *info, int verbose) -{ - int ret; - unsigned int ns; - unsigned int sec; - int fd; - struct itimerspec itval; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (info==0) - { - dlt_log(LOG_ERR,"No data pointer passed!\n"); - return -1; - } - - /* Create the timer */ - fd = timerfd_create (CLOCK_MONOTONIC, 0); - - info->wakeups_missed = 0; - info->timer_fd = fd; - - if (fd == -1) - { - dlt_log(LOG_ERR,"Can't create timer filedescriptor"); - return -1; - } - - /* Make the timer periodic */ - sec = period/1000000; - ns = (period - (sec * 1000000)) * 1000; - itval.it_interval.tv_sec = sec; - itval.it_interval.tv_nsec = ns; - itval.it_value.tv_sec = sec; - itval.it_value.tv_nsec = ns; - - ret = timerfd_settime (fd, 0, &itval, NULL); - - return ret; -} - -void dlt_daemon_wait_period (DltDaemonPeriodicData *info, int verbose) -{ - unsigned long long missed; - int ret; - - PRINT_FUNCTION_VERBOSE(verbose); - - ret = read (info->timer_fd, &missed, sizeof (missed)); - if (0 > ret){ - dlt_log(LOG_ERR,"dlt_daemon_wait_period: Read failed"); - } - - if (missed > 0) - { - info->wakeups_missed += (missed - 1); - } -} - int create_timer_fd(DltDaemonLocal *daemon_local, int period_sec, int starts_in, int* fd, const char* timer_name) { int local_fd; @@ -2489,35 +2407,11 @@ int create_timer_fd(DltDaemonLocal *daemon_local, int period_sec, int starts_in, return local_fd; } -void dlt_daemon_send_timingpacket(DltDaemon *daemon, DltDaemonLocal *daemon_local) -{ - if (daemon->timingpackets) - { - dlt_log(LOG_DEBUG, "timingpacket\n"); - dlt_daemon_control_message_time(DLT_DAEMON_SEND_TO_ALL, daemon, daemon_local, daemon_local->flags.vflag); - } -} - -void dlt_daemon_send_ecuversion(DltDaemon *daemon, DltDaemonLocal *daemon_local) -{ - dlt_log(LOG_DEBUG, "ecu_version\n"); - if(daemon_local->flags.sendECUSoftwareVersion > 0) - dlt_daemon_control_get_software_version(DLT_DAEMON_SEND_TO_ALL, daemon,daemon_local, daemon_local->flags.vflag); - - if(daemon_local->flags.sendTimezone > 0) - { - // send timezone information - time_t t = time(NULL); - struct tm lt = {0}; - localtime_r(&t, <); - dlt_daemon_control_message_timezone(DLT_DAEMON_SEND_TO_ALL,daemon,daemon_local,(int32_t) lt.tm_gmtoff,(uint8_t) lt.tm_isdst,daemon_local->flags.vflag); - } -} - /* Close connection function */ int dlt_daemon_close_socket(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, int verbose) { - close(sock); + dlt_daemon_socket_close(sock); + FD_CLR(sock, &(daemon_local->master)); if (daemon_local->client_connections) @@ -2544,1489 +2438,6 @@ int dlt_daemon_close_socket(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_ return 0; } -int dlt_daemon_client_send(int sock,DltDaemon *daemon,DltDaemonLocal *daemon_local,void* data1,int size1,void* data2,int size2,char ringbuffer,int verbose) -{ - int j,third_value; - - if (sock!=DLT_DAEMON_SEND_TO_ALL) - { - /* Send message to specific socket */ - if (isatty(sock)) - { - DLT_DAEMON_SEM_LOCK(); - - if(dlt_daemon_serial_send(sock,data1,size1,data2,size2,daemon->sendserialheader)) - { - dlt_log(LOG_WARNING,"dlt_daemon_control_send_control_message: serial send dlt message failed\n"); - DLT_DAEMON_SEM_FREE(); - return -1; - } - - DLT_DAEMON_SEM_FREE(); - } - else - { - DLT_DAEMON_SEM_LOCK(); - - if(dlt_daemon_socket_send(sock,data1,size1,data2,size2,daemon->sendserialheader)) - { - dlt_log(LOG_WARNING,"dlt_daemon_control_send_control_message: socket send dlt message failed\n"); - DLT_DAEMON_SEM_FREE(); - return -1; - } - - DLT_DAEMON_SEM_FREE(); - } - return 0; - } - - /* write message to offline trace */ - if (!ringbuffer && (daemon->state == DLT_DAEMON_STATE_SEND_DIRECT)) - { - if(((daemon->mode == DLT_USER_MODE_INTERNAL) || (daemon->mode == DLT_USER_MODE_BOTH)) - && daemon_local->flags.offlineTraceDirectory[0]) - { - dlt_offline_trace_write(&(daemon_local->offlineTrace),daemon_local->msg.headerbuffer,daemon_local->msg.headersize, - daemon_local->msg.databuffer,daemon_local->msg.datasize,0,0); - } - } - - /* send messages to daemon socket */ - if (ringbuffer || (daemon->state == DLT_DAEMON_STATE_SEND_DIRECT)) - { - /* look if TCP connection to client is available */ - for (j = 0; j <= daemon_local->fdmax; j++) - { - /* send to everyone! */ - if (FD_ISSET(j, &(daemon_local->master))) - { - /* except the listener and ourselves */ - if (daemon_local->flags.yvalue[0]) - { - third_value = daemon_local->fdserial; - } - else - { - third_value = daemon_local->sock; - } - if ((j != daemon_local->fp) && (j != daemon_local->sock) && (j != third_value) - #ifdef DLT_SYSTEMD_WATCHDOG_ENABLE - && (j!=daemon_local->timer_wd) - #endif - && (j!=daemon_local->timer_timingpacket) && (j!=daemon_local->timer_ecuversion)) - { - /* Send message */ - if (isatty(j)) - { - DLT_DAEMON_SEM_LOCK(); - - if(dlt_daemon_serial_send(j,data1,size1,data2,size2,daemon->sendserialheader)) - { - dlt_log(LOG_WARNING,"dlt_daemon_send_all: serial send dlt message failed\n"); - } - - DLT_DAEMON_SEM_FREE(); - } - else - { - DLT_DAEMON_SEM_LOCK(); - - if(dlt_daemon_socket_send(j,data1,size1,data2,size2,daemon->sendserialheader)) - { - dlt_log(LOG_WARNING,"dlt_daemon_send_all: socket send dlt message failed\n"); - dlt_daemon_close_socket(j, daemon, daemon_local, verbose); - } - - DLT_DAEMON_SEM_FREE(); - } - - } - } - } - } - - /* Message was not sent to client, so store it in client ringbuffer */ - if (!ringbuffer && (daemon->state == DLT_DAEMON_STATE_BUFFER || daemon->state == DLT_DAEMON_STATE_SEND_BUFFER)) - { - DLT_DAEMON_SEM_LOCK(); - /* Store message in history buffer */ - if (dlt_buffer_push3(&(daemon->client_ringbuffer),data1,size1,data2,size2,0, 0)<0) - { - DLT_DAEMON_SEM_FREE(); - dlt_log(LOG_ERR,"dlt_daemon_send_all: Buffer is full! Message discarded.\n"); - } - DLT_DAEMON_SEM_FREE(); - } - - return 0; - -} - -void dlt_daemon_control_get_software_version(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, int verbose) -{ - DltMessage msg; - uint32_t len; - DltServiceGetSoftwareVersionResponse *resp; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (daemon==0) - { - return; - } - - /* initialise new message */ - if (dlt_message_init(&msg,0)==-1) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_GET_SOFTWARE_VERSION, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - /* prepare payload of data */ - len = strlen(daemon->ECUVersionString); - - msg.datasize = sizeof(DltServiceGetSoftwareVersionResponse) + len; - if (msg.databuffer && (msg.databuffersize < msg.datasize)) - { - free(msg.databuffer); - msg.databuffer=0; - } - if (msg.databuffer == 0){ - msg.databuffer = (uint8_t *) malloc(msg.datasize); - msg.databuffersize = msg.datasize; - } - if (msg.databuffer==0) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_GET_SOFTWARE_VERSION, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - resp = (DltServiceGetSoftwareVersionResponse*) msg.databuffer; - resp->service_id = DLT_SERVICE_ID_GET_SOFTWARE_VERSION; - resp->status = DLT_SERVICE_RESPONSE_OK; - resp->length = len; - memcpy(msg.databuffer+sizeof(DltServiceGetSoftwareVersionResponse),daemon->ECUVersionString,len); - - /* send message */ - dlt_daemon_control_send_control_message(sock, daemon,daemon_local, &msg,"","", verbose); - - /* free message */ - dlt_message_free(&msg,0); -} - -void dlt_daemon_control_get_default_log_level(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, int verbose) -{ - DltMessage msg; - DltServiceGetDefaultLogLevelResponse *resp; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (daemon==0) - { - return; - } - - /* initialise new message */ - if (dlt_message_init(&msg,0)==-1) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_GET_DEFAULT_LOG_LEVEL, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - msg.datasize = sizeof(DltServiceGetDefaultLogLevelResponse); - if (msg.databuffer && (msg.databuffersize<msg.datasize)) - { - free(msg.databuffer); - msg.databuffer=0; - } - if (msg.databuffer == 0){ - msg.databuffer = (uint8_t *) malloc(msg.datasize); - msg.databuffersize = msg.datasize; - } - if (msg.databuffer==0) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_GET_DEFAULT_LOG_LEVEL, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - resp = (DltServiceGetDefaultLogLevelResponse*) msg.databuffer; - resp->service_id = DLT_SERVICE_ID_GET_DEFAULT_LOG_LEVEL; - resp->status = DLT_SERVICE_RESPONSE_OK; - resp->log_level = daemon->default_log_level; - - /* send message */ - dlt_daemon_control_send_control_message(sock,daemon,daemon_local,&msg,"","", verbose); - - /* free message */ - dlt_message_free(&msg,0); -} - -void dlt_daemon_control_get_log_info(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, int verbose) -{ - DltServiceGetLogInfoRequest *req; - DltMessage resp; - DltDaemonContext *context=0; - DltDaemonApplication *application=0; - - int num_applications=0, num_contexts=0; - uint16_t count_app_ids=0, count_con_ids=0; - -#if (DLT_DEBUG_GETLOGINFO==1) - char buf[255]; -#endif - - int32_t i,j,offset=0; - char *apid=0; - int8_t ll,ts; - uint16_t len; - int8_t value; - int32_t sizecont=0; - int offset_base; - - uint32_t sid; - - PRINT_FUNCTION_VERBOSE(verbose); - - if ((daemon==0) || (msg==0)) - { - return; - } - - /* prepare pointer to message request */ - req = (DltServiceGetLogInfoRequest*) (msg->databuffer); - - /* initialise new message */ - if (dlt_message_init(&resp,0)==-1) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_GET_LOG_INFO, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - /* check request */ - if ((req->options < 3 ) || (req->options>7)) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_GET_LOG_INFO, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - if (req->apid[0]!='\0') - { - application = dlt_daemon_application_find(daemon, req->apid, verbose); - if (application) - { - num_applications = 1; - if (req->ctid[0]!='\0') - { - context = dlt_daemon_context_find(daemon, req->apid, req->ctid, verbose); - - num_contexts = ((context)?1:0); - } - else - { - num_contexts = application->num_contexts; - } - } - else - { - num_applications = 0; - num_contexts = 0; - } - } - else - { - /* Request all applications and contexts */ - num_applications = daemon->num_applications; - num_contexts = daemon->num_contexts; - } - - /* prepare payload of data */ - - /* Calculate maximum size for a response */ - resp.datasize = sizeof(uint32_t) /* SID */ + sizeof(int8_t) /* status*/ + sizeof(ID4) /* DLT_DAEMON_REMO_STRING */; - - sizecont = sizeof(uint32_t) /* context_id */; - - /* Add additional size for response of Mode 4, 6, 7 */ - if ((req->options==4) || (req->options==6) || (req->options==7)) - { - sizecont += sizeof(int8_t); /* log level */ - } - - /* Add additional size for response of Mode 5, 6, 7 */ - if ((req->options==5) || (req->options==6) || (req->options==7)) - { - sizecont+= sizeof(int8_t); /* trace status */ - } - - resp.datasize+= (num_applications * (sizeof(uint32_t) /* app_id */ + sizeof(uint16_t) /* count_con_ids */)) + - (num_contexts * sizecont); - - resp.datasize+= sizeof(uint16_t) /* count_app_ids */; - - /* Add additional size for response of Mode 7 */ - if (req->options==7) - { - if (req->apid[0]!='\0') - { - if (req->ctid[0]!='\0') - { - /* One application, one context */ - // context = dlt_daemon_context_find(daemon, req->apid, req->ctid, verbose); - if (context) - { - resp.datasize+=sizeof(uint16_t) /* len_context_description */; - if (context->context_description!=0) - { - resp.datasize+=strlen(context->context_description); /* context_description */ - } - } - } - else - { - /* One application, all contexts */ - if ((daemon->applications) && (application)) - { - /* Calculate start offset within contexts[] */ - offset_base=0; - for (i=0; i<(application-(daemon->applications)); i++) - { - offset_base+=daemon->applications[i].num_contexts; - } - - /* Iterate over all contexts belonging to this application */ - for (j=0;j<application->num_contexts;j++) - { - - context = &(daemon->contexts[offset_base+j]); - if (context) - { - resp.datasize+=sizeof(uint16_t) /* len_context_description */; - if (context->context_description!=0) - { - resp.datasize+=strlen(context->context_description); /* context_description */ - } - } - } - } - } - - /* Space for application description */ - if (application) - { - resp.datasize+=sizeof(uint16_t) /* len_app_description */; - if (application->application_description!=0) - { - resp.datasize+=strlen(application->application_description); /* app_description */ - } - } - } - else - { - /* All applications, all contexts */ - for (i=0;i<daemon->num_contexts;i++) - { - resp.datasize+=sizeof(uint16_t) /* len_context_description */; - if (daemon->contexts[i].context_description!=0) - { - resp.datasize+=strlen(daemon->contexts[i].context_description); /* context_description */ - } - } - - for (i=0;i<daemon->num_applications;i++) - { - resp.datasize+=sizeof(uint16_t) /* len_app_description */; - if (daemon->applications[i].application_description!=0) - { - resp.datasize+=strlen(daemon->applications[i].application_description); /* app_description */ - } - } - } - } - - if (verbose) - { - sprintf(str,"Allocate %d bytes for response msg databuffer\n", resp.datasize); - dlt_log(LOG_INFO, str); - } - - /* Allocate buffer for response message */ - resp.databuffer = (uint8_t *) malloc(resp.datasize); - resp.databuffersize = resp.datasize; - - if (resp.databuffer==0) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_GET_LOG_INFO, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - memset(resp.databuffer,0,resp.datasize); - /* Preparation finished */ - - /* Prepare response */ - sid = DLT_SERVICE_ID_GET_LOG_INFO; - memcpy(resp.databuffer,&sid,sizeof(uint32_t)); - offset+=sizeof(uint32_t); - - value = (((num_applications!=0)&&(num_contexts!=0))?req->options:8); /* 8 = no matching context found */ - - memcpy(resp.databuffer+offset,&value,sizeof(int8_t)); - offset+=sizeof(int8_t); - - count_app_ids = num_applications; - - if (count_app_ids!=0) - { - memcpy(resp.databuffer+offset,&count_app_ids,sizeof(uint16_t)); - offset+=sizeof(uint16_t); - -#if (DLT_DEBUG_GETLOGINFO==1) - sprintf(str,"#apid: %d \n", count_app_ids); - dlt_log(LOG_DEBUG, str); -#endif - - for (i=0;i<count_app_ids;i++) - { - if (req->apid[0]!='\0') - { - apid = req->apid; - } - else - { - if (daemon->applications) - { - apid = daemon->applications[i].apid; - } - else - { - /* This should never occur! */ - apid=0; - } - } - - application = dlt_daemon_application_find(daemon, apid, verbose); - - if (application) - { - /* Calculate start offset within contexts[] */ - offset_base=0; - for (j=0; j<(application-(daemon->applications)); j++) - { - offset_base+=daemon->applications[j].num_contexts; - } - - dlt_set_id((char*)(resp.databuffer+offset),apid); - offset+=sizeof(ID4); - -#if (DLT_DEBUG_GETLOGINFO==1) - dlt_print_id(buf, apid); - sprintf(str,"apid: %s\n",buf); - dlt_log(LOG_DEBUG, str); -#endif - - if (req->apid[0]!='\0') - { - count_con_ids = num_contexts; - } - else - { - count_con_ids = application->num_contexts; - } - - memcpy(resp.databuffer+offset,&count_con_ids,sizeof(uint16_t)); - offset+=sizeof(uint16_t); - -#if (DLT_DEBUG_GETLOGINFO==1) - sprintf(str,"#ctid: %d \n", count_con_ids); - dlt_log(LOG_DEBUG, str); -#endif - - for (j=0;j<count_con_ids;j++) - { -#if (DLT_DEBUG_GETLOGINFO==1) - sprintf(str,"j: %d \n",j); - dlt_log(LOG_DEBUG, str); -#endif - if (!((count_con_ids==1) && (req->apid[0]!='\0') && (req->ctid[0]!='\0'))) - { - context = &(daemon->contexts[offset_base+j]); - } - /* else: context was already searched and found - (one application (found) with one context (found))*/ - - if ((context) && - ((req->ctid[0]=='\0') || - ((req->ctid[0]!='\0') && (memcmp(context->ctid,req->ctid,DLT_ID_SIZE)==0))) - ) - { - dlt_set_id((char*)(resp.databuffer+offset),context->ctid); - offset+=sizeof(ID4); - -#if (DLT_DEBUG_GETLOGINFO==1) - dlt_print_id(buf, context->ctid); - sprintf(str,"ctid: %s \n",buf); - dlt_log(LOG_DEBUG, str); -#endif - - /* Mode 4, 6, 7 */ - if ((req->options==4) || (req->options==6) || (req->options==7)) - { - ll=context->log_level; - memcpy(resp.databuffer+offset,&ll,sizeof(int8_t)); - offset+=sizeof(int8_t); - } - - /* Mode 5, 6, 7 */ - if ((req->options==5) || (req->options==6) || (req->options==7)) - { - ts=context->trace_status; - memcpy(resp.databuffer+offset,&ts,sizeof(int8_t)); - offset+=sizeof(int8_t); - } - - /* Mode 7 */ - if (req->options==7) - { - if (context->context_description) - { - len = strlen(context->context_description); - memcpy(resp.databuffer+offset,&len,sizeof(uint16_t)); - offset+=sizeof(uint16_t); - memcpy(resp.databuffer+offset,context->context_description,strlen(context->context_description)); - offset+=strlen(context->context_description); - } - else - { - len = 0; - memcpy(resp.databuffer+offset,&len,sizeof(uint16_t)); - offset+=sizeof(uint16_t); - } - } - -#if (DLT_DEBUG_GETLOGINFO==1) - sprintf(str,"ll=%d ts=%d \n",(int32_t)ll,(int32_t)ts); - dlt_log(LOG_DEBUG, str); -#endif - } - -#if (DLT_DEBUG_GETLOGINFO==1) - dlt_log(LOG_DEBUG,"\n"); -#endif - } - - /* Mode 7 */ - if (req->options==7) - { - if (application->application_description) - { - len = strlen(application->application_description); - memcpy(resp.databuffer+offset,&len,sizeof(uint16_t)); - offset+=sizeof(uint16_t); - memcpy(resp.databuffer+offset,application->application_description,strlen(application->application_description)); - offset+=strlen(application->application_description); - } - else - { - len = 0; - memcpy(resp.databuffer+offset,&len,sizeof(uint16_t)); - offset+=sizeof(uint16_t); - } - } - } /* if (application) */ - } /* for (i=0;i<count_app_ids;i++) */ - } /* if (count_app_ids!=0) */ - - dlt_set_id((char*)(resp.databuffer+offset),DLT_DAEMON_REMO_STRING); - - /* send message */ - dlt_daemon_control_send_control_message(sock,daemon,daemon_local,&resp,"","", verbose); - - /* free message */ - dlt_message_free(&resp,0); -} - -int dlt_daemon_control_message_buffer_overflow(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, unsigned int overflow_counter,char* apid, int verbose) -{ - DltMessage msg; - DltServiceMessageBufferOverflowResponse *resp; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (daemon==0) - { - return -1; - } - - /* initialise new message */ - if (dlt_message_init(&msg,0)==-1) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_MESSAGE_BUFFER_OVERFLOW, DLT_SERVICE_RESPONSE_ERROR, verbose); - return -1; - } - - /* prepare payload of data */ - msg.datasize = sizeof(DltServiceMessageBufferOverflowResponse); - if (msg.databuffer && (msg.databuffersize < msg.datasize)) - { - free(msg.databuffer); - msg.databuffer=0; - } - if (msg.databuffer == 0){ - msg.databuffer = (uint8_t *) malloc(msg.datasize); - msg.databuffersize = msg.datasize; - } - if (msg.databuffer==0) - { - return -1; - } - - resp = (DltServiceMessageBufferOverflowResponse*) msg.databuffer; - resp->service_id = DLT_SERVICE_ID_MESSAGE_BUFFER_OVERFLOW; - resp->status = DLT_SERVICE_RESPONSE_OK; - resp->overflow = daemon->message_buffer_overflow; - resp->overflow_counter = overflow_counter; - - /* send message */ - if(dlt_daemon_control_send_control_message(sock,daemon,daemon_local,&msg,apid,"", verbose)) - { - dlt_message_free(&msg,0); - return -1; - } - - /* free message */ - dlt_message_free(&msg,0); - - return 0; -} - -void dlt_daemon_control_service_response( int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, uint32_t service_id, int8_t status , int verbose) -{ - DltMessage msg; - DltServiceResponse *resp; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (daemon==0) - { - return; - } - - /* initialise new message */ - if (dlt_message_init(&msg,0)==-1) - { - return; - } - - /* prepare payload of data */ - msg.datasize = sizeof(DltServiceResponse); - if (msg.databuffer && (msg.databuffersize < msg.datasize)) - { - free(msg.databuffer); - msg.databuffer=0; - } - if (msg.databuffer == 0){ - msg.databuffer = (uint8_t *) malloc(msg.datasize); - msg.databuffersize = msg.datasize; - } - if (msg.databuffer==0) - { - return; - } - - resp = (DltServiceResponse*) msg.databuffer; - resp->service_id = service_id; - resp->status = status; - - /* send message */ - dlt_daemon_control_send_control_message(sock,daemon,daemon_local,&msg,"","", verbose); - - /* free message */ - dlt_message_free(&msg,0); -} - -int dlt_daemon_control_message_unregister_context(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, char* apid, char* ctid, char* comid, int verbose) -{ - DltMessage msg; - DltServiceUnregisterContext *resp; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (daemon==0) - { - return -1; - } - - /* initialise new message */ - if (dlt_message_init(&msg,0)==-1) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_MESSAGE_BUFFER_OVERFLOW, DLT_SERVICE_RESPONSE_ERROR, verbose); - return -1; - } - - /* prepare payload of data */ - msg.datasize = sizeof(DltServiceUnregisterContext); - if (msg.databuffer && (msg.databuffersize < msg.datasize)) - { - free(msg.databuffer); - msg.databuffer=0; - } - if (msg.databuffer == 0){ - msg.databuffer = (uint8_t *) malloc(msg.datasize); - msg.databuffersize = msg.datasize; - } - if (msg.databuffer==0) - { - return -1; - } - - resp = (DltServiceUnregisterContext*) msg.databuffer; - resp->service_id = DLT_SERVICE_ID_UNREGISTER_CONTEXT; - resp->status = DLT_SERVICE_RESPONSE_OK; - dlt_set_id(resp->apid, apid); - dlt_set_id(resp->ctid, ctid); - dlt_set_id(resp->comid, comid); - - /* send message */ - if(dlt_daemon_control_send_control_message(sock,daemon,daemon_local,&msg,"","", verbose)) - { - dlt_message_free(&msg,0); - return -1; - } - - /* free message */ - dlt_message_free(&msg,0); - - return 0; -} - -int dlt_daemon_control_message_connection_info(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, uint8_t state, char* comid, int verbose) -{ - DltMessage msg; - DltServiceConnectionInfo *resp; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (daemon==0) - { - return -1; - } - - /* initialise new message */ - if (dlt_message_init(&msg,0)==-1) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_MESSAGE_BUFFER_OVERFLOW, DLT_SERVICE_RESPONSE_ERROR, verbose); - return -1; - } - - /* prepare payload of data */ - msg.datasize = sizeof(DltServiceConnectionInfo); - if (msg.databuffer && (msg.databuffersize < msg.datasize)) - { - free(msg.databuffer); - msg.databuffer=0; - } - if (msg.databuffer == 0){ - msg.databuffer = (uint8_t *) malloc(msg.datasize); - msg.databuffersize = msg.datasize; - } - if (msg.databuffer==0) - { - return -1; - } - - resp = (DltServiceConnectionInfo*) msg.databuffer; - resp->service_id = DLT_SERVICE_ID_CONNECTION_INFO; - resp->status = DLT_SERVICE_RESPONSE_OK; - resp->state = state; - dlt_set_id(resp->comid, comid); - - /* send message */ - if(dlt_daemon_control_send_control_message(sock,daemon,daemon_local,&msg,"","", verbose)) - { - dlt_message_free(&msg,0); - return -1; - } - - /* free message */ - dlt_message_free(&msg,0); - - return 0; -} - -int dlt_daemon_control_message_timezone(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, int32_t timezone, uint8_t isdst, int verbose) -{ - DltMessage msg; - DltServiceTimezone *resp; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (daemon==0) - { - return -1; - } - - /* initialise new message */ - if (dlt_message_init(&msg,0)==-1) - { - dlt_daemon_control_service_response(sock, daemon,daemon_local, DLT_SERVICE_ID_MESSAGE_BUFFER_OVERFLOW, DLT_SERVICE_RESPONSE_ERROR, verbose); - return -1; - } - - /* prepare payload of data */ - msg.datasize = sizeof(DltServiceTimezone); - if (msg.databuffer && (msg.databuffersize < msg.datasize)) - { - free(msg.databuffer); - msg.databuffer=0; - } - if (msg.databuffer == 0){ - msg.databuffer = (uint8_t *) malloc(msg.datasize); - msg.databuffersize = msg.datasize; - } - if (msg.databuffer==0) - { - return -1; - } - - resp = (DltServiceTimezone*) msg.databuffer; - resp->service_id = DLT_SERVICE_ID_TIMEZONE; - resp->status = DLT_SERVICE_RESPONSE_OK; - resp->timezone = timezone; - resp->isdst = isdst; - - /* send message */ - if(dlt_daemon_control_send_control_message(sock,daemon,daemon_local,&msg,"","", verbose)) - { - dlt_message_free(&msg,0); - return -1; - } - - /* free message */ - dlt_message_free(&msg,0); - - return 0; -} - -int dlt_daemon_control_send_control_message( int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, char* appid, char* ctid, int verbose) -{ - int32_t len; - - PRINT_FUNCTION_VERBOSE(verbose); - - if ((daemon==0) || (msg==0) || (appid==0) || (ctid==0)) - { - return -1; - } - - /* prepare storage header */ - msg->storageheader = (DltStorageHeader*)msg->headerbuffer; - - if (dlt_set_storageheader(msg->storageheader,daemon->ecuid)==-1) - { - return -1; - } - - /* prepare standard header */ - msg->standardheader = (DltStandardHeader*)(msg->headerbuffer + sizeof(DltStorageHeader)); - msg->standardheader->htyp = DLT_HTYP_WEID | DLT_HTYP_WTMS | DLT_HTYP_UEH | DLT_HTYP_PROTOCOL_VERSION1 ; - -#if (BYTE_ORDER==BIG_ENDIAN) - msg->standardheader->htyp = ( msg->standardheader->htyp | DLT_HTYP_MSBF); -#endif - - msg->standardheader->mcnt = 0; - - /* Set header extra parameters */ - dlt_set_id(msg->headerextra.ecu,daemon->ecuid); - - //msg->headerextra.seid = 0; - - msg->headerextra.tmsp = dlt_uptime(); - - dlt_message_set_extraparameters(msg, verbose); - - /* prepare extended header */ - msg->extendedheader = (DltExtendedHeader*)(msg->headerbuffer + sizeof(DltStorageHeader) + sizeof(DltStandardHeader) + DLT_STANDARD_HEADER_EXTRA_SIZE(msg->standardheader->htyp)); - msg->extendedheader->msin = DLT_MSIN_CONTROL_RESPONSE; - - msg->extendedheader->noar = 1; /* number of arguments */ - if (strcmp(appid,"")==0) - { - dlt_set_id(msg->extendedheader->apid,DLT_DAEMON_CTRL_APID); /* application id */ - } - else - { - dlt_set_id(msg->extendedheader->apid, appid); - } - if (strcmp(ctid,"")==0) - { - dlt_set_id(msg->extendedheader->ctid,DLT_DAEMON_CTRL_CTID); /* context id */ - } - else - { - dlt_set_id(msg->extendedheader->ctid, ctid); - } - - /* prepare length information */ - msg->headersize = sizeof(DltStorageHeader) + sizeof(DltStandardHeader) + sizeof(DltExtendedHeader) + DLT_STANDARD_HEADER_EXTRA_SIZE(msg->standardheader->htyp); - - len=msg->headersize - sizeof(DltStorageHeader) + msg->datasize; - if (len>UINT16_MAX) - { - dlt_log(LOG_CRIT,"Huge control message discarded!\n"); - return -1; - } - - msg->standardheader->len = DLT_HTOBE_16(((uint16_t)len)); - - if(dlt_daemon_client_send(sock,daemon,daemon_local,msg->headerbuffer+sizeof(DltStorageHeader),msg->headersize-sizeof(DltStorageHeader), - msg->databuffer,msg->datasize,0/* no ringbuffer operation */,verbose)) - { - DLT_DAEMON_SEM_FREE(); - dlt_log(LOG_ERR,"dlt_daemon_control_send_control_message: DLT message send to all failed!.\n"); - return -1; - } - - return 0; -} - -int dlt_daemon_control_process_control(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, int verbose) -{ - uint32_t id,id_tmp=0; - - PRINT_FUNCTION_VERBOSE(verbose); - - if ((daemon==0) || (msg==0)) - { - return -1; - } - - if (msg->datasize < (int32_t)sizeof(uint32_t)) - { - return -1; - } - - id_tmp = *((uint32_t*)(msg->databuffer)); - id=DLT_ENDIAN_GET_32(msg->standardheader->htyp ,id_tmp); - - if ((id > 0) && (id <= DLT_SERVICE_ID_MESSAGE_BUFFER_OVERFLOW)) - { - /* Control message handling */ - switch (id) - { - case DLT_SERVICE_ID_SET_LOG_LEVEL: - { - dlt_daemon_control_set_log_level(sock, daemon, daemon_local, msg, verbose); - break; - } - case DLT_SERVICE_ID_SET_TRACE_STATUS: - { - dlt_daemon_control_set_trace_status(sock, daemon, daemon_local, msg, verbose); - break; - } - case DLT_SERVICE_ID_GET_LOG_INFO: - { - dlt_daemon_control_get_log_info(sock, daemon, daemon_local, msg, verbose); - break; - } - case DLT_SERVICE_ID_GET_DEFAULT_LOG_LEVEL: - { - dlt_daemon_control_get_default_log_level(sock, daemon, daemon_local, verbose); - break; - } - case DLT_SERVICE_ID_STORE_CONFIG: - { - if (dlt_daemon_applications_save(daemon, daemon->runtime_application_cfg, verbose)==0) - { - if (dlt_daemon_contexts_save(daemon, daemon->runtime_context_cfg, verbose)==0) - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - } - else - { - /* Delete saved files */ - dlt_daemon_control_reset_to_factory_default(daemon, daemon->runtime_application_cfg, daemon->runtime_context_cfg, verbose); - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } - } - else - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } - break; - } - case DLT_SERVICE_ID_RESET_TO_FACTORY_DEFAULT: - { - dlt_daemon_control_reset_to_factory_default(daemon, daemon->runtime_application_cfg, daemon->runtime_context_cfg, verbose); - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - break; - } - case DLT_SERVICE_ID_SET_COM_INTERFACE_STATUS: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - case DLT_SERVICE_ID_SET_COM_INTERFACE_MAX_BANDWIDTH: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - case DLT_SERVICE_ID_SET_VERBOSE_MODE: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - case DLT_SERVICE_ID_SET_MESSAGE_FILTERING: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - case DLT_SERVICE_ID_SET_TIMING_PACKETS: - { - dlt_daemon_control_set_timing_packets(sock, daemon, daemon_local, msg, verbose); - break; - } - case DLT_SERVICE_ID_GET_LOCAL_TIME: - { - /* Send response with valid timestamp (TMSP) field */ - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - break; - } - case DLT_SERVICE_ID_USE_ECU_ID: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - case DLT_SERVICE_ID_USE_SESSION_ID: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - case DLT_SERVICE_ID_USE_TIMESTAMP: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - case DLT_SERVICE_ID_USE_EXTENDED_HEADER: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - case DLT_SERVICE_ID_SET_DEFAULT_LOG_LEVEL: - { - dlt_daemon_control_set_default_log_level(sock, daemon, daemon_local, msg, verbose); - break; - } - case DLT_SERVICE_ID_SET_DEFAULT_TRACE_STATUS: - { - dlt_daemon_control_set_default_trace_status(sock, daemon, daemon_local, msg, verbose); - break; - } - case DLT_SERVICE_ID_GET_SOFTWARE_VERSION: - { - dlt_daemon_control_get_software_version(sock, daemon, daemon_local, verbose); - break; - } - case DLT_SERVICE_ID_MESSAGE_BUFFER_OVERFLOW: - { - dlt_daemon_control_message_buffer_overflow(sock, daemon, daemon_local, daemon->overflow_counter,"",verbose); - break; - } - default: - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - break; - } - } - } - else - { - /* Injection handling */ - dlt_daemon_control_callsw_cinjection(sock, daemon, daemon_local, msg, verbose); - } - - return 0; -} - -void dlt_daemon_control_callsw_cinjection(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, int verbose) -{ - char apid[DLT_ID_SIZE],ctid[DLT_ID_SIZE]; - uint32_t id=0,id_tmp=0; - uint8_t *ptr; - DltDaemonContext *context; - int32_t data_length_inject=0; - uint32_t data_length_inject_tmp=0; - - int32_t datalength; - - DltUserHeader userheader; - DltUserControlMsgInjection usercontext; - uint8_t *userbuffer; - - PRINT_FUNCTION_VERBOSE(verbose); - - if ((daemon==0) || (msg==0)) - { - return; - } - - datalength = msg->datasize; - ptr = msg->databuffer; - - if (ptr==0) - { - return; - } - - DLT_MSG_READ_VALUE(id_tmp,ptr,datalength,uint32_t); /* Get service id */ - id=DLT_ENDIAN_GET_32(msg->standardheader->htyp, id_tmp); - - if ((id>=DLT_DAEMON_INJECTION_MIN) && (id<=DLT_DAEMON_INJECTION_MAX)) - { - /* This a a real SW-C injection call */ - data_length_inject=0; - data_length_inject_tmp=0; - - DLT_MSG_READ_VALUE(data_length_inject_tmp,ptr,datalength,uint32_t); /* Get data length */ - data_length_inject=DLT_ENDIAN_GET_32(msg->standardheader->htyp, data_length_inject_tmp); - - /* Get context handle for apid, ctid (and seid) */ - /* Warning: seid is ignored in this implementation! */ - if (DLT_IS_HTYP_UEH(msg->standardheader->htyp)) - { - dlt_set_id(apid, msg->extendedheader->apid); - dlt_set_id(ctid, msg->extendedheader->ctid); - } - else - { - /* No extended header, and therefore no apid and ctid available */ - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - /* At this point, apid and ctid is available */ - context=dlt_daemon_context_find(daemon, apid, ctid, verbose); - - if (context==0) - { - // dlt_log(LOG_INFO,"No context found!\n"); - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - /* Send user message to handle, specified in context */ - if (dlt_user_set_userheader(&userheader, DLT_USER_MESSAGE_INJECTION)==-1) - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - usercontext.log_level_pos = context->log_level_pos; - - if(data_length_inject > msg->databuffersize) - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - userbuffer = malloc(data_length_inject); - - if (userbuffer==0) - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - return; - } - - usercontext.data_length_inject = data_length_inject; - usercontext.service_id = id; - - memcpy(userbuffer,ptr,data_length_inject); /* Copy received injection to send buffer */ - - /* write to FIFO */ - DltReturnValue ret = - dlt_user_log_out3(context->user_handle, &(userheader), sizeof(DltUserHeader), - &(usercontext), sizeof(DltUserControlMsgInjection), - userbuffer, data_length_inject); - if (ret != DLT_RETURN_OK) - { - if (ret == DLT_RETURN_PIPE_ERROR) - { - /* Close connection */ - close(context->user_handle); - context->user_handle=DLT_FD_INIT; - } - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } - else - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - } - - free(userbuffer); - userbuffer=0; - - } - else - { - /* Invalid ID */ - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_NOT_SUPPORTED, verbose); - } -} - -void dlt_daemon_control_set_log_level(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, int verbose) -{ - PRINT_FUNCTION_VERBOSE(verbose); - - char apid[DLT_ID_SIZE],ctid[DLT_ID_SIZE]; - DltServiceSetLogLevel *req; - DltDaemonContext *context; - int32_t id=DLT_SERVICE_ID_SET_LOG_LEVEL; - - int8_t old_log_level; - - if ((daemon==0) || (msg==0)) - { - return; - } - - req = (DltServiceSetLogLevel*) (msg->databuffer); - - dlt_set_id(apid, req->apid); - dlt_set_id(ctid, req->ctid); - - context=dlt_daemon_context_find(daemon, apid, ctid, verbose); - - /* Set log level */ - if (context!=0) - { - old_log_level = context->log_level; - context->log_level = req->log_level; /* No endianess conversion necessary*/ - - if ((context->user_handle >= DLT_FD_MINIMUM) && - (dlt_daemon_user_send_log_level(daemon, context, verbose)==0)) - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - } - else - { - //dlt_log(LOG_ERR, "Log level could not be sent!\n"); - context->log_level = old_log_level; - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } - } - else - { - //dlt_log(LOG_ERR, "Context not found!\n"); - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } -} - -void dlt_daemon_control_set_trace_status(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, int verbose) -{ - PRINT_FUNCTION_VERBOSE(verbose); - - char apid[DLT_ID_SIZE],ctid[DLT_ID_SIZE]; - DltServiceSetLogLevel *req; /* request uses same struct as set log level */ - DltDaemonContext *context; - int32_t id=DLT_SERVICE_ID_SET_TRACE_STATUS; - - int8_t old_trace_status; - - if ((daemon==0) || (msg==0)) - { - return; - } - - req = (DltServiceSetLogLevel*) (msg->databuffer); - - dlt_set_id(apid, req->apid); - dlt_set_id(ctid, req->ctid); - - context=dlt_daemon_context_find(daemon, apid, ctid, verbose); - - /* Set log level */ - if (context!=0) - { - old_trace_status = context->trace_status; - context->trace_status = req->log_level; /* No endianess conversion necessary */ - - if ((context->user_handle >= DLT_FD_MINIMUM ) && - (dlt_daemon_user_send_log_level(daemon, context, verbose)==0)) - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - } - else - { - //dlt_log(LOG_ERR, "Trace Status could not be sent!\n"); - context->trace_status = old_trace_status; - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } - } - else - { - //dlt_log(LOG_ERR, "Context not found!\n"); - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } -} - -void dlt_daemon_control_set_default_log_level(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, int verbose) -{ - PRINT_FUNCTION_VERBOSE(verbose); - - DltServiceSetDefaultLogLevel *req; - int32_t id=DLT_SERVICE_ID_SET_DEFAULT_LOG_LEVEL; - - if ((daemon==0) || (msg==0)) - { - return; - } - - req = (DltServiceSetDefaultLogLevel*) (msg->databuffer); - - /* No endianess conversion necessary */ - if (/*(req->log_level>=0) &&*/ - (req->log_level<=DLT_LOG_VERBOSE)) - { - daemon->default_log_level = req->log_level; /* No endianess conversion necessary */ - - /* Send Update to all contexts using the default log level */ - dlt_daemon_user_send_default_update(daemon, verbose); - - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - } - else - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } -} - -void dlt_daemon_control_set_default_trace_status(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, int verbose) -{ - PRINT_FUNCTION_VERBOSE(verbose); - - /* Payload of request message */ - DltServiceSetDefaultLogLevel *req; - int32_t id=DLT_SERVICE_ID_SET_DEFAULT_TRACE_STATUS; - - if ((daemon==0) || (msg==0)) - { - return; - } - - req = (DltServiceSetDefaultLogLevel*) (msg->databuffer); - - /* No endianess conversion necessary */ - if ((req->log_level==DLT_TRACE_STATUS_OFF) || - (req->log_level==DLT_TRACE_STATUS_ON)) - { - daemon->default_trace_status = req->log_level; /* No endianess conversion necessary*/ - - /* Send Update to all contexts using the default trace status */ - dlt_daemon_user_send_default_update(daemon, verbose); - - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - } - else - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } -} - -void dlt_daemon_control_set_timing_packets(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, DltMessage *msg, int verbose) -{ - PRINT_FUNCTION_VERBOSE(verbose); - - DltServiceSetVerboseMode *req; /* request uses same struct as set verbose mode */ - int32_t id=DLT_SERVICE_ID_SET_TIMING_PACKETS; - - if ((daemon==0) || (msg==0)) - { - return; - } - - req = (DltServiceSetVerboseMode*) (msg->databuffer); - if ((req->new_status==0) || (req->new_status==1)) - { - daemon->timingpackets = req->new_status; - - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_OK, verbose); - } - else - { - dlt_daemon_control_service_response(sock, daemon, daemon_local, id, DLT_SERVICE_RESPONSE_ERROR, verbose); - } -} - -void dlt_daemon_control_message_time(int sock, DltDaemon *daemon, DltDaemonLocal *daemon_local, int verbose) -{ - DltMessage msg; - int32_t len; - - PRINT_FUNCTION_VERBOSE(verbose); - - if (daemon==0) - { - return; - } - - /* initialise new message */ - if (dlt_message_init(&msg,0)==-1) - { - return; - } - - /* send message */ - - /* prepare storage header */ - msg.storageheader = (DltStorageHeader*)msg.headerbuffer; - dlt_set_storageheader(msg.storageheader,daemon->ecuid); - - /* prepare standard header */ - msg.standardheader = (DltStandardHeader*)(msg.headerbuffer + sizeof(DltStorageHeader)); - msg.standardheader->htyp = DLT_HTYP_WEID | DLT_HTYP_WTMS | DLT_HTYP_UEH | DLT_HTYP_PROTOCOL_VERSION1 ; - -#if (BYTE_ORDER==BIG_ENDIAN) - msg.standardheader->htyp = ( msg.standardheader->htyp | DLT_HTYP_MSBF); -#endif - - msg.standardheader->mcnt = 0; - - /* Set header extra parameters */ - dlt_set_id(msg.headerextra.ecu,daemon->ecuid); - msg.headerextra.tmsp = dlt_uptime(); - - dlt_message_set_extraparameters(&msg, verbose); - - /* prepare extended header */ - msg.extendedheader = (DltExtendedHeader*)(msg.headerbuffer + sizeof(DltStorageHeader) + sizeof(DltStandardHeader) + DLT_STANDARD_HEADER_EXTRA_SIZE(msg.standardheader->htyp)); - msg.extendedheader->msin = DLT_MSIN_CONTROL_TIME; - - msg.extendedheader->noar = 0; /* number of arguments */ - dlt_set_id(msg.extendedheader->apid,""); /* application id */ - dlt_set_id(msg.extendedheader->ctid,""); /* context id */ - - /* prepare length information */ - msg.headersize = sizeof(DltStorageHeader) + sizeof(DltStandardHeader) + sizeof(DltExtendedHeader) + DLT_STANDARD_HEADER_EXTRA_SIZE(msg.standardheader->htyp); - - len=msg.headersize - sizeof(DltStorageHeader) + msg.datasize; - if (len>UINT16_MAX) - { - dlt_log(LOG_CRIT,"Huge control message discarded!\n"); - - /* free message */ - dlt_message_free(&msg,0); - - return; - } - - msg.standardheader->len = DLT_HTOBE_16(((uint16_t)len)); - - /* Send message */ - dlt_daemon_client_send(sock,daemon,daemon_local,msg.headerbuffer+sizeof(DltStorageHeader),msg.headersize-sizeof(DltStorageHeader), - msg.databuffer,msg.datasize,0 /* no ringbuffer only */,verbose); - - /* free message */ - dlt_message_free(&msg,0); -} - /** \} */ |