taosdata / TDengine / #4897

coverage: 65.717% (-0.2%) from 65.929%
#4897

push

travis-ci

web-flow 
fix: [6622889291] Fix invalid rowSize. (#34043)

186011 of 283047 relevant lines covered (65.72%)

113853896.64 hits per line

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

94.18
/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,190,320✔





44



  char    appPath[PATH_MAX] = {0};




1,190,320✔





45



  int32_t ret = taosAppPath(appPath, PATH_MAX);




1,190,320✔





46



  if (ret == 0) {




1,190,320✔





47



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




1,190,320✔





48



    ret = taosRealPath(driverPath, NULL, PATH_MAX);




1,190,320✔





49



  }










50












51



  return ret;




1,190,320✔





52



}










53












54



int32_t taosDriverInit(EDriverType driverType) {




1,190,320✔





55



  int32_t     code = -1;




1,190,320✔





56



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




1,190,320✔





57



  const char *driverName = NULL;




1,190,320✔





58



  const char *funcName = NULL;




1,190,320✔





59












60



  if (driverType == DRIVER_NATIVE) {




1,190,320✔





61



    driverName = DRIVER_NATIVE_NAME;




1,176,128✔





62



  } else {










63



    driverName = DRIVER_WSBSOCKET_NAME;




14,192✔





64



  }










65












66



  // load from develop build path










67



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




1,190,320✔





68



    tsDriver = taosLoadDll(driverPath);




845,778✔





69



  }  










70












71



  // load from system path










