diff --git a/src/client/src/tscSystem.c b/src/client/src/tscSystem.c index 35ee916d7db3b9b0df69c2d027db41ae9b0a4590..ff605dad72a876eacd4243b02be85bb6d8803634 100644 --- a/src/client/src/tscSystem.c +++ b/src/client/src/tscSystem.c @@ -132,7 +132,8 @@ void taos_init_imp(void) { int64_t refreshTime = 10; // 10 seconds by default if (tscMetaCache == NULL) { tscMetaCache = taosCacheInit(TSDB_DATA_TYPE_BINARY, refreshTime, false, tscFreeTableMetaHelper, "tableMeta"); - tscObjRef = taosOpenRef(40960, tscFreeRegisteredSqlObj); + tscObjRef = taosOpenRef(40960, tscFreeRegisteredSqlObj); + tscHashMap = taosHashInit(1024, taosGetDefaultHashFunction(TSDB_DATA_TYPE_INT), true, HASH_ENTRY_LOCK); } tscRefId = taosOpenRef(200, tscCloseTscObj); diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c index bbad7bf257f075aa0b1fa0ee4bbf78ecab3bca9e..172887c1107ef237007dbb0646bcc41efb799a72 100644 --- a/src/client/src/tscUtil.c +++ b/src/client/src/tscUtil.c @@ -1913,7 +1913,7 @@ void registerSqlObj(SSqlObj* pSql) { int32_t num = atomic_add_fetch_32(&pSql->pTscObj->numOfObj, 1); int32_t total = atomic_add_fetch_32(&tscNumOfObj, 1); - tscDebug("%p new SqlObj, total in tscObj:%d, total:%d", pSql, num, total); + tscDebug("%p new SqlObj from %p, total in tscObj:%d, total:%d", pSql, pSql->pTscObj, num, total); } SSqlObj* createSimpleSubObj(SSqlObj* pSql, void (*fp)(), void* param, int32_t cmd) { diff --git a/src/util/inc/hash.h b/src/util/inc/hash.h index 6a97a74c046aa015dbe2d23f38a59ccf54d9c00e..7ec4e5445aa2fed72bb7962bcec4c7da159a7afb 100644 --- a/src/util/inc/hash.h +++ b/src/util/inc/hash.h @@ -43,6 +43,7 @@ typedef struct SHashNode { #define GET_HASH_NODE_KEY(_n) ((char*)(_n) + sizeof(SHashNode) + (_n)->dataLen) #define GET_HASH_NODE_DATA(_n) ((char*)(_n) + sizeof(SHashNode)) #define GET_HASH_PNODE(_n) ((char*)(_n) - sizeof(SHashNode)); + typedef enum SHashLockTypeE { HASH_NO_LOCK = 0, HASH_ENTRY_LOCK = 1,