myvtm/DevAdapter/self/liblog4vendor/log4upload.cpp

#include "log4upload.h"
#include "log4vendor.h"
#include <algorithm>


#if defined(_MSC_VER)
#else
#include <dlfcn.h>
#include <errno.h>
#include <string.h>
#include <locale.h>


#define LOG_SDKNAME "libRVCLogSDK.so"

int log4vendor__dlerror(log4vendor_lib_t* lib)
{
    const char* errmsg;
    free(lib->errmsg);
    errmsg = dlerror();
    if (errmsg) {
        lib->errmsg = strdup(errmsg);
        return -1;
    } else {
        lib->errmsg = NULL;
        return 0;
    }
}

int log4vendor_dlopen(const char* filename, log4vendor_lib_t* lib)
{
    dlerror(); /* Reset error status. */
    lib->errmsg = NULL;
    lib->handle = dlopen(filename, RTLD_LAZY);
    return lib->handle ? 0 : log4vendor__dlerror(lib);
}

void log4vendor_dlclose(log4vendor_lib_t* lib)
{
    if (lib->errmsg) {
        free(lib->errmsg);
        lib->errmsg = NULL;
    }
    if (lib->handle) {
        /* Ignore errors. No good way to signal them without leaking memory. */
        dlclose(lib->handle);
        lib->handle = NULL;
    }
}

int log4vendor_dlsym(log4vendor_lib_t* lib, const char* name, void** ptr)
{
    dlerror(); /* Reset error status. */
    *ptr = dlsym(lib->handle, name);
    return log4vendor__dlerror(lib);
}

const char* log4vendor_dlerror(const log4vendor_lib_t* lib)
{
    return lib->errmsg ? lib->errmsg : "no error";
}

#endif //_MSC_VER

std::string to_lower(std::string str)
{
    std::transform(str.begin(), str.end(), str.begin(), [](unsigned char c) {
        return static_cast<char>(std::tolower(c));
                   });
    return str;
}

bool upload_helper::initialize(const cmb::log_init_config& cfg)
{
    if (is_initialized()) return false;

    bool res = (0 == load_logsdk());
    if (res) {
        log_producer_config* config = pinst_create_log_producer_config();
        pinst_log_producer_config_set_packet_log_bytes(config, 4 * 1024 * 1024);
        pinst_log_producer_config_set_packet_log_count(config, 24);//最大发送条数
        pinst_log_producer_config_set_max_buffer_limit(config, 64 * 1024 * 1024);
        //set send thread count
        pinst_log_producer_config_set_send_thread_count(config, 2);
        pinst_log_producer_config_set_persistent_max_log_count(config, 20 * 1000);
        pinst_log_producer_config_set_skyeye_servname(config, (char*)"Terminal");
        pinst_log_producer_config_set_skyeye_cmptId(config, (char*)"LR04");
        pinst_log_producer_config_set_skyeye_cmptname(config, (char*)"FrameworkLib");
        pinst_log_producer_config_set_skyeye_version(config, (char*)"1.0");
        pinst_log_producer_config_set_persistent(config, 1);

        //本地日志开关
        //pinst_log_producer_config_switch_debug_mode(config, 1);

        char value[128] = { '\0' };
        strcpy(value, to_lower(cfg.dev_name).c_str());
        pinst_log_producer_config_set_skyeye_entityname(config, value);

        memset(value, '\0', sizeof(value));
        strcpy(value, "0");
        pinst_log_producer_config_set_skyeye_item(config, value);
        pinst_log_producer_config_set_persistent_file_path(config, "/opt/rvc/terminaldbstorage");

        //新加统一日志配置
        pinst_log_producer_config_set_united_appname(config, (char*)"LR04");
        pinst_log_producer_config_set_united_version(config, (char*)"1.0");
        pinst_log_producer_config_set_united_needArchived(config, 0);
        pinst_log_producer_config_set_united_deployUnitId(config, (char*)"LR04.02@FrameworkLib_PRD_PRD");
        pinst_log_producer_config_set_united_serviceUnitId(config, (char*)"LR04.02_FrameworkLib");

        _client = pinst_create_log_producer_client(config, NULL, NULL);
        res = (_client != nullptr);

        if (!res) {
            unload_logsdk();
        }
    }

    _initialized = res;

    return res;
}

