debug tags updated
authorVictor Kirhenshtein <victor@netxms.org>
Fri, 13 Oct 2017 11:34:25 +0000 (14:34 +0300)
committerVictor Kirhenshtein <victor@netxms.org>
Fri, 13 Oct 2017 11:34:25 +0000 (14:34 +0300)
doc/internal/debug_tags.txt
src/db/libnxdb/dbcp.cpp
src/db/libnxdb/session.cpp

index fea742c..d5c3db9 100644 (file)
@@ -1,14 +1,12 @@
 db.*           Database related
 db.query       SQL query trace
-db.sessions    DB sessions (connections)
+db.conn                DB connections
 db.cpool       DB connection pool
 
 housekeeper    Housekeeper messages
 
-objects.*      Object related trace
-objects.dc.*   Data collection related
-objects.locks.*        Locks
+obj.*          Object related trace
+obj.dc.*       Data collection related
+obj.locks.*    Locks
 
 threads.*      Thread related
-
-
index 075db5a..a665db2 100644 (file)
@@ -42,6 +42,8 @@ static THREAD m_maintThread = INVALID_THREAD_HANDLE;
 static CONDITION m_condShutdown = INVALID_CONDITION_HANDLE;
 static CONDITION m_condRelease = INVALID_CONDITION_HANDLE;
 
+#define DEBUG_TAG _T("db.cpool")
+
 /**
  * Create connections on pool initialization
  */
@@ -68,7 +70,7 @@ static bool DBConnectionPoolPopulate()
       }
       else
       {
-         nxlog_debug_tag(_T("db.connection.poll"), 3, _T("Database Connection Pool: cannot create DB connection %d (%s)"), i, errorText);
+         nxlog_debug_tag(DEBUG_TAG, 3, _T("Cannot create DB connection %d (%s)"), i, errorText);
          delete conn;
       }
        }
@@ -114,12 +116,12 @@ static bool ResetConnection(PoolConnectionInfo *conn)
                conn->lastAccessTime = now;
                conn->usageCount = 0;
 
-               nxlog_debug_tag(_T("db.connection.poll"), 3, _T("Database Connection Pool: connection %p reconnected"), conn->handle);
+               nxlog_debug_tag(DEBUG_TAG, 3, _T("Connection %p reconnected"), conn->handle);
                return true;
        }
    else
    {
-               nxlog_debug_tag(_T("db.connection.poll"), 3, _T("Database Connection Pool: connection %p reconnect failure (%s)"), conn->handle, errorText);
+               nxlog_debug_tag(DEBUG_TAG, 3, _T("Connection %p reconnect failure (%s)"), conn->handle, errorText);
                return false;
        }
 }
@@ -192,7 +194,7 @@ static void ResetExpiredConnections()
 static THREAD_RESULT THREAD_CALL MaintenanceThread(void *arg)
 {
    ThreadSetName("DBPoolMaint");
-   nxlog_debug_tag(_T("db.connection.poll"), 1, _T("Database Connection Pool maintenance thread started"));
+   nxlog_debug_tag(DEBUG_TAG, 1, _T("Database Connection Pool maintenance thread started"));
 
    while(!ConditionWait(m_condShutdown, (m_connectionTTL > 0) ? m_connectionTTL * 750 : 300000))
    {
@@ -203,7 +205,7 @@ static THREAD_RESULT THREAD_CALL MaintenanceThread(void *arg)
       }
    }
 
-       nxlog_debug_tag(_T("db.connection.poll"), 1, _T("Database Connection Pool maintenance thread stopped"));
+       nxlog_debug_tag(DEBUG_TAG, 1, _T("Database Connection Pool maintenance thread stopped"));
    return THREAD_OK;
 }
 
@@ -247,7 +249,7 @@ bool LIBNXDB_EXPORTABLE DBConnectionPoolStartup(DB_DRIVER driver, const TCHAR *s
    m_maintThread = ThreadCreateEx(MaintenanceThread, 0, NULL);
 
    s_initialized = true;
-       nxlog_debug_tag(_T("db.connection.poll"), 1, _T("Database Connection Pool initialized"));
+       nxlog_debug_tag(DEBUG_TAG, 1, _T("Database Connection Pool initialized"));
 
        return true;
 }
@@ -275,8 +277,7 @@ void LIBNXDB_EXPORTABLE DBConnectionPoolShutdown()
    m_connections.clear();
 
    s_initialized = false;
