taosdata / TDengine / #4875

coverage: 64.472% (-0.2%) from 64.623%
#4875

push

travis-ci

guanshengliang 
fix: temporarily disable memory leak detection for UDF tests (#33856)

162014 of 251293 relevant lines covered (64.47%)

104318075.66 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

93.96
/source/client/wrapper/src/wrapperDriver.c
1 
/*
2 
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
3 
 *
4 
 * This program is free software: you can use, redistribute, and/or modify
5 
 * it under the terms of the GNU Affero General Public License, version 3
6 
 * or later ("AGPL"), as published by the Free Software Foundation.
7 
 *
8 
 * This program is distributed in the hope that it will be useful, but WITHOUT
9 
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10 
 * FITNESS FOR A PARTICULAR PURPOSE.
11 
 *
12 
 * You should have received a copy of the GNU Affero General Public License
13 
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
14 
 */
15 









16



#include "wrapper.h"










17



#include "wrapperHint.h"










18












19



#ifdef WINDOWS










20



#define DRIVER_NATIVE_NAME    "taosnative.dll"










21



#define DRIVER_WSBSOCKET_NAME "taosws.dll"










22



#elif defined(DARWIN)










23



#define DRIVER_NATIVE_NAME    "libtaosnative.dylib"










24



#define DRIVER_WSBSOCKET_NAME "libtaosws.dylib"










25



#else










26



#define DRIVER_NATIVE_NAME    "libtaosnative.so"










27



#define DRIVER_WSBSOCKET_NAME "libtaosws.so"










28



#endif










29












30



#define LOAD_FUNC(fptr, fname)                \










31



  funcName = fname;                           \










32



  fptr = taosLoadDllFunc(tsDriver, funcName); \










33



  if (fptr == NULL) goto _OVER;










34












35



#ifdef WEBSOCKET










36



EDriverType tsDriverType = DRIVER_NATIVE;  // todo simon










37



#else










38



EDriverType tsDriverType = DRIVER_NATIVE;










39



#endif










40












41



void *tsDriver = NULL;










42












43



static int32_t taosGetDevelopPath(char *driverPath, const char *driverName) {




1,254,853✔





44



  char    appPath[PATH_MAX] = {0};




1,254,853✔





45



  int32_t ret = taosAppPath(appPath, PATH_MAX);




1,254,853✔





46



  if (ret == 0) {




1,254,853✔





47



    snprintf(driverPath, PATH_MAX, "%s%s..%slib%s%s", appPath, TD_DIRSEP, TD_DIRSEP, TD_DIRSEP, driverName);




1,254,853✔





48



    ret = taosRealPath(driverPath, NULL, PATH_MAX);




1,254,853✔





49



  }










50












51



  return ret;




1,254,853✔





52



}










53












54



int32_t taosDriverInit(EDriverType driverType) {




1,254,853✔





55



  int32_t     code = -1;




1,254,853✔





56



  char        driverPath[PATH_MAX + 32] = {0};




1,254,853✔





57



  const char *driverName = NULL;




1,254,853✔





58



  const char *funcName = NULL;




1,254,853✔





59












60



  if (driverType == DRIVER_NATIVE) {




1,254,853✔





61



    driverName = DRIVER_NATIVE_NAME;




1,233,460✔





62



  } else {










63



    driverName = DRIVER_WSBSOCKET_NAME;




21,393✔





64



  }










65












66



  // load from develop build path










67



  if (tsDriver == NULL && taosGetDevelopPath(driverPath, driverName) == 0) {




1,254,853✔





68



    tsDriver = taosLoadDll(driverPath);




901,852✔





69



  }  










70












71



  // load from system path










72



  if (tsDriver == NULL) {




1,254,853✔





73



    tsDriver = taosLoadDll(driverName);




353,001✔





74



  }










75












76



  // load from install path on mac










77



#if defined(DARWIN)










78



  if (tsDriver == NULL) {










79



    snprintf(driverPath, PATH_MAX, "/usr/local/lib/%s", driverName);










80



    tsDriver = taosLoadDll(driverPath);










81



  }










82



#endif










83












84



  if (tsDriver == NULL) {




1,254,853✔





85



    printf("failed to load %s since %s [0x%X]\r\n", driverName, terrstr(), terrno);




×







86



    showWrapperHint(terrno);




×







87



    return code;




×







88



  }










89












90



  // printf("load driver from %s\r\n", driverPath);










91



  LOAD_FUNC(fp_taos_set_config, "taos_set_config");




1,254,853✔





92












93



  LOAD_FUNC(fp_taos_init, "taos_init");




1,254,853✔





94



  LOAD_FUNC(fp_taos_cleanup, "taos_cleanup");




1,254,853✔





95



  LOAD_FUNC(fp_taos_options, "taos_options");




1,254,853✔





96



  LOAD_FUNC(fp_taos_options_connection, "taos_options_connection");




1,254,853✔





97



  LOAD_FUNC(fp_taos_connect, "taos_connect");




1,254,853✔





98



  LOAD_FUNC(fp_taos_connect_auth, "taos_connect_auth");




1,254,853✔





99



  LOAD_FUNC(fp_taos_connect_with_dsn, "taos_connect_with_dsn");




1,254,853✔





100



  LOAD_FUNC(fp_taos_close, "taos_close");




1,254,853✔





101












102



  LOAD_FUNC(fp_taos_data_type, "taos_data_type");




1,254,853✔





103












104



  LOAD_FUNC(fp_taos_stmt_init, "taos_stmt_init");




1,254,853✔





105



  LOAD_FUNC(fp_taos_stmt_init_with_reqid, "taos_stmt_init_with_reqid");




1,254,853✔





106



  LOAD_FUNC(fp_taos_stmt_init_with_options, "taos_stmt_init_with_options");




1,254,853✔





107



  LOAD_FUNC(fp_taos_stmt_prepare, "taos_stmt_prepare");




1,254,853✔





108



  LOAD_FUNC(fp_taos_stmt_set_tbname_tags, "taos_stmt_set_tbname_tags");




1,254,853✔





109



  LOAD_FUNC(fp_taos_stmt_set_tbname, "taos_stmt_set_tbname");




1,254,853✔





110



  LOAD_FUNC(fp_taos_stmt_set_tags, "taos_stmt_set_tags");




1,254,853✔





111



  LOAD_FUNC(fp_taos_stmt_set_sub_tbname, "taos_stmt_set_sub_tbname");




1,254,853✔





112



  LOAD_FUNC(fp_taos_stmt_get_tag_fields, "taos_stmt_get_tag_fields");




1,254,853✔





113



  LOAD_FUNC(fp_taos_stmt_get_col_fields, "taos_stmt_get_col_fields");




1,254,853✔





114



  LOAD_FUNC(fp_taos_stmt_reclaim_fields, "taos_stmt_reclaim_fields");




1,254,853✔





115












116



  LOAD_FUNC(fp_taos_stmt_is_insert, "taos_stmt_is_insert");




1,254,853✔





117



  LOAD_FUNC(fp_taos_stmt_num_params, "taos_stmt_num_params");




1,254,853✔





118



  LOAD_FUNC(fp_taos_stmt_get_param, "taos_stmt_get_param");




1,254,853✔





119



  LOAD_FUNC(fp_taos_stmt_bind_param, "taos_stmt_bind_param");




1,254,853✔





120



  LOAD_FUNC(fp_taos_stmt_bind_param_batch, "taos_stmt_bind_param_batch");




1,254,853✔





121



  LOAD_FUNC(fp_taos_stmt_bind_single_param_batch, "taos_stmt_bind_single_param_batch");




1,254,853✔





122



  LOAD_FUNC(fp_taos_stmt_add_batch, "taos_stmt_add_batch");




1,254,853✔





123



  LOAD_FUNC(fp_taos_stmt_execute, "taos_stmt_execute");




1,254,853✔





124



  LOAD_FUNC(fp_taos_stmt_use_result, "taos_stmt_use_result");




1,254,853✔





125



  LOAD_FUNC(fp_taos_stmt_close, "taos_stmt_close");




1,254,853✔





126



  LOAD_FUNC(fp_taos_stmt_errstr, "taos_stmt_errstr");




1,254,853✔





127



  LOAD_FUNC(fp_taos_stmt_affected_rows, "taos_stmt_affected_rows");




1,254,853✔





128



  LOAD_FUNC(fp_taos_stmt_affected_rows_once, "taos_stmt_affected_rows_once");




1,254,853✔





129












130



  LOAD_FUNC(fp_taos_stmt2_init, "taos_stmt2_init");




1,254,853✔





131



  LOAD_FUNC(fp_taos_stmt2_prepare, "taos_stmt2_prepare");




1,254,853✔





132



  LOAD_FUNC(fp_taos_stmt2_bind_param, "taos_stmt2_bind_param");




1,254,853✔





133



  LOAD_FUNC(fp_taos_stmt2_bind_param_a, "taos_stmt2_bind_param_a");




1,254,853✔





134



  LOAD_FUNC(fp_taos_stmt2_exec, "taos_stmt2_exec");




1,254,853✔





135



  LOAD_FUNC(fp_taos_stmt2_close, "taos_stmt2_close");




1,254,853✔





136



  LOAD_FUNC(fp_taos_stmt2_is_insert, "taos_stmt2_is_insert");




1,254,853✔





137



  LOAD_FUNC(fp_taos_stmt2_get_fields, "taos_stmt2_get_fields");




1,254,853✔





138



  LOAD_FUNC(fp_taos_stmt2_free_fields, "taos_stmt2_free_fields");




1,254,853✔





139



  LOAD_FUNC(fp_taos_stmt2_result, "taos_stmt2_result");




1,254,853✔





140



  LOAD_FUNC(fp_taos_stmt2_error, "taos_stmt2_error");




1,254,853✔





141












142



  LOAD_FUNC(fp_taos_query, "taos_query");




1,254,853✔





143



  LOAD_FUNC(fp_taos_query_with_reqid, "taos_query_with_reqid");




1,254,853✔





144












145



  LOAD_FUNC(fp_taos_fetch_row, "taos_fetch_row");




1,254,853✔





146



  LOAD_FUNC(fp_taos_result_precision, "taos_result_precision");




1,254,853✔





147



  LOAD_FUNC(fp_taos_free_result, "taos_free_result");




1,254,853✔





148



  LOAD_FUNC(fp_taos_kill_query, "taos_kill_query");




1,254,853✔





149



  LOAD_FUNC(fp_taos_field_count, "taos_field_count");




1,254,853✔





150



  LOAD_FUNC(fp_taos_num_fields, "taos_num_fields");




1,254,853✔





151



  LOAD_FUNC(fp_taos_affected_rows, "taos_affected_rows");




1,254,853✔





152



  LOAD_FUNC(fp_taos_affected_rows64, "taos_affected_rows64");




1,254,853✔





153












154



  LOAD_FUNC(fp_taos_fetch_fields, "taos_fetch_fields");




1,254,853✔





155



  LOAD_FUNC(fp_taos_fetch_fields_e, "taos_fetch_fields_e");




1,254,853✔





156



  LOAD_FUNC(fp_taos_select_db, "taos_select_db");




1,254,853✔





157



  LOAD_FUNC(fp_taos_print_row, "taos_print_row");




1,254,853✔





158



  LOAD_FUNC(fp_taos_print_row_with_size, "taos_print_row_with_size");




1,254,853✔





159



  LOAD_FUNC(fp_taos_stop_query, "taos_stop_query");




1,254,853✔





160



  LOAD_FUNC(fp_taos_is_null, "taos_is_null");




1,254,853✔





161



  LOAD_FUNC(fp_taos_is_null_by_column, "taos_is_null_by_column");




1,254,853✔





162



  LOAD_FUNC(fp_taos_is_update_query, "taos_is_update_query");




1,254,853✔





163



  LOAD_FUNC(fp_taos_fetch_block, "taos_fetch_block");




1,254,853✔





164



  LOAD_FUNC(fp_taos_fetch_block_s, "taos_fetch_block_s");




1,254,853✔





165



  LOAD_FUNC(fp_taos_fetch_raw_block, "taos_fetch_raw_block");




1,254,853✔





166



  LOAD_FUNC(fp_taos_get_column_data_offset, "taos_get_column_data_offset");




1,254,853✔





167



  LOAD_FUNC(fp_taos_validate_sql, "taos_validate_sql");




1,254,853✔





168



  LOAD_FUNC(fp_taos_reset_current_db, "taos_reset_current_db");




1,254,853✔





169












170



  LOAD_FUNC(fp_taos_fetch_lengths, "taos_fetch_lengths");




1,254,853✔





171



  LOAD_FUNC(fp_taos_result_block, "taos_result_block");




1,254,853✔





172












173



  LOAD_FUNC(fp_taos_get_server_info, "taos_get_server_info");




1,254,853✔





174



  LOAD_FUNC(fp_taos_get_client_info, "taos_get_client_info");




1,254,853✔





175



  LOAD_FUNC(fp_taos_get_current_db, "taos_get_current_db");




1,254,853✔





176












177



  LOAD_FUNC(fp_taos_errstr, "taos_errstr");




1,254,853✔





178



  LOAD_FUNC(fp_taos_errno, "taos_errno");




1,254,853✔





179












180



  LOAD_FUNC(fp_taos_query_a, "taos_query_a");




1,254,853✔





181



  LOAD_FUNC(fp_taos_query_a_with_reqid, "taos_query_a_with_reqid");




1,254,853✔





182



  LOAD_FUNC(fp_taos_fetch_rows_a, "taos_fetch_rows_a");




1,254,853✔





183



  LOAD_FUNC(fp_taos_fetch_raw_block_a, "taos_fetch_raw_block_a");




1,254,853✔





184



  LOAD_FUNC(fp_taos_get_raw_block, "taos_get_raw_block");




1,254,853✔





185












186



  LOAD_FUNC(fp_taos_get_db_route_info, "taos_get_db_route_info");




1,254,853✔





187



  LOAD_FUNC(fp_taos_get_table_vgId, "taos_get_table_vgId");




1,254,853✔





188



  LOAD_FUNC(fp_taos_get_tables_vgId, "taos_get_tables_vgId");




1,254,853✔





189












190



  LOAD_FUNC(fp_taos_load_table_info, "taos_load_table_info");




1,254,853✔





191












192



  LOAD_FUNC(fp_taos_set_hb_quit, "taos_set_hb_quit");




1,254,853✔





193












194



  LOAD_FUNC(fp_taos_set_notify_cb, "taos_set_notify_cb");




1,254,853✔





195












196



  LOAD_FUNC(fp_taos_fetch_whitelist_a, "taos_fetch_whitelist_a");




1,254,853✔





197












198



  LOAD_FUNC(fp_taos_fetch_whitelist_dual_stack_a, "taos_fetch_whitelist_dual_stack_a");




1,254,853✔





199



  LOAD_FUNC(fp_taos_fetch_ip_whitelist_a, "taos_fetch_ip_whitelist_a");




1,254,853✔





200



  LOAD_FUNC(fp_taos_fetch_datetime_whitelist_a, "taos_fetch_datetime_whitelist_a");




1,254,853✔





201












202



  LOAD_FUNC(fp_taos_set_conn_mode, "taos_set_conn_mode");




1,254,853✔





203












204



  LOAD_FUNC(fp_taos_schemaless_insert, "taos_schemaless_insert");




1,254,853✔





205



  LOAD_FUNC(fp_taos_schemaless_insert_with_reqid, "taos_schemaless_insert_with_reqid");




1,254,853✔





206



  LOAD_FUNC(fp_taos_schemaless_insert_raw, "taos_schemaless_insert_raw");




1,254,853✔





207



  LOAD_FUNC(fp_taos_schemaless_insert_raw_with_reqid, "taos_schemaless_insert_raw_with_reqid");




1,254,853✔





208



  LOAD_FUNC(fp_taos_schemaless_insert_ttl, "taos_schemaless_insert_ttl");




1,254,853✔





209



  LOAD_FUNC(fp_taos_schemaless_insert_ttl_with_reqid, "taos_schemaless_insert_ttl_with_reqid");




1,254,853✔





210



  LOAD_FUNC(fp_taos_schemaless_insert_raw_ttl, "taos_schemaless_insert_raw_ttl");




1,254,853✔





211



  LOAD_FUNC(fp_taos_schemaless_insert_raw_ttl_with_reqid, "taos_schemaless_insert_raw_ttl_with_reqid");




1,254,853✔





212



  LOAD_FUNC(fp_taos_schemaless_insert_raw_ttl_with_reqid_tbname_key,




1,254,853✔





213



            "taos_schemaless_insert_raw_ttl_with_reqid_tbname_key");










214



  LOAD_FUNC(fp_taos_schemaless_insert_ttl_with_reqid_tbname_key, "taos_schemaless_insert_ttl_with_reqid_tbname_key");




1,254,853✔





215












216



  LOAD_FUNC(fp_tmq_conf_new, "tmq_conf_new");




1,254,853✔





217



  LOAD_FUNC(fp_tmq_conf_set, "tmq_conf_set");




1,254,853✔





218



  LOAD_FUNC(fp_tmq_conf_destroy, "tmq_conf_destroy");




1,254,853✔





219



  LOAD_FUNC(fp_tmq_conf_set_auto_commit_cb, "tmq_conf_set_auto_commit_cb");




1,254,853✔





220












221



  LOAD_FUNC(fp_tmq_list_new, "tmq_list_new");




1,254,853✔





222



  LOAD_FUNC(fp_tmq_list_append, "tmq_list_append");




1,254,853✔





223



  LOAD_FUNC(fp_tmq_list_destroy, "tmq_list_destroy");




1,254,853✔





224



  LOAD_FUNC(fp_tmq_list_get_size, "tmq_list_get_size");




1,254,853✔





225



  LOAD_FUNC(fp_tmq_list_to_c_array, "tmq_list_to_c_array");




1,254,853✔





226












227



  LOAD_FUNC(fp_tmq_consumer_new, "tmq_consumer_new");




1,254,853✔





228



  LOAD_FUNC(fp_tmq_subscribe, "tmq_subscribe");




1,254,853✔





229



  LOAD_FUNC(fp_tmq_unsubscribe, "tmq_unsubscribe");




1,254,853✔





230



  LOAD_FUNC(fp_tmq_subscription, "tmq_subscription");




1,254,853✔





231



  LOAD_FUNC(fp_tmq_consumer_poll, "tmq_consumer_poll");




1,254,853✔





232



  LOAD_FUNC(fp_tmq_consumer_close, "tmq_consumer_close");




1,254,853✔





233



  LOAD_FUNC(fp_tmq_commit_sync, "tmq_commit_sync");




1,254,853✔





234



  LOAD_FUNC(fp_tmq_commit_async, "tmq_commit_async");




1,254,853✔





235



  LOAD_FUNC(fp_tmq_commit_offset_sync, "tmq_commit_offset_sync");




1,254,853✔





236



  LOAD_FUNC(fp_tmq_commit_offset_async, "tmq_commit_offset_async");




1,254,853✔





237



  LOAD_FUNC(fp_tmq_get_topic_assignment, "tmq_get_topic_assignment");




1,254,853✔





238



  LOAD_FUNC(fp_tmq_free_assignment, "tmq_free_assignment");




1,254,853✔





239



  LOAD_FUNC(fp_tmq_offset_seek, "tmq_offset_seek");




1,254,853✔





240



  LOAD_FUNC(fp_tmq_position, "tmq_position");




1,254,853✔





241



  LOAD_FUNC(fp_tmq_committed, "tmq_committed");




1,254,853✔





242












243



  LOAD_FUNC(fp_tmq_get_connect, "tmq_get_connect");




1,254,853✔





244



  LOAD_FUNC(fp_tmq_get_table_name, "tmq_get_table_name");




1,254,853✔





245



  LOAD_FUNC(fp_tmq_get_res_type, "tmq_get_res_type");




1,254,853✔





246



  LOAD_FUNC(fp_tmq_get_topic_name, "tmq_get_topic_name");




1,254,853✔





247



  LOAD_FUNC(fp_tmq_get_db_name, "tmq_get_db_name");




1,254,853✔





248



  LOAD_FUNC(fp_tmq_get_vgroup_id, "tmq_get_vgroup_id");




1,254,853✔





249



  LOAD_FUNC(fp_tmq_get_vgroup_offset, "tmq_get_vgroup_offset");




1,254,853✔





250



  LOAD_FUNC(fp_tmq_err2str, "tmq_err2str");




1,254,853✔





251












252



  LOAD_FUNC(fp_tmq_get_raw, "tmq_get_raw");




1,254,853✔





253



  LOAD_FUNC(fp_tmq_write_raw, "tmq_write_raw");




1,254,853✔





254



  LOAD_FUNC(fp_taos_write_raw_block, "taos_write_raw_block");




1,254,853✔





255



  LOAD_FUNC(fp_taos_write_raw_block_with_reqid, "taos_write_raw_block_with_reqid");




1,254,853✔





256



  LOAD_FUNC(fp_taos_write_raw_block_with_fields, "taos_write_raw_block_with_fields");




1,254,853✔





257



  LOAD_FUNC(fp_taos_write_raw_block_with_fields_with_reqid, "taos_write_raw_block_with_fields_with_reqid");




1,254,853✔





258



  LOAD_FUNC(fp_tmq_free_raw, "tmq_free_raw");




1,254,853✔





259












260



  LOAD_FUNC(fp_tmq_get_json_meta, "tmq_get_json_meta");




1,254,853✔





261



  LOAD_FUNC(fp_tmq_free_json_meta, "tmq_free_json_meta");




1,254,853✔





262












263



  LOAD_FUNC(fp_taos_check_server_status, "taos_check_server_status");




1,254,853✔





264



  LOAD_FUNC(fp_taos_write_crashinfo, "taos_write_crashinfo");




1,254,853✔





265



  LOAD_FUNC(fp_getBuildInfo, "getBuildInfo");




1,254,853✔





266












267



  code = 0;




1,254,853✔





268












269



_OVER:




1,254,853✔





270



  if (code != 0) {




1,254,853✔





271



    printf("failed to load function %s from %s since %s [0x%X]\r\n", funcName, driverPath, terrstr(), terrno);




×







272



    showWrapperHint(terrno);




×







273



    taosDriverCleanup();




×







274



  }










275












276



  return code;




1,254,853✔





277



}










278












279



void taosDriverCleanup() {




×







280



  if (tsDriver != NULL) {




×







281



    taosCloseDll(tsDriver);




×







282



    tsDriver = NULL;




×







283



  }










284



}




×





















    

  • 

    •