From e3c2501313d98ff9f4519116e6d2f36314e0240e Mon Sep 17 00:00:00 2001 From: ManikandanC Date: Tue, 18 Oct 2016 15:43:44 +0530 Subject: UnitTest: Updates Gateway Logstorage Event Handler Signed-off-by: Christoph Lipka Signed-off-by: S. Hameed Signed-off-by: Aditya Paluri Signed-off-by: Saya Sugiura Signed-off-by: ManikandanC --- tests/CMakeLists.txt | 27 +- tests/dlt_test_receiver.c | 2 - tests/g_test_dlt_daemon_gateway.sh | 139 ----- tests/gtest_common.h | 251 --------- tests/gtest_dlt_common.cpp | 33 +- tests/gtest_dlt_daemon_common.cpp | 64 +-- tests/gtest_dlt_daemon_event_handler.cpp | 139 +++-- tests/gtest_dlt_daemon_gateway.cpp | 85 ++- tests/gtest_dlt_daemon_gateway.sh | 241 +++++++++ tests/gtest_dlt_daemon_logstorage.sh | 57 +++ tests/gtest_dlt_daemon_offline_log.cpp | 852 +++++++++++++++++++++++-------- tests/start_multinode_test.sh | 88 +++- 12 files changed, 1183 insertions(+), 795 deletions(-) delete mode 100755 tests/g_test_dlt_daemon_gateway.sh delete mode 100644 tests/gtest_common.h create mode 100755 tests/gtest_dlt_daemon_gateway.sh create mode 100755 tests/gtest_dlt_daemon_logstorage.sh (limited to 'tests') diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt index ab7ed9d..50cca4f 100644 --- a/tests/CMakeLists.txt +++ b/tests/CMakeLists.txt @@ -11,6 +11,15 @@ SET(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=gnu++0x") configure_file(${CMAKE_SOURCE_DIR}/tests/testfile.dlt ${PROJECT_BINARY_DIR}/tests COPYONLY) configure_file(${CMAKE_SOURCE_DIR}/tests/testfilter.txt ${PROJECT_BINARY_DIR}/tests COPYONLY) +if(${CMAKE_SYSTEM_NAME} STREQUAL "Linux") + set(LIBRARIES gtest gtest_main) +else() + set(LIBRARIES gtest socket) +endif() + +set(DLT_LIBRARIES ${LIBRARIES} dlt) +set(DLT_DAEMON_LIBRARIES ${LIBRARIES} dlt_daemon) + add_executable(gtest_dlt_common gtest_dlt_common.cpp) add_executable(gtest_dlt_user gtest_dlt_user.cpp) add_executable(gtest_dlt_daemon_common gtest_dlt_daemon_common.cpp ../src/daemon/dlt_daemon_common.c) @@ -19,17 +28,19 @@ add_executable(dlt_env_ll_unit_test dlt_env_ll_unit_test.cpp) add_executable(dlt-test-preregister-context dlt-test-preregister-context.c) add_executable(gtest_dlt_daemon_gateway gtest_dlt_daemon_gateway.cpp) add_executable(gtest_dlt_daemon_event_handler gtest_dlt_daemon_event_handler.cpp) -target_link_libraries(gtest_dlt_common gtest gtest_main dlt) -target_link_libraries(gtest_dlt_user gtest gtest_main dlt) -target_link_libraries(gtest_dlt_daemon_common gtest gtest_main dlt) +add_executable(gtest_dlt_daemon_offline_log gtest_dlt_daemon_offline_log.cpp) +target_link_libraries(gtest_dlt_common ${DLT_LIBRARIES}) +target_link_libraries(gtest_dlt_user ${DLT_LIBRARIES}) +target_link_libraries(gtest_dlt_daemon_common ${DLT_LIBRARIES}) target_link_libraries(dlt_test_receiver dlt) -target_link_libraries(dlt_env_ll_unit_test gtest gtest_main dlt) -target_link_libraries(dlt-test-preregister-context gtest gtest_main dlt) -target_link_libraries(gtest_dlt_daemon_gateway gtest gtest_main dlt_daemon) -target_link_libraries(gtest_dlt_daemon_event_handler gtest gtest_main dlt_daemon) +target_link_libraries(dlt_env_ll_unit_test ${DLT_LIBRARIES}) +target_link_libraries(dlt-test-preregister-context ${DLT_LIBRARIES}) +target_link_libraries(gtest_dlt_daemon_gateway ${DLT_DAEMON_LIBRARIES}) +target_link_libraries(gtest_dlt_daemon_event_handler ${DLT_DAEMON_LIBRARIES}) +target_link_libraries(gtest_dlt_daemon_offline_log ${DLT_DAEMON_LIBRARIES}) if(${WITH_DLT_CXX11_EXT}) add_executable(dlt-test-cpp-extension dlt-test-cpp-extension.cpp) set_target_properties(dlt-test-cpp-extension PROPERTIES COMPILE_FLAGS "-std=gnu++0x") - target_link_libraries(dlt-test-cpp-extension gtest gtest_main dlt) + target_link_libraries(dlt-test-cpp-extension ${DLT_LIBRARIES}) endif() diff --git a/tests/dlt_test_receiver.c b/tests/dlt_test_receiver.c index 86147ec..e7abd83 100644 --- a/tests/dlt_test_receiver.c +++ b/tests/dlt_test_receiver.c @@ -82,8 +82,6 @@ #include "dlt_client.h" #include -#define DLT_RECEIVE_TEXTBUFSIZE 10024 /* Size of buffer for text output */ - #define DLT_RECEIVE_ECU_ID "RECV" /* Function prototypes */ diff --git a/tests/g_test_dlt_daemon_gateway.sh b/tests/g_test_dlt_daemon_gateway.sh deleted file mode 100755 index 85f37db..0000000 --- a/tests/g_test_dlt_daemon_gateway.sh +++ /dev/null @@ -1,139 +0,0 @@ -#!/bin/sh -################################################################################ -# @licence make begin@ -# SPDX license identifier: MPL-2.0 -# -# Copyright (C) 2016, Advanced Driver Information Technology -# This code is developed by Advanced Driver Information Technology. -# Copyright of Advanced Driver Information Technology, Bosch and DENSO. -# -# This file is part of GENIVI Project DLT - Diagnostic Log and Trace. -# -# This Source Code Form is subject to the terms of the -# Mozilla Public License (MPL), v. 2.0. -# If a copy of the MPL was not distributed with this file, -# You can obtain one at http://mozilla.org/MPL/2.0/. -# -# For further information see http://www.genivi.org/. -# @licence end@ -################################################################################ - -################################################################################ -#file : g_test_dlt_daemon_gateway.sh -# -#Description : gateway unit test preparation -# -#Author Name : Onkar Palkar -#Email Id : onkar.palkar@wipro.com -# -#History : Last modified date : 29/07/2016 -################################################################################ -# -# Function: -cleanup() -# -# Description -Delete the dlt_test folder if it already present -# -Check weather required binaries are avaiable or not -# -Restore dlt_gateway.conf file -# -# Return -Zero on success -# -Non zero on failure -# -ipaddr=127.0.0.1 - -cleanup() -{ - tmpPath=/tmp - cd $tmpPath - pidof dlt-daemon > /dev/null - if [ $? -eq '0' ] - then - killall dlt-daemon - if [ $? -eq '1' ] - then - echo "Failed to kill daemons" - return 1 - fi - fi - rm $tmpPath/dlt.conf - rm $tmpPath/idlt_gateway.conf - return 0 -} -# -# Function: -setupTest() -# -# Description -Create gateway folder -# -Create and add dlt.conf and dlt_gateway.conf file in the gateway folder -# -# Return -Zero on success -# -Non zero on failure -# -setupTest() -{ - which dlt-daemon > /dev/null - if [ $? -eq '1' ] - then - echo "dlt-daemon is not available" - return 1 - fi - touch $tmpPath/dlt.conf - if [ $? -eq '1' ] - then - echo "Error in creating dlt.conf file" - return 1 - fi - echo "SendContextRegistration = 1" >>$tmpPath/dlt.conf - echo "ECUId = ECU1" >>$tmpPath/dlt.conf - echo "GatewayMode = 1" >>$tmpPath/dlt.conf - echo "SharedMemorySize = 100000" >>$tmpPath/dlt.conf - echo "LoggingMode = 0" >>$tmpPath/dlt.conf - echo "LoggingLevel = 6" >>$tmpPath/dlt.conf - echo "LoggingFilename = /tmp/dlt.log" >>$tmpPath/dlt.conf - echo "TimeOutOnSend = 4" >>$tmpPath/dlt.conf - echo "RingbufferMinSize = 500000" >>$tmpPath/dlt.conf - echo "RingbufferMaxSize = 10000000" >>$tmpPath/dlt.conf - echo "RingbufferStepSize = 500000" >>$tmpPath/dlt.conf - echo "ControlSocketPath = /tmp/dlt-ctrl.sock" >>$tmpPath/dlt.conf - echo "GatewayConfigFile = /tmp/$tmpFolder/dlt_gateway.conf" >>$tmpPath/dlt.conf - touch $tmpPath/dlt_gateway.conf - if [ $? -eq '1' ] - then - echo "Error in creating dlt_gateway file" - return 1 - fi - echo "[PassiveNode1]" >>$tmpPath/dlt_gateway.conf - echo "IPaddress=$ipaddr">>$tmpPath/dlt_gateway.conf - echo "Port=3495" >>$tmpPath/dlt_gateway.conf - echo "EcuID=ECU1" >>$tmpPath/dlt_gateway.conf - echo "Connect=OnStartup" >>$tmpPath/dlt_gateway.conf - echo "Timeout=10" >>$tmpPath/dlt_gateway.conf - echo "SendControl=0x03,0x13" >>$tmpPath/dlt_gateway.conf - echo "SendSerialHeader=0" >>$tmpPath/dlt_gateway.conf - echo "NOFiles=1" >>$tmpPath/dlt_gateway.conf - return 0 -} -# -# Function: -startDaemons() -# -# Description -Start dlt-daemon as passive node -# -# Return -Zero on success -# -Non zero on failure -# -startDaemons() -{ - dlt-daemon -p 3495 - return 0 -} -#main function -######################################################################################## -cleanup -if [ $? -ne '0' ] -then -return 1 -fi -setupTest -if [ $? -ne '0' ] -then -return 1 -fi -startDaemons diff --git a/tests/gtest_common.h b/tests/gtest_common.h deleted file mode 100644 index 0ca9f7e..0000000 --- a/tests/gtest_common.h +++ /dev/null @@ -1,251 +0,0 @@ -/** - * @licence app begin@ - * Copyright (C) 2016 Advanced Driver Information Technology. - * This code is developed by Advanced Driver Information Technology. - * Copyright of Advanced Driver Information Technology, Bosch and DENSO. - * - * DLT gtest common header file. - * - * \copyright - * This Source Code Form is subject to the terms of the - * Mozilla Public License, v. 2.0. If a copy of the MPL was not distributed with - * this file, You can obtain one at http://mozilla.org/MPL/2.0/. - * - * - * \author Onkar Palkar - * - * \file: gtest_common.h - * For further information see http://www.genivi.org/. - * @licence end@ - */ - -/******************************************************************************* - * ** - * SRC-MODULE: gtest_common.h ** - * ** - * TARGET : linux ** - * ** - * PROJECT : DLT ** - * ** - * AUTHOR : onkar.palkar@wipro.com ** - * PURPOSE : ** - * ** - * REMARKS : ** - * ** - * PLATFORM DEPENDANT [yes/no]: yes ** - * ** - * TO BE CHANGED BY USER [yes/no]: no ** - * ** - ******************************************************************************/ - -/******************************************************************************* -* Author Identity ** -******************************************************************************* -* ** -* Initials Name Company ** -* -------- ------------------------- ---------------------------------- ** -* op Onkar Palkar Wipro ** -*******************************************************************************/ -#ifndef GTEST_COMMON_H -#define GTEST_COMMON_H -int dlt_logstorage_split_key(char *key, char *appid, char *ctxid); -int dlt_logstorage_update_all_contexts(DltDaemon *daemon, - char *id, - int curr_log_level, - int cmp_flag, - int verbose); -int dlt_logstorage_update_context(DltDaemon *daemon, - char *apid, - char *ctxid, - char *ecuid, - int curr_log_level, - int verbose); -int dlt_logstorage_update_context_loglevel(DltDaemon *daemon, - char *key, - int curr_log_level, - int verbose); -void dlt_daemon_logstorage_reset_application_loglevel(DltDaemon *daemon, - int dev_num, - int max_device, - int verbose); -typedef struct { - char *key; /* The configuration key */ - int (*func)(DltLogStorage *handle, char *value); /* conf handler */ - int is_opt; /* If configuration is optional or not */ -} DltLogstorageGeneralConf; - -typedef enum { - DLT_LOGSTORAGE_GENERAL_CONF_BLOCKMODE = 0, - DLT_LOGSTORAGE_GENERAL_CONF_COUNT -} DltLogstorageGeneralConfType; - -typedef struct { - char *key; /* Configuration key */ - int (*func)(DltLogStorageFilterConfig *config, char *value); /* conf handler */ - int is_opt; /* If configuration is optional or not */ -} DltLogstorageFilterConf; - -typedef enum { - DLT_LOGSTORAGE_FILTER_CONF_LOGAPPNAME = 0, - DLT_LOGSTORAGE_FILTER_CONF_CONTEXTNAME, - DLT_LOGSTORAGE_FILTER_CONF_LOGLEVEL, - DLT_LOGSTORAGE_FILTER_CONF_FILE, - DLT_LOGSTORAGE_FILTER_CONF_FILESIZE, - DLT_LOGSTORAGE_FILTER_CONF_NOFILES, - DLT_LOGSTORAGE_FILTER_CONF_SYNCBEHAVIOR, - DLT_LOGSTORAGE_FILTER_CONF_ECUID, - DLT_LOGSTORAGE_FILTER_CONF_COUNT -} DltLogstorageFilterConfType; - - int dlt_logstorage_hash_create(int num_entries, - struct hsearch_data *htab); - int dlt_logstorage_hash_destroy(struct hsearch_data *htab); - int dlt_logstorage_hash_add(char *key, void *value, - struct hsearch_data *htab); - void *dlt_logstorage_hash_find(char *key, struct hsearch_data *htab); - int dlt_logstorage_count_ids(const char *str); - int dlt_logstorage_read_number(unsigned int *number, char *value); - int dlt_logstorage_read_list_of_names(char **names, char *value); - int dlt_logstorage_check_apids(DltLogStorageFilterConfig *config, char *value); - int dlt_logstorage_check_ctids(DltLogStorageFilterConfig *config, char *value); - int dlt_logstorage_check_loglevel(DltLogStorageFilterConfig *config, char *value); - int dlt_logstorage_check_filename(DltLogStorageFilterConfig *config, char *value); - int dlt_logstorage_check_filesize(DltLogStorageFilterConfig *config, char *value); - int dlt_logstorage_check_nofiles(DltLogStorageFilterConfig *config, char *value); - int dlt_logstorage_check_sync_strategy(DltLogStorageFilterConfig *config, char *value); - int dlt_logstorage_check_ecuid(DltLogStorageFilterConfig *config, char *value); - int dlt_logstorage_check_param(DltLogStorageFilterConfig *config, - DltLogstorageFilterConfType ctype, - char *value); - int dlt_logstorage_check_blockmode(DltLogStorage *handle, - char *value); - int dlt_logstorage_check_general_param(DltLogStorage *handle, - DltLogstorageGeneralConfType ctype, - char *value); - int dlt_daemon_setup_general_properties(DltLogStorage *handle, - DltConfigFile *config_file, - char *sec_name); - int dlt_logstorage_store_filters(DltLogStorage *handle, - char *config_file_name); - void dlt_logstorage_free(DltLogStorage *handle, int reason); - int dlt_logstorage_create_keys(char *appids, - char *ctxids, - char **keys, - int *num_keys); - int dlt_logstorage_prepare_table(DltLogStorage *handle, - DltLogStorageFilterConfig *data); - int dlt_logstorage_validate_filter_name(char *name); - void dlt_logstorage_filter_set_strategy(DltLogStorageFilterConfig *config, - int strategy); - int dlt_logstorage_load_config(DltLogStorage *handle); - int dlt_logstorage_filter(DltLogStorage *handle, - DltLogStorageFilterConfig **config, - char *apid, - char *ctid, - char *ecuid, - int log_level); -void dlt_logstorage_log_file_name(char *log_file_name, - DltLogStorageUserConfig *file_config, - char *name, - int idx); -void dlt_logstorage_sort_file_name(DltLogStorageFileList **head); -void dlt_logstorage_rearrange_file_name(DltLogStorageFileList **head); -unsigned int dlt_logstorage_get_idx_of_log_file( - DltLogStorageUserConfig *file_config, - char *file); -int dlt_logstorage_storage_dir_info(DltLogStorageUserConfig *file_config, - char *path, - DltLogStorageFilterConfig *config); -int dlt_logstorage_open_log_file(DltLogStorageFilterConfig *config, - DltLogStorageUserConfig *file_config, - char *dev_path, - int msg_size); -/* gtest_dlt_daemon_gateway */ -typedef enum { - GW_CONF_IP_ADDRESS = 0, - GW_CONF_PORT, - GW_CONF_ECUID, - GW_CONF_CONNECT, - GW_CONF_TIMEOUT, - GW_CONF_SEND_CONTROL, - GW_CONF_SEND_PERIODIC_CONTROL, - GW_CONF_SEND_SERIAL_HEADER, - GW_CONF_COUNT -} DltGatewayConfType; -int enable_all(DltServiceIdFlag *flags); -int init_flags(DltServiceIdFlag *flags); -int set_bit(DltServiceIdFlag *flags, int id); -int bit(DltServiceIdFlag *flags, int id); -int dlt_daemon_filter_name(DltMessageFilter *mf, - DltFilterConfiguration *config, - char *value); -int dlt_daemon_filter_level(DltMessageFilter *mf, - DltFilterConfiguration *config, - char *value); -int dlt_daemon_filter_control_mask(DltMessageFilter *mf, - DltFilterConfiguration *config, - char *value); -int dlt_daemon_filter_client_mask(DltMessageFilter *mf, - DltFilterConfiguration *config, - char *value); -int dlt_daemon_filter_injections(DltMessageFilter *mf, - DltFilterConfiguration *config, - char *value); -int dlt_daemon_set_injection_service_ids(int **ids, - int *num, - char *value); -DltInjectionConfig *dlt_daemon_filter_find_injection_by_name( - DltInjectionConfig *injections, - char *name); -int dlt_daemon_injection_name(DltMessageFilter *mf, - DltInjectionConfig *config, - char *value); -int dlt_daemon_injection_apid(DltMessageFilter *mf, - DltInjectionConfig *config, - char *value); -int dlt_daemon_injection_ctid(DltMessageFilter *mf, - DltInjectionConfig *config, - char *value); -int dlt_daemon_injection_ecu_id(DltMessageFilter *mf, - DltInjectionConfig *config, - char *value); -int dlt_daemon_injection_service_id(DltMessageFilter *mf, - DltInjectionConfig *config, - char *value); -int dlt_daemon_get_name(DltMessageFilter *mf, char *val); -int dlt_daemon_get_default_level(DltMessageFilter *mf, char *val); -int dlt_daemon_get_backend(DltMessageFilter *mf, char *val); -int dlt_daemon_setup_filter_section(DltMessageFilter *mf, - DltConfigFile *config, - char *sec_name); -int dlt_daemon_setup_filter_properties(DltMessageFilter *mf, - DltConfigFile *config, - char *sec_name); -void dlt_daemon_filter_backend_level_changed(unsigned int level, - void *ptr1, - void *ptr2); -int dlt_gateway_check_ip(DltGatewayConnection *con, char *value); -int dlt_gateway_check_port(DltGatewayConnection *con, char *value); -int dlt_gateway_check_ecu(DltGatewayConnection *con, char *value); -int dlt_gateway_check_connect_trigger(DltGatewayConnection *con, - char *value); -int dlt_gateway_check_timeout(DltGatewayConnection *con, char *value); -int dlt_gateway_check_send_serial(DltGatewayConnection *con, char *value); -int dlt_gateway_allocate_control_messages(DltGatewayConnection *con); -int dlt_gateway_check_control_messages(DltGatewayConnection *con, - char *value); -int dlt_gateway_check_periodic_control_messages(DltGatewayConnection *con, - char *value); -int dlt_gateway_check_param(DltGateway *gateway, - DltGatewayConnection *con, - DltGatewayConfType ctype, - char *value); -int dlt_gateway_configure(DltGateway *gateway, char *config_file, int verbose); -int dlt_gateway_store_connection(DltGateway *gateway, - DltGatewayConnection *tmp, - int verbose); -int dlt_gateway_parse_get_log_info(DltDaemon *daemon, - char *ecu, - DltMessage *msg, - int verbose); -#endif diff --git a/tests/gtest_dlt_common.cpp b/tests/gtest_dlt_common.cpp index d7c6d9c..27831d3 100644 --- a/tests/gtest_dlt_common.cpp +++ b/tests/gtest_dlt_common.cpp @@ -261,7 +261,7 @@ TEST(t_dlt_buffer_reset, normal) // Normal Use-Case. expect 0 EXPECT_LE(DLT_RETURN_OK, dlt_buffer_init_dynamic(&buf, DLT_USER_RINGBUFFER_MIN_SIZE, DLT_USER_RINGBUFFER_MAX_SIZE, DLT_USER_RINGBUFFER_STEP_SIZE)); EXPECT_LE(0, dlt_buffer_reset(&buf)); - EXPECT_LE(DLT_RETURN_OK, dlt_buffer_free_dynamic(&buf)); + } TEST(t_dlt_buffer_reset, abnormal) { @@ -812,15 +812,15 @@ TEST(t_dlt_buffer_copy, nullpointer) int size = sizeof(DltUserHeader); // NULL-Pointer, expected -1 - EXPECT_LE(-1, dlt_buffer_copy(NULL,NULL,size)); - EXPECT_LE(-1, dlt_buffer_copy(NULL,NULL,0)); - EXPECT_LE(-1, dlt_buffer_copy(NULL,(unsigned char *)&header,size)); - EXPECT_LE(-1, dlt_buffer_copy(NULL,(unsigned char *)&header,0)); + EXPECT_LE(DLT_RETURN_WRONG_PARAMETER, dlt_buffer_copy(NULL,NULL,size)); + EXPECT_LE(DLT_RETURN_WRONG_PARAMETER, dlt_buffer_copy(NULL,NULL,0)); + EXPECT_LE(DLT_RETURN_WRONG_PARAMETER, dlt_buffer_copy(NULL,(unsigned char *)&header,size)); + EXPECT_LE(DLT_RETURN_WRONG_PARAMETER, dlt_buffer_copy(NULL,(unsigned char *)&header,0)); EXPECT_LE(DLT_RETURN_OK, dlt_buffer_init_dynamic(&buf, DLT_USER_RINGBUFFER_MIN_SIZE, DLT_USER_RINGBUFFER_MAX_SIZE, DLT_USER_RINGBUFFER_STEP_SIZE)); - EXPECT_LE(-1, dlt_buffer_copy(&buf,NULL,size)); + EXPECT_LE(DLT_RETURN_WRONG_PARAMETER, dlt_buffer_copy(&buf,NULL,size)); EXPECT_LE(DLT_RETURN_OK, dlt_buffer_free_dynamic(&buf)); EXPECT_LE(DLT_RETURN_OK, dlt_buffer_init_dynamic(&buf, DLT_USER_RINGBUFFER_MIN_SIZE, DLT_USER_RINGBUFFER_MAX_SIZE, DLT_USER_RINGBUFFER_STEP_SIZE)); - EXPECT_LE(-1, dlt_buffer_copy(&buf,NULL,0)); + EXPECT_LE(DLT_RETURN_WRONG_PARAMETER, dlt_buffer_copy(&buf,NULL,0)); EXPECT_LE(DLT_RETURN_OK, dlt_buffer_free_dynamic(&buf)); } /* End Method: dlt_common::dlt_buffer_copy */ @@ -1238,7 +1238,6 @@ TEST(t_dlt_buffer_info, normal) // Normal Use-Case EXPECT_LE(DLT_RETURN_OK, dlt_buffer_init_dynamic(&buf, DLT_USER_RINGBUFFER_MIN_SIZE, DLT_USER_RINGBUFFER_MAX_SIZE, DLT_USER_RINGBUFFER_STEP_SIZE)); EXPECT_NO_THROW(dlt_buffer_info(&buf)); - EXPECT_LE(DLT_RETURN_OK, dlt_buffer_free_dynamic(&buf)); } TEST(t_dlt_buffer_info, abnormal) { @@ -1263,7 +1262,6 @@ TEST(t_dlt_buffer_status, normal) // Normal Use-Case EXPECT_LE(DLT_RETURN_OK, dlt_buffer_init_dynamic(&buf, DLT_USER_RINGBUFFER_MIN_SIZE, DLT_USER_RINGBUFFER_MAX_SIZE, DLT_USER_RINGBUFFER_STEP_SIZE)); EXPECT_NO_THROW(dlt_buffer_status(&buf)); - EXPECT_LE(DLT_RETURN_OK, dlt_buffer_free_dynamic(&buf)); } TEST(t_dlt_buffer_status, abnormal) { @@ -3094,8 +3092,7 @@ TEST(t_dlt_message_read, normal) EXPECT_LE(DLT_RETURN_ERROR, dlt_message_read(&file.msg,(unsigned char*) buffer,255,0,1)); } EXPECT_LE(DLT_RETURN_OK, dlt_buffer_free_dynamic(&buf)); - EXPECT_LE(DLT_RETURN_OK, dlt_file_close(&file, 0)); - EXPECT_LE(DLT_RETURN_OK, dlt_file_free(&file, 0)); + EXPECT_LE(DLT_RETURN_OK, dlt_buffer_init_dynamic(&buf, DLT_USER_RINGBUFFER_MIN_SIZE, DLT_USER_RINGBUFFER_MAX_SIZE, DLT_USER_RINGBUFFER_STEP_SIZE)); EXPECT_LE(DLT_RETURN_OK, dlt_file_init(&file, 0)); EXPECT_LE(DLT_RETURN_OK, dlt_file_open(&file, openfile, 0)); @@ -3106,8 +3103,6 @@ TEST(t_dlt_message_read, normal) EXPECT_LE(DLT_RETURN_ERROR, dlt_message_read(&file.msg,(unsigned char *) buffer,255,1,1)); } EXPECT_LE(DLT_RETURN_OK, dlt_buffer_free_dynamic(&buf)); - EXPECT_LE(DLT_RETURN_OK, dlt_file_close(&file, 0)); - EXPECT_LE(DLT_RETURN_OK, dlt_file_free(&file, 0)); } TEST(t_dlt_message_read, abnormal) { @@ -3130,9 +3125,9 @@ TEST(t_dlt_message_read, nullpointer) // NULL_Pointer, expected -1 EXPECT_GE(DLT_RETURN_ERROR, dlt_message_read(NULL, NULL, 0,0,0)); - EXPECT_GE(DLT_RETURN_ERROR, dlt_message_read(NULL, (u_int8_t *)&buf, 0,0,0)); + EXPECT_GE(DLT_RETURN_ERROR, dlt_message_read(NULL, (uint8_t *)&buf, 0,0,0)); EXPECT_GE(DLT_RETURN_ERROR, dlt_message_read(&file.msg, NULL, 0,0,0)); - EXPECT_GE(DLT_RETURN_ERROR, dlt_message_read(&file.msg, (u_int8_t *)&buf, 0,0,0)); + EXPECT_GE(DLT_RETURN_ERROR, dlt_message_read(&file.msg, (uint8_t *)&buf, 0,0,0)); } /* End Method:dlt_common::dlt_message_read */ @@ -3340,16 +3335,11 @@ TEST(t_dlt_log_init, normal) // Normal Use-Case, exptect 0-3 EXPECT_NO_THROW(dlt_log_init(DLT_LOG_TO_CONSOLE)); - EXPECT_NO_THROW(dlt_log_free()); EXPECT_NO_THROW(dlt_log_init(DLT_LOG_TO_SYSLOG)); - EXPECT_NO_THROW(dlt_log_free()); EXPECT_NO_THROW(dlt_log_set_filename("/tmp/dlt.log")); EXPECT_NO_THROW(dlt_log_init(DLT_LOG_TO_FILE)); - EXPECT_NO_THROW(dlt_log_free()); EXPECT_NO_THROW(dlt_log_init(DLT_LOG_TO_FILE)); - EXPECT_NO_THROW(dlt_log_free()); EXPECT_NO_THROW(dlt_log_init(DLT_LOG_DROPPED)); - EXPECT_NO_THROW(dlt_log_free()); } TEST(t_dlt_log_init, abnormal) { @@ -3377,11 +3367,8 @@ TEST(t_dlt_log_free, normal) // Normal Use-Case, expected 0 EXPECT_NO_THROW(dlt_log_init(DLT_LOG_TO_CONSOLE)); - EXPECT_NO_THROW(dlt_log_free()); EXPECT_NO_THROW(dlt_log_init(DLT_LOG_TO_SYSLOG)); - EXPECT_NO_THROW(dlt_log_free()); EXPECT_NO_THROW(dlt_log_init(DLT_LOG_DROPPED)); - EXPECT_NO_THROW(dlt_log_free()); } TEST(t_dlt_log_free, abnormal) { diff --git a/tests/gtest_dlt_daemon_common.cpp b/tests/gtest_dlt_daemon_common.cpp index 69cc940..5e22c2d 100644 --- a/tests/gtest_dlt_daemon_common.cpp +++ b/tests/gtest_dlt_daemon_common.cpp @@ -69,7 +69,7 @@ TEST(t_dlt_daemon_init_user_information, normal_one_list) DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); EXPECT_EQ(0, dlt_daemon_free(&daemon, 0)); } @@ -100,9 +100,9 @@ TEST(t_dlt_daemon_init_user_information, normal_multiple_lists) dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 1, 0)); EXPECT_EQ(3, daemon.num_user_lists); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); - EXPECT_STREQ(gateway.connections[0].ecuid, daemon.user_list[1].ecu); - EXPECT_STREQ(gateway.connections[1].ecuid, daemon.user_list[2].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); + EXPECT_EQ(DLT_RETURN_OK, strncmp(gateway.connections[0].ecuid, daemon.user_list[1].ecu, DLT_ID_SIZE)); + EXPECT_EQ(DLT_RETURN_OK, strncmp(gateway.connections[1].ecuid, daemon.user_list[2].ecu, DLT_ID_SIZE)); EXPECT_EQ(0, dlt_daemon_free(&daemon, 0)); free(gateway.connections); @@ -138,7 +138,7 @@ TEST(t_dlt_daemon_find_users_list, normal_one_list) user_list = dlt_daemon_find_users_list(&daemon, &ecu[0], 0); EXPECT_NE(user_list, nullptr); - EXPECT_STREQ(user_list->ecu, daemon.ecuid); + EXPECT_EQ(DLT_RETURN_OK, strncmp(user_list->ecu, daemon.ecuid, DLT_ID_SIZE)); EXPECT_EQ(0, dlt_daemon_free(&daemon, 0)); } @@ -194,21 +194,21 @@ TEST(t_dlt_daemon_find_users_list, normal_multiple_lists) dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 1, 0)); EXPECT_EQ(3, daemon.num_user_lists); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); - EXPECT_STREQ(gateway.connections[0].ecuid, daemon.user_list[1].ecu); - EXPECT_STREQ(gateway.connections[1].ecuid, daemon.user_list[2].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); + EXPECT_EQ(DLT_RETURN_OK, strncmp(gateway.connections[0].ecuid, daemon.user_list[1].ecu, DLT_ID_SIZE)); + EXPECT_EQ(DLT_RETURN_OK, strncmp(gateway.connections[1].ecuid, daemon.user_list[2].ecu, DLT_ID_SIZE)); user_list = dlt_daemon_find_users_list(&daemon, &ecu[0], 0); EXPECT_NE(user_list, nullptr); - EXPECT_STREQ(user_list->ecu, daemon.ecuid); + EXPECT_EQ(DLT_RETURN_OK, strncmp(user_list->ecu, daemon.ecuid, DLT_ID_SIZE)); user_list = dlt_daemon_find_users_list(&daemon, &ecu2[0], 0); EXPECT_NE(user_list, nullptr); - EXPECT_STREQ(user_list->ecu, gateway.connections[0].ecuid); + EXPECT_EQ(DLT_RETURN_OK, strncmp(user_list->ecu, gateway.connections[0].ecuid, DLT_ID_SIZE)); user_list = dlt_daemon_find_users_list(&daemon, &ecu3[0], 0); EXPECT_NE(user_list, nullptr); - EXPECT_STREQ(user_list->ecu, gateway.connections[1].ecuid); + EXPECT_EQ(DLT_RETURN_OK, strncmp(user_list->ecu, gateway.connections[1].ecuid, DLT_ID_SIZE)); EXPECT_EQ(0, dlt_daemon_free(&daemon, 0)); free(gateway.connections); @@ -240,7 +240,7 @@ TEST(t_dlt_daemon_application_add, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon,(char *) apid, pid, (char *) desc, fd, ecu, 0); //printf("### APP: APID=%s DESCR=%s NUMCONTEXT=%i PID=%i USERHANDLE=%i\n", app->apid,app->application_description, app->num_contexts, app->pid, app->user_handle); @@ -344,7 +344,7 @@ TEST(t_dlt_daemon_application_del, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon,(char *) apid, pid, (char *) desc, fd, ecu, 0); EXPECT_LE(0, dlt_daemon_application_del(&daemon,app, ecu, 0)); EXPECT_LE(0, dlt_daemon_applications_clear(&daemon, ecu, 0)); @@ -409,7 +409,7 @@ TEST(t_dlt_daemon_application_find, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon,(char *) apid, pid, (char *) desc, fd, ecu, 0); EXPECT_STREQ(apid, app->apid); EXPECT_STREQ(desc, app->application_description); @@ -474,7 +474,7 @@ TEST(t_dlt_daemon_applications_clear, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); EXPECT_LE((DltDaemonApplication *) 0, dlt_daemon_application_add(&daemon, (char *) "TES1", pid, (char *) "Test clear 1", fd, ecu, 0)); dlt_daemon_application_add(&daemon, (char *) "TES2", pid, (char *) "Test clear 2", fd, ecu, 0); EXPECT_LE(0, dlt_daemon_applications_clear(&daemon, ecu, 0)); @@ -520,7 +520,7 @@ TEST(t_dlt_daemon_applications_invalidate_fd, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon,(char *) apid, pid, (char *) desc, fd, ecu, 0); EXPECT_LE(0, dlt_daemon_applications_invalidate_fd(&daemon, ecu, app->user_handle, 0)); EXPECT_LE(0, dlt_daemon_application_del(&daemon, app, ecu, 0)); @@ -573,7 +573,7 @@ TEST(t_dlt_daemon_applications_save, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon,(char *) apid, pid, (char *) desc, fd, ecu, 0); EXPECT_LE(0, dlt_daemon_applications_save(&daemon, (char *) filename, 0)); EXPECT_LE(0, dlt_daemon_application_del(&daemon, app, ecu, 0)); @@ -633,7 +633,7 @@ TEST(t_dlt_daemon_applications_load, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); EXPECT_LE(0, dlt_daemon_applications_load(&daemon,(char *) filename, 0)); EXPECT_EQ(0, dlt_daemon_free(&daemon, 0)); } @@ -717,7 +717,7 @@ TEST(t_dlt_daemon_context_add, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon, apid, ctid, DLT_LOG_DEFAULT, DLT_TRACE_STATUS_DEFAULT, 0, 0, desc, ecu, 0); @@ -749,7 +749,7 @@ TEST(t_dlt_daemon_context_add, abnormal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); DltLogLevelType DLT_LOG_NOT_EXIST = (DltLogLevelType) - 100; app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon,apid,ctid,DLT_LOG_NOT_EXIST,DLT_TRACE_STATUS_DEFAULT,0,0,desc,ecu,0); @@ -856,7 +856,7 @@ TEST(t_dlt_daemon_context_add, nullpointer) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); EXPECT_EQ((DltDaemonContext *) 0, dlt_daemon_context_add(NULL,NULL,NULL,0,0,0,0,NULL,NULL,0)); EXPECT_EQ((DltDaemonContext *) 0, dlt_daemon_context_add(NULL,NULL,NULL,0,0,0,0,desc,NULL,0)); EXPECT_EQ((DltDaemonContext *) 0, dlt_daemon_context_add(NULL,NULL,ctid,0,0,0,0,NULL,NULL,0)); @@ -895,7 +895,7 @@ TEST(t_dlt_daemon_context_del, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon,apid,ctid,DLT_LOG_DEFAULT,DLT_TRACE_STATUS_DEFAULT,0,0,desc,ecu,0); EXPECT_LE(0, dlt_daemon_context_del(&daemon, daecontext, ecu, 0)); @@ -973,7 +973,7 @@ TEST(t_dlt_daemon_context_find, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon,apid,ctid,DLT_LOG_DEFAULT,DLT_TRACE_STATUS_DEFAULT,0,0,desc,ecu,0); EXPECT_STREQ(apid, daecontext->apid); @@ -1003,7 +1003,7 @@ TEST(t_dlt_daemon_context_find, abnormal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); EXPECT_EQ((DltDaemonContext *) 0 ,dlt_daemon_context_find(&daemon, apid, ctid, ecu, 0)); // No apid @@ -1081,7 +1081,7 @@ TEST(t_dlt_daemon_contexts_clear, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon,apid,ctid,DLT_LOG_DEFAULT,DLT_TRACE_STATUS_DEFAULT,0,0,desc,ecu,0); EXPECT_LE(0, dlt_daemon_context_del(&daemon, daecontext, ecu, 0)); @@ -1139,7 +1139,7 @@ TEST(t_dlt_daemon_contexts_invalidate_fd, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon,apid,ctid,DLT_LOG_DEFAULT,DLT_TRACE_STATUS_DEFAULT,0,0,desc,ecu,0); EXPECT_LE(0, dlt_daemon_contexts_invalidate_fd(&daemon, ecu, app->user_handle, 0)); @@ -1200,7 +1200,7 @@ TEST(t_dlt_daemon_contexts_save, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon,apid,ctid,DLT_LOG_DEFAULT,DLT_TRACE_STATUS_DEFAULT,0,0,desc,ecu,0); EXPECT_LE(0, dlt_daemon_contexts_save(&daemon, filename, 0)); @@ -1276,7 +1276,7 @@ TEST(t_dlt_daemon_contexts_load, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon,apid,ctid,DLT_LOG_DEFAULT,DLT_TRACE_STATUS_DEFAULT,0,0,desc,ecu,0); EXPECT_LE(0, dlt_daemon_contexts_load(&daemon, filename, 0)); @@ -1354,7 +1354,7 @@ TEST(t_dlt_daemon_user_send_all_log_state, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); EXPECT_NO_FATAL_FAILURE(dlt_daemon_user_send_all_log_state(&daemon, 0)); EXPECT_EQ(0, dlt_daemon_free(&daemon, 0)); } @@ -1383,7 +1383,7 @@ TEST(t_dlt_daemon_user_send_default_update, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); EXPECT_NO_FATAL_FAILURE(dlt_daemon_user_send_default_update(&daemon, 0)); EXPECT_EQ(0, dlt_daemon_free(&daemon, 0)); } @@ -1417,7 +1417,7 @@ TEST(t_dlt_daemon_user_send_log_level, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); app = dlt_daemon_application_add(&daemon, apid, 0, desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon,apid,ctid,DLT_LOG_DEFAULT,DLT_TRACE_STATUS_DEFAULT,0,1,desc,ecu,0); EXPECT_LE(0, dlt_daemon_user_send_log_level(&daemon, daecontext, 0)); @@ -1493,7 +1493,7 @@ TEST(t_dlt_daemon_user_send_log_state, normal) EXPECT_EQ(0, dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, DLT_RUNTIME_DEFAULT_DIRECTORY,DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + EXPECT_EQ(DLT_RETURN_OK, strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE)); // open(filename, O_RDWR |O_NONBLOCK); // dlt_daemon_init(&daemon, DLT_DAEMON_RINGBUFFER_MIN_SIZE, DLT_DAEMON_RINGBUFFER_MAX_SIZE, DLT_DAEMON_RINGBUFFER_STEP_SIZE, "",0); // app = dlt_daemon_application_add(&daemon, apid, pid, desc, 0); diff --git a/tests/gtest_dlt_daemon_event_handler.cpp b/tests/gtest_dlt_daemon_event_handler.cpp index e55d072..235b69e 100644 --- a/tests/gtest_dlt_daemon_event_handler.cpp +++ b/tests/gtest_dlt_daemon_event_handler.cpp @@ -56,50 +56,24 @@ *******************************************************************************/ #include -#include -#include -#include -#include -#include -#include -#include -#include int connectServer(void); extern "C" { - #include "dlt-daemon.h" - #include "dlt_user.h" - #include "dlt_user_shared.h" - #include "dlt_user_shared_cfg.h" - #include "dlt_user_cfg.h" - #include "dlt-daemon_cfg.h" - #include "dlt_version.h" - #include "dlt_gateway.h" - #include "dlt_daemon_common.h" - #include "dlt_daemon_connection_types.h" #include "dlt_daemon_event_handler.h" #include "dlt_daemon_connection.h" - #include "dlt_daemon_event_handler_types.h" - #include - #include - #include - #include - #include - #include #include - #include - #include - #include "dlt_config_file_parser.h" - #include "dlt_common.h" - #include "dlt_daemon_client.h" + #include + #include + #include } /* Begin Method: dlt_daemon_event_handler::t_dlt_daemon_prepare_event_handling*/ TEST(t_dlt_daemon_prepare_event_handling, normal) { DltEventHandler ev; + EXPECT_EQ(DLT_RETURN_OK, dlt_daemon_prepare_event_handling(&ev)); } @@ -165,8 +139,10 @@ TEST(t_dlt_daemon_add_connection, normal) connections1->receiver = &receiver; EXPECT_EQ(DLT_CONNECTION_CLIENT_MSG_SERIAL, ev1.connections->type); + dlt_daemon_add_connection(&ev1, connections1); head = (DltConnection*)ev1.connections->next; + EXPECT_EQ(DLT_CONNECTION_GATEWAY, head->type); free(ev1.connections); @@ -190,7 +166,6 @@ TEST(t_dlt_daemon_remove_connection, normal) memset(connections1, 0, sizeof(DltConnection)); connections1->next = 0; connections1->type = DLT_CONNECTION_GATEWAY; - DltReceiver receiver; connections1->receiver = &receiver; @@ -220,24 +195,21 @@ TEST(t_dlt_event_handler_cleanup_connections, normal) } /* Begin Method: dlt_daemon_event_handler::dlt_connection_check_activate*/ -/* TEST(t_dlt_connection_check_activate, normal) { int ret; DltEventHandler evhdl = {}; DltReceiver receiver = {}; DltConnection con = {}; - DltFilterConfiguration current = {}; - DltMessageFilter filter = {}; receiver.fd = 1; - filter.current = ¤t; con.receiver = &receiver; con.status = INACTIVE; con.type = DLT_CONNECTION_CLIENT_MSG_TCP; EXPECT_EQ(DLT_RETURN_OK, dlt_daemon_prepare_event_handling(&evhdl)); - + + ret = dlt_connection_check_activate(&evhdl, &con, ACTIVATE); EXPECT_EQ(DLT_RETURN_OK, ret); ret = dlt_connection_check_activate(&evhdl, &con, DEACTIVATE); @@ -250,7 +222,7 @@ TEST(t_dlt_connection_check_activate, nullpointer) { EXPECT_EQ(DLT_RETURN_ERROR, dlt_connection_check_activate(NULL, NULL, DEACTIVATE)); } -*/ + /* Begin Method: dlt_daemon_event_handler::dlt_event_handler_register_connection*/ TEST(t_dlt_event_handler_register_connection, normal) { @@ -260,7 +232,6 @@ TEST(t_dlt_event_handler_register_connection, normal) DltEventHandler ev1 = {}; DltConnection *connections1 = nullptr; DltReceiver receiver = {}; - DltFilterConfiguration current = {}; EXPECT_EQ(DLT_RETURN_OK, dlt_daemon_prepare_event_handling(&ev1)); @@ -270,7 +241,6 @@ TEST(t_dlt_event_handler_register_connection, normal) connections1->type = DLT_CONNECTION_GATEWAY; connections1->receiver = &receiver; - daemon_local.pFilter.current = ¤t; ret = dlt_event_handler_register_connection(&ev1, &daemon_local, @@ -298,7 +268,6 @@ TEST(t_dlt_event_handler_unregister_connection, normal) DltEventHandler ev1 = {}; DltConnection *connections1 = nullptr; DltReceiver receiver = {}; - DltFilterConfiguration current = {}; EXPECT_EQ(DLT_RETURN_OK, dlt_daemon_prepare_event_handling(&ev1)); @@ -308,10 +277,7 @@ TEST(t_dlt_event_handler_unregister_connection, normal) connections1->next = 0; connections1->type = DLT_CONNECTION_GATEWAY; connections1->receiver = &receiver; - - receiver.fd = 1; - - daemon_local.pFilter.current = ¤t; + receiver.fd = 100; ret = dlt_event_handler_register_connection(&ev1, &daemon_local, @@ -320,7 +286,7 @@ TEST(t_dlt_event_handler_unregister_connection, normal) EXPECT_EQ(DLT_RETURN_OK, ret); EXPECT_EQ(DLT_CONNECTION_GATEWAY, ev1.connections->type); - ret = dlt_event_handler_unregister_connection(&ev1, &daemon_local, 1); + ret = dlt_event_handler_unregister_connection(&ev1, &daemon_local, receiver.fd); EXPECT_EQ(DLT_RETURN_OK, ret); free(ev1.pfd); @@ -329,13 +295,9 @@ TEST(t_dlt_event_handler_unregister_connection, normal) /* Begin Method: dlt_daemon_connections::dlt_connection_create*/ TEST(t_dlt_connection_create, normal) { - int fd = 1; + int fd = 100; int ret = 0; DltDaemonLocal daemon_local = {}; - DltFilterConfiguration current = {}; - - - daemon_local.pFilter.current = ¤t; EXPECT_EQ(DLT_RETURN_OK, dlt_daemon_prepare_event_handling(&daemon_local.pEvent)); @@ -451,7 +413,6 @@ TEST(t_dlt_connection_send, normal_1) receiver.fd = connectServer(); EXPECT_NE(-1, receiver.fd); - conn.receiver = &receiver; conn.type = DLT_CONNECTION_CLIENT_MSG_TCP; @@ -470,6 +431,9 @@ TEST(t_dlt_connection_send, normal_1) ret = dlt_connection_send(&conn, data1, size1); EXPECT_EQ(DLT_RETURN_OK, ret); + + close(receiver.fd); + free(daemon_local.msg.databuffer); } TEST(t_dlt_connection_send, normal_2) @@ -481,10 +445,12 @@ TEST(t_dlt_connection_send, normal_2) receiver.fd = 1; conn.receiver = &receiver; conn.type = DLT_CONNECTION_CLIENT_MSG_SERIAL; + ret = dlt_connection_send(&conn, (void *)dltSerialHeader, sizeof(dltSerialHeader)); - EXPECT_EQ(sizeof(dltSerialHeader), ret); + + EXPECT_EQ(DLT_RETURN_OK, ret); } TEST(t_dlt_connection_send, abnormal) @@ -496,6 +462,7 @@ TEST(t_dlt_connection_send, abnormal) receiver.fd = -1; conn.receiver = &receiver; conn.type = DLT_CONNECTION_TYPE_MAX; + ret = dlt_connection_send(&conn, (void *)dltSerialHeader, sizeof(dltSerialHeader)); @@ -520,17 +487,44 @@ TEST(t_dlt_connection_send_multiple, normal_1) size2 = daemon_local.msg.datasize; receiver.fd = connectServer(); - EXPECT_NE(-1,receiver.fd); + EXPECT_NE(-1, receiver.fd); + conn.receiver = &receiver; conn.type = DLT_CONNECTION_CLIENT_MSG_TCP; + + daemon_local.msg.headersize = sizeof(DltStorageHeader) + + sizeof(DltStandardHeader) + + sizeof(DltStandardHeaderExtra) + + sizeof(DltExtendedHeader); + + memset(daemon_local.msg.headerbuffer, 0, daemon_local.msg.headersize); + + data1 = daemon_local.msg.headerbuffer + sizeof(DltStorageHeader); + size1 = daemon_local.msg.headersize - sizeof(DltStorageHeader); + + daemon_local.msg.databuffer = (uint8_t *)malloc(sizeof(uint8_t)); + if (daemon_local.msg.databuffer == NULL) + close(receiver.fd); + + EXPECT_NE((uint8_t *)NULL, daemon_local.msg.databuffer); + + memset(daemon_local.msg.databuffer, 0, sizeof(uint8_t)); + daemon_local.msg.datasize = sizeof(uint8_t); + + data2 = daemon_local.msg.databuffer; + size2 = daemon_local.msg.datasize; + ret = dlt_connection_send_multiple(&conn, data1, size1, data2, size2, 1); + EXPECT_EQ(DLT_RETURN_OK, ret); + close(receiver.fd); + free(daemon_local.msg.databuffer); } TEST(t_dlt_connection_send_multiple, normal_2) @@ -550,18 +544,44 @@ TEST(t_dlt_connection_send_multiple, normal_2) size2 = daemon_local.msg.datasize; receiver.fd = connectServer(); - EXPECT_NE(-1,receiver.fd); + EXPECT_NE(-1, receiver.fd); + conn.receiver = &receiver; conn.type = DLT_CONNECTION_CLIENT_MSG_TCP; + daemon_local.msg.headersize = sizeof(DltStorageHeader) + + sizeof(DltStandardHeader) + + sizeof(DltStandardHeaderExtra) + + sizeof(DltExtendedHeader); + + memset(daemon_local.msg.headerbuffer, 0, daemon_local.msg.headersize); + + data1 = daemon_local.msg.headerbuffer + sizeof(DltStorageHeader); + size1 = daemon_local.msg.headersize - sizeof(DltStorageHeader); + + daemon_local.msg.databuffer = (uint8_t *)malloc(sizeof(uint8_t)); + if (daemon_local.msg.databuffer == NULL) + close(receiver.fd); + + EXPECT_NE((uint8_t *)NULL, daemon_local.msg.databuffer); + + memset(daemon_local.msg.databuffer, 0, sizeof(uint8_t)); + daemon_local.msg.datasize = sizeof(uint8_t); + + data2 = daemon_local.msg.databuffer; + size2 = daemon_local.msg.datasize; + ret = dlt_connection_send_multiple(&conn, data1, size1, data2, size2, 0); + EXPECT_EQ(DLT_RETURN_OK, ret); + close(receiver.fd); + free(daemon_local.msg.databuffer); } TEST(t_dlt_connection_send_multiple, nullpointer) @@ -584,6 +604,7 @@ TEST(t_dlt_connection_send_multiple, nullpointer) data2, size2, 0); + EXPECT_EQ(DLT_RETURN_ERROR, ret); } @@ -615,6 +636,8 @@ int connectServer(void) return sockfd; } +#define GTEST_SOCKS_ACCEPTED 3 + int main(int argc, char **argv) { pid_t cpid = fork(); @@ -662,6 +685,7 @@ int main(int argc, char **argv) if(j == -1) { perror("Bind Error\n"); + close(sockfd); return -1; } @@ -682,8 +706,11 @@ int main(int argc, char **argv) bzero(buffer, 256); (void)(read(newsockfd[i - 1], buffer, 255) + 1); /* just ignore result */ i--; - close(newsockfd); } + + for(j = 0; j < GTEST_SOCKS_ACCEPTED; j++) + close(newsockfd[i]); + close(sockfd); } else @@ -691,7 +718,7 @@ int main(int argc, char **argv) ::testing::InitGoogleTest(&argc, argv); ::testing::FLAGS_gtest_break_on_failure = false; - //::testing::FLAGS_gtest_filter = "t_dlt_connection_send_multiple*"; +// ::testing::FLAGS_gtest_filter = "t_dlt_event_handler_register_connection*"; return RUN_ALL_TESTS(); } return 0; diff --git a/tests/gtest_dlt_daemon_gateway.cpp b/tests/gtest_dlt_daemon_gateway.cpp index f681243..d07c35d 100644 --- a/tests/gtest_dlt_daemon_gateway.cpp +++ b/tests/gtest_dlt_daemon_gateway.cpp @@ -62,7 +62,7 @@ extern "C" { #include "dlt_gateway.h" -#include "gtest_common.h" +#include "dlt_gateway_internal.h" } /* Begin Method: dlt_gateway::t_dlt_gateway_init*/ @@ -73,11 +73,12 @@ TEST(t_dlt_gateway_init, normal) daemon_local.pGateway.connections = &connections; daemon_local.pGateway.num_connections = 1; daemon_local.flags.lflag = 0; - DltFilterConfiguration current; - daemon_local.pFilter.current = ¤t; DltConnection connections1; DltReceiver receiver; daemon_local.pEvent.connections = &connections1; + daemon_local.pEvent.pfd = 0; + daemon_local.pEvent.nfds = 0; + daemon_local.pEvent.max_nfds = 0; daemon_local.pEvent.connections->receiver = &receiver; daemon_local.pEvent.connections->next = NULL; memset(daemon_local.flags.gatewayConfigFile,0,DLT_DAEMON_FLAG_MAX); @@ -90,8 +91,7 @@ TEST(t_dlt_gateway_init, normal) TEST(t_dlt_gateway_init, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_init(NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_init(NULL, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_send_control_message*/ @@ -99,14 +99,15 @@ TEST(t_dlt_gateway_send_control_message, Normal) { int ret = 0; DltDaemonLocal daemon_local; - DltFilterConfiguration current; - daemon_local.pFilter.current = ¤t; DltGatewayConnection connections; DltConnection connections1; DltReceiver receiver1; daemon_local.pGateway.connections = &connections; daemon_local.pEvent.connections = &connections1; daemon_local.pEvent.connections->next = NULL; + daemon_local.pEvent.pfd = 0; + daemon_local.pEvent.nfds = 0; + daemon_local.pEvent.max_nfds = 0; daemon_local.pEvent.connections->receiver = &receiver1; memset(daemon_local.flags.gatewayConfigFile,0,DLT_DAEMON_FLAG_MAX); strncpy(daemon_local.flags.gatewayConfigFile, "/tmp/dlt_gateway.conf", DLT_DAEMON_FLAG_MAX - 1); @@ -120,15 +121,14 @@ TEST(t_dlt_gateway_send_control_message, Normal) TEST(t_dlt_gateway_send_control_message, nullpointer) { - //NULL-Pointer, expect -1 - dlt_gateway_send_control_message(NULL, NULL, NULL, 0); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_send_control_message(NULL, NULL, NULL, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_store_connection*/ TEST(t_dlt_gateway_store_connection, normal) { char ip_address[DLT_CONFIG_FILE_ENTRY_MAX_LEN] = "10.113.100.100"; - char ecuid[DLT_CONFIG_FILE_ENTRY_MAX_LEN] = "1234"; + char ecuid[] = "1234"; DltGateway gateway; DltGatewayConnection tmp; DltGatewayConnection tmp1; @@ -152,11 +152,10 @@ TEST(t_dlt_gateway_store_connection, normal) TEST(t_dlt_gateway_store_connection, nullpointer) { - // NULL-Pointer, expect -1 DltGateway gateway; - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_store_connection(NULL , NULL, 0)); - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_store_connection(&gateway , NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_store_connection(NULL , NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_store_connection(&gateway , NULL, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_ip*/ @@ -172,8 +171,7 @@ TEST(t_dlt_gateway_check_ip, normal) TEST(t_dlt_gateway_check_ip, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_ip(NULL,NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_ip(NULL, NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_send_serial*/ @@ -189,8 +187,7 @@ TEST(t_dlt_gateway_check_send_serial, normal) TEST(t_dlt_gateway_check_send_serial, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_send_serial(NULL,NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_send_serial(NULL, NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_allocate_control_messages*/ @@ -205,7 +202,7 @@ TEST(t_dlt_gateway_allocate_control_messages, normal) TEST(t_dlt_gateway_allocate_control_messages, nullpointer) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_allocate_control_messages(NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_allocate_control_messages(NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_control_messages*/ @@ -221,8 +218,7 @@ TEST(t_dlt_gateway_check_control_messages, normal) TEST(t_dlt_gateway_check_control_messages, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_control_messages(NULL,NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_control_messages(NULL, NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_periodic_control_messages*/ @@ -238,7 +234,7 @@ TEST(t_dlt_gateway_check_periodic_control_messages, normal) TEST(t_dlt_gateway_check_periodic_control_messages, nullpointer) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_periodic_control_messages(NULL,NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_periodic_control_messages(NULL, NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_port*/ @@ -264,8 +260,7 @@ TEST(t_dlt_gateway_check_port, abnormal) TEST(t_dlt_gateway_check_port, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_port(NULL,NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_port(NULL, NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_ecu*/ @@ -281,8 +276,7 @@ TEST(t_dlt_gateway_check_ecu, normal) TEST(t_dlt_gateway_check_ecu, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_ecu(NULL,NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_ecu(NULL, NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_connect_trigger*/ @@ -308,8 +302,7 @@ TEST(t_dlt_gateway_check_connect_trigger, abnormal) TEST(t_dlt_gateway_check_connect_trigger, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_connect_trigger(NULL,NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_connect_trigger(NULL, NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_timeout*/ @@ -335,8 +328,7 @@ TEST(t_dlt_gateway_check_timeout, abnormal) TEST(t_dlt_gateway_check_timeout, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_timeout(NULL,NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_timeout(NULL, NULL)); } /* Begin Method: dlt_gateway::t_dlt_gateway_establish_connections*/ @@ -355,8 +347,7 @@ TEST(t_dlt_gateway_establish_connections, normal) TEST(t_dlt_gateway_establish_connections, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_establish_connections(NULL,NULL,0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_establish_connections(NULL, NULL, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_get_connection_receiver*/ @@ -393,7 +384,6 @@ TEST(t_dlt_gateway_get_connection_receiver, abnormal) TEST(t_dlt_gateway_get_connection_receiver, nullpointer) { - // NULL-Pointer, expect -1 DltReceiver *ret; ret = dlt_gateway_get_connection_receiver(NULL, 0); @@ -404,10 +394,11 @@ TEST(t_dlt_gateway_get_connection_receiver, nullpointer) TEST(t_dlt_gateway_parse_get_log_info, normal) { int32_t len; + int32_t ret = DLT_RETURN_ERROR; DltDaemon daemon; DltGateway gateway; DltMessage msg; - char ecuid[DLT_CONFIG_FILE_ENTRY_MAX_LEN] = "ECU2"; + char ecuid[] = "ECU2"; uint32_t sid = DLT_SERVICE_ID_GET_LOG_INFO; uint8_t status = 7; uint16_t count_app_ids = 1; @@ -422,15 +413,20 @@ TEST(t_dlt_gateway_parse_get_log_info, normal) int8_t log_level = -1; int8_t trace_status = -1;; int offset = 0; + memset(&daemon, 0, sizeof(DltDaemon)); dlt_set_id(daemon.ecuid, ecuid); EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_STREQ(daemon.ecuid, daemon.user_list[0].ecu); + + ret = strncmp(daemon.ecuid, daemon.user_list[0].ecu, DLT_ID_SIZE); + ASSERT_EQ(DLT_RETURN_OK, ret); /* create response message */ msg.datasize = sizeof(DltServiceGetLogInfoResponse) + sizeof(AppIDsType) + - sizeof(ContextIDsInfoType); + sizeof(ContextIDsInfoType) + + strlen(app_description) + + strlen(context_description); msg.databuffer = (uint8_t *) malloc(msg.datasize); msg.databuffersize = msg.datasize; memset(msg.databuffer, 0, msg.datasize); @@ -502,12 +498,12 @@ TEST(t_dlt_gateway_parse_get_log_info, normal) len = msg.headersize - sizeof(DltStorageHeader) + msg.datasize; msg.standardheader->len = DLT_HTOBE_16(len); - EXPECT_EQ(DLT_RETURN_OK, dlt_gateway_parse_get_log_info(&daemon, ecuid, &msg, 0)); + EXPECT_EQ(DLT_RETURN_OK, dlt_gateway_parse_get_log_info(&daemon, ecuid, &msg, CONTROL_MESSAGE_NOT_REQUESTED, 0)); } TEST(t_dlt_gateway_parse_get_log_info, nullpointer) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_parse_get_log_info(NULL, NULL, NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_parse_get_log_info(NULL, NULL, NULL, 0, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_process_passive_node_messages*/ @@ -530,8 +526,7 @@ TEST(t_dlt_gateway_process_passive_node_messages, normal) TEST(t_dlt_gateway_process_passive_node_messages, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_process_passive_node_messages(NULL, NULL, NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_process_passive_node_messages(NULL, NULL, NULL, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_process_gateway_timer*/ @@ -560,8 +555,7 @@ TEST(t_dlt_gateway_process_gateway_timer, normal) TEST(t_dlt_gateway_process_gateway_timer, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_process_gateway_timer(NULL, NULL, NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_process_gateway_timer(NULL, NULL, NULL, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_process_on_demand_request*/ @@ -604,9 +598,8 @@ TEST(t_dlt_gateway_process_on_demand_request, abnormal) TEST(t_dlt_gateway_process_on_demand_request, nullpointer) { - // NULL-Pointer, expect -1 char node_id[DLT_ID_SIZE] = "123"; - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_process_on_demand_request(NULL, NULL, node_id, 1, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_process_on_demand_request(NULL, NULL, node_id, 1, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_check_param*/ @@ -644,8 +637,7 @@ TEST(t_dlt_gateway_check_param, abnormal) TEST(t_dlt_gateway_check_param, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_check_param(NULL, NULL, GW_CONF_PORT, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_check_param(NULL, NULL, GW_CONF_PORT, 0)); } /* Begin Method: dlt_gateway::t_dlt_gateway_configure*/ @@ -663,8 +655,7 @@ TEST(t_dlt_gateway_configure, Normal) TEST(t_dlt_gateway_configure, nullpointer) { - // NULL-Pointer, expect -1 - EXPECT_EQ(DLT_RETURN_ERROR, dlt_gateway_configure(NULL, NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_gateway_configure(NULL, NULL, 0)); } int main(int argc, char **argv) diff --git a/tests/gtest_dlt_daemon_gateway.sh b/tests/gtest_dlt_daemon_gateway.sh new file mode 100755 index 0000000..21cc82e --- /dev/null +++ b/tests/gtest_dlt_daemon_gateway.sh @@ -0,0 +1,241 @@ +#!/bin/sh +################################################################################ +# @licence make begin@ +# SPDX license identifier: MPL-2.0 +# +# Copyright (C) 2016, Advanced Driver Information Technology +# This code is developed by Advanced Driver Information Technology. +# Copyright of Advanced Driver Information Technology, Bosch and DENSO. +# +# This file is part of GENIVI Project DLT - Diagnostic Log and Trace. +# +# This Source Code Form is subject to the terms of the +# Mozilla Public License (MPL), v. 2.0. +# If a copy of the MPL was not distributed with this file, +# You can obtain one at http://mozilla.org/MPL/2.0/. +# +# For further information see http://www.genivi.org/. +# @licence end@ +################################################################################ + +################################################################################ +#file : g_test_dlt_daemon_gateway.sh +# +#Description : gateway unit test preparation +# +#Author Name : Onkar Palkar +# Jeevan Ramakant Nagvekar +#Email Id : onkar.palkar@wipro.com +# jeevan.nagvekar1@wipro.com +# +#History : Last modified date : 31/07/2018 + +ipaddr=127.0.0.1 + +################################################################################ +# Function: -getOSname() +# +# Description -Retrieves OS name +# +getOSname() +{ + OS="`uname`" +} + +################################################################################ +# +# Function: -cleanup() +# +# Description -Delete the dlt_test folder if it already present +# -Check weather required binaries are avaiable or not +# -Restore dlt_gateway.conf file +# +# Return -Zero on success +# -Non zero on failure +# +cleanup() +{ + tmpPath=/tmp + + if [ "$OS" = "QNX" ] + then + PIDOF() + { + slay -p $1 > /dev/null + if [ $? -eq '0' ] + then + return 1 + else + return 0 + fi + } + KILLALL() + { + slay -9 -f $1 > /dev/null + if [ $? -eq '0' ] + then + return 1 + else + return 0 + fi + } + else + PIDOF() + { + pidof $1 > /dev/null + return $? + } + KILLALL() + { + killall $1 > /dev/null + return $? + } + fi + + cd $tmpPath + + PIDOF dlt-daemon + if [ $? -eq '0' ] + then + KILLALL dlt-daemon + if [ $? -eq '1' ] + then + echo "Failed to kill daemons" + return 1 + fi + fi + + rm -f $tmpPath/dlt.conf + rm -f $tmpPath/dlt_gateway.conf + return 0 +} +# +# Function: -setupTest() +# +# Description -Create gateway folder +# -Create and add dlt.conf and dlt_gateway.conf file in the gateway folder +# +# Return -Zero on success +# -Non zero on failure +# +setupTest() +{ + which dlt-daemon > /dev/null + if [ $? -eq '1' ] + then + echo "dlt-daemon is not available" + return 1 + fi + touch $tmpPath/dlt.conf + if [ $? -eq '1' ] + then + echo "Error in creating dlt.conf file" + return 1 + fi + echo "SendContextRegistration = 1" >>$tmpPath/dlt.conf + echo "ECUId = ECU2" >>$tmpPath/dlt.conf + echo "GatewayMode = 1" >>$tmpPath/dlt.conf + echo "SharedMemorySize = 100000" >>$tmpPath/dlt.conf + echo "LoggingMode = 0" >>$tmpPath/dlt.conf + echo "LoggingLevel = 6" >>$tmpPath/dlt.conf + echo "LoggingFilename = /tmp/dlt.log" >>$tmpPath/dlt.conf + echo "TimeOutOnSend = 4" >>$tmpPath/dlt.conf + echo "RingbufferMinSize = 500000" >>$tmpPath/dlt.conf + echo "RingbufferMaxSize = 10000000" >>$tmpPath/dlt.conf + echo "RingbufferStepSize = 500000" >>$tmpPath/dlt.conf + echo "ControlSocketPath = /tmp/dlt-ctrl.sock" >>$tmpPath/dlt.conf + echo "GatewayConfigFile = /tmp/dlt_gateway.conf" >>$tmpPath/dlt.conf + touch $tmpPath/dlt_gateway.conf + if [ $? -eq '1' ] + then + echo "Error in creating dlt_gateway file" + return 1 + fi + echo "[PassiveNode1]" >>$tmpPath/dlt_gateway.conf + echo "IPaddress=$ipaddr">>$tmpPath/dlt_gateway.conf + echo "Port=3490" >>$tmpPath/dlt_gateway.conf + echo "EcuID=ECU1" >>$tmpPath/dlt_gateway.conf + echo "Connect=OnStartup" >>$tmpPath/dlt_gateway.conf + echo "Timeout=10" >>$tmpPath/dlt_gateway.conf + echo "SendControl=0x03,0x13" >>$tmpPath/dlt_gateway.conf + echo "SendSerialHeader=0" >>$tmpPath/dlt_gateway.conf + echo "NOFiles=1" >>$tmpPath/dlt_gateway.conf + return 0 +} +# +# Function: -startDaemons() +# +# Description -Start dlt-daemon as passive node +# -Start dlt-daemon as gateway node +# +# Return -Zero on success +# -Non zero on failure +# +startDaemons() +{ + tmpPath=/tmp + dlt-daemon -d + dlt-daemon -d -p 3495 -c $tmpPath/dlt.conf + return 0 +} + +# +# Function: -checkDaemonStart +# +# Description -Check if dlt-daemon instances started successfully +# +checkDaemonStart() +{ + if [ "$OS" = "QNX" ]; then + slay -p dlt-daemon > /dev/null + total=$? + else + total=`pgrep -c dlt-daemon` + fi + + if [ $total -ne '2' ]; then + echo "Initialization of dlt-daemon instances failed" + exit + fi +} + +help() +{ + echo "Usage: " + echo "sh ./gtest_dlt_daemon_gateway.sh" +} + +executeTests() +{ + echo "Execute: gtest_dlt_daemon_gateway unit test" +} + +#main function +######################################################################################## + +getOSname + +echo "Cleaning up dlt-daemon instances" +cleanup + +if [ $? -ne '0' ] +then + help + exit +fi + +echo "Initializing test" +setupTest + +if [ $? -ne '0' ] +then + help + exit +fi + +echo "Restarting dlt-daemons" +startDaemons + +checkDaemonStart + +executeTests diff --git a/tests/gtest_dlt_daemon_logstorage.sh b/tests/gtest_dlt_daemon_logstorage.sh new file mode 100755 index 0000000..704feb7 --- /dev/null +++ b/tests/gtest_dlt_daemon_logstorage.sh @@ -0,0 +1,57 @@ +#!/bin/sh +######################################################################################## +#file : g_test_dlt_daemon_logstorage.sh +# +#Description : logstorage unit test preparation +# +#Author Name : Onkar Palkar +#Email Id : onkar.palkar@wipro.com +# +#History : Last modified date : 02/09/2016 +######################################################################################## +# +# Function: -cleanup() +# +# Description -Delete dlt_logstorage.conf file from tmp folder if present +# +# Return -Zero on success +# -Non zero on failure +# + +cleanup() +{ + tmpPath=/tmp + cd $tmpPath + rm -rf $tmpPath/dlt_logstorage.conf + return 0 +} + +# +# Function: -setupTest() +# +# Description -create logstorage.conf file +# +# Return -Zero on success +# -Non zero on failure +# +setupTest() +{ + touch $tmpPath/dlt_logstorage.conf + if [ $? -eq '1' ] + then + echo "Error in creating dlt_logstorage.conf file" + return 1 + fi + echo "[FILTER1]" >>$tmpPath/dlt_logstorage.conf + echo "LogAppName=DLST" >>$tmpPath/dlt_logstorage.conf + echo "ContextName=.*" >>$tmpPath/dlt_logstorage.conf + echo "LogLevel=DLT_LOG_ERROR" >>$tmpPath/dlt_logstorage.conf + echo "File=Test" >>$tmpPath/dlt_logstorage.conf + echo "FileSize=1000000" >>$tmpPath/dlt_logstorage.conf + echo "NOFiles=1" >>$tmpPath/dlt_logstorage.conf + return 0 +} +#main function +######################################################################################## +cleanup +setupTest diff --git a/tests/gtest_dlt_daemon_offline_log.cpp b/tests/gtest_dlt_daemon_offline_log.cpp index 7711839..f2848a1 100644 --- a/tests/gtest_dlt_daemon_offline_log.cpp +++ b/tests/gtest_dlt_daemon_offline_log.cpp @@ -11,83 +11,129 @@ */ #include +int connectServer(void); + extern "C" { #include "dlt_offline_logstorage.h" +#include "dlt_offline_logstorage_internal.h" #include "dlt_offline_logstorage_behavior.h" +#include "dlt_offline_logstorage_behavior_internal.h" #include "dlt_daemon_offline_logstorage.h" +#include "dlt_daemon_offline_logstorage_internal.h" #include "dlt_daemon_common_cfg.h" -#include "gtest_common.h" +#include +#include +#include +#include } #ifndef DLT_DAEMON_BLOCKING_TEST #define DLT_DAEMON_BLOCKING_TEST 1 #endif -/* Begin Method: dlt_logstorage::t_dlt_logstorage_hash_create*/ -TEST(t_dlt_logstorage_hash_create, normal) +/* Begin Method: dlt_logstorage::t_dlt_logstorage_hash_add*/ +TEST(t_dlt_logstorage_hash_add, normal) { - struct hsearch_data htab; + DltLogStorageFilterList *list = NULL; + DltLogStorageFilterConfig *data = NULL; + char key = 1; + + data = (DltLogStorageFilterConfig *) calloc(1, sizeof(DltLogStorageFilterConfig)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5,&htab)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_destroy(&htab)); + if (data != NULL) + { + dlt_logstorage_filter_set_strategy(data, DLT_LOGSTORAGE_SYNC_ON_MSG); + + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(&key, data, &list)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_destroy(&list, 0)); + } } -/* Begin Method: dlt_logstorage::t_dlt_logstorage_hash_add*/ -TEST(t_dlt_logstorage_hash_add, normal) +/* Begin Method: dlt_logstorage::t_dlt_logstorage_list_add_config*/ +TEST(t_dlt_logstorage_list_add_config, normal) { - struct hsearch_data htab; - char key = 1; - char value = 5; + DltLogStorageFilterConfig *data = NULL; + DltLogStorageFilterConfig *listdata = NULL; + + data = (DltLogStorageFilterConfig *) calloc(1, sizeof(DltLogStorageFilterConfig)); + listdata = (DltLogStorageFilterConfig *) calloc(1, sizeof(DltLogStorageFilterConfig)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5,&htab)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(&key, &value, &htab)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_destroy(&htab)); + if ((data != NULL) && (listdata != NULL)) + { + dlt_logstorage_list_add_config(data, &listdata); + free(data); + free(listdata); + } } /* Begin Method: dlt_logstorage::t_dlt_logstorage_hash_destroy*/ TEST(t_dlt_logstorage_hash_destroy, normal) { - struct hsearch_data htab; + DltLogStorageFilterList *list = NULL; + DltLogStorageFilterConfig *data = NULL; char key = 1; - char value = 5; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5,&htab)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(&key, &value, &htab)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_destroy(&htab)); + data = (DltLogStorageFilterConfig *) calloc(1, sizeof(DltLogStorageFilterConfig)); + + if (data != NULL) + { + dlt_logstorage_filter_set_strategy(data, DLT_LOGSTORAGE_SYNC_ON_MSG); + + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(&key, data, &list)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_destroy(&list, 0)); + } } /* Begin Method: dlt_logstorage::t_dlt_logstorage_hash_find*/ TEST(t_dlt_logstorage_hash_find, normal) { - struct hsearch_data htab; - char key = 1; - char value = 5; - char *retData; + DltLogStorageFilterList *list = NULL; + DltLogStorageFilterConfig *data = NULL; + DltLogStorageFilterConfig *retData; + char key[] = "1"; + char apid[] = "1234"; + char ctid[] = "5678"; + + data = (DltLogStorageFilterConfig *) calloc(1, sizeof(DltLogStorageFilterConfig)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5,&htab)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(&key, &value, &htab)); + if (data != NULL) + { + data->apids = strdup(apid); + data->ctids = strdup(ctid); + dlt_logstorage_filter_set_strategy(data, DLT_LOGSTORAGE_SYNC_ON_MSG); - retData = (char*)dlt_logstorage_hash_find(&key, &htab); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key, data, &list)); - EXPECT_EQ(5, *retData); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_destroy(&htab)); + retData = (DltLogStorageFilterConfig*)dlt_logstorage_list_find(key, &list); + EXPECT_NE((DltLogStorageFilterConfig *)NULL, retData); + + if (retData != NULL) + { + EXPECT_STREQ(apid, retData->apids); + EXPECT_STREQ(ctid, retData->ctids); + } + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_destroy(&list, 0)); + } } /* Begin Method: dlt_logstorage::t_dlt_logstorage_free*/ TEST(t_dlt_logstorage_free, normal) { char key = 1; - char value = 5; DltLogStorage handle; + DltLogStorageFilterConfig *data = NULL; int reason = 0; handle.num_configs = 0; - handle.filter_keys = (char *)calloc (1, sizeof(char)); - handle.configs = (DltLogStorageFilterConfig *)calloc (1, sizeof(DltLogStorageFilterConfig)); - if(handle.filter_keys != NULL && handle.configs != NULL) + handle.config_list = NULL; + + data = (DltLogStorageFilterConfig *) calloc(1, sizeof(DltLogStorageFilterConfig)); + + if(data != NULL) { - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5,&handle.config_htab)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(&key, &value, &handle.config_htab)); + dlt_logstorage_filter_set_strategy(data, DLT_LOGSTORAGE_SYNC_ON_MSG); + + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(&key, data, &handle.config_list)); dlt_logstorage_free(&handle, reason); } @@ -129,12 +175,13 @@ TEST(t_dlt_logstorage_create_keys, normal) DltLogStorageFilterConfig data; char *keys = NULL; int num_keys = 0; - char apids; - char ctids; - data.apids = &apids; - data.ctids = &ctids; + char apids[] = "1234"; + char ctids[] = "5678"; + char ecuid[] = "ECU1"; + data.apids = apids; + data.ctids = ctids; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_create_keys(data.apids, data.ctids, &keys, &num_keys)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_create_keys(data.apids, data.ctids, ecuid, &keys, &num_keys)); } /* Begin Method: dlt_logstorage::t_dlt_logstorage_prepare_table*/ @@ -144,20 +191,19 @@ TEST(t_dlt_logstorage_prepare_table, normal) DltLogStorageFilterConfig data; memset(&handle, 0, sizeof(DltLogStorage)); memset(&data, 0, sizeof(DltLogStorageFilterConfig)); - char apids; - char ctids; - char filter_keys; - data.apids = &apids; - data.ctids = &ctids; + char apids[] = "1234"; + char ctids[] = "5678"; + data.apids = apids; + data.ctids = ctids; handle.num_filter_keys = 1; data.records = NULL; data.log = NULL; data.cache = NULL; - handle.filter_keys = &filter_keys; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5,&handle.config_htab)); + dlt_logstorage_filter_set_strategy(&data, DLT_LOGSTORAGE_SYNC_ON_MSG); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_prepare_table(&handle, &data)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_destroy(&handle.config_htab)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_destroy(&handle.config_list, 0)); } TEST(t_dlt_logstorage_prepare_table, null) @@ -343,7 +389,7 @@ TEST(t_dlt_logstorage_check_sync_strategy, abnormal) DltLogStorageFilterConfig config; config.sync = 0; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_check_sync_strategy(&config, value)); + EXPECT_EQ(DLT_RETURN_TRUE, dlt_logstorage_check_sync_strategy(&config, value)); EXPECT_EQ(DLT_LOGSTORAGE_SYNC_ON_MSG, config.sync); } @@ -399,18 +445,15 @@ TEST(t_dlt_logstorage_store_filters, normal) handle.write_errors = 0; handle.num_filter_keys = 0; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5,&(handle.config_htab))); - - handle.configs = NULL; - handle.filter_keys = NULL; + handle.config_list = NULL; EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_store_filters(&handle, config_file_name)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_destroy(&handle.config_htab)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_destroy(&handle.config_list, 0)); } TEST(t_dlt_logstorage_store_filters, null) { - EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_store_filters(NULL, NULL)); + EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_store_filters(NULL, NULL)); } /* Begin Method: dlt_logstorage::t_dlt_logstorage_load_config*/ @@ -421,12 +464,11 @@ TEST(t_dlt_logstorage_load_config, normal) handle.config_status = 0; handle.write_errors = 0; handle.num_filter_keys = 0; - handle.configs = NULL; - handle.filter_keys = NULL; + handle.config_list = NULL; strncpy(handle.device_mount_point, "/tmp", DLT_MOUNT_PATH_MAX); EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_load_config(&handle)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_destroy(&handle.config_htab)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_destroy(&handle.config_list, 0)); } TEST(t_dlt_logstorage_load_config, null) @@ -438,11 +480,14 @@ TEST(t_dlt_logstorage_load_config, null) TEST(t_dlt_logstorage_device_connected, normal) { DltLogStorage handle; - char mount_point[DLT_MOUNT_PATH_MAX] = "/tmp"; + handle.connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_DISCONNECTED; handle.config_status = 0; - handle.connection_type = 0; + handle.write_errors = 0; + handle.num_filter_keys = 0; + handle.config_list = NULL; + strncpy(handle.device_mount_point, "/tmp", DLT_MOUNT_PATH_MAX); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_device_connected(&handle, mount_point)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_device_connected(&handle, handle.device_mount_point)); } TEST(t_dlt_logstorage_device_connected, null) @@ -469,17 +514,24 @@ TEST(t_dlt_logstorage_get_loglevel_by_key, normal) { char arr[] = "abc"; char *key = arr; - DltLogStorageFilterConfig config; + DltLogStorageFilterConfig* config = NULL; DltLogStorage handle; handle.config_status = 0; handle.connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_CONNECTED; handle.config_status = DLT_OFFLINE_LOGSTORAGE_CONFIG_DONE; + handle.config_list = NULL; + + config = (DltLogStorageFilterConfig *) calloc(1, sizeof(DltLogStorageFilterConfig)); - config.log_level = DLT_LOG_ERROR; + if (config != NULL) + { + config->log_level = DLT_LOG_ERROR; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5,&(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key, &config, &(handle.config_htab))); - EXPECT_GE(DLT_LOG_ERROR, dlt_logstorage_get_loglevel_by_key(&handle, key)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key, config, &(handle.config_list))); + EXPECT_GE(DLT_LOG_ERROR, dlt_logstorage_get_loglevel_by_key(&handle, key)); + + free(config); + } } TEST(t_dlt_logstorage_get_loglevel_by_key, null) @@ -493,26 +545,28 @@ TEST(t_dlt_logstorage_get_config, normal) char apid[] = "1234"; char ctid[] = "5678"; char ecuid[] = "12"; + char file_name[] = "file_name"; int num_config = 0; DltLogStorageFilterConfig value; value.log_level = 0; value.apids = apid; value.ctids = ctid; value.ecuid = ecuid; - char key0[] = "1234:\000\000\000\000"; - char key1[] = ":5678\000\000\000\000"; - char key2[] = "1234:5678"; + value.file_name = file_name; + char key0[] = ":1234:\000\000\000\000"; + char key1[] = "::5678\000\000\000\000"; + char key2[] = ":1234:5678"; DltLogStorageFilterConfig *config[3] = {0}; DltLogStorage handle; handle.connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_CONNECTED; handle.config_status = DLT_OFFLINE_LOGSTORAGE_CONFIG_DONE; + handle.config_list = NULL; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key0, &value, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key1, &value, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key2, &value, &(handle.config_htab))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key0, &value, &(handle.config_list))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key1, &value, &(handle.config_list))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key2, &value, &(handle.config_list))); - num_config = dlt_logstorage_get_config(&handle, config, apid, ctid); + num_config = dlt_logstorage_get_config(&handle, config, apid, ctid, ecuid); EXPECT_EQ(num_config, 3); } @@ -520,7 +574,7 @@ TEST(t_dlt_logstorage_get_config, normal) TEST(t_dlt_logstorage_get_config, null) { int num = -1; - num = dlt_logstorage_get_config(NULL, NULL, NULL, NULL); + num = dlt_logstorage_get_config(NULL, NULL, NULL, NULL, NULL); EXPECT_EQ(num, 0); } @@ -531,23 +585,26 @@ TEST(t_dlt_logstorage_filter, normal) char apid[] = "1234"; char ctid[] = "5678"; char ecuid[] = "12"; + char filename[] = "file_name"; int num = 1; DltLogStorageFilterConfig value; value.apids = apid; value.ctids = ctid; value.ecuid = ecuid; - char key0[] = "1234:\000\000\000\000"; - char key1[] = ":5678\000\000\000\000"; - char key2[] = "1234:5678"; - DltLogStorageFilterConfig *config[3] = {0}; + value.file_name = filename; + value.log_level = DLT_LOG_VERBOSE; + char key0[] = ":1234:\000\000\000\000"; + char key1[] = "::5678\000\000\000\000"; + char key2[] = ":1234:5678"; + DltLogStorageFilterConfig *config[DLT_OFFLINE_LOGSTORAGE_MAX_POSSIBLE_CONFIGS] = {0}; DltLogStorage handle; handle.connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_CONNECTED; handle.config_status = DLT_OFFLINE_LOGSTORAGE_CONFIG_DONE; + handle.config_list = NULL; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key0, &value, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key1, &value, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key2, &value, &(handle.config_htab))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key0, &value, &(handle.config_list))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key1, &value, &(handle.config_list))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key2, &value, &(handle.config_list))); num = dlt_logstorage_filter(&handle, config, apid, ctid, ecuid, 0); @@ -558,7 +615,7 @@ TEST(t_dlt_logstorage_filter, null) { DltLogStorageFilterConfig *config[3] = {0}; int num = dlt_logstorage_filter(NULL, config, NULL, NULL, NULL, 0); - EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, num); + EXPECT_EQ(DLT_RETURN_ERROR, num); } /* Begin Method: dlt_logstorage::t_dlt_logstorage_write*/ @@ -567,6 +624,7 @@ TEST(t_dlt_logstorage_write, normal) char apid[] = "1234"; char ctid[] = "5678"; char ecuid[] = "12"; + char file_name[] = "file_name"; DltLogStorage handle; DltLogStorageUserConfig uconfig; unsigned char data1[] = "123"; @@ -577,18 +635,19 @@ TEST(t_dlt_logstorage_write, normal) int size3 = 3; handle.connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_CONNECTED; handle.config_status = DLT_OFFLINE_LOGSTORAGE_CONFIG_DONE; + handle.config_list = NULL; DltLogStorageFilterConfig value; value.apids = apid; value.ctids = ctid; value.ecuid = ecuid; - char key0[] = "1234:\000\000\000\000"; - char key1[] = ":5678\000\000\000\000"; - char key2[] = "1234:5678"; - - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key0, &value, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key1, &value, &(handle.config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key2, &value, &(handle.config_htab))); + value.file_name = file_name; + char key0[] = ":1234:\000\000\000\000"; + char key1[] = "::5678\000\000\000\000"; + char key2[] = ":1234:5678"; + + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key0, &value, &(handle.config_list))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key1, &value, &(handle.config_list))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key2, &value, &(handle.config_list))); EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_write(&handle, &uconfig, data1, size1, data2, size2, data3, size3)); } @@ -603,15 +662,19 @@ TEST(t_dlt_logstorage_sync_caches, normal) char apid[] = "1234"; char ctid[] = "5678"; char ecuid[] = "12"; + char filename[] = "file_name"; + char key[] = "12:1234:5678"; DltLogStorage handle; handle.num_configs = 1; + handle.config_list = NULL; DltLogStorageFilterConfig configs; - handle.configs = &configs; configs.apids = apid; configs.ctids = ctid; configs.ecuid = ecuid; - dlt_logstorage_filter_set_strategy(handle.configs, DLT_LOGSTORAGE_SYNC_ON_MSG); + configs.file_name = filename; + dlt_logstorage_filter_set_strategy(&configs, DLT_LOGSTORAGE_SYNC_ON_MSG); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key, &configs, &(handle.config_list))); EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_sync_caches(&handle)); } @@ -874,20 +937,23 @@ TEST(t_dlt_logstorage_write_on_msg, null) TEST(t_dlt_logstorage_sync_on_msg, normal) { DltLogStorageFilterConfig config; + DltLogStorageUserConfig file_config; char apids; char ctids; + memset(&config, 0, sizeof(DltLogStorageFilterConfig)); config.apids = &apids; config.ctids = &ctids; config.file_name = (char*)"Test"; config.records = NULL; config.log = NULL; + char *path = NULL; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_sync_on_msg(&config, DLT_LOGSTORAGE_SYNC_ON_MSG)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_sync_on_msg(&config, &file_config, path, DLT_LOGSTORAGE_SYNC_ON_MSG)); } TEST(t_dlt_logstorage_sync_on_msg, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_sync_on_msg(NULL, 0)); + EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_sync_on_msg(NULL,NULL,NULL, 0)); } /* Begin Method: dlt_logstorage::t_dlt_logstorage_prepare_msg_cache*/ @@ -909,6 +975,7 @@ TEST(t_dlt_logstorage_prepare_msg_cache, normal) config.log = NULL; config.cache = NULL; config.file_size = 0; + config.sync = DLT_LOGSTORAGE_SYNC_ON_DEMAND; g_logstorage_cache_max = 16; EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_prepare_msg_cache(&config, &file_config, path, 1)); @@ -950,58 +1017,75 @@ TEST(t_dlt_logstorage_write_msg_cache, null) /* Begin Method: dlt_logstorage::t_dlt_logstorage_split_key*/ TEST(t_dlt_logstorage_split_key, normal) { - char key[] = "dlt:1020"; - char appid[] = "2345"; - char ctxid[] = "6789"; + char key[] = "dlt:1020:"; + char appid[] = ":2345:"; + char ctxid[] = "::6789"; + char ecuid[] = "ECU1"; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_split_key(key, appid, ctxid)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_split_key(key, appid, ctxid, ecuid)); } TEST(t_dlt_logstorage_split_key, null) { - char key[] = "dlt:1020"; + char key[] = "dlt:1020:"; char appid[] = "2345"; char ctxid[] = "6789"; - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_split_key(NULL, NULL, NULL)); - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_split_key(NULL, appid, ctxid)); - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_split_key(key, NULL, ctxid)); - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_split_key(key, appid, NULL)); + char ecuid[] = "ECU1"; + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_split_key(NULL, NULL, NULL, NULL)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_split_key(NULL, appid, ctxid, ecuid)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_split_key(key, NULL, ctxid, ecuid)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_split_key(key, appid, NULL, ecuid)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_split_key(key, appid, ctxid, NULL)); } /* Begin Method: dlt_logstorage::t_dlt_logstorage_update_all_contexts*/ TEST(t_dlt_logstorage_update_all_contexts, normal) { DltDaemon daemon; - DltGateway gateway; + DltDaemonLocal daemon_local; memset(&daemon, 0, sizeof(DltDaemon)); - memset(&gateway, 0, sizeof(DltGateway)); + memset(&daemon_local.pGateway, 0, sizeof(DltGateway)); char ecu[] = "ECU1"; + char apid[] = "123"; + + daemon_local.RingbufferMinSize = DLT_DAEMON_RINGBUFFER_MIN_SIZE; + daemon_local.RingbufferMaxSize = DLT_DAEMON_RINGBUFFER_MAX_SIZE; + daemon_local.RingbufferStepSize = DLT_DAEMON_RINGBUFFER_STEP_SIZE; EXPECT_EQ(0, dlt_daemon_init(&daemon, - DLT_DAEMON_RINGBUFFER_MIN_SIZE, - DLT_DAEMON_RINGBUFFER_MAX_SIZE, - DLT_DAEMON_RINGBUFFER_STEP_SIZE, + daemon_local.RingbufferMinSize, + daemon_local.RingbufferMaxSize, + daemon_local.RingbufferStepSize, DLT_RUNTIME_DEFAULT_DIRECTORY, DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); - EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_update_all_contexts(&daemon, ecu, 1, 1, 0)); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_update_all_contexts(&daemon, ecu, 0, 1, 0)); + EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &daemon_local.pGateway, 0, 0)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_update_all_contexts(&daemon, &daemon_local, apid, 1, 1, ecu, 0)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_update_all_contexts(&daemon, &daemon_local, apid, 0, 1, ecu, 0)); } TEST(t_dlt_logstorage_update_all_contexts, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_update_all_contexts(NULL, NULL, 0, 0, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_update_all_contexts(NULL, NULL, NULL, 0, 0, NULL, 0)); } /* Begin Method: dlt_logstorage::t_dlt_logstorage_update_context*/ TEST(t_dlt_logstorage_update_context, normal) { DltDaemon daemon; - DltGateway gateway; + DltDaemonLocal daemon_local; DltDaemonContext *daecontext = NULL; + DltDaemonApplication *app = NULL; memset(&daemon, 0, sizeof(DltDaemon)); - memset(&gateway, 0, sizeof(DltGateway)); + memset(&daemon_local, 0, sizeof(DltDaemonLocal)); + memset(&daemon_local.pGateway, 0, sizeof(DltGateway)); + + int fd = connectServer(); + EXPECT_NE(-1, fd); + + daemon_local.RingbufferMinSize = DLT_DAEMON_RINGBUFFER_MIN_SIZE; + daemon_local.RingbufferMaxSize = DLT_DAEMON_RINGBUFFER_MAX_SIZE; + daemon_local.RingbufferStepSize = DLT_DAEMON_RINGBUFFER_STEP_SIZE; char apid[] = "123"; char ctid[] = "456"; @@ -1009,139 +1093,166 @@ TEST(t_dlt_logstorage_update_context, normal) char ecu[] = "ECU1"; EXPECT_EQ(0, dlt_daemon_init(&daemon, - DLT_DAEMON_RINGBUFFER_MIN_SIZE, - DLT_DAEMON_RINGBUFFER_MAX_SIZE, - DLT_DAEMON_RINGBUFFER_STEP_SIZE, + daemon_local.RingbufferMinSize, + daemon_local.RingbufferMaxSize, + daemon_local.RingbufferStepSize, DLT_RUNTIME_DEFAULT_DIRECTORY, DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); - EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); + EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &daemon_local.pGateway, 0, 0)); + app = dlt_daemon_application_add(&daemon, apid, getpid() , desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon, apid, ctid, DLT_LOG_DEFAULT, - DLT_TRACE_STATUS_DEFAULT, 0, 0, desc, daemon.ecuid, 0); - EXPECT_EQ((DltDaemonContext*)(NULL), daecontext); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_update_context(&daemon, apid, ctid, 1, 0)); + DLT_TRACE_STATUS_DEFAULT, 0, app->user_handle, desc, daemon.ecuid, 0); + EXPECT_NE((DltDaemonContext*)(NULL), daecontext); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_update_context(&daemon, &daemon_local, apid, ctid, ecu, 1, 0)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_update_context(&daemon, &daemon_local, apid, ctid, ecu, 0, 0)); } TEST(t_dlt_logstorage_update_context, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_update_context(NULL, NULL, NULL, 0, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_update_context(NULL, NULL, NULL, NULL, NULL, 0, 0)); } /* Begin Method: dlt_logstorage::t_dlt_logstorage_update_context_loglevel*/ TEST(t_dlt_logstorage_update_context_loglevel, normal) { DltDaemon daemon; - DltGateway gateway; + DltDaemonLocal daemon_local; DltDaemonContext *daecontext = NULL; + DltDaemonApplication *app = NULL; memset(&daemon, 0, sizeof(DltDaemon)); - memset(&gateway, 0, sizeof(DltGateway)); + memset(&daemon_local, 0, sizeof(DltDaemonLocal)); + memset(&daemon_local.pGateway, 0, sizeof(DltGateway)); + + int fd = connectServer(); + EXPECT_NE(-1, fd); + + daemon_local.RingbufferMinSize = DLT_DAEMON_RINGBUFFER_MIN_SIZE; + daemon_local.RingbufferMaxSize = DLT_DAEMON_RINGBUFFER_MAX_SIZE; + daemon_local.RingbufferStepSize = DLT_DAEMON_RINGBUFFER_STEP_SIZE; char apid[] = "123"; char ctid[] = "456"; - char key[] = "123:456"; - char desc[255] = "TEST dlt_logstorage_update_context"; + char key[] = ":123:456"; + char desc[255] = "TEST dlt_logstorage_update_context_loglevel"; char ecu[] = "ECU1"; EXPECT_EQ(0, dlt_daemon_init(&daemon, - DLT_DAEMON_RINGBUFFER_MIN_SIZE, - DLT_DAEMON_RINGBUFFER_MAX_SIZE, - DLT_DAEMON_RINGBUFFER_STEP_SIZE, + daemon_local.RingbufferMinSize, + daemon_local.RingbufferMaxSize, + daemon_local.RingbufferStepSize, DLT_RUNTIME_DEFAULT_DIRECTORY, DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); - EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - + EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &daemon_local.pGateway, 0, 0)); + app = dlt_daemon_application_add(&daemon, apid, getpid(), desc, fd, ecu, 0); daecontext = dlt_daemon_context_add(&daemon, apid, ctid, DLT_LOG_DEFAULT, - DLT_TRACE_STATUS_DEFAULT, 0, 0, desc, daemon.ecuid, 0); - - EXPECT_EQ((DltDaemonContext*)(NULL), daecontext); + DLT_TRACE_STATUS_DEFAULT, 0, app->user_handle, desc, daemon.ecuid, 0); + EXPECT_NE((DltDaemonContext*)(NULL), daecontext); EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_update_context_loglevel - (&daemon, key, 1, 0)); + (&daemon, &daemon_local, key, 1, 0)); } TEST(t_dlt_logstorage_update_context_loglevel, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_update_context_loglevel(NULL, NULL, 0, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_update_context_loglevel(NULL, NULL, NULL, 0, 0)); } /* Begin Method: dlt_logstorage::t_dlt_daemon_logstorage_reset_application_loglevel*/ TEST(t_dlt_daemon_logstorage_reset_application_loglevel, normal) { DltDaemon daemon; - DltGateway gateway; + DltDaemonLocal daemon_local; memset(&daemon, 0, sizeof(DltDaemon)); - memset(&gateway, 0, sizeof(DltGateway)); + memset(&daemon_local, 0, sizeof(daemon_local)); + memset(&daemon_local.pGateway, 0, sizeof(DltGateway)); + + daemon_local.RingbufferMinSize = DLT_DAEMON_RINGBUFFER_MIN_SIZE; + daemon_local.RingbufferMaxSize = DLT_DAEMON_RINGBUFFER_MAX_SIZE; + daemon_local.RingbufferStepSize = DLT_DAEMON_RINGBUFFER_STEP_SIZE; + char ecu[] = "ECU1"; int device_index = 0; + EXPECT_EQ(0, dlt_daemon_init(&daemon, - DLT_DAEMON_RINGBUFFER_MIN_SIZE, - DLT_DAEMON_RINGBUFFER_MAX_SIZE, - DLT_DAEMON_RINGBUFFER_STEP_SIZE, + daemon_local.RingbufferMinSize, + daemon_local.RingbufferMaxSize, + daemon_local.RingbufferStepSize, DLT_RUNTIME_DEFAULT_DIRECTORY, DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); - EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); - EXPECT_NO_THROW(dlt_daemon_logstorage_reset_application_loglevel(&daemon, device_index, 1, 0)); + EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &daemon_local.pGateway, 0, 0)); + EXPECT_NO_THROW(dlt_daemon_logstorage_reset_application_loglevel(&daemon, &daemon_local, device_index, 1, 0)); } TEST(t_dlt_daemon_logstorage_reset_application_loglevel, null) { - EXPECT_NO_THROW(dlt_daemon_logstorage_reset_application_loglevel(NULL, 0, 0, 0)); + EXPECT_NO_THROW(dlt_daemon_logstorage_reset_application_loglevel(NULL, NULL, 0, 0, 0)); } -/* Begin Method: dlt_logstorage::t_dlt_daemon_logstorage_update_application_loglevel*/ -TEST(t_dlt_daemon_logstorage_update_application_loglevel, normal) +/* Begin Method: dlt_logstorage::t_dlt_daemon_logstorage_get_loglevel*/ +TEST(t_dlt_daemon_logstorage_get_loglevel, normal) { char ecu[] = "ECU1"; + char apid[] = "1234"; + char ctid[] = "5678"; + char key[] = "ECU1:1234:5678"; int device_index = 0; DltDaemon daemon; - DltGateway gateway; + DltDaemonLocal daemon_local; memset(&daemon, 0, sizeof(DltDaemon)); - memset(&gateway, 0, sizeof(DltGateway)); + memset(&daemon_local, 0, sizeof(DltDaemonLocal)); + memset(&daemon_local.pGateway, 0, sizeof(DltGateway)); DltLogStorageFilterConfig value; - value.log_level = 5; + value.log_level = 4; + value.apids = apid; + value.ctids = ctid; + value.ecuid = ecu; DltLogStorage storage_handle; + daemon_local.RingbufferMinSize = DLT_DAEMON_RINGBUFFER_MIN_SIZE; + daemon_local.RingbufferMaxSize = DLT_DAEMON_RINGBUFFER_MAX_SIZE; + daemon_local.RingbufferStepSize = DLT_DAEMON_RINGBUFFER_STEP_SIZE; + EXPECT_EQ(0, dlt_daemon_init(&daemon, - DLT_DAEMON_RINGBUFFER_MIN_SIZE, - DLT_DAEMON_RINGBUFFER_MAX_SIZE, - DLT_DAEMON_RINGBUFFER_STEP_SIZE, + daemon_local.RingbufferMinSize, + daemon_local.RingbufferMaxSize, + daemon_local.RingbufferStepSize, DLT_RUNTIME_DEFAULT_DIRECTORY, DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); - EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); + EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &daemon_local.pGateway, 0, 0)); daemon.storage_handle = &storage_handle; daemon.storage_handle->connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_CONNECTED; daemon.storage_handle->num_filter_keys = 1; daemon.storage_handle->config_status = DLT_OFFLINE_LOGSTORAGE_CONFIG_DONE; - daemon.storage_handle->filter_keys = (char*)calloc( - DLT_OFFLINE_LOGSTORAGE_MAX_KEY_LEN, sizeof(char)); - strncpy(daemon.storage_handle->filter_keys, "key:1020", - DLT_OFFLINE_LOGSTORAGE_MAX_KEY_LEN); + daemon.storage_handle->config_list = NULL; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5, &(daemon.storage_handle->config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(daemon.storage_handle->filter_keys, &value, &(daemon.storage_handle->config_htab))); - EXPECT_NO_THROW(dlt_daemon_logstorage_update_application_loglevel(&daemon, device_index, 0)); - free(daemon.storage_handle->filter_keys); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key, &value, &(daemon.storage_handle->config_list))); + EXPECT_NO_THROW(dlt_daemon_logstorage_update_application_loglevel(&daemon, &daemon_local, device_index, 0)); + + EXPECT_EQ(4, dlt_daemon_logstorage_get_loglevel(&daemon, 1, apid, ctid)); } -TEST(t_dlt_daemon_logstorage_update_application_loglevel, null) +TEST(t_dlt_daemon_logstorage_get_loglevel, null) { - EXPECT_NO_THROW(dlt_daemon_logstorage_update_application_loglevel(NULL, 0, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_daemon_logstorage_get_loglevel(NULL, 0, NULL, NULL)); } -/* Begin Method: dlt_logstorage::t_dlt_daemon_logstorage_get_loglevel*/ -TEST(t_dlt_daemon_logstorage_get_loglevel, normal) +/* Begin Method: dlt_logstorage::t_dlt_daemon_logstorage_update_application_loglevel*/ +TEST(t_dlt_daemon_logstorage_update_application_loglevel, normal) { - char ecu[] = "ECU1"; + char ecu[] = "key"; char apid[] = "1234"; char ctid[] = "5678"; + char key[] = "key:1234:5678"; int device_index = 0; DltDaemon daemon; - DltGateway gateway; + DltDaemonLocal daemon_local; memset(&daemon, 0, sizeof(DltDaemon)); - memset(&gateway, 0, sizeof(DltGateway)); + memset(&daemon_local, 0, sizeof(DltDaemonLocal)); + memset(&daemon_local.pGateway, 0, sizeof(DltGateway)); DltLogStorageFilterConfig value; value.log_level = 5; value.apids = apid; @@ -1149,36 +1260,32 @@ TEST(t_dlt_daemon_logstorage_get_loglevel, normal) value.ecuid = ecu; DltLogStorage storage_handle; + daemon_local.RingbufferMinSize = DLT_DAEMON_RINGBUFFER_MIN_SIZE; + daemon_local.RingbufferMaxSize = DLT_DAEMON_RINGBUFFER_MAX_SIZE; + daemon_local.RingbufferStepSize = DLT_DAEMON_RINGBUFFER_STEP_SIZE; + EXPECT_EQ(0, dlt_daemon_init(&daemon, - DLT_DAEMON_RINGBUFFER_MIN_SIZE, - DLT_DAEMON_RINGBUFFER_MAX_SIZE, - DLT_DAEMON_RINGBUFFER_STEP_SIZE, + daemon_local.RingbufferMinSize, + daemon_local.RingbufferMaxSize, + daemon_local.RingbufferStepSize, DLT_RUNTIME_DEFAULT_DIRECTORY, DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); dlt_set_id(daemon.ecuid, ecu); - EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); + EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &daemon_local.pGateway, 0, 0)); daemon.storage_handle = &storage_handle; daemon.storage_handle->connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_CONNECTED; daemon.storage_handle->num_filter_keys = 1; daemon.storage_handle->config_status = DLT_OFFLINE_LOGSTORAGE_CONFIG_DONE; - daemon.storage_handle->filter_keys = (char*)calloc( - DLT_OFFLINE_LOGSTORAGE_MAX_KEY_LEN, sizeof(char)); - strncpy(daemon.storage_handle->filter_keys, "1234:5678", - DLT_OFFLINE_LOGSTORAGE_MAX_KEY_LEN); - - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5, &(daemon.storage_handle->config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(daemon.storage_handle-> - filter_keys, &value, &(daemon.storage_handle->config_htab))); - EXPECT_NO_THROW(dlt_daemon_logstorage_update_application_loglevel(&daemon, device_index, 0)); + daemon.storage_handle->config_list = NULL; - EXPECT_EQ(5, dlt_daemon_logstorage_get_loglevel(&daemon, 1, apid, ctid)); - free(daemon.storage_handle->filter_keys); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key, &value, &(daemon.storage_handle->config_list))); + EXPECT_NO_THROW(dlt_daemon_logstorage_update_application_loglevel(&daemon, &daemon_local, device_index, 0)); } -TEST(t_dlt_daemon_logstorage_get_loglevel, null) +TEST(t_dlt_daemon_logstorage_update_application_loglevel, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_daemon_logstorage_get_loglevel(NULL, 0, NULL, NULL)); + EXPECT_NO_THROW(dlt_daemon_logstorage_update_application_loglevel(NULL, NULL, 0, 0)); } /* Begin Method: dlt_logstorage::t_dlt_daemon_logstorage_write*/ @@ -1215,6 +1322,7 @@ TEST(t_dlt_daemon_logstorage_write, normal) int size = 10 * sizeof(uint32_t);; daemon.storage_handle->connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_CONNECTED; daemon.storage_handle->config_status = DLT_OFFLINE_LOGSTORAGE_CONFIG_DONE; + daemon.storage_handle->config_list = NULL; DltLogStorageFilterConfig value; value.apids = apid; value.ctids = ctid; @@ -1222,17 +1330,10 @@ TEST(t_dlt_daemon_logstorage_write, normal) char key0[] = "1234:\000\000\000\000"; char key1[] = ":5678\000\000\000\000"; char key2[] = "1234:5678"; - DltLogStorageFilterConfig configs; - daemon.storage_handle->configs = &configs; - daemon.storage_handle->configs->apids = apid; - daemon.storage_handle->configs->ctids = ctid; - daemon.storage_handle->configs->ecuid = ecuid; - daemon.storage_handle->configs->log_level = 5; - - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_create(5, &(daemon.storage_handle->config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key0, &value, &(daemon.storage_handle->config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key1, &value, &(daemon.storage_handle->config_htab))); - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_hash_add(key2, &value, &(daemon.storage_handle->config_htab))); + + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key0, &value, &(daemon.storage_handle->config_list))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key1, &value, &(daemon.storage_handle->config_list))); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key2, &value, &(daemon.storage_handle->config_list))); EXPECT_NO_THROW(dlt_daemon_logstorage_write(&daemon, &uconfig, data1, size, data2, size, data3, size)); } @@ -1245,29 +1346,37 @@ TEST(t_dlt_daemon_logstorage_write, null) TEST(t_dlt_daemon_logstorage_setup_internal_storage, normal) { DltDaemon daemon; - DltGateway gateway; + DltDaemonLocal daemon_local; memset(&daemon, 0, sizeof(DltDaemon)); - memset(&gateway, 0, sizeof(DltGateway)); + memset(&daemon_local, 0, sizeof(DltDaemonLocal)); + memset(&daemon_local.pGateway, 0, sizeof(DltGateway)); + + daemon_local.RingbufferMinSize = DLT_DAEMON_RINGBUFFER_MIN_SIZE; + daemon_local.RingbufferMaxSize = DLT_DAEMON_RINGBUFFER_MAX_SIZE; + daemon_local.RingbufferStepSize = DLT_DAEMON_RINGBUFFER_STEP_SIZE; char ecu[] = "ECU1"; char path[] = "/tmp"; + EXPECT_EQ(0, dlt_daemon_init(&daemon, - DLT_DAEMON_RINGBUFFER_MIN_SIZE, - DLT_DAEMON_RINGBUFFER_MAX_SIZE, - DLT_DAEMON_RINGBUFFER_STEP_SIZE, + daemon_local.RingbufferMinSize, + daemon_local.RingbufferMaxSize, + daemon_local.RingbufferStepSize, DLT_RUNTIME_DEFAULT_DIRECTORY, DLT_LOG_INFO, DLT_TRACE_STATUS_OFF,0,0)); + dlt_set_id(daemon.ecuid, ecu); - EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &gateway, 0, 0)); + EXPECT_EQ(0, dlt_daemon_init_user_information(&daemon, &daemon_local.pGateway, 0, 0)); DltLogStorage storage_handle; daemon.storage_handle = &storage_handle; daemon.storage_handle->config_status = 0; daemon.storage_handle->connection_type = DLT_OFFLINE_LOGSTORAGE_DEVICE_DISCONNECTED; - EXPECT_EQ(DLT_RETURN_OK, dlt_daemon_logstorage_setup_internal_storage(&daemon, path, 1, 0)); + daemon.storage_handle->config_list = NULL; + EXPECT_EQ(DLT_RETURN_OK, dlt_daemon_logstorage_setup_internal_storage(&daemon, &daemon_local, path, 1)); } TEST(t_dlt_daemon_logstorage_setup_internal_storage, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_daemon_logstorage_setup_internal_storage(NULL, NULL, 0, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_daemon_logstorage_setup_internal_storage(NULL, NULL, NULL, 0)); } /* Begin Method: dlt_logstorage::dlt_daemon_logstorage_set_logstorage_cache_size*/ @@ -1290,7 +1399,7 @@ TEST(t_dlt_daemon_logstorage_cleanup, normal) TEST(t_dlt_daemon_logstorage_cleanup, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_daemon_logstorage_cleanup(NULL, NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_daemon_logstorage_cleanup(NULL, NULL, 0)); } /* Begin Method: dlt_logstorage::t_dlt_daemon_logstorage_sync_cache*/ @@ -1306,20 +1415,25 @@ TEST(t_dlt_daemon_logstorage_sync_cache, normal) char apid[] = "1234"; char ctid[] = "5678"; char ecuid[] = "12"; + char file_name[] = "file_name"; + char key[] = "12:1234:5678"; daemon.storage_handle->num_configs = 1; + daemon.storage_handle->config_list = NULL; + strncpy(daemon.storage_handle->device_mount_point, "/tmp", 5); DltLogStorageFilterConfig configs; - daemon.storage_handle->configs = &configs; configs.apids = apid; configs.ctids = ctid; configs.ecuid = ecuid; - dlt_logstorage_filter_set_strategy(daemon.storage_handle->configs, DLT_LOGSTORAGE_SYNC_ON_MSG); + configs.file_name = file_name; + dlt_logstorage_filter_set_strategy(&configs, DLT_LOGSTORAGE_SYNC_ON_MSG); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_list_add(key, &configs, &(daemon.storage_handle->config_list))); EXPECT_EQ(DLT_RETURN_OK, dlt_daemon_logstorage_sync_cache(&daemon, &daemon_local, path, 0)); } TEST(t_dlt_daemon_logstorage_sync_cache, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_daemon_logstorage_sync_cache(NULL, NULL, NULL, 0)); + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_daemon_logstorage_sync_cache(NULL, NULL, NULL, 0)); } /* Begin Method: dlt_logstorage::t_dlt_daemon_logstorage_get_device*/ @@ -1342,34 +1456,328 @@ TEST(t_dlt_daemon_logstorage_get_device, null) EXPECT_EQ((DltLogStorage *)NULL, dlt_daemon_logstorage_get_device(NULL, NULL, NULL, 0)); } -/* Begin Method: dlt_logstorage::t_dlt_logstorage_sync_msg_cache*/ -TEST(t_dlt_logstorage_sync_msg_cache, normal) +/* Begin Method: dlt_logstorage::t_dlt_logstorage_find_dlt_header*/ +TEST(t_dlt_logstorage_find_dlt_header, normal) { + char data[] = {'a','b','D','L','T',0x01}; DltLogStorageFilterConfig config; memset(&config, 0, sizeof(DltLogStorageFilterConfig)); - config.sync = 1; - config.log = fopen("/tmp/test.log", "a+"); - if(config.log != NULL) + config.cache = calloc(1, sizeof(data)); + if (config.cache != NULL) { - config.cache = calloc(1, 1 + sizeof(DltLogStorageCacheFooter)); - if(config.cache != NULL) + strncpy((char *)config.cache, data, sizeof(data)); + /* DLT header starts from index 2 */ + EXPECT_EQ(2, dlt_logstorage_find_dlt_header(config.cache, 0,sizeof(data))); + free(config.cache); + } + +} + +TEST(t_dlt_logstorage_find_dlt_header, null) +{ + char data[] = {'N','o','H','e','a','d','e','r'}; + DltLogStorageFilterConfig config; + memset(&config, 0, sizeof(DltLogStorageFilterConfig)); + config.cache = calloc(1, sizeof(data)); + if (config.cache != NULL) + { + /* config.cache =(void *) "a,b,D,L,T,0x01"; */ + strncpy((char *)config.cache, data, sizeof(data)); + EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_find_dlt_header(config.cache, 0,sizeof(data))); + free(config.cache); + } +} + +/* Begin Method: dlt_logstorage::t_dlt_logstorage_sync_create_new_file*/ +TEST(t_dlt_logstorage_sync_create_new_file, normal) +{ + DltLogStorageUserConfig file_config; + memset(&file_config, 0, sizeof(DltLogStorageUserConfig)); + file_config.logfile_timestamp =191132; + file_config.logfile_delimiter = {'_'}; + file_config.logfile_maxcounter = 5; + file_config.logfile_counteridxlen = 2; + char *path = (char*)"/tmp"; + DltLogStorageFilterConfig config; + memset(&config, 0, sizeof(DltLogStorageFilterConfig)); + char apids; + char ctids; + config.apids = &apids; + config.ctids = &ctids; + config.file_name = (char*)"Test"; + config.records = NULL; + config.log = NULL; + config.cache = NULL; + config.file_size = 50; + config.sync = DLT_LOGSTORAGE_SYNC_ON_DEMAND; + config.num_files = 5; + g_logstorage_cache_max = 16; + unsigned int size = 10; + unsigned char data1[10] = "dlt_data1"; + unsigned char data2[10] = "dlt_data2"; + unsigned char data3[10] = "dlt_data3"; + DltLogStorageCacheFooter *footer = NULL; + + config.cache = calloc(1, 50 + sizeof(DltLogStorageCacheFooter)); + if(config.cache != NULL) + { + footer = (DltLogStorageCacheFooter *)(config.cache + 50); + if (footer != NULL) { - config.file_size = 1; - EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_sync_msg_cache(&config, 1)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_prepare_msg_cache(&config, &file_config, path, 1)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_write_msg_cache(&config, data1, size, data2, size, data3, size)); + footer->offset = 0; + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_sync_create_new_file(&config, &file_config, path, 0)); free(config.cache); config.cache = NULL; } } + +} + +TEST(t_dlt_logstorage_sync_create_new_file, null) +{ + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_sync_create_new_file(NULL, NULL, NULL, 0)); +} + +/* Begin Method: dlt_logstorage::t_dlt_logstorage_sync_to_file*/ +TEST(t_dlt_logstorage_sync_to_file, normal) +{ + DltLogStorageUserConfig file_config; + memset(&file_config, 0, sizeof(DltLogStorageUserConfig)); + file_config.logfile_timestamp =191132; + file_config.logfile_delimiter = {'_'}; + file_config.logfile_maxcounter = 6; + file_config.logfile_counteridxlen = 2; + char *path = (char*)"/tmp"; + DltLogStorageFilterConfig config; + memset(&config, 0, sizeof(DltLogStorageFilterConfig)); + char apids; + char ctids; + config.apids = &apids; + config.ctids = &ctids; + config.file_name = (char*)"Test"; + config.records = NULL; + config.log = NULL; + config.cache = NULL; + config.file_size = 0; + config.sync = DLT_LOGSTORAGE_SYNC_ON_DEMAND; + config.num_files = 6; + config.file_size = 50; + g_logstorage_cache_max = 16; + unsigned int size = 10; + unsigned char data1[10] = "dlt_data0"; + unsigned char data2[10] = "dlt_data1"; + unsigned char data3[10] = "dlt_data2"; + + config.cache = calloc(1, 50 + sizeof(DltLogStorageCacheFooter)); + if(config.cache != NULL) + { + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_prepare_msg_cache(&config, &file_config, path, 1)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_write_msg_cache(&config, data1, size, data2, size, data3, size)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_sync_to_file(&config, &file_config, path)); + free(config.cache); + config.cache = NULL; + + } +} + +TEST(t_dlt_logstorage_sync_to_file, null) +{ + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_sync_to_file(NULL, NULL, NULL)); +} + +/* Begin Method: dlt_logstorage::t_dlt_logstorage_sync_capable_data_to_file*/ +TEST(t_dlt_logstorage_sync_capable_data_to_file, normal) +{ + DltLogStorageUserConfig file_config; + memset(&file_config, 0, sizeof(DltLogStorageUserConfig)); + file_config.logfile_timestamp =191132; + file_config.logfile_delimiter = {'_'}; + file_config.logfile_maxcounter = 7; + file_config.logfile_counteridxlen = 2; + char *path = (char*)"/tmp"; + DltLogStorageFilterConfig config; + memset(&config, 0, sizeof(DltLogStorageFilterConfig)); + char apids; + char ctids; + config.apids = &apids; + config.ctids = &ctids; + config.file_name = (char*)"Test"; + config.records = NULL; + config.log = NULL; + config.cache = NULL; + config.file_size = 0; + config.sync = DLT_LOGSTORAGE_SYNC_ON_DEMAND; + config.num_files = 7; + config.file_size = 50; + g_logstorage_cache_max = 16; + unsigned int size = 10; + unsigned char data1[10] = "Dlt_data0"; + unsigned char data2[10] = "Dlt_data1"; + unsigned char data3[10] = "Dlt_data2"; + + config.cache = calloc(1, 50 + sizeof(DltLogStorageCacheFooter)); + if(config.cache != NULL) + { + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_prepare_msg_cache(&config, &file_config, path, 1)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_write_msg_cache(&config, data1, size, data2, size, data3, size)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_sync_capable_data_to_file(&config, 0)); + free(config.cache); + config.cache = NULL; + } + +} + +TEST(t_dlt_logstorage_sync_capable_data_to_file, null) +{ + EXPECT_EQ(DLT_RETURN_WRONG_PARAMETER, dlt_logstorage_sync_capable_data_to_file(NULL, 0)); +} + +/* Begin Method: dlt_logstorage::t_dlt_logstorage_sync_msg_cache*/ +TEST(t_dlt_logstorage_sync_msg_cache, normal) +{ + + DltLogStorageUserConfig file_config; + memset(&file_config, 0, sizeof(DltLogStorageUserConfig)); + file_config.logfile_timestamp =191132; + file_config.logfile_delimiter = {'_'}; + file_config.logfile_maxcounter = 8; + file_config.logfile_counteridxlen = 2; + char *path = (char*)"/tmp"; + + DltLogStorageFilterConfig config; + memset(&config, 0, sizeof(DltLogStorageFilterConfig)); + char apids; + char ctids; + config.apids = &apids; + config.ctids = &ctids; + config.file_name = (char*)"Test"; + config.records = NULL; + config.log = NULL; + config.cache = NULL; + config.file_size = 50; + config.sync = DLT_LOGSTORAGE_SYNC_ON_DEMAND; + config.num_files = 8; + g_logstorage_cache_max = 16; + + unsigned int size = 10; + unsigned char data1[10] = "dlt_dataA"; + unsigned char data2[10] = "dlt_dataB"; + unsigned char data3[10] = "dlt_dataC"; + + config.cache = calloc(1, 50 + sizeof(DltLogStorageCacheFooter)); + if(config.cache != NULL) + { + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_prepare_msg_cache(&config, &file_config, path, 1)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_write_msg_cache(&config, data1, size, data2, size, data3, size)); + EXPECT_EQ(DLT_RETURN_OK, dlt_logstorage_sync_msg_cache(&config, &file_config, path, DLT_LOGSTORAGE_SYNC_ON_DEMAND)); + free(config.cache); + config.cache = NULL; + } + } TEST(t_dlt_logstorage_sync_msg_cache, null) { - EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_sync_msg_cache(NULL, 0)); + EXPECT_EQ(DLT_RETURN_ERROR, dlt_logstorage_sync_msg_cache(NULL, NULL, NULL, 0)); +} + +int connectServer(void) +{ + int sockfd, portno; + struct sockaddr_in serv_addr; + struct hostent *server; + portno = 8080; + sockfd = socket(AF_INET, SOCK_STREAM, 0); + server = gethostbyname("127.0.0.1"); + bzero((char *) &serv_addr, sizeof(serv_addr)); + serv_addr.sin_family = AF_INET; + bcopy((char *)server->h_addr, + (char *)&serv_addr.sin_addr.s_addr, + server->h_length); + serv_addr.sin_port = htons(portno); + if (connect(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0) + { + printf("Error: %s (%d) occured in connect socket\n", strerror(errno), errno); + close(sockfd); + return -1; + } + return sockfd; } +#define GTEST_SOCKS_ACCEPTED 2 + int main(int argc, char **argv) { - ::testing::InitGoogleTest(&argc, argv); - ::testing::FLAGS_gtest_break_on_failure = true; - return RUN_ALL_TESTS(); + pid_t cpid; + cpid = fork(); + if(cpid == -1) + { + printf("fork fail\n"); + return -1; + } + if (cpid) + { + int i = GTEST_SOCKS_ACCEPTED; + int j, optval = 1; + char buffer[256]; + int sockfd, newsockfd[GTEST_SOCKS_ACCEPTED], portno; + socklen_t clilen; + struct sockaddr_in serv_addr, cli_addr; + sockfd = socket(AF_INET, SOCK_STREAM, 0); + if(sockfd == -1) + { + printf("Error in creating socket\n"); + return -1; + } + bzero((char *) &serv_addr, sizeof(serv_addr)); + portno = 8080; + + serv_addr.sin_family = AF_INET; + serv_addr.sin_addr.s_addr = INADDR_ANY; + serv_addr.sin_port = htons(portno); + + if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval)) == -1) { + perror("setsockopt"); + close(sockfd); + exit(1); + } + + j = bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)); + if(j == -1) + { + perror("Bind Error\n"); + close(sockfd); + return -1; + } + listen(sockfd, 5); + while(i) + { + clilen = sizeof(cli_addr); + newsockfd[i-1] = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen); + if(newsockfd[i-1] == -1) + { + printf("Error in accept"); + return -1; + } + bzero(buffer, 256); + (void)(read(newsockfd[i-1], buffer, 255) + 1); /* just ignore result */ + i--; + } + + for(j = 0; j < GTEST_SOCKS_ACCEPTED; j++) + close(newsockfd[i]); + + close(sockfd); + } + else + { + + ::testing::InitGoogleTest(&argc, argv); + ::testing::FLAGS_gtest_break_on_failure = false; +// ::testing::FLAGS_gtest_filter = "t_dlt_event_handler_register_connection*"; + return RUN_ALL_TESTS(); + } + return 0; } diff --git a/tests/start_multinode_test.sh b/tests/start_multinode_test.sh index f152056..54a58b5 100755 --- a/tests/start_multinode_test.sh +++ b/tests/start_multinode_test.sh @@ -24,13 +24,24 @@ #Description : Smoke testing for multinode feature of DLT # #Author Name : Onkar Palkar +# Jeevan Ramakant Nagvekar #Email Id : onkar.palkar@wipro.com +# jeevan.nagvekar1@wipro.com # -#History : 8/06/2016 +#History : 31/07/2018 ################################################################################ ipaddr=127.0.0.1 +# +# Function: -getOSname() +# +# Description -Retrieves OS name +# +getOSname() +{ + OS="`uname`" +} # # Function: -cleanup() # @@ -50,38 +61,74 @@ cleanup() tmpPassiveDIR=tmpPassive tmpLogFile=log_multinode.txt tmpLogAsciFile=log_multinode_a.txt + + if [ "$OS" = "QNX" ] + then + PIDOF() + { + slay -p $1 > /dev/null + if [ $? -eq '0' ] + then + return 1 + else + return 0 + fi + } + KILLALL() + { + slay -9 -f $1 > /dev/null + if [ $? -eq '0' ] + then + return 1 + else + return 0 + fi + } + else + PIDOF() + { + pidof $1 > /dev/null + return $? + } + KILLALL() + { + killall $1 > /dev/null + return $? + } + fi + cd $tmpPath - rm -rf $tmpPath/$tmpFolder - pidof dlt-daemon > /dev/null + PIDOF "dlt-daemon" if [ $? -eq '0' ] then - killall dlt-daemon + KILLALL "dlt-daemon" if [ $? -ne '0' ] then echo "Failed to kill daemons" return 1 fi fi - pidof dlt-receive > /dev/null + PIDOF "dlt-receive" if [ $? -eq '0' ] then - killall dlt-receive + KILLALL "dlt-receive" if [ $? -ne '0' ] then echo "Failed to kill dlt-receive" return 1 fi fi - pidof dlt-convert > /dev/null + PIDOF "dlt-convert" if [ $? -eq '0' ] then - killall dlt-convert + KILLALL "dlt-convert" if [ $? -ne '0' ] then echo "Failed to kill dlt-convert" return 1 fi fi + rm -rf $tmpPath/$tmpFolder >/dev/null return 0 } # @@ -96,6 +143,13 @@ cleanup() # setupTest() { + if [ "$OS" = "QNX" ] + then + MESSAGE_FILTER_CONF="/etc/dlt_message_filter.conf" + else + MESSAGE_FILTER_CONF="/etc/dlt_message_filter_ald.conf" + fi + which dlt-daemon > /dev/null if [ $? -ne '0' ] then @@ -114,13 +168,13 @@ setupTest() echo "dlt-receive is not available" return 1 fi - mkdir $tmpPath/$tmpFolder + mkdir -p $tmpPath/$tmpFolder if [ $? -ne '0' ] then echo "Error in creating dlt_test folder" return 1 fi - mkdir $tmpPath/$tmpFolder/$gatewayFolderName + mkdir -p $tmpPath/$tmpFolder/$gatewayFolderName if [ $? -ne '0' ] then echo "Error in creating gateway folder" @@ -145,6 +199,7 @@ setupTest() echo "RingbufferStepSize = 500000" >>$tmpPath/$tmpFolder/$gatewayFolderName/dlt.conf echo "ControlSocketPath = /tmp/dlt-ctrl.sock" >>$tmpPath/$tmpFolder/$gatewayFolderName/dlt.conf echo "GatewayConfigFile = $tmpPath/$tmpFolder/$gatewayFolderName/dlt_gateway.conf" >> $tmpPath/$tmpFolder/$gatewayFolderName/dlt.conf + echo "MessageFilterConfigFile = $MESSAGE_FILTER_CONF" >> $tmpPath/$tmpFolder/$gatewayFolderName/dlt.conf touch $tmpPath/$tmpFolder/$gatewayFolderName/dlt_gateway.conf if [ $? -ne '0' ] then @@ -158,7 +213,7 @@ setupTest() echo "Connect=OnStartup" >>$tmpPath/$tmpFolder/$gatewayFolderName/dlt_gateway.conf echo "Timeout=10" >>$tmpPath/$tmpFolder/$gatewayFolderName/dlt_gateway.conf echo "NOFiles=1" >>$tmpPath/$tmpFolder/$gatewayFolderName/dlt_gateway.conf - mkdir $tmpPath/$tmpFolder/$passiveFolderName + mkdir -p $tmpPath/$tmpFolder/$passiveFolderName if [ $? -ne '0' ] then echo "Error in creating passive folder" @@ -181,7 +236,8 @@ setupTest() echo "RingbufferMaxSize = 10000000" >>$tmpPath/$tmpFolder/$passiveFolderName/dlt.conf echo "RingbufferStepSize = 500000" >>$tmpPath/$tmpFolder/$passiveFolderName/dlt.conf echo "ControlSocketPath = /tmp/dlt-ctrl.sock" >>$tmpPath/$tmpFolder/$passiveFolderName/dlt.conf - mkdir $tmpPath/$tmpFolder/$tmpPassiveDIR + echo "MessageFilterConfigFile = $MESSAGE_FILTER_CONF" >> $tmpPath/$tmpFolder/$passiveFolderName/dlt.conf + mkdir -p $tmpPath/$tmpFolder/$tmpPassiveDIR if [ $? -ne '0' ] then echo "Error while creating tempPassive folder" @@ -243,7 +299,8 @@ startReceive() verifyTest() { dlt-convert -a $tmpPath/$tmpFolder/$tmpLogFile > $tmpPath/$tmpFolder/$tmpLogAsciFile - cat $tmpPath/$tmpFolder/$tmpLogAsciFile | grep -w "ECU2" > /dev/null + cat $tmpPath/$tmpFolder/$tmpLogAsciFile | grep -F "ECU2" > /dev/null + if [ $? -eq '0' ] then return 0 @@ -253,6 +310,7 @@ verifyTest() } #main function ######################################################################################## +getOSname cleanup if [ $? -ne '0' ] then @@ -282,7 +340,7 @@ then return 1 fi #wait for 1 sec before starting dlt-receive to start dlt-example-user application properly -sleep 1s +sleep 1 startReceive if [ $? -ne '0' ] then @@ -291,7 +349,7 @@ then return 1 fi #Wait for 1 sec to collect messages sent by application at gateway -sleep 1s +sleep 1 verifyTest if [ $? -eq '0' ] then -- cgit v1.2.1