-       nxlog_debug_tag(_T("db.connection.poll"), 1, _T("Database Connection Pool terminated"));
-
+       nxlog_debug_tag(DEBUG_TAG, 1, _T("Database Connection Pool terminated"));
 }
 
 /**
@@ -331,7 +332,7 @@ retry:
       }
       else
       {
-         nxlog_debug_tag(_T("db.connection.poll"), 3, _T("Database Connection Pool: cannot create additional DB connection (%s)"), errorText);
+         nxlog_debug_tag(DEBUG_TAG, 3, _T("Cannot create additional DB connection (%s)"), errorText);
          delete conn;
       }
        }
@@ -340,13 +341,13 @@ retry:
 
        if (handle == NULL)
        {
-       nxlog_debug_tag(_T("db.connection.poll"), 1, _T("Database Connection Pool exhausted (call from %hs:%d)"), srcFile, srcLine);
+       nxlog_debug_tag(DEBUG_TAG, 1, _T("Database connection pool exhausted (call from %hs:%d)"), srcFile, srcLine);
       ConditionWait(m_condRelease, 10000);
-      nxlog_debug_tag(_T("db.connection.poll"), 5, _T("Database Connection Pool: retry acquire connection (call from %hs:%d)"), srcFile, srcLine);
+      nxlog_debug_tag(DEBUG_TAG, 5, _T("Retry acquire connection (call from %hs:%d)"), srcFile, srcLine);
       goto retry;
        }
 
-   nxlog_debug_tag(_T("db.connection.poll"), 7, _T("Database Connection Pool: handle %p acquired (call from %hs:%d)"), handle, srcFile, srcLine);
+   nxlog_debug_tag(DEBUG_TAG, 7, _T("Handle %p acquired (call from %hs:%d)"), handle, srcFile, srcLine);
        return handle;
 }
 
@@ -372,7 +373,7 @@ void LIBNXDB_EXPORTABLE DBConnectionPoolReleaseConnection(DB_HANDLE handle)
 
        MutexUnlock(m_poolAccessMutex);
 
-   nxlog_debug_tag(_T("db.connection.poll"), 7, _T("Database Connection Pool: handle %p released"), handle);
+   nxlog_debug_tag(DEBUG_TAG, 7, _T("Handle %p released"), handle);
    ConditionPulse(m_condRelease);
 }
 
index 3a7211f..8b68062 100644 (file)
@@ -23,6 +23,9 @@
 
 #include "libnxdb.h"
 
+#define DEBUG_TAG_CONNECTION  _T("db.conn")
+#define DEBUG_TAG_QUERY       _T("db.query")
+
 /**
  * Check if statement handle is valid
  */
@@ -66,7 +69,7 @@ DB_HANDLE LIBNXDB_EXPORTABLE DBConnect(DB_DRIVER driver, const TCHAR *server, co
    DBDRV_CONNECTION hDrvConn;
    DB_HANDLE hConn = NULL;
 
-       nxlog_debug_tag(_T("db.connect"), 8, _T("DBConnect: server=%s db=%s login=%s schema=%s"), CHECK_NULL(server), CHECK_NULL(dbName), CHECK_NULL(login), CHECK_NULL(schema));
+       nxlog_debug_tag(DEBUG_TAG_CONNECTION, 8, _T("DBConnect: server=%s db=%s login=%s schema=%s"), CHECK_NULL(server), CHECK_NULL(dbName), CHECK_NULL(login), CHECK_NULL(schema));
 #ifdef UNICODE
        char *mbServer = (server == NULL) ? NULL : MBStringFromWideString(server);
        char *mbDatabase = (dbName == NULL) ? NULL : MBStringFromWideString(dbName);
@@ -108,7 +111,7 @@ DB_HANDLE LIBNXDB_EXPORTABLE DBConnect(DB_DRIVER driver, const TCHAR *server, co
 #endif
          if (driver->m_fpDrvSetPrefetchLimit != NULL)
             driver->m_fpDrvSetPrefetchLimit(hDrvConn, driver->m_defaultPrefetchLimit);
-                  nxlog_debug_tag(_T("db.connect"), 4, _T("New DB connection opened: handle=%p"), hConn);
+                  nxlog_debug_tag(DEBUG_TAG_CONNECTION, 4, _T("New DB connection opened: handle=%p"), hConn);
          if (s_sessionInitCb != NULL)
             s_sessionInitCb(hConn);
       }
@@ -138,7 +141,7 @@ void LIBNXDB_EXPORTABLE DBDisconnect(DB_HANDLE hConn)
    if (hConn == NULL)
       return;
 
-   nxlog_debug_tag(_T("db.connect"), 4, _T("DB connection %p closed"), hConn);
+   nxlog_debug_tag(DEBUG_TAG_CONNECTION, 4, _T("DB connection %p closed"), hConn);
    
    InvalidatePreparedStatements(hConn);
 
@@ -172,7 +175,7 @@ static void DBReconnect(DB_HANDLE hConn)
    int nCount;
        WCHAR errorText[DBDRV_MAX_ERROR_TEXT];
 
-   nxlog_debug_tag(_T("db.connect"), 4, _T("DB reconnect: handle=%p"), hConn);
+   nxlog_debug_tag(DEBUG_TAG_CONNECTION, 4, _T("DB reconnect: handle=%p"), hConn);
 
    InvalidatePreparedStatements(hConn);
        hConn->m_driver->m_fpDrvDisconnect(hConn->m_connection);
@@ -264,11 +267,11 @@ bool LIBNXDB_EXPORTABLE DBQueryEx(DB_HANDLE hConn, const TCHAR *szQuery, TCHAR *
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s sync query: \"%s\" [%d ms]"), (dwResult == DBERR_SUCCESS) ? _T("Successful") : _T("Failed"), szQuery, ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s sync query: \"%s\" [%d ms]"), (dwResult == DBERR_SUCCESS) ? _T("Successful") : _T("Failed"), szQuery, ms);
    }
    if ((dwResult == DBERR_SUCCESS) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
       s_perfLongRunningQueries++;
    }
    