int upload_helper::load_logsdk()
{
    LOG4VTM(DEBUG, "pre load sdk...");
    int res = log4vendor_dlopen(LOG_SDKNAME, &m_lib);
    if (res != 0) {
        LOG4VTM(ERROR, ("log4vendor_dlopen failed with error") << LOG_SDKNAME << log4vendor_dlerror(&m_lib));
        return res;
    }
    do {
        res = -1;

        if (log4vendor_dlsym(&m_lib, "create_log_producer_config", (void**)&pinst_create_log_producer_config) != 0 || pinst_create_log_producer_config == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_packet_log_bytes", (void**)&pinst_log_producer_config_set_packet_log_bytes) != 0 || pinst_log_producer_config_set_packet_log_bytes == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_packet_log_count", (void**)&pinst_log_producer_config_set_packet_log_count) != 0 || pinst_log_producer_config_set_packet_log_count == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_max_buffer_limit", (void**)&pinst_log_producer_config_set_max_buffer_limit) != 0 || pinst_log_producer_config_set_max_buffer_limit == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_send_thread_count", (void**)&pinst_log_producer_config_set_send_thread_count) != 0 || pinst_log_producer_config_set_send_thread_count == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_persistent_max_log_count", (void**)&pinst_log_producer_config_set_persistent_max_log_count) != 0 || pinst_log_producer_config_set_persistent_max_log_count == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_skyeye_servname", (void**)&pinst_log_producer_config_set_skyeye_servname) != 0 || pinst_log_producer_config_set_skyeye_servname == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_skyeye_cmptId", (void**)&pinst_log_producer_config_set_skyeye_cmptId) != 0 || pinst_log_producer_config_set_skyeye_cmptId == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_skyeye_cmptname", (void**)&pinst_log_producer_config_set_skyeye_cmptname) != 0 || pinst_log_producer_config_set_skyeye_cmptname == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_skyeye_version", (void**)&pinst_log_producer_config_set_skyeye_version) != 0 || pinst_log_producer_config_set_skyeye_version == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_persistent", (void**)&pinst_log_producer_config_set_persistent) != 0 || pinst_log_producer_config_set_persistent == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_skyeye_entityname", (void**)&pinst_log_producer_config_set_skyeye_entityname) != 0 || pinst_log_producer_config_set_skyeye_entityname == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_skyeye_item", (void**)&pinst_log_producer_config_set_skyeye_item) != 0 || pinst_log_producer_config_set_skyeye_item == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_persistent_file_path", (void**)&pinst_log_producer_config_set_persistent_file_path) != 0 || pinst_log_producer_config_set_persistent_file_path == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_united_appname", (void**)&pinst_log_producer_config_set_united_appname) != 0 || pinst_log_producer_config_set_united_appname == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_united_version", (void**)&pinst_log_producer_config_set_united_version) != 0 || pinst_log_producer_config_set_united_version == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_united_needArchived", (void**)&pinst_log_producer_config_set_united_needArchived) != 0 || pinst_log_producer_config_set_united_needArchived == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_united_deployUnitId", (void**)&pinst_log_producer_config_set_united_deployUnitId) != 0 || pinst_log_producer_config_set_united_deployUnitId == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_set_united_serviceUnitId", (void**)&pinst_log_producer_config_set_united_serviceUnitId) != 0 || pinst_log_producer_config_set_united_serviceUnitId == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "create_log_producer_client", (void**)&pinst_create_log_producer_client) != 0 || pinst_create_log_producer_client == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_client_add_log", (void**)&pinst_log_producer_client_add_log) != 0 || pinst_log_producer_client_add_log == nullptr) break;
        if (log4vendor_dlsym(&m_lib, "log_producer_config_switch_debug_mode", (void**)&pinst_log_producer_config_switch_debug_mode) != 0 || pinst_log_producer_config_switch_debug_mode == nullptr) break;

        res = 0;
    } while (false);

    if (0 != res) {
        LOG4VTM(ERROR, ("get funcs' address failed with error ") << log4vendor_dlerror(&m_lib));
        log4vendor_dlclose(&m_lib);
    } else {
        LOG4VTM(DEBUG, "load_logsdk succ");
    }
    return res;
}

int upload_helper::unload_logsdk()
{
    log4vendor_dlclose(&m_lib);
    return 0;
}