72



  if (tsDriver == NULL) {




1,190,320✔





73



    tsDriver = taosLoadDll(driverName);




344,542✔





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,190,320✔





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,190,320✔





92












93



  LOAD_FUNC(fp_taos_init, "taos_init");




1,190,320✔





94



  LOAD_FUNC(fp_taos_cleanup, "taos_cleanup");




1,190,320✔





95



  LOAD_FUNC(fp_taos_options, "taos_options");




1,190,320✔





96



  LOAD_FUNC(fp_taos_set_option, "taos_set_option");




1,190,320✔





97



  LOAD_FUNC(fp_taos_options_connection, "taos_options_connection");




1,190,320✔





98



  LOAD_FUNC(fp_taos_connect, "taos_connect");




1,190,320✔





99



  LOAD_FUNC(fp_taos_connect_totp, "taos_connect_totp");




1,190,320✔





100



  LOAD_FUNC(fp_taos_connect_token, "taos_connect_token");




1,190,320✔





101



  LOAD_FUNC(fp_taos_connect_test, "taos_connect_test");




1,190,320✔





102



  LOAD_FUNC(fp_taos_connect_auth, "taos_connect_auth");




1,190,320✔





103



  LOAD_FUNC(fp_taos_connect_with, "taos_connect_with");




1,190,320✔





104



  LOAD_FUNC(fp_taos_connect_with_dsn, "taos_connect_with_dsn");




1,190,320✔





105



  LOAD_FUNC(fp_taos_close, "taos_close");




1,190,320✔





106












107



  LOAD_FUNC(fp_taos_data_type, "taos_data_type");




1,190,320✔





108












109



  LOAD_FUNC(fp_taos_stmt_init, "taos_stmt_init");




1,190,320✔





110



  LOAD_FUNC(fp_taos_stmt_init_with_reqid, "taos_stmt_init_with_reqid");




1,190,320✔





111



  LOAD_FUNC(fp_taos_stmt_init_with_options, "taos_stmt_init_with_options");




1,190,320✔





112



  LOAD_FUNC(fp_taos_stmt_prepare, "taos_stmt_prepare");




1,190,320✔





113



  LOAD_FUNC(fp_taos_stmt_set_tbname_tags, "taos_stmt_set_tbname_tags");




1,190,320✔





114



  LOAD_FUNC(fp_taos_stmt_set_tbname, "taos_stmt_set_tbname");




1,190,320✔





115



  LOAD_FUNC(fp_taos_stmt_set_tags, "taos_stmt_set_tags");




1,190,320✔





116



  LOAD_FUNC(fp_taos_stmt_set_sub_tbname, "taos_stmt_set_sub_tbname");




1,190,320✔





117



  LOAD_FUNC(fp_taos_stmt_get_tag_fields, "taos_stmt_get_tag_fields");




1,190,320✔





118



  LOAD_FUNC(fp_taos_stmt_get_col_fields, "taos_stmt_get_col_fields");




1,190,320✔





119



  LOAD_FUNC(fp_taos_stmt_reclaim_fields, "taos_stmt_reclaim_fields");




1,190,320✔





120












121



  LOAD_FUNC(fp_taos_stmt_is_insert, "taos_stmt_is_insert");




1,190,320✔





122



  LOAD_FUNC(fp_taos_stmt_num_params, "taos_stmt_num_params");




1,190,320✔





123



  LOAD_FUNC(fp_taos_stmt_get_param, "taos_stmt_get_param");




1,190,320✔





124



  LOAD_FUNC(fp_taos_stmt_bind_param, "taos_stmt_bind_param");




1,190,320✔





125



  LOAD_FUNC(fp_taos_stmt_bind_param_batch, "taos_stmt_bind_param_batch");




1,190,320✔





126



  LOAD_FUNC(fp_taos_stmt_bind_single_param_batch, "taos_stmt_bind_single_param_batch");




1,190,320✔





127



  LOAD_FUNC(fp_taos_stmt_add_batch, "taos_stmt_add_batch");




1,190,320✔





128



  LOAD_FUNC(fp_taos_stmt_execute, "taos_stmt_execute");




1,190,320✔





129



  LOAD_FUNC(fp_taos_stmt_use_result, "taos_stmt_use_result");




1,190,320✔





130



  LOAD_FUNC(fp_taos_stmt_close, "taos_stmt_close");




1,190,320✔





131



  LOAD_FUNC(fp_taos_stmt_errstr, "taos_stmt_errstr");




1,190,320✔





132



  LOAD_FUNC(fp_taos_stmt_affected_rows, "taos_stmt_affected_rows");




1,190,320✔





133



  LOAD_FUNC(fp_taos_stmt_affected_rows_once, "taos_stmt_affected_rows_once");




1,190,320✔





134












135



  LOAD_FUNC(fp_taos_stmt2_init, "taos_stmt2_init");




1,190,320✔





136



  LOAD_FUNC(fp_taos_stmt2_prepare, "taos_stmt2_prepare");




1,190,320✔





137



  LOAD_FUNC(fp_taos_stmt2_bind_param, "taos_stmt2_bind_param");




1,190,320✔





138



  LOAD_FUNC(fp_taos_stmt2_bind_param_a, "taos_stmt2_bind_param_a");




1,190,320✔





139



  LOAD_FUNC(fp_taos_stmt2_exec, "taos_stmt2_exec");




1,190,320✔





140



  LOAD_FUNC(fp_taos_stmt2_close, "taos_stmt2_close");




1,190,320✔





141



  LOAD_FUNC(fp_taos_stmt2_is_insert, "taos_stmt2_is_insert");




1,190,320✔





142



  LOAD_FUNC(fp_taos_stmt2_get_fields, "taos_stmt2_get_fields");




1,190,320✔





143



  LOAD_FUNC(fp_taos_stmt2_free_fields, "taos_stmt2_free_fields");




1,190,320✔





144



  LOAD_FUNC(fp_taos_stmt2_result, "taos_stmt2_result");




1,190,320✔





145



  LOAD_FUNC(fp_taos_stmt2_error, "taos_stmt2_error");




1,190,320✔





146












147



  LOAD_FUNC(fp_taos_query, "taos_query");




1,190,320✔





148



  LOAD_FUNC(fp_taos_query_with_reqid, "taos_query_with_reqid");




1,190,320✔





149












150



  LOAD_FUNC(fp_taos_fetch_row, "taos_fetch_row");




1,190,320✔





151



  LOAD_FUNC(fp_taos_result_precision, "taos_result_precision");




1,190,320✔





152



  LOAD_FUNC(fp_taos_free_result, "taos_free_result");




1,190,320✔





153



  LOAD_FUNC(fp_taos_kill_query, "taos_kill_query");




1,190,320✔





154



  LOAD_FUNC(fp_taos_field_count, "taos_field_count");




1,190,320✔





155



  LOAD_FUNC(fp_taos_num_fields, "taos_num_fields");




1,190,320✔





156



  LOAD_FUNC(fp_taos_affected_rows, "taos_affected_rows");




1,190,320✔





157



  LOAD_FUNC(fp_taos_affected_rows64, "taos_affected_rows64");




1,190,320✔





158












159



  LOAD_FUNC(fp_taos_fetch_fields, "taos_fetch_fields");




1,190,320✔





160



  LOAD_FUNC(fp_taos_fetch_fields_e, "taos_fetch_fields_e");




1,190,320✔





161



  LOAD_FUNC(fp_taos_select_db, "taos_select_db");




1,190,320✔





162



  LOAD_FUNC(fp_taos_print_row, "taos_print_row");




1,190,320✔





163



  LOAD_FUNC(fp_taos_print_row_with_size, "taos_print_row_with_size");




1,190,320✔





164



  LOAD_FUNC(fp_taos_stop_query, "taos_stop_query");




1,190,320✔





165



  LOAD_FUNC(fp_taos_is_null, "taos_is_null");




1,190,320✔





166



  LOAD_FUNC(fp_taos_is_null_by_column, "taos_is_null_by_column");




1,190,320✔





167



  LOAD_FUNC(fp_taos_is_update_query, "taos_is_update_query");




1,190,320✔





168



  LOAD_FUNC(fp_taos_fetch_block, "taos_fetch_block");




1,190,320✔





169



  LOAD_FUNC(fp_taos_fetch_block_s, "taos_fetch_block_s");




1,190,320✔





170



  LOAD_FUNC(fp_taos_fetch_raw_block, "taos_fetch_raw_block");




1,190,320✔





171



  LOAD_FUNC(fp_taos_get_column_data_offset, "taos_get_column_data_offset");




1,190,320✔





172



  LOAD_FUNC(fp_taos_validate_sql, "taos_validate_sql");




1,190,320✔





173



  LOAD_FUNC(fp_taos_reset_current_db, "taos_reset_current_db");




1,190,320✔





174












175



  LOAD_FUNC(fp_taos_fetch_lengths, "taos_fetch_lengths");




1,190,320✔





176



  LOAD_FUNC(fp_taos_result_block, "taos_result_block");




1,190,320✔





177












178



  LOAD_FUNC(fp_taos_get_server_info, "taos_get_server_info");




1,190,320✔





179



  LOAD_FUNC(fp_taos_get_client_info, "taos_get_client_info");




1,190,320✔





180



  LOAD_FUNC(fp_taos_get_current_db, "taos_get_current_db");




1,190,320✔





181



  LOAD_FUNC(fp_taos_get_connection_info, "taos_get_connection_info");




1,190,320✔





182












183



  LOAD_FUNC(fp_taos_errstr, "taos_errstr");




1,190,320✔





184



  LOAD_FUNC(fp_taos_errno, "taos_errno");




1,190,320✔





185












186



  LOAD_FUNC(fp_taos_query_a, "taos_query_a");




1,190,320✔





187



  LOAD_FUNC(fp_taos_query_a_with_reqid, "taos_query_a_with_reqid");




1,190,320✔





188



  LOAD_FUNC(fp_taos_fetch_rows_a, "taos_fetch_rows_a");




1,190,320✔





189



  LOAD_FUNC(fp_taos_fetch_raw_block_a, "taos_fetch_raw_block_a");




1,190,320✔





190



  LOAD_FUNC(fp_taos_get_raw_block, "taos_get_raw_block");




1,190,320✔





191












192



  LOAD_FUNC(fp_taos_get_db_route_info, "taos_get_db_route_info");




1,190,320✔





193



  LOAD_FUNC(fp_taos_get_table_vgId, "taos_get_table_vgId");




1,190,320✔





194



  LOAD_FUNC(fp_taos_get_tables_vgId, "taos_get_tables_vgId");




1,190,320✔





195












196



  LOAD_FUNC(fp_taos_load_table_info, "taos_load_table_info");




1,190,320✔





197












198



  LOAD_FUNC(fp_taos_set_hb_quit, "taos_set_hb_quit");




1,190,320✔





199












200



  LOAD_FUNC(fp_taos_set_notify_cb, "taos_set_notify_cb");




1,190,320✔





201












202



  LOAD_FUNC(fp_taos_fetch_whitelist_a, "taos_fetch_whitelist_a");




1,190,320✔





203












204



  LOAD_FUNC(fp_taos_fetch_whitelist_dual_stack_a, "taos_fetch_whitelist_dual_stack_a");




1,190,320✔





205



  LOAD_FUNC(fp_taos_fetch_ip_whitelist_a, "taos_fetch_ip_whitelist_a");




1,190,320✔





206



  LOAD_FUNC(fp_taos_fetch_datetime_whitelist_a, "taos_fetch_datetime_whitelist_a");




1,190,320✔





207












208



  LOAD_FUNC(fp_taos_set_conn_mode, "taos_set_conn_mode");




1,190,320✔





209












210



  LOAD_FUNC(fp_taos_schemaless_insert, "taos_schemaless_insert");




1,190,320✔





211



  LOAD_FUNC(fp_taos_schemaless_insert_with_reqid, "taos_schemaless_insert_with_reqid");




1,190,320✔





212



  LOAD_FUNC(fp_taos_schemaless_insert_raw, "taos_schemaless_insert_raw");




1,190,320✔





213



  LOAD_FUNC(fp_taos_schemaless_insert_raw_with_reqid, "taos_schemaless_insert_raw_with_reqid");




1,190,320✔





214



  LOAD_FUNC(fp_taos_schemaless_insert_ttl, "taos_schemaless_insert_ttl");




1,190,320✔





215



  LOAD_FUNC(fp_taos_schemaless_insert_ttl_with_reqid, "taos_schemaless_insert_ttl_with_reqid");




1,190,320✔





216



  LOAD_FUNC(fp_taos_schemaless_insert_raw_ttl, "taos_schemaless_insert_raw_ttl");




1,190,320✔





217



  LOAD_FUNC(fp_taos_schemaless_insert_raw_ttl_with_reqid, "taos_schemaless_insert_raw_ttl_with_reqid");




1,190,320✔





218



  LOAD_FUNC(fp_taos_schemaless_insert_raw_ttl_with_reqid_tbname_key,




1,190,320✔





219



            "taos_schemaless_insert_raw_ttl_with_reqid_tbname_key");










220



  LOAD_FUNC(fp_taos_schemaless_insert_ttl_with_reqid_tbname_key, "taos_schemaless_insert_ttl_with_reqid_tbname_key");




1,190,320✔





221












222



  LOAD_FUNC(fp_tmq_conf_new, "tmq_conf_new");




1,190,320✔





223



  LOAD_FUNC(fp_tmq_conf_set, "tmq_conf_set");




1,190,320✔





224



  LOAD_FUNC(fp_tmq_conf_destroy, "tmq_conf_destroy");




1,190,320✔





225



  LOAD_FUNC(fp_tmq_conf_set_auto_commit_cb, "tmq_conf_set_auto_commit_cb");




1,190,320✔





226












227



  LOAD_FUNC(fp_tmq_list_new, "tmq_list_new");




1,190,320✔





228



  LOAD_FUNC(fp_tmq_list_append, "tmq_list_append");




1,190,320✔





229



  LOAD_FUNC(fp_tmq_list_destroy, "tmq_list_destroy");




1,190,320✔





230



  LOAD_FUNC(fp_tmq_list_get_size, "tmq_list_get_size");




1,190,320✔





231



  LOAD_FUNC(fp_tmq_list_to_c_array, "tmq_list_to_c_array");




1,190,320✔





232












233



  LOAD_FUNC(fp_tmq_consumer_new, "tmq_consumer_new");




1,190,320✔





234



  LOAD_FUNC(fp_tmq_subscribe, "tmq_subscribe");




1,190,320✔





235



  LOAD_FUNC(fp_tmq_unsubscribe, "tmq_unsubscribe");




1,190,320✔





236



  LOAD_FUNC(fp_tmq_subscription, "tmq_subscription");




1,190,320✔





237



  LOAD_FUNC(fp_tmq_consumer_poll, "tmq_consumer_poll");




1,190,320✔





238



  LOAD_FUNC(fp_tmq_consumer_close, "tmq_consumer_close");




1,190,320✔





239



  LOAD_FUNC(fp_tmq_commit_sync, "tmq_commit_sync");




1,190,320✔





240



  LOAD_FUNC(fp_tmq_commit_async, "tmq_commit_async");




1,190,320✔





241



  LOAD_FUNC(fp_tmq_commit_offset_sync, "tmq_commit_offset_sync");




1,190,320✔





242



  LOAD_FUNC(fp_tmq_commit_offset_async, "tmq_commit_offset_async");




1,190,320✔





243



  LOAD_FUNC(fp_tmq_get_topic_assignment, "tmq_get_topic_assignment");




1,190,320✔





244



  LOAD_FUNC(fp_tmq_free_assignment, "tmq_free_assignment");




1,190,320✔





245



  LOAD_FUNC(fp_tmq_offset_seek, "tmq_offset_seek");




1,190,320✔





246



  LOAD_FUNC(fp_tmq_position, "tmq_position");




1,190,320✔





247



  LOAD_FUNC(fp_tmq_committed, "tmq_committed");




1,190,320✔





248












249



  LOAD_FUNC(fp_tmq_get_connect, "tmq_get_connect");




1,190,320✔





250



  LOAD_FUNC(fp_tmq_get_table_name, "tmq_get_table_name");




1,190,320✔





251



  LOAD_FUNC(fp_tmq_get_res_type, "tmq_get_res_type");




1,190,320✔





252



  LOAD_FUNC(fp_tmq_get_topic_name, "tmq_get_topic_name");




1,190,320✔





253



  LOAD_FUNC(fp_tmq_get_db_name, "tmq_get_db_name");




1,190,320✔





254



  LOAD_FUNC(fp_tmq_get_vgroup_id, "tmq_get_vgroup_id");




1,190,320✔





255



  LOAD_FUNC(fp_tmq_get_vgroup_offset, "tmq_get_vgroup_offset");




1,190,320✔





256



  LOAD_FUNC(fp_tmq_err2str, "tmq_err2str");




1,190,320✔





257












258



  LOAD_FUNC(fp_tmq_get_raw, "tmq_get_raw");




1,190,320✔





259



  LOAD_FUNC(fp_tmq_write_raw, "tmq_write_raw");




1,190,320✔





260



  LOAD_FUNC(fp_taos_write_raw_block, "taos_write_raw_block");




1,190,320✔





261



  LOAD_FUNC(fp_taos_write_raw_block_with_reqid, "taos_write_raw_block_with_reqid");




1,190,320✔





262



  LOAD_FUNC(fp_taos_write_raw_block_with_fields, "taos_write_raw_block_with_fields");




1,190,320✔





263



  LOAD_FUNC(fp_taos_write_raw_block_with_fields_with_reqid, "taos_write_raw_block_with_fields_with_reqid");




1,190,320✔





264



  LOAD_FUNC(fp_tmq_free_raw, "tmq_free_raw");




1,190,320✔





265












266



  LOAD_FUNC(fp_tmq_get_json_meta, "tmq_get_json_meta");




1,190,320✔





267



  LOAD_FUNC(fp_tmq_free_json_meta, "tmq_free_json_meta");




1,190,320✔





268












269



  LOAD_FUNC(fp_taos_check_server_status, "taos_check_server_status");




1,190,320✔





270



  LOAD_FUNC(fp_taos_write_crashinfo, "taos_write_crashinfo");




1,190,320✔





271



  LOAD_FUNC(fp_getBuildInfo, "getBuildInfo");




1,190,320✔





272












273



  LOAD_FUNC(fp_taos_connect_is_alive, "taos_connect_is_alive");




1,190,320✔





274












275



  code = 0;




1,190,320✔





276












277



_OVER:




1,190,320✔





278



  if (code != 0) {




1,190,320✔





279



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




×







280



    showWrapperHint(terrno);




×







281



    taosDriverCleanup();




×







282



  }










283












284



  return code;




1,190,320✔





285



}










286












287



void taosDriverCleanup() {




×







288



  if (tsDriver != NULL) {




×







289



    taosCloseDll(tsDriver);




×







290



    tsDriver = NULL;




×







291



  }










292



}




×





















    

  • 

    •