@@ -335,11 +338,11 @@ DB_RESULT LIBNXDB_EXPORTABLE DBSelectEx(DB_HANDLE hConn, const TCHAR *szQuery, T
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s sync query: \"%s\" [%d ms]"), (hResult != NULL) ? _T("Successful") : _T("Failed"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s sync query: \"%s\" [%d ms]"), (hResult != NULL) ? _T("Successful") : _T("Failed"), szQuery, (int)ms);
    }
    if ((hResult != NULL) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
       s_perfLongRunningQueries++;
    }
    MutexUnlock(hConn->m_mutexTransLock);
@@ -816,11 +819,11 @@ DB_UNBUFFERED_RESULT LIBNXDB_EXPORTABLE DBSelectUnbufferedEx(DB_HANDLE hConn, co
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s unbuffered query: \"%s\" [%d ms]"), (hResult != NULL) ? _T("Successful") : _T("Failed"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s unbuffered query: \"%s\" [%d ms]"), (hResult != NULL) ? _T("Successful") : _T("Failed"), szQuery, (int)ms);
    }
    if ((hResult != NULL) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
       s_perfLongRunningQueries++;
    }
    if (hResult == NULL)
@@ -1163,7 +1166,7 @@ DB_STATEMENT LIBNXDB_EXPORTABLE DBPrepareEx(DB_HANDLE hConn, const TCHAR *query,
    if (hConn->m_driver->m_dumpSql)
    {
       ms = GetCurrentTimeMs() - ms;
-               nxlog_debug_tag(_T("db.query"), 9, _T("{%p} %s prepare: \"%s\" [%d ms]"), result, (result != NULL) ? _T("Successful") : _T("Failed"), query, ms);
+               nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("{%p} %s prepare: \"%s\" [%d ms]"), result, (result != NULL) ? _T("Successful") : _T("Failed"), query, ms);
        }
 
 #ifndef UNICODE
@@ -1245,11 +1248,11 @@ void LIBNXDB_EXPORTABLE DBBind(DB_STATEMENT hStmt, int pos, int sqlType, int cTy
    {
                if (cType == DB_CTYPE_STRING)
                {
-                       nxlog_debug_tag(_T("db.query"), 9, _T("{%p} bind at pos %d: \"%s\""), hStmt, pos, buffer);
+                       nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("{%p} bind at pos %d: \"%s\""), hStmt, pos, buffer);
                }
                else if (cType == DB_CTYPE_UTF8_STRING)
       {
-         nxlog_debug_tag(_T("db.query"), 9, _T("{%p} bind at pos %d (UTF-8): \"%hs\""), hStmt, pos, buffer);
+         nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("{%p} bind at pos %d (UTF-8): \"%hs\""), hStmt, pos, buffer);
       }
                else
                {
@@ -1272,7 +1275,7 @@ void LIBNXDB_EXPORTABLE DBBind(DB_STATEMENT hStmt, int pos, int sqlType, int cTy
                                        _sntprintf(text, 64, _T("%f"), *((double *)buffer));
                                        break;
                        }
-                       nxlog_debug_tag(_T("db.query"), 9, _T("{%p} bind at pos %d: \"%s\""), hStmt, pos, text);
+                       nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("{%p} bind at pos %d: \"%s\""), hStmt, pos, text);
                }
        }
 
@@ -1431,11 +1434,11 @@ bool LIBNXDB_EXPORTABLE DBExecuteEx(DB_STATEMENT hStmt, TCHAR *errorText)
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s prepared sync query: \"%s\" [%d ms]"), (dwResult == DBERR_SUCCESS) ? _T("Successful") : _T("Failed"), hStmt->m_query, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s prepared sync query: \"%s\" [%d ms]"), (dwResult == DBERR_SUCCESS) ? _T("Successful") : _T("Failed"), hStmt->m_query, (int)ms);
    }
    if ((dwResult == DBERR_SUCCESS) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
       s_perfLongRunningQueries++;
    }
 
@@ -1514,12 +1517,12 @@ DB_RESULT LIBNXDB_EXPORTABLE DBSelectPreparedEx(DB_STATEMENT hStmt, TCHAR *error
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s prepared sync query: \"%s\" [%d ms]"),
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s prepared sync query: \"%s\" [%d ms]"),
                              (hResult != NULL) ? _T("Successful") : _T("Failed"), hStmt->m_query, (int)ms);
    }
    if ((hResult != NULL) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
       s_perfLongRunningQueries++;
    }
 
@@ -1606,12 +1609,12 @@ DB_UNBUFFERED_RESULT LIBNXDB_EXPORTABLE DBSelectPreparedUnbufferedEx(DB_STATEMEN
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s prepared sync query: \"%s\" [%d ms]"),
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s prepared sync query: \"%s\" [%d ms]"),
                     (hResult != NULL) ? _T("Successful") : _T("Failed"), hStmt->m_query, (int)ms);
    }
    if ((hResult != NULL) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
       s_perfLongRunningQueries++;
    }
 
@@ -1688,19 +1691,19 @@ bool LIBNXDB_EXPORTABLE DBBegin(DB_HANDLE hConn)
       {
          hConn->m_transactionLevel++;
          bRet = true;
-                       nxlog_debug_tag(_T("db.query"), 9, _T("BEGIN TRANSACTION successful (level %d)"), hConn->m_transactionLevel);
+                       nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("BEGIN TRANSACTION successful (level %d)"), hConn->m_transactionLevel);
       }
       else
       {
          MutexUnlock(hConn->m_mutexTransLock);
-                       nxlog_debug_tag(_T("db.query"), 9, _T("BEGIN TRANSACTION failed"), hConn->m_transactionLevel);
+                       nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("BEGIN TRANSACTION failed"), hConn->m_transactionLevel);
       }
    }
    else
    {
       hConn->m_transactionLevel++;
       bRet = true;
-               nxlog_debug_tag(_T("db.query"), 9, _T("BEGIN TRANSACTION successful (level %d)"), hConn->m_transactionLevel);
+               nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("BEGIN TRANSACTION successful (level %d)"), hConn->m_transactionLevel);
    }
    return bRet;
 }
@@ -1720,7 +1723,7 @@ bool LIBNXDB_EXPORTABLE DBCommit(DB_HANDLE hConn)
          bRet = (hConn->m_driver->m_fpDrvCommit(hConn->m_connection) == DBERR_SUCCESS);
       else
          bRet = true;
-               nxlog_debug_tag(_T("db.query"), 9, _T("COMMIT TRANSACTION %s (level %d)"), bRet ? _T("successful") : _T("failed"), hConn->m_transactionLevel);
+               nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("COMMIT TRANSACTION %s (level %d)"), bRet ? _T("successful") : _T("failed"), hConn->m_transactionLevel);
       MutexUnlock(hConn->m_mutexTransLock);
    }
    MutexUnlock(hConn->m_mutexTransLock);
@@ -1742,7 +1745,7 @@ bool LIBNXDB_EXPORTABLE DBRollback(DB_HANDLE hConn)
          bRet = (hConn->m_driver->m_fpDrvRollback(hConn->m_connection) == DBERR_SUCCESS);
       else
          bRet = true;
-               nxlog_debug_tag(_T("db.query"), 9, _T("ROLLBACK TRANSACTION %s (level %d)"), bRet ? _T("successful") : _T("failed"), hConn->m_transactionLevel);
+               nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("ROLLBACK TRANSACTION %s (level %d)"), bRet ? _T("successful") : _T("failed"), hConn->m_transactionLevel);
       MutexUnlock(hConn->m_mutexTransLock);
    }
    MutexUnlock(hConn->m_mutexTransLock);