removed "timeout" argument from MutexLock call
authorVictor Kirhenshtein <victor@netxms.org>
Fri, 11 Nov 2011 14:19:16 +0000 (14:19 +0000)
committerVictor Kirhenshtein <victor@netxms.org>
Fri, 11 Nov 2011 14:19:16 +0000 (14:19 +0000)
60 files changed:
include/netxms_maps.h
include/nms_threads.h
include/nxconfig.h
include/nxcpapi.h
include/nxqueue.h
include/nxsl_classes.h
src/agent/core/comm.cpp
src/agent/core/epp.cpp
src/agent/core/extagent.cpp
src/agent/core/push.cpp
src/agent/core/trap.cpp
src/agent/subagents/informix/main.cpp
src/agent/subagents/ups/ups.cpp
src/client/windows/nxcon/nxcon.cpp
src/db/dbdrv/db2/db2.cpp
src/db/dbdrv/informix/informix.cpp
src/db/dbdrv/mssql/mssql.cpp
src/db/dbdrv/mysql/mysql.cpp
src/db/dbdrv/odbc/odbc.cpp
src/db/dbdrv/oracle/oracle.cpp
src/db/dbdrv/pgsql/pgsql.cpp
src/db/dbdrv/sqlite/sqlite.cpp
src/db/libnxdb/dbcp.cpp
src/db/libnxdb/drivers.cpp
src/db/libnxdb/session.cpp
src/libnetxms/crypto.cpp
src/libnetxms/log.cpp
src/libnetxms/msgwq.cpp
src/libnetxms/tools.cpp
src/libnxcl/comm.cpp
src/libnxcl/libnxcl.h
src/libnxcl/session.cpp
src/libnxmb/dispatcher.cpp
src/server/core/cert.cpp
src/server/core/debug.cpp
src/server/core/id.cpp
src/server/core/job.cpp
src/server/core/jobqueue.cpp
src/server/core/locks.cpp
src/server/core/logs.cpp
src/server/core/node.cpp
src/server/core/package.cpp
src/server/core/session.cpp
src/server/core/snmptrap.cpp
src/server/core/syslogd.cpp
src/server/core/tracert.cpp
src/server/core/upload_job.cpp
src/server/core/userdb.cpp
src/server/core/watchdog.cpp
src/server/include/nms_alarm.h
src/server/include/nms_core.h
src/server/include/nms_dcoll.h
src/server/include/nms_objects.h
src/server/include/nms_users.h
src/server/include/nxcore_logs.h
src/server/include/nxcore_situations.h
src/server/include/nxsrvapi.h
src/server/libnxsrv/agent.cpp
src/server/libnxsrv/isc.cpp
src/tools/nxcptest/nxcptest.cpp

index 3599eba..b03d743 100644 (file)
@@ -321,7 +321,7 @@ protected:
    MUTEX m_mutex;
    SUBMAP_CREATION_CALLBACK m_pfCreateSubmap;
 
-   void CommonInit(void);
+   void CommonInit();
 
 public:
    nxMap();
@@ -329,14 +329,14 @@ public:
    nxMap(CSCPMessage *pMsg);
    virtual ~nxMap();
 
-   void Lock(void) { MutexLock(m_mutex, INFINITE); }
-   void Unlock(void) { MutexUnlock(m_mutex); }
+   void Lock() { MutexLock(m_mutex); }
+   void Unlock() { MutexUnlock(m_mutex); }
 
        void SetName(const TCHAR *name) { safe_free(m_pszName); m_pszName = _tcsdup(name); }
 
-   DWORD MapId(void) { return m_dwMapId; }
-   DWORD ObjectId(void) { return m_dwObjectId; }
-   TCHAR *Name(void) { return CHECK_NULL(m_pszName); }
+   DWORD MapId() { return m_dwMapId; }
+   DWORD ObjectId() { return m_dwObjectId; }
+   TCHAR *Name() { return CHECK_NULL(m_pszName); }
 
    void AddSubmap(nxSubmap *pSubmap);
    DWORD GetSubmapCount(void) { return m_dwNumSubmaps; }
index fad8016..05adeaf 100644 (file)
@@ -1,6 +1,6 @@
 /* 
 ** NetXMS - Network Management System
-** Copyright (C) 2003-2010 Victor Kirhenshtein
+** Copyright (C) 2003-2011 Victor Kirhenshtein
 **
 ** This program is free software; you can redistribute it and/or modify
 ** it under the terms of the GNU Lesser General Public License as published
@@ -190,11 +190,11 @@ inline void MutexDestroy(MUTEX mutex)
    CloseHandle(mutex);
 }
 
-inline BOOL MutexLock(MUTEX mutex, DWORD dwTimeOut)
+inline BOOL MutexLock(MUTEX mutex)
 {
        if (mutex == INVALID_MUTEX_HANDLE)
                return FALSE;
-   return WaitForSingleObject(mutex, dwTimeOut) == WAIT_OBJECT_0;
+   return WaitForSingleObject(mutex, INFINITE) == WAIT_OBJECT_0;
 }
 
 inline void MutexUnlock(MUTEX mutex)
@@ -364,30 +364,16 @@ inline void MutexDestroy(MUTEX mutex)
       free(mutex);
 }
 
-inline BOOL MutexLock(MUTEX mutex, DWORD dwTimeOut)
+inline BOOL MutexLock(MUTEX mutex)
 {
        int i;
        int ret = FALSE;
 
    if (mutex != NULL)
    {
-               if (dwTimeOut == INFINITE)
-               {
-                       if (pth_mutex_acquire(mutex, FALSE, NULL))
-         {
-                               ret = TRUE;
-                       }
-               }
-               else
-               {
-         pth_event_t ev;
-
-         ev = pth_event(PTH_EVENT_TIME, pth_timeout(dwTimeOut / 1000, (dwTimeOut % 1000) * 1000));
-                       if (pth_mutex_acquire(mutex, FALSE, ev))
-         {
-            ret = TRUE;
-         }
-         pth_event_free(ev, PTH_FREE_ALL);
+               if (pth_mutex_acquire(mutex, FALSE, NULL))
+      {
+                       ret = TRUE;
                }
        }
    return ret;
@@ -720,31 +706,16 @@ inline void MutexDestroy(MUTEX mutex)
    }
 }
 
-inline BOOL MutexLock(MUTEX mutex, DWORD dwTimeOut)
+inline BOOL MutexLock(MUTEX mutex)
 {
        int i;
        int ret = FALSE;
 
    if (mutex != NULL)
    {
-               if (dwTimeOut == INFINITE)
-               {
-                       if (pthread_mutex_lock(&mutex->mutex) == 0)
-         {
-                               ret = TRUE;
-                       }
-               }
-               else
-               {
-                       for (i = (dwTimeOut / 50) + 1; i > 0; i--)
-         {
-                               if (pthread_mutex_trylock(&mutex->mutex) == 0) 
-            {
-                                       ret = TRUE;
-                                       break;
-                               }
-                               ThreadSleepMs(50);
-                       }
+               if (pthread_mutex_lock(&mutex->mutex) == 0)
+      {
+                       ret = TRUE;
                }
        }
    return ret;
@@ -898,12 +869,12 @@ inline BOOL ConditionWait(CONDITION cond, DWORD dwTimeOut)
        return ret;
 }
 
-inline DWORD GetCurrentProcessId(void)
+inline DWORD GetCurrentProcessId()
 {
    return getpid();
 }
 
-inline THREAD GetCurrentThreadId(void)
+inline THREAD GetCurrentThreadId()
 {
    return pthread_self();
 }
index 422d5c3..0378afb 100644 (file)
@@ -139,7 +139,7 @@ public:
        Config();
        ~Config();
 
-       void lock() { MutexLock(m_mutex, INFINITE); }
+       void lock() { MutexLock(m_mutex); }
        void unlock() { MutexUnlock(m_mutex); }
 
        void setTopLevelTag(const TCHAR *topLevelTag) { m_root->setName(topLevelTag); }
index 57c506c..f5699a0 100644 (file)
@@ -148,30 +148,30 @@ private:
    WAIT_QUEUE_ELEMENT *m_pElements;
    THREAD m_hHkThread;
 
-   void Lock(void) { MutexLock(m_mutexDataAccess, INFINITE); }
-   void Unlock(void) { MutexUnlock(m_mutexDataAccess); }
-   void HousekeeperThread(void);
-   void *WaitForMessageInternal(WORD wIsBinary, WORD wCode, DWORD dwId, DWORD dwTimeOut);
+   void lock() { MutexLock(m_mutexDataAccess); }
+   void unlock() { MutexUnlock(m_mutexDataAccess); }
+   void housekeeperThread();
+   void *waitForMessageInternal(WORD wIsBinary, WORD wCode, DWORD dwId, DWORD dwTimeOut);
    
-   static THREAD_RESULT THREAD_CALL MWQThreadStarter(void *);
+   static THREAD_RESULT THREAD_CALL mwqThreadStarter(void *);
 
 public:
    MsgWaitQueue();
    ~MsgWaitQueue();
 
-   void Put(CSCPMessage *pMsg);
-   void Put(CSCP_MESSAGE *pMsg);
-   CSCPMessage *WaitForMessage(WORD wCode, DWORD dwId, DWORD dwTimeOut)
+   void put(CSCPMessage *pMsg);
+   void put(CSCP_MESSAGE *pMsg);
+   CSCPMessage *waitForMessage(WORD wCode, DWORD dwId, DWORD dwTimeOut)
    {
-      return (CSCPMessage *)WaitForMessageInternal(0, wCode, dwId, dwTimeOut);
+      return (CSCPMessage *)waitForMessageInternal(0, wCode, dwId, dwTimeOut);
    }
-   CSCP_MESSAGE *WaitForRawMessage(WORD wCode, DWORD dwId, DWORD dwTimeOut)
+   CSCP_MESSAGE *waitForRawMessage(WORD wCode, DWORD dwId, DWORD dwTimeOut)
    {
-      return (CSCP_MESSAGE *)WaitForMessageInternal(1, wCode, dwId, dwTimeOut);
+      return (CSCP_MESSAGE *)waitForMessageInternal(1, wCode, dwId, dwTimeOut);
    }
    
-   void Clear(void);
-   void SetHoldTime(DWORD dwHoldTime) { m_dwMsgHoldTime = dwHoldTime; }
+   void clear();
+   void setHoldTime(DWORD dwHoldTime) { m_dwMsgHoldTime = dwHoldTime; }
 };
 
 
index 1612836..806f1b4 100644 (file)
@@ -45,8 +45,8 @@ private:
    DWORD m_dwBufferIncrement;
        BOOL m_bShutdownFlag;
 
-       void CommonInit(void);
-   void Lock() { MutexLock(m_mutexQueueAccess, INFINITE); }
+       void CommonInit();
+   void Lock() { MutexLock(m_mutexQueueAccess); }
    void Unlock() { MutexUnlock(m_mutexQueueAccess); }
 
 public:
index 4807ab5..73f8604 100644 (file)
@@ -543,7 +543,7 @@ public:
    NXSL_Library();
    ~NXSL_Library();
 
-   void lock() { MutexLock(m_mutex, INFINITE); }
+   void lock() { MutexLock(m_mutex); }
    void unlock() { MutexUnlock(m_mutex); }
 
    BOOL addScript(DWORD dwId, const TCHAR *pszName, NXSL_Program *pScript);
index 59b558f..4c33a69 100644 (file)
@@ -82,7 +82,7 @@ static BOOL RegisterSession(CommSession *pSession)
 {
    DWORD i;
 
-   MutexLock(g_hSessionListAccess, INFINITE);
+   MutexLock(g_hSessionListAccess);
    for(i = 0; i < g_dwMaxSessions; i++)
       if (g_pSessionList[i] == NULL)
       {
@@ -104,7 +104,7 @@ static BOOL RegisterSession(CommSession *pSession)
 
 void UnregisterSession(DWORD dwIndex)
 {
-   MutexLock(g_hSessionListAccess, INFINITE);
+   MutexLock(g_hSessionListAccess);
    g_pSessionList[dwIndex] = NULL;
    MutexUnlock(g_hSessionListAccess);
 }
@@ -246,7 +246,7 @@ THREAD_RESULT THREAD_CALL ListenerThread(void *)
    }
 
    // Wait for watchdog thread
-   MutexLock(m_mutexWatchdogActive, INFINITE);
+   MutexLock(m_mutexWatchdogActive);
    MutexUnlock(m_mutexWatchdogActive);
    MutexDestroy(m_mutexWatchdogActive);
 
@@ -268,14 +268,14 @@ THREAD_RESULT THREAD_CALL SessionWatchdog(void *)
    time_t now;
 
    m_mutexWatchdogActive = MutexCreate();
-   MutexLock(m_mutexWatchdogActive, INFINITE);
+   MutexLock(m_mutexWatchdogActive);
 
    ThreadSleep(5);
    while(!(g_dwFlags & AF_SHUTDOWN))
    {
       ThreadSleep(1);
 
-      MutexLock(g_hSessionListAccess, INFINITE);
+      MutexLock(g_hSessionListAccess);
       now = time(NULL);
       for(i = 0; i < g_dwMaxSessions; i++)
          if (g_pSessionList[i] != NULL)
@@ -290,7 +290,7 @@ THREAD_RESULT THREAD_CALL SessionWatchdog(void *)
    }
 
    // Disconnect all sessions
-   MutexLock(g_hSessionListAccess, INFINITE);
+   MutexLock(g_hSessionListAccess);
    for(i = 0; i < g_dwMaxSessions; i++)
       if (g_pSessionList[i] != NULL)
          g_pSessionList[i]->disconnect();
@@ -313,7 +313,7 @@ LONG H_ActiveConnections(const TCHAR *pszCmd, const TCHAR *pArg, TCHAR *pValue)
    int nCounter;
    DWORD i;
 
-   MutexLock(g_hSessionListAccess, INFINITE);
+   MutexLock(g_hSessionListAccess);
    for(i = 0, nCounter = 0; i < g_dwMaxSessions; i++)
       if (g_pSessionList[i] != NULL)
          nCounter++;
index ff82e05..4434fa7 100644 (file)
@@ -35,7 +35,7 @@ private:
        MUTEX m_mutex;\r
        StringMap *m_parameters;\r
 \r
-       void lock() { MutexLock(m_mutex, INFINITE); }\r
+       void lock() { MutexLock(m_mutex); }\r
        void unlock() { MutexUnlock(m_mutex); }\r
 \r
 public:\r
index 3f0f472..cf2a2c8 100644 (file)
@@ -71,7 +71,7 @@ void ExternalSubagent::sendMessage(CSCPMessage *msg)
        AgentWriteDebugLog(6, _T("ExternalSubagent::sendMessage(%s): sending message %s"), m_name, NXCPMessageCodeName(msg->GetCode(), buffer));
 
        CSCP_MESSAGE *rawMsg = msg->CreateMessage();
-       MutexLock(m_mutexPipeWrite, INFINITE);
+       MutexLock(m_mutexPipeWrite);
 #ifdef _WIN32
        DWORD bytes = 0;
        WriteFile(m_pipe, rawMsg, ntohl(rawMsg->dwSize), &bytes, NULL);
@@ -86,7 +86,7 @@ void ExternalSubagent::sendMessage(CSCPMessage *msg)
  */
 CSCPMessage *ExternalSubagent::waitForMessage(WORD code, DWORD id)
 {
-       return m_msgQueue->WaitForMessage(code, id, 5000);      // 5 sec timeout
+       return m_msgQueue->waitForMessage(code, id, 5000);      // 5 sec timeout
 }
 
 /**
@@ -152,12 +152,12 @@ void ExternalSubagent::connect(HANDLE hPipe)
                if (msg == NULL)
                        break;
                AgentWriteDebugLog(6, _T("ExternalSubagent(%s): received message %s"), m_name, NXCPMessageCodeName(msg->GetCode(), buffer));
-               m_msgQueue->Put(msg);
+               m_msgQueue->put(msg);
        }
 
        AgentWriteDebugLog(2, _T("ExternalSubagent(%s): connection closed"), m_name);
        m_connected = false;
-       m_msgQueue->Clear();
+       m_msgQueue->clear();
 }
 
 /**
index b7a6039..7512b17 100644 (file)
@@ -36,7 +36,7 @@ BOOL PushData(const TCHAR *parameter, const TCHAR *value)
        msg.SetVariable(VID_NAME, parameter);\r
        msg.SetVariable(VID_VALUE, value);\r
 \r
-   MutexLock(g_hSessionListAccess, INFINITE);\r
+   MutexLock(g_hSessionListAccess);\r
    for(DWORD i = 0; i < g_dwMaxSessions; i++)\r
       if (g_pSessionList[i] != NULL)\r
          if (g_pSessionList[i]->canAcceptTraps())\r
index b571e75..164019c 100644 (file)
@@ -55,7 +55,7 @@ THREAD_RESULT THREAD_CALL TrapSender(void *pArg)
 
       bTrapSent = FALSE;
 
-      MutexLock(g_hSessionListAccess, INFINITE);
+      MutexLock(g_hSessionListAccess);
       for(i = 0; i < g_dwMaxSessions; i++)
          if (g_pSessionList[i] != NULL)
             if (g_pSessionList[i]->canAcceptTraps())
index 81ee7d3..613b15f 100644 (file)
@@ -64,7 +64,7 @@ LONG H_DatabaseParameter(const TCHAR *parameter, const TCHAR *argument, TCHAR *v
                        {
                                if (!_tcsnicmp(g_paramGroup[k].prefix, parameter, _tcslen(g_paramGroup[k].prefix))) // found prefix
                                {
-                                       MutexLock(g_dbInfo[i].accessMutex, INFINITE);
+                                       MutexLock(g_dbInfo[i].accessMutex);
                                        // Loop through the values
                                        AgentWriteDebugLog(7, _T("%s: valuecount %d"), MYNAMESTR, g_paramGroup[k].valueCount[i]);
                                        for (int j = 0; j < g_paramGroup[k].valueCount[i]; j++)
@@ -285,7 +285,7 @@ bool getParametersFromDB( int dbIndex )
                return false;
        }
 
-       MutexLock(info.accessMutex, INFINITE);
+       MutexLock(info.accessMutex);
 
        for (int i = 0; g_paramGroup[i].prefix; i++)
        {
index c983879..6a35bf0 100644 (file)
@@ -120,7 +120,7 @@ LONG UPSInterface::GetParameter(int nParam, TCHAR *pszValue)
    if ((nParam < 0) || (nParam >= UPS_PARAM_COUNT))
       return SYSINFO_RC_UNSUPPORTED;
 
-   MutexLock(m_mutex, INFINITE);
+   MutexLock(m_mutex);
 
    if (m_paramList[nParam].dwFlags & UPF_NOT_SUPPORTED)
    {
@@ -251,7 +251,7 @@ void UPSInterface::CommThread(void)
       AgentWriteLog(EVENTLOG_INFORMATION_TYPE, _T("UPS: Established communication with device #%d \"%s\""), m_nIndex, m_pszName);
 
       // Open successfully, query all parameters
-      MutexLock(m_mutex, INFINITE);
+      MutexLock(m_mutex);
       QueryModel();
       QueryFirmwareVersion();
       QueryMfgDate();
@@ -307,7 +307,7 @@ void UPSInterface::CommThread(void)
       // Query parameters if we are connected
       if (m_bIsConnected)
       {
-         MutexLock(m_mutex, INFINITE);
+         MutexLock(m_mutex);
 
          // Check rarely changing parameters only every 100th poll
          if (nIteration == 100)
index 31c1d06..55733bc 100644 (file)
@@ -1134,7 +1134,7 @@ void CConsoleApp::EventHandler(DWORD dwEvent, DWORD dwCode, void *pArg)
          ((CMainFrame *)m_pMainWnd)->PostMessage(NXCM_DEPLOYMENT_INFO, dwCode, (LPARAM)pStatus);
          break;
                case NXC_EVENT_SITUATION_UPDATE:
-                       MutexLock(m_mutexSituationList, INFINITE);
+                       MutexLock(m_mutexSituationList);
                        if (m_pSituationList != NULL)
                        {
                                NXCUpdateSituationList(m_pSituationList, dwCode, (NXC_SITUATION *)pArg);
@@ -3462,7 +3462,7 @@ void CConsoleApp::OnAlarmUpdate(DWORD dwCode, NXC_ALARM *pAlarm)
 {
    NXC_ALARM *pListItem;
 
-   MutexLock(m_mutexAlarmList, INFINITE);
+   MutexLock(m_mutexAlarmList);
    switch(dwCode)
    {
       case NX_NOTIFY_NEW_ALARM:
@@ -3499,7 +3499,7 @@ void CConsoleApp::OnAlarmUpdate(DWORD dwCode, NXC_ALARM *pAlarm)
 
 DWORD CConsoleApp::OpenAlarmList(NXC_ALARM **ppList)
 {
-   MutexLock(m_mutexAlarmList, INFINITE);
+   MutexLock(m_mutexAlarmList);
    *ppList = m_pAlarmList;
    return m_dwNumAlarms;
 }
@@ -4485,7 +4485,7 @@ DWORD CConsoleApp::LoadSituations()
 NXC_SITUATION_LIST *CConsoleApp::GetSituationList()
 {
        if (m_pSituationList != NULL)
-               MutexLock(m_mutexSituationList, INFINITE);
+               MutexLock(m_mutexSituationList);
        return m_pSituationList;
 }
 
@@ -4514,7 +4514,7 @@ TCHAR *CConsoleApp::GetSituationName(DWORD id, TCHAR *buffer)
        }
        else
        {
-               MutexLock(m_mutexSituationList, INFINITE);
+               MutexLock(m_mutexSituationList);
                if (m_pSituationList != NULL)
                {
                        for(i = 0; i < m_pSituationList->m_count; i++)
index e6db58f..27ed414 100644 (file)
@@ -314,7 +314,7 @@ connect_failure_0:
 
 extern "C" void EXPORT DrvDisconnect(DB2DRV_CONN *pConn)
 {
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        MutexUnlock(pConn->mutexQuery);
        SQLDisconnect(pConn->sqlConn);
        SQLFreeHandle(SQL_HANDLE_DBC, pConn->sqlConn);
@@ -333,7 +333,7 @@ extern "C" DBDRV_STATEMENT EXPORT DrvPrepare(DB2DRV_CONN *pConn, NETXMS_WCHAR *p
        SQLHSTMT statement;
        DB2DRV_STATEMENT *result;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
 
        // Allocate statement handle
        iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &statement);
@@ -452,7 +452,7 @@ extern "C" DWORD EXPORT DrvExecute(DB2DRV_CONN *pConn, DB2DRV_STATEMENT *stateme
 {
        DWORD dwResult;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        long rc = SQLExecute(statement->handle);
        if (
                (rc == SQL_SUCCESS) ||
@@ -482,7 +482,7 @@ extern "C" void EXPORT DrvFreeStatement(DB2DRV_STATEMENT *statement)
                return;
        }
 
-       MutexLock(statement->connection->mutexQuery, INFINITE);
+       MutexLock(statement->connection->mutexQuery);
        SQLFreeHandle(SQL_HANDLE_STMT, statement->handle);
        MutexUnlock(statement->connection->mutexQuery);
        delete statement->buffers;
@@ -499,7 +499,7 @@ extern "C" DWORD EXPORT DrvQuery(DB2DRV_CONN *pConn, NETXMS_WCHAR *pwszQuery, NE
        long iResult;
        DWORD dwResult;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
 
        // Allocate statement handle
        iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -614,7 +614,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(DB2DRV_CONN *pConn, NETXMS_WCHAR *pwszQ
 {
        DB2DRV_QUERY_RESULT *pResult = NULL;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
 
        // Allocate statement handle
        long iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -659,7 +659,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelectPrepared(DB2DRV_CONN *pConn, DB2DRV_STAT
 {
        DB2DRV_QUERY_RESULT *pResult = NULL;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        long rc = SQLExecute(statement->handle);
        if (
                (rc == SQL_SUCCESS) ||
@@ -794,7 +794,7 @@ extern "C" DBDRV_ASYNC_RESULT EXPORT DrvAsyncSelect(DB2DRV_CONN *pConn, NETXMS_W
        short wNumCols;
        int i;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
 
        // Allocate statement handle
        iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -1006,7 +1006,7 @@ extern "C" DWORD EXPORT DrvBegin(DB2DRV_CONN *pConn)
                return DBERR_INVALID_HANDLE;
        }
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        nRet = SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_OFF, 0);
        if ((nRet == SQL_SUCCESS) || (nRet == SQL_SUCCESS_WITH_INFO))
        {
@@ -1034,7 +1034,7 @@ extern "C" DWORD EXPORT DrvCommit(DB2DRV_CONN *pConn)
                return DBERR_INVALID_HANDLE;
        }
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        nRet = SQLEndTran(SQL_HANDLE_DBC, pConn->sqlConn, SQL_COMMIT);
        SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, 0);
        MutexUnlock(pConn->mutexQuery);
@@ -1055,7 +1055,7 @@ extern "C" DWORD EXPORT DrvRollback(DB2DRV_CONN *pConn)
                return DBERR_INVALID_HANDLE;
        }
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        nRet = SQLEndTran(SQL_HANDLE_DBC, pConn->sqlConn, SQL_ROLLBACK);
        SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, 0);
        MutexUnlock(pConn->mutexQuery);
index fb41145..b4c5b79 100644 (file)
@@ -269,7 +269,7 @@ connect_failure_0:
 
 extern "C" void EXPORT DrvDisconnect(INFORMIX_CONN *pConn)
 {
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        MutexUnlock(pConn->mutexQuery);
        SQLDisconnect(pConn->sqlConn);
        SQLFreeHandle(SQL_HANDLE_DBC, pConn->sqlConn);
@@ -288,7 +288,7 @@ extern "C" DBDRV_STATEMENT EXPORT DrvPrepare(INFORMIX_CONN *pConn, WCHAR *pwszQu
        SQLHSTMT statement;
        INFORMIX_STATEMENT *result;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
 
        // Allocate statement handle
        iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &statement);
@@ -363,7 +363,7 @@ extern "C" DWORD EXPORT DrvExecute(INFORMIX_CONN *pConn, INFORMIX_STATEMENT *sta
 {
        DWORD dwResult;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        long rc = SQLExecute(statement->handle);
        if (
                (rc == SQL_SUCCESS) ||
@@ -393,7 +393,7 @@ extern "C" void EXPORT DrvFreeStatement(INFORMIX_STATEMENT *statement)
                return;
        }
 
-       MutexLock(statement->connection->mutexQuery, INFINITE);
+       MutexLock(statement->connection->mutexQuery);
        SQLFreeHandle(SQL_HANDLE_STMT, statement->handle);
        MutexUnlock(statement->connection->mutexQuery);
        delete statement->buffers;
@@ -410,7 +410,7 @@ extern "C" DWORD EXPORT DrvQuery(INFORMIX_CONN *pConn, WCHAR *pwszQuery, WCHAR *
        long iResult;
        DWORD dwResult;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
 
        // Allocate statement handle
        iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -515,7 +515,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(INFORMIX_CONN *pConn, WCHAR *pwszQuery,
 {
        INFORMIX_QUERY_RESULT *pResult = NULL;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
 
        // Allocate statement handle
        long iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -554,7 +554,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelectPrepared(INFORMIX_CONN *pConn, INFORMIX_
 {
        INFORMIX_QUERY_RESULT *pResult = NULL;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        long rc = SQLExecute(statement->handle);
        if (
                (rc == SQL_SUCCESS) ||
@@ -689,7 +689,7 @@ extern "C" DBDRV_ASYNC_RESULT EXPORT DrvAsyncSelect(INFORMIX_CONN *pConn, WCHAR
        short wNumCols;
        int i;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
 
        // Allocate statement handle
        iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -888,7 +888,7 @@ extern "C" DWORD EXPORT DrvBegin(INFORMIX_CONN *pConn)
                return DBERR_INVALID_HANDLE;
        }
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        nRet = SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_OFF, 0);
        if ((nRet == SQL_SUCCESS) || (nRet == SQL_SUCCESS_WITH_INFO))
        {
@@ -916,7 +916,7 @@ extern "C" DWORD EXPORT DrvCommit(INFORMIX_CONN *pConn)
                return DBERR_INVALID_HANDLE;
        }
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        nRet = SQLEndTran(SQL_HANDLE_DBC, pConn->sqlConn, SQL_COMMIT);
        SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, 0);
        MutexUnlock(pConn->mutexQuery);
@@ -937,7 +937,7 @@ extern "C" DWORD EXPORT DrvRollback(INFORMIX_CONN *pConn)
                return DBERR_INVALID_HANDLE;
        }
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
        nRet = SQLEndTran(SQL_HANDLE_DBC, pConn->sqlConn, SQL_ROLLBACK);
        SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, 0);
        MutexUnlock(pConn->mutexQuery);
index 4b4c304..838e299 100644 (file)
@@ -276,7 +276,7 @@ connect_failure_0:
 
 extern "C" void EXPORT DrvDisconnect(MSSQL_CONN *pConn)
 {
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
    MutexUnlock(pConn->mutexQuery);
    SQLDisconnect(pConn->sqlConn);
    SQLFreeHandle(SQL_HANDLE_DBC, pConn->sqlConn);
@@ -296,7 +296,7 @@ extern "C" DBDRV_STATEMENT EXPORT DrvPrepare(MSSQL_CONN *pConn, WCHAR *pwszQuery
        SQLHSTMT stmt;
        MSSQL_STATEMENT *result;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
 
    // Allocate statement handle
    iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &stmt);
@@ -372,7 +372,7 @@ extern "C" DWORD EXPORT DrvExecute(MSSQL_CONN *pConn, MSSQL_STATEMENT *stmt, WCH
 {
    DWORD dwResult;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
        long rc = SQLExecute(stmt->handle);
    if ((rc == SQL_SUCCESS) || 
        (rc == SQL_SUCCESS_WITH_INFO) || 
@@ -399,7 +399,7 @@ extern "C" void EXPORT DrvFreeStatement(MSSQL_STATEMENT *stmt)
        if (stmt == NULL)
                return;
 
-       MutexLock(stmt->connection->mutexQuery, INFINITE);
+       MutexLock(stmt->connection->mutexQuery);
        SQLFreeHandle(SQL_HANDLE_STMT, stmt->handle);
        MutexUnlock(stmt->connection->mutexQuery);
        delete stmt->buffers;
@@ -416,7 +416,7 @@ extern "C" DWORD EXPORT DrvQuery(MSSQL_CONN *pConn, WCHAR *pwszQuery, WCHAR *err
    long iResult;
    DWORD dwResult;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
 
    // Allocate statement handle
    iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -521,7 +521,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(MSSQL_CONN *pConn, WCHAR *pwszQuery, DW
 {
    MSSQL_QUERY_RESULT *pResult = NULL;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
 
    // Allocate statement handle
    SQLRETURN iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -559,7 +559,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelectPrepared(MSSQL_CONN *pConn, MSSQL_STATEM
 {
    MSSQL_QUERY_RESULT *pResult = NULL;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
        long rc = SQLExecute(stmt->handle);
    if ((rc == SQL_SUCCESS) || 
        (rc == SQL_SUCCESS_WITH_INFO))
@@ -682,7 +682,7 @@ extern "C" DBDRV_ASYNC_RESULT EXPORT DrvAsyncSelect(MSSQL_CONN *pConn, WCHAR *pw
    short wNumCols;
        int i;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
 
    // Allocate statement handle
    iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -867,7 +867,7 @@ extern "C" DWORD EXPORT DrvBegin(MSSQL_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
    nRet = SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_OFF, 0);
    if ((nRet == SQL_SUCCESS) || (nRet == SQL_SUCCESS_WITH_INFO))
    {
@@ -893,7 +893,7 @@ extern "C" DWORD EXPORT DrvCommit(MSSQL_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
    nRet = SQLEndTran(SQL_HANDLE_DBC, pConn->sqlConn, SQL_COMMIT);
    SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, 0);
        MutexUnlock(pConn->mutexQuery);
@@ -912,7 +912,7 @@ extern "C" DWORD EXPORT DrvRollback(MSSQL_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
    nRet = SQLEndTran(SQL_HANDLE_DBC, pConn->sqlConn, SQL_ROLLBACK);
    SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, 0);
        MutexUnlock(pConn->mutexQuery);
index dc49e0f..1ec31d0 100644 (file)
@@ -276,7 +276,7 @@ extern "C" DBDRV_STATEMENT EXPORT DrvPrepare(MYSQL_CONN *pConn, WCHAR *pwszQuery
 {
        MYSQL_STATEMENT *result = NULL;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        MYSQL_STMT *stmt = mysql_stmt_init(pConn->pMySQL);
        if (stmt != NULL)
        {
@@ -380,7 +380,7 @@ extern "C" DWORD EXPORT DrvExecute(MYSQL_CONN *pConn, MYSQL_STATEMENT *hStmt, WC
 {
        DWORD dwResult;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
 
        if (mysql_stmt_bind_param(hStmt->statement, hStmt->bindings) == 0)
        {
@@ -422,7 +422,7 @@ extern "C" void EXPORT DrvFreeStatement(MYSQL_STATEMENT *hStmt)
        if (hStmt == NULL)
                return;
 
-       MutexLock(hStmt->connection->mutexQueryLock, INFINITE);
+       MutexLock(hStmt->connection->mutexQueryLock);
        mysql_stmt_close(hStmt->statement);
        MutexUnlock(hStmt->connection->mutexQueryLock);
        delete hStmt->buffers;
@@ -440,7 +440,7 @@ static DWORD DrvQueryInternal(MYSQL_CONN *pConn, const char *pszQuery, WCHAR *er
 {
        DWORD dwRet = DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (mysql_query(pConn->pMySQL, pszQuery) == 0)
        {
                dwRet = DBERR_SUCCESS;
@@ -498,7 +498,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(MYSQL_CONN *pConn, WCHAR *pwszQuery, DW
        }
 
        pszQueryUTF8 = UTF8StringFromWideString(pwszQuery);
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (mysql_query(pConn->pMySQL, pszQueryUTF8) == 0)
        {
                result = (MYSQL_RESULT *)malloc(sizeof(MYSQL_RESULT));
@@ -542,7 +542,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelectPrepared(MYSQL_CONN *pConn, MYSQL_STATEM
                return NULL;
        }
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
 
        if (mysql_stmt_bind_param(hStmt->statement, hStmt->bindings) == 0)
        {
@@ -783,7 +783,7 @@ extern "C" DBDRV_ASYNC_RESULT EXPORT DrvAsyncSelect(MYSQL_CONN *pConn, WCHAR *pw
        }
 
        pszQueryUTF8 = UTF8StringFromWideString(pwszQuery);
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (mysql_query(pConn->pMySQL, pszQueryUTF8) == 0)
        {
                pResult = (MYSQL_ASYNC_RESULT *)malloc(sizeof(MYSQL_ASYNC_RESULT));
index adad5a7..69019da 100644 (file)
@@ -288,7 +288,7 @@ connect_failure_0:
 
 extern "C" void EXPORT DrvDisconnect(ODBCDRV_CONN *pConn)
 {
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
    MutexUnlock(pConn->mutexQuery);
    SQLDisconnect(pConn->sqlConn);
    SQLFreeHandle(SQL_HANDLE_DBC, pConn->sqlConn);
@@ -308,7 +308,7 @@ extern "C" DBDRV_STATEMENT EXPORT DrvPrepare(ODBCDRV_CONN *pConn, NETXMS_WCHAR *
        SQLHSTMT stmt;
        ODBCDRV_STATEMENT *result;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
 
    // Allocate statement handle
    iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &stmt);
@@ -434,7 +434,7 @@ extern "C" DWORD EXPORT DrvExecute(ODBCDRV_CONN *pConn, ODBCDRV_STATEMENT *stmt,
 {
    DWORD dwResult;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
        long rc = SQLExecute(stmt->handle);
    if ((rc == SQL_SUCCESS) || 
        (rc == SQL_SUCCESS_WITH_INFO) || 
@@ -461,7 +461,7 @@ extern "C" void EXPORT DrvFreeStatement(ODBCDRV_STATEMENT *stmt)
        if (stmt == NULL)
                return;
 
-       MutexLock(stmt->connection->mutexQuery, INFINITE);
+       MutexLock(stmt->connection->mutexQuery);
        SQLFreeHandle(SQL_HANDLE_STMT, stmt->handle);
        MutexUnlock(stmt->connection->mutexQuery);
        delete stmt->buffers;
@@ -478,7 +478,7 @@ extern "C" DWORD EXPORT DrvQuery(ODBCDRV_CONN *pConn, NETXMS_WCHAR *pwszQuery, N
    long iResult;
    DWORD dwResult;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
 
    // Allocate statement handle
    iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -610,7 +610,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(ODBCDRV_CONN *pConn, NETXMS_WCHAR *pwsz
 {
    ODBCDRV_QUERY_RESULT *pResult = NULL;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
 
    // Allocate statement handle
    SQLRETURN iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -663,7 +663,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelectPrepared(ODBCDRV_CONN *pConn, ODBCDRV_ST
 {
    ODBCDRV_QUERY_RESULT *pResult = NULL;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
        long rc = SQLExecute(stmt->handle);
    if ((rc == SQL_SUCCESS) || 
        (rc == SQL_SUCCESS_WITH_INFO))
@@ -791,7 +791,7 @@ extern "C" DBDRV_ASYNC_RESULT EXPORT DrvAsyncSelect(ODBCDRV_CONN *pConn, NETXMS_
    short wNumCols;
        int i;
 
-   MutexLock(pConn->mutexQuery, INFINITE);
+   MutexLock(pConn->mutexQuery);
 
    // Allocate statement handle
    iResult = SQLAllocHandle(SQL_HANDLE_STMT, pConn->sqlConn, &pConn->sqlStatement);
@@ -1012,7 +1012,7 @@ extern "C" DWORD EXPORT DrvBegin(ODBCDRV_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
    nRet = SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_OFF, 0);
    if ((nRet == SQL_SUCCESS) || (nRet == SQL_SUCCESS_WITH_INFO))
    {
@@ -1038,7 +1038,7 @@ extern "C" DWORD EXPORT DrvCommit(ODBCDRV_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
    nRet = SQLEndTran(SQL_HANDLE_DBC, pConn->sqlConn, SQL_COMMIT);
    SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, 0);
        MutexUnlock(pConn->mutexQuery);
@@ -1057,7 +1057,7 @@ extern "C" DWORD EXPORT DrvRollback(ODBCDRV_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQuery, INFINITE);
+       MutexLock(pConn->mutexQuery);
    nRet = SQLEndTran(SQL_HANDLE_DBC, pConn->sqlConn, SQL_ROLLBACK);
    SQLSetConnectAttr(pConn->sqlConn, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, 0);
        MutexUnlock(pConn->mutexQuery);
index ca3ef87..7b5684d 100644 (file)
@@ -372,7 +372,7 @@ extern "C" ORACLE_STATEMENT EXPORT *DrvPrepare(ORACLE_CONN *pConn, WCHAR *pwszQu
 
        UCS2CHAR *ucs2Query = ConvertQuery(pwszQuery);
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (OCIStmtPrepare2(pConn->handleService, &handleStmt, pConn->handleError, (text *)ucs2Query,
                            (ub4)ucs2_strlen(ucs2Query) * sizeof(UCS2CHAR), NULL, 0, OCI_NTV_SYNTAX, OCI_DEFAULT) == OCI_SUCCESS)
        {
@@ -471,7 +471,7 @@ extern "C" DWORD EXPORT DrvExecute(ORACLE_CONN *pConn, ORACLE_STATEMENT *stmt, W
 {
        DWORD dwResult;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (OCIStmtExecute(pConn->handleService, stmt->handleStmt, pConn->handleError, 1, 0, NULL, NULL,
                           (pConn->nTransLevel == 0) ? OCI_COMMIT_ON_SUCCESS : OCI_DEFAULT) == OCI_SUCCESS)
        {
@@ -502,7 +502,7 @@ extern "C" void EXPORT DrvFreeStatement(ORACLE_STATEMENT *stmt)
        if (stmt == NULL)
                return;
 
-       MutexLock(stmt->connection->mutexQueryLock, INFINITE);
+       MutexLock(stmt->connection->mutexQueryLock);
        OCIStmtRelease(stmt->handleStmt, stmt->handleError, NULL, 0, OCI_DEFAULT);
        OCIHandleFree(stmt->handleError, OCI_HTYPE_ERROR);
        MutexUnlock(stmt->connection->mutexQueryLock);
@@ -527,7 +527,7 @@ extern "C" DWORD EXPORT DrvQuery(ORACLE_CONN *pConn, WCHAR *pwszQuery, WCHAR *er
        UCS2CHAR *ucs2Query = pwszQuery;
 #endif
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (OCIStmtPrepare2(pConn->handleService, &handleStmt, pConn->handleError, (text *)ucs2Query,
                            (ub4)ucs2_strlen(ucs2Query) * sizeof(UCS2CHAR), NULL, 0, OCI_NTV_SYNTAX, OCI_DEFAULT) == OCI_SUCCESS)
        {
@@ -704,7 +704,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(ORACLE_CONN *pConn, WCHAR *pwszQuery, D
        UCS2CHAR *ucs2Query = pwszQuery;
 #endif
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (OCIStmtPrepare2(pConn->handleService, &handleStmt, pConn->handleError, (text *)ucs2Query,
                            (ub4)ucs2_strlen(ucs2Query) * sizeof(UCS2CHAR), NULL, 0, OCI_NTV_SYNTAX, OCI_DEFAULT) == OCI_SUCCESS)
        {
@@ -747,7 +747,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelectPrepared(ORACLE_CONN *pConn, ORACLE_STAT
 {
        ORACLE_RESULT *pResult = NULL;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (OCIStmtExecute(pConn->handleService, stmt->handleStmt, pConn->handleError,
                           0, 0, NULL, NULL, (pConn->nTransLevel == 0) ? OCI_COMMIT_ON_SUCCESS : OCI_DEFAULT) == OCI_SUCCESS)
        {
@@ -875,7 +875,7 @@ extern "C" DBDRV_ASYNC_RESULT EXPORT DrvAsyncSelect(ORACLE_CONN *pConn, WCHAR *p
        UCS2CHAR *ucs2Query = pwszQuery;
 #endif
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
 
        pConn->pBuffers = NULL;
        pConn->nCols = 0;
@@ -1105,7 +1105,7 @@ extern "C" DWORD EXPORT DrvBegin(ORACLE_CONN *pConn)
        if (pConn == NULL)
                return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        pConn->nTransLevel++;
        MutexUnlock(pConn->mutexQueryLock);
        return DBERR_SUCCESS;
@@ -1123,7 +1123,7 @@ extern "C" DWORD EXPORT DrvCommit(ORACLE_CONN *pConn)
        if (pConn == NULL)
                return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (pConn->nTransLevel > 0)
        {
                if (OCITransCommit(pConn->handleService, pConn->handleError, OCI_DEFAULT) == OCI_SUCCESS)
@@ -1157,7 +1157,7 @@ extern "C" DWORD EXPORT DrvRollback(ORACLE_CONN *pConn)
        if (pConn == NULL)
                return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (pConn->nTransLevel > 0)
        {
                if (OCITransRollback(pConn->handleService, pConn->handleError, OCI_DEFAULT) == OCI_SUCCESS)
index 50657e6..6c6f846 100644 (file)
@@ -323,7 +323,7 @@ extern "C" DBDRV_STATEMENT EXPORT DrvPrepare(PG_CONN *pConn, WCHAR *pwszQuery, W
        hStmt->connection = pConn;
        snprintf(hStmt->name, 64, "netxms_stmt_%p", hStmt);
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        PGresult        *pResult = PQprepare(pConn->pHandle, hStmt->name, pszQueryUTF8, 0, NULL);
        if ((pResult == NULL) || (PQresultStatus(pResult) != PGRES_COMMAND_OK))
        {
@@ -416,7 +416,7 @@ extern "C" DWORD EXPORT DrvExecute(PG_CONN *pConn, PG_STATEMENT *hStmt, WCHAR *e
 {
        DWORD rc;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        PGresult        *pResult = PQexecPrepared(pConn->pHandle, hStmt->name, hStmt->pcount, hStmt->buffers, NULL, NULL, 0);
        if (pResult != NULL)
        {
@@ -462,7 +462,7 @@ extern "C" void EXPORT DrvFreeStatement(PG_STATEMENT *hStmt)
        char query[256];
        snprintf(query, 256, "DEALLOCATE \"%s\"", hStmt->name);
 
-       MutexLock(hStmt->connection->mutexQueryLock, INFINITE);
+       MutexLock(hStmt->connection->mutexQueryLock);
        UnsafeDrvQuery(hStmt->connection, query, NULL);
        MutexUnlock(hStmt->connection->mutexQueryLock);
 
@@ -512,7 +512,7 @@ extern "C" DWORD EXPORT DrvQuery(PG_CONN *pConn, WCHAR *pwszQuery, WCHAR *errorT
        DWORD dwRet;
 
    char *pszQueryUTF8 = UTF8StringFromWideString(pwszQuery);
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (UnsafeDrvQuery(pConn, pszQueryUTF8, errorText))
    {
       dwRet = DBERR_SUCCESS;
@@ -568,7 +568,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(PG_CONN *pConn, WCHAR *pwszQuery, DWORD
    char *pszQueryUTF8;
 
    pszQueryUTF8 = UTF8StringFromWideString(pwszQuery);
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        pResult = UnsafeDrvSelect(pConn, pszQueryUTF8, errorText);
    if (pResult != NULL)
    {
@@ -591,7 +591,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(PG_CONN *pConn, WCHAR *pwszQuery, DWORD
 
 extern "C" DBDRV_RESULT EXPORT DrvSelectPrepared(PG_CONN *pConn, PG_STATEMENT *hStmt, DWORD *pdwError, WCHAR *errorText)
 {
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        PGresult        *pResult = PQexecPrepared(pConn->pHandle, hStmt->name, hStmt->pcount, hStmt->buffers, NULL, NULL, 0);
 
        if (pResult != NULL)
@@ -717,7 +717,7 @@ extern "C" DBDRV_ASYNC_RESULT EXPORT DrvAsyncSelect(PG_CONN *pConn, WCHAR *pwszQ
        if (pConn == NULL)
                return NULL;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
 
        if (UnsafeDrvQuery(pConn, "BEGIN", errorText))
    {
@@ -919,7 +919,7 @@ extern "C" DWORD EXPORT DrvBegin(PG_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        if (UnsafeDrvQuery(pConn, "BEGIN", NULL))
    {
       dwResult = DBERR_SUCCESS;
@@ -944,7 +944,7 @@ extern "C" DWORD EXPORT DrvCommit(PG_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        bRet = UnsafeDrvQuery(pConn, "COMMIT", NULL);
        MutexUnlock(pConn->mutexQueryLock);
    return bRet ? DBERR_SUCCESS : DBERR_OTHER_ERROR;
@@ -962,7 +962,7 @@ extern "C" DWORD EXPORT DrvRollback(PG_CONN *pConn)
        if (pConn == NULL)
       return DBERR_INVALID_HANDLE;
 
-       MutexLock(pConn->mutexQueryLock, INFINITE);
+       MutexLock(pConn->mutexQueryLock);
        bRet = UnsafeDrvQuery(pConn, "ROLLBACK", NULL);
        MutexUnlock(pConn->mutexQueryLock);
    return bRet ? DBERR_SUCCESS : DBERR_OTHER_ERROR;
index e41969b..0ab3c2d 100644 (file)
@@ -188,7 +188,7 @@ extern "C" void EXPORT DrvDisconnect(SQLITE_CONN *hConn)
 extern "C" DBDRV_STATEMENT EXPORT DrvPrepare(SQLITE_CONN *hConn, WCHAR *pwszQuery, WCHAR *errorText)
 {
    char *pszQueryUTF8 = UTF8StringFromWideString(pwszQuery);
-   MutexLock(hConn->mutexQueryLock, INFINITE);
+   MutexLock(hConn->mutexQueryLock);
        sqlite3_stmt *stmt;
        if (sqlite3_prepare_v2(hConn->pdb, pszQueryUTF8, -1, &stmt, NULL) != SQLITE_OK)
    {
@@ -255,7 +255,7 @@ extern "C" DWORD EXPORT DrvExecute(SQLITE_CONN *hConn, sqlite3_stmt *stmt, WCHAR
 {
        DWORD result;
 
-       MutexLock(hConn->mutexQueryLock, INFINITE);
+       MutexLock(hConn->mutexQueryLock);
        if (sqlite3_reset(stmt) == SQLITE_OK)
        {
                int rc = sqlite3_step(stmt);
@@ -297,7 +297,7 @@ static DWORD DrvQueryInternal(SQLITE_CONN *pConn, const char *pszQuery, WCHAR *e
 {
    DWORD result;
 
-   MutexLock(pConn->mutexQueryLock, INFINITE);
+   MutexLock(pConn->mutexQueryLock);
    if (sqlite3_exec(pConn->pdb, pszQuery, NULL, NULL, NULL) == SQLITE_OK)
        {
                result = DBERR_SUCCESS;
@@ -404,7 +404,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelect(SQLITE_CONN *hConn, WCHAR *pwszQuery, D
        SQLITE_RESULT *result = (SQLITE_RESULT *)malloc(sizeof(SQLITE_RESULT));
    memset(result, 0, sizeof(SQLITE_RESULT));
 
-       MutexLock(hConn->mutexQueryLock, INFINITE);
+       MutexLock(hConn->mutexQueryLock);
    if (sqlite3_exec(hConn->pdb, pszQueryUTF8, SelectCallback, result, NULL) != SQLITE_OK)
    {
                GetErrorMessage(hConn->pdb, errorText);
@@ -428,7 +428,7 @@ extern "C" DBDRV_RESULT EXPORT DrvSelectPrepared(SQLITE_CONN *hConn, sqlite3_stm
    SQLITE_RESULT *result = (SQLITE_RESULT *)malloc(sizeof(SQLITE_RESULT));
    memset(result, 0, sizeof(SQLITE_RESULT));
 
-   MutexLock(hConn->mutexQueryLock, INFINITE);
+   MutexLock(hConn->mutexQueryLock);
        if (sqlite3_reset(stmt) == SQLITE_OK)
        {
                int nCols = sqlite3_column_count(stmt);
@@ -561,7 +561,7 @@ extern "C" DBDRV_ASYNC_RESULT EXPORT DrvAsyncSelect(SQLITE_CONN *hConn, WCHAR *p
    char *pszQueryUTF8;
 
    pszQueryUTF8 = UTF8StringFromWideString(pwszQuery);
-   MutexLock(hConn->mutexQueryLock, INFINITE);
+   MutexLock(hConn->mutexQueryLock);
        if (sqlite3_prepare(hConn->pdb, pszQueryUTF8, -1, &hConn->pvm, NULL) == SQLITE_OK)
    {
       hResult = hConn;
index a79b1f7..6a12030 100644 (file)
@@ -50,7 +50,7 @@ static void DBConnectionPoolPopulate()
 {\r
        TCHAR errorText[DBDRV_MAX_ERROR_TEXT];\r
 \r
-       MutexLock(m_poolAccessMutex, INFINITE);\r
+       MutexLock(m_poolAccessMutex);\r
        for (int i = 0; i < m_basePoolSize; i++)\r
        {\r
                m_dbHandles[i] = DBConnect(m_driver, m_server, m_dbName, m_login, m_password, m_schema, errorText);\r
@@ -63,7 +63,7 @@ static void DBConnectionPoolPopulate()
  */\r
 static void DBConnectionPoolShrink()\r
 {\r
-       MutexLock(m_poolAccessMutex, INFINITE);\r
+       MutexLock(m_poolAccessMutex);\r
 \r
        for (int i = 0; i < m_maxPoolSize; i++)\r
        {\r
@@ -156,7 +156,7 @@ void LIBNXDB_EXPORTABLE DBConnectionPoolShutdown()
  */\r
 DB_HANDLE LIBNXDB_EXPORTABLE DBConnectionPoolAcquireConnection()\r
 {\r
-       MutexLock(m_poolAccessMutex, INFINITE);\r
+       MutexLock(m_poolAccessMutex);\r
 \r
        DB_HANDLE handle = NULL;\r
        for (int i = 0; i < m_maxPoolSize; i++)\r
@@ -204,7 +204,7 @@ void LIBNXDB_EXPORTABLE DBConnectionPoolReleaseConnection(DB_HANDLE connection)
        if (connection == m_hFallback)\r
                return;\r
 \r
-       MutexLock(m_poolAccessMutex, INFINITE);\r
+       MutexLock(m_poolAccessMutex);\r
 \r
        DB_HANDLE handle = NULL;\r
        for (int i = 0; i < m_maxPoolSize; i++)\r
index c405a70..268690c 100644 (file)
@@ -95,7 +95,7 @@ DB_DRIVER LIBNXDB_EXPORTABLE DBLoadDriver(const TCHAR *module, const TCHAR *init
        bool alreadyLoaded = false;
        int position = -1;
 
-       MutexLock(s_driverListLock, INFINITE);
+       MutexLock(s_driverListLock);
 
        driver = (DB_DRIVER)malloc(sizeof(db_driver_t));
        memset(driver, 0, sizeof(db_driver_t));
@@ -269,7 +269,7 @@ reuse_driver:
 
 void LIBNXDB_EXPORTABLE DBUnloadDriver(DB_DRIVER driver)
 {
-       MutexLock(s_driverListLock, INFINITE);
+       MutexLock(s_driverListLock);
 
        for(int i = 0; i < MAX_DB_DRIVERS; i++)
        {
index 630bdd7..9e99420 100644 (file)
@@ -133,7 +133,7 @@ static void DBReconnect(DB_HANDLE hConn)
          break;
       if (nCount == 0)
       {
-                       MutexLock(hConn->m_driver->m_mutexReconnect, INFINITE);
+                       MutexLock(hConn->m_driver->m_mutexReconnect);
          if ((hConn->m_driver->m_reconnect == 0) && (hConn->m_driver->m_fpEventHandler != NULL))
                                hConn->m_driver->m_fpEventHandler(DBEVENT_CONNECTION_LOST, NULL, NULL, hConn->m_driver->m_userArg);
          hConn->m_driver->m_reconnect++;
@@ -143,7 +143,7 @@ static void DBReconnect(DB_HANDLE hConn)
    }
    if (nCount > 0)
    {
-      MutexLock(hConn->m_driver->m_mutexReconnect, INFINITE);
+      MutexLock(hConn->m_driver->m_mutexReconnect);
       hConn->m_driver->m_reconnect--;
       if ((hConn->m_driver->m_reconnect == 0) && (hConn->m_driver->m_fpEventHandler != NULL))
                        hConn->m_driver->m_fpEventHandler(DBEVENT_CONNECTION_RESTORED, NULL, NULL, hConn->m_driver->m_userArg);
@@ -168,7 +168,7 @@ BOOL LIBNXDB_EXPORTABLE DBQueryEx(DB_HANDLE hConn, const TCHAR *szQuery, TCHAR *
        WCHAR wcErrorText[DBDRV_MAX_ERROR_TEXT] = L"";
 #endif
 
-   MutexLock(hConn->m_mutexTransLock, INFINITE);
+   MutexLock(hConn->m_mutexTransLock);
    if (hConn->m_driver->m_dumpSql)
       ms = GetCurrentTimeMs();
 
@@ -235,7 +235,7 @@ DB_RESULT LIBNXDB_EXPORTABLE DBSelectEx(DB_HANDLE hConn, const TCHAR *szQuery, T
        WCHAR wcErrorText[DBDRV_MAX_ERROR_TEXT] = L"";
 #endif
    
-   MutexLock(hConn->m_mutexTransLock, INFINITE);
+   MutexLock(hConn->m_mutexTransLock);
    if (hConn->m_driver->m_dumpSql)
       ms = GetCurrentTimeMs();
    hResult = hConn->m_driver->m_fpDrvSelect(hConn->m_connection, pwszQuery, &dwError, wcErrorText);
@@ -638,7 +638,7 @@ DB_ASYNC_RESULT LIBNXDB_EXPORTABLE DBAsyncSelectEx(DB_HANDLE hConn, const TCHAR
        WCHAR wcErrorText[DBDRV_MAX_ERROR_TEXT] = L"";
 #endif
    
-   MutexLock(hConn->m_mutexTransLock, INFINITE);
+   MutexLock(hConn->m_mutexTransLock);
        if (hConn->m_driver->m_dumpSql)
       ms = GetCurrentTimeMs();
    hResult = hConn->m_driver->m_fpDrvAsyncSelect(hConn->m_connection, pwszQuery, &dwError, wcErrorText);
@@ -1027,7 +1027,7 @@ BOOL LIBNXDB_EXPORTABLE DBExecuteEx(DB_STATEMENT hStmt, TCHAR *errorText)
        QWORD ms;
 
        DB_HANDLE hConn = hStmt->m_connection;
-       MutexLock(hConn->m_mutexTransLock, INFINITE);
+       MutexLock(hConn->m_mutexTransLock);
    if (hConn->m_driver->m_dumpSql)
       ms = GetCurrentTimeMs();
 
@@ -1095,7 +1095,7 @@ DB_RESULT LIBNXDB_EXPORTABLE DBSelectPreparedEx(DB_STATEMENT hStmt, TCHAR *error
 #endif
 
        DB_HANDLE hConn = hStmt->m_connection;
-   MutexLock(hConn->m_mutexTransLock, INFINITE);
+   MutexLock(hConn->m_mutexTransLock);
    if (hConn->m_driver->m_dumpSql)
       ms = GetCurrentTimeMs();
        hResult = hConn->m_driver->m_fpDrvSelectPrepared(hConn->m_connection, hStmt->m_statement, &dwError, wcErrorText);
@@ -1162,7 +1162,7 @@ BOOL LIBNXDB_EXPORTABLE DBBegin(DB_HANDLE hConn)
    DWORD dwResult;
    BOOL bRet = FALSE;
 
-   MutexLock(hConn->m_mutexTransLock, INFINITE);
+   MutexLock(hConn->m_mutexTransLock);
    if (hConn->m_transactionLevel == 0)
    {
       dwResult = hConn->m_driver->m_fpDrvBegin(hConn->m_connection);
@@ -1201,7 +1201,7 @@ BOOL LIBNXDB_EXPORTABLE DBCommit(DB_HANDLE hConn)
 {
    BOOL bRet = FALSE;
 
-   MutexLock(hConn->m_mutexTransLock, INFINITE);
+   MutexLock(hConn->m_mutexTransLock);
    if (hConn->m_transactionLevel > 0)
    {
       hConn->m_transactionLevel--;
@@ -1225,7 +1225,7 @@ BOOL LIBNXDB_EXPORTABLE DBRollback(DB_HANDLE hConn)
 {
    BOOL bRet = FALSE;
 
-   MutexLock(hConn->m_mutexTransLock, INFINITE);
+   MutexLock(hConn->m_mutexTransLock);
    if (hConn->m_transactionLevel > 0)
    {
       hConn->m_transactionLevel--;
index 6697580..88c99ba 100644 (file)
@@ -96,7 +96,7 @@ static MUTEX *m_pCryptoMutexList = NULL;
 static void CryptoLockingCallback(int nMode, int nLock, const char *pszFile, int nLine)
 {
    if (nMode & CRYPTO_LOCK)
-      MutexLock(m_pCryptoMutexList[nLock], INFINITE);
+      MutexLock(m_pCryptoMutexList[nLock]);
    else
       MutexUnlock(m_pCryptoMutexList[nLock]);
 }
index 327678c..ab50bd4 100644 (file)
@@ -107,7 +107,7 @@ static BOOL RotateLog(BOOL needLock)
                return FALSE;   // Cannot rotate system logs
 
        if (needLock)
-               MutexLock(m_mutexLogAccess, INFINITE);
+               MutexLock(m_mutexLogAccess);
 
        if ((m_logFileHandle != NULL) && (m_flags & NXLOG_IS_OPEN))
        {
@@ -279,7 +279,7 @@ static void WriteLogToFile(TCHAR *message)
 #endif
 
    // Prevent simultaneous write to log file
-   MutexLock(m_mutexLogAccess, INFINITE);
+   MutexLock(m_mutexLogAccess);
 
    t = time(NULL);
 #if HAVE_LOCALTIME_R
index 413b831..6223b02 100644 (file)
@@ -1,7 +1,7 @@
 /* 
 ** NetXMS - Network Management System
 ** NetXMS Foundation Library
-** Copyright (C) 2003-2010 Victor Kirhenshtein
+** Copyright (C) 2003-2011 Victor Kirhenshtein
 **
 ** This program is free software; you can redistribute it and/or modify
 ** it under the terms of the GNU Lesser General Public License as published
@@ -43,7 +43,7 @@ MsgWaitQueue::MsgWaitQueue()
    m_mutexDataAccess = MutexCreate();
    m_condStop = ConditionCreate(FALSE);
    m_condNewMsg = ConditionCreate(TRUE);
-   m_hHkThread = ThreadCreateEx(MWQThreadStarter, 0, this);
+   m_hHkThread = ThreadCreateEx(mwqThreadStarter, 0, this);
 }
 
 
@@ -59,7 +59,7 @@ MsgWaitQueue::~MsgWaitQueue()
    ThreadJoin(m_hHkThread);
 
    // Housekeeper thread stopped, proceed with object destruction
-   Clear();
+   clear();
    safe_free(m_pElements);
    MutexDestroy(m_mutexDataAccess);
    ConditionDestroy(m_condStop);
@@ -71,11 +71,11 @@ MsgWaitQueue::~MsgWaitQueue()
 // Clear queue
 //
 
-void MsgWaitQueue::Clear(void)
+void MsgWaitQueue::clear()
 {
    DWORD i;
 
-   Lock();
+   lock();
 
    for(i = 0; i < m_dwNumElements; i++)
       if (m_pElements[i].wIsBinary)
@@ -87,7 +87,7 @@ void MsgWaitQueue::Clear(void)
          delete (CSCPMessage *)(m_pElements[i].pMsg);
       }
    m_dwNumElements = 0;
-   Unlock();
+   unlock();
 }
 
 
@@ -95,9 +95,9 @@ void MsgWaitQueue::Clear(void)
 // Put message into queue
 //
 
-void MsgWaitQueue::Put(CSCPMessage *pMsg)
+void MsgWaitQueue::put(CSCPMessage *pMsg)
 {
-   Lock();
+   lock();
 
        // FIXME possible memory leak/fault
    m_pElements = (WAIT_QUEUE_ELEMENT *)realloc(m_pElements,
@@ -110,7 +110,7 @@ void MsgWaitQueue::Put(CSCPMessage *pMsg)
    m_pElements[m_dwNumElements].pMsg = pMsg;
    m_dwNumElements++;
 
-   Unlock();
+   unlock();
 
    ConditionPulse(m_condNewMsg);
 }
@@ -120,9 +120,9 @@ void MsgWaitQueue::Put(CSCPMessage *pMsg)
 // Put raw message into queue
 //
 
-void MsgWaitQueue::Put(CSCP_MESSAGE *pMsg)
+void MsgWaitQueue::put(CSCP_MESSAGE *pMsg)
 {
-   Lock();
+   lock();
 
    m_pElements = (WAIT_QUEUE_ELEMENT *)realloc(m_pElements, 
                               sizeof(WAIT_QUEUE_ELEMENT) * (m_dwNumElements + 1));
@@ -132,7 +132,7 @@ void MsgWaitQueue::Put(CSCP_MESSAGE *pMsg)
    m_pElements[m_dwNumElements].dwTTL = m_dwMsgHoldTime;
    m_pElements[m_dwNumElements].pMsg = pMsg;
    m_dwNumElements++;
-   Unlock();
+   unlock();
 
    ConditionPulse(m_condNewMsg);
 }
@@ -144,14 +144,14 @@ void MsgWaitQueue::Put(CSCP_MESSAGE *pMsg)
 // NULL on timeout or error
 //
 
-void *MsgWaitQueue::WaitForMessageInternal(WORD wIsBinary, WORD wCode, DWORD dwId, DWORD dwTimeOut)
+void *MsgWaitQueue::waitForMessageInternal(WORD wIsBinary, WORD wCode, DWORD dwId, DWORD dwTimeOut)
 {
    DWORD i, dwSleepTime;
    QWORD qwStartTime;
 
    do
    {
-      Lock();
+      lock();
       for(i = 0; i < m_dwNumElements; i++)
                {
          if ((m_pElements[i].dwId == dwId) &&
@@ -164,11 +164,11 @@ void *MsgWaitQueue::WaitForMessageInternal(WORD wIsBinary, WORD wCode, DWORD dwI
             m_dwNumElements--;
             memmove(&m_pElements[i], &m_pElements[i + 1],
                                                sizeof(WAIT_QUEUE_ELEMENT) * (m_dwNumElements - i));
-            Unlock();
+            unlock();
             return pMsg;
          }
                }
-      Unlock();
+      unlock();
 
       qwStartTime = GetCurrentTimeMs();
       ConditionWait(m_condNewMsg, min(dwTimeOut, 100));
@@ -184,7 +184,7 @@ void *MsgWaitQueue::WaitForMessageInternal(WORD wIsBinary, WORD wCode, DWORD dwI
 // Housekeeping thread
 //
 
-void MsgWaitQueue::HousekeeperThread(void)
+void MsgWaitQueue::housekeeperThread()
 {
    DWORD i;
 
@@ -193,7 +193,7 @@ void MsgWaitQueue::HousekeeperThread(void)
       if (ConditionWait(m_condStop, TTL_CHECK_INTERVAL))
          break;
 
-      Lock();
+      lock();
       for(i = 0; i < m_dwNumElements; i++)
                {
          if (m_pElements[i].dwTTL <= TTL_CHECK_INTERVAL)
@@ -215,7 +215,7 @@ void MsgWaitQueue::HousekeeperThread(void)
             m_pElements[i].dwTTL -= TTL_CHECK_INTERVAL;
          }
                }
-      Unlock();
+      unlock();
    }
 }
 
@@ -224,8 +224,8 @@ void MsgWaitQueue::HousekeeperThread(void)
 // Housekeeper thread starter
 //
 
-THREAD_RESULT THREAD_CALL MsgWaitQueue::MWQThreadStarter(void *pArg)
+THREAD_RESULT THREAD_CALL MsgWaitQueue::mwqThreadStarter(void *pArg)
 {
-   ((MsgWaitQueue *)pArg)->HousekeeperThread();
+   ((MsgWaitQueue *)pArg)->housekeeperThread();
    return THREAD_OK;
 }
index dbf6ba2..c00621d 100644 (file)
@@ -709,7 +709,7 @@ int LIBNETXMS_EXPORTABLE SendEx(SOCKET nSocket, const void *pBuff, size_t nSize,
        int nRet;
 
        if (mutex != NULL)
-               MutexLock(mutex, INFINITE);
+               MutexLock(mutex);
 
        do
        {
@@ -1798,14 +1798,14 @@ RefCountObject::~RefCountObject()
 
 void RefCountObject::incRefCount()
 {
-       MutexLock(m_mutex, INFINITE);
+       MutexLock(m_mutex);
        m_refCount++;
        MutexUnlock(m_mutex);
 }
 
 void RefCountObject::decRefCount()
 {
-       MutexLock(m_mutex, INFINITE);
+       MutexLock(m_mutex);
        m_refCount--;
        if (m_refCount == 0)
        {
index 2d5c6a7..06107ea 100644 (file)
@@ -101,7 +101,7 @@ THREAD_RESULT THREAD_CALL NetReceiver(NXCL_Session *pSession)
          switch(pRawMsg->wCode)
          {
             case CMD_FILE_DATA:
-               MutexLock(pSession->m_mutexFileRq, INFINITE);
+               MutexLock(pSession->m_mutexFileRq);
                if ((pSession->m_hCurrFile != -1) && (pSession->m_dwFileRqId == pRawMsg->dwId))
                {
                   if (write(pSession->m_hCurrFile, pRawMsg->df, pRawMsg->dwNumVars) == (int)pRawMsg->dwNumVars)
@@ -124,7 +124,7 @@ THREAD_RESULT THREAD_CALL NetReceiver(NXCL_Session *pSession)
                MutexUnlock(pSession->m_mutexFileRq);
                break;
             case CMD_ABORT_FILE_TRANSFER:
-               MutexLock(pSession->m_mutexFileRq, INFINITE);
+               MutexLock(pSession->m_mutexFileRq);
                if ((pSession->m_hCurrFile != -1) && (pSession->m_dwFileRqId == pRawMsg->dwId))
                {
                   // I/O error
@@ -135,7 +135,7 @@ THREAD_RESULT THREAD_CALL NetReceiver(NXCL_Session *pSession)
                MutexUnlock(pSession->m_mutexFileRq);
                break;
             default:    // Put unknown raw messages into the wait queue
-               pSession->m_msgWaitQueue.Put((CSCP_MESSAGE *)nx_memdup(pRawMsg, pRawMsg->dwSize));
+               pSession->m_msgWaitQueue.put((CSCP_MESSAGE *)nx_memdup(pRawMsg, pRawMsg->dwSize));
                break;
          }
       }
@@ -207,7 +207,7 @@ THREAD_RESULT THREAD_CALL NetReceiver(NXCL_Session *pSession)
                                        ProcessSituationChange(pSession, pMsg);
                                        break;
             default:
-               pSession->m_msgWaitQueue.Put(pMsg);
+               pSession->m_msgWaitQueue.put(pMsg);
                bMsgNotNeeded = FALSE;
                break;
          }
index 38520af..9ef96fa 100644 (file)
@@ -216,7 +216,7 @@ public:
    NXC_USER *FindUserById(DWORD dwId);
 
    DWORD syncObjects(const TCHAR *pszCacheFile, BOOL bSyncComments);
-   void lockObjectIndex() { MutexLock(m_mutexIndexAccess, INFINITE); }
+   void lockObjectIndex() { MutexLock(m_mutexIndexAccess); }
    void unlockObjectIndex() { MutexUnlock(m_mutexIndexAccess); }
    NXC_OBJECT *findObjectById(DWORD id, BOOL lock);
    NXC_OBJECT *findObjectByName(const TCHAR *name, DWORD currObject);
index eab0678..456de07 100644 (file)
@@ -102,12 +102,12 @@ NXCL_Session::~NXCL_Session()
 
    MutexDestroy(m_mutexIndexAccess);
 
-   MutexLock(m_mutexEventAccess, INFINITE);
+   MutexLock(m_mutexEventAccess);
    MutexUnlock(m_mutexEventAccess);
    MutexDestroy(m_mutexEventAccess);
 
    ConditionSet(m_condFileRq);
-   MutexLock(m_mutexFileRq, INFINITE);
+   MutexLock(m_mutexFileRq);
    MutexUnlock(m_mutexFileRq);
    MutexDestroy(m_mutexFileRq);
    ConditionDestroy(m_condFileRq);
@@ -153,7 +153,7 @@ void NXCL_Session::disconnect()
    m_hSocket = -1;
 
    // Clear message wait queue
-   m_msgWaitQueue.Clear();
+   m_msgWaitQueue.clear();
 
    // Cleanup
    destroyAllObjects();
@@ -176,7 +176,7 @@ void NXCL_Session::destroyAllObjects()
 {
    DWORD i;
 
-   MutexLock(m_mutexIndexAccess, INFINITE);
+   MutexLock(m_mutexIndexAccess);
    for(i = 0; i < m_dwNumObjects; i++)
       DestroyObject(m_pIndexById[i].pObject);
    m_dwNumObjects = 0;
@@ -194,7 +194,7 @@ CSCPMessage *NXCL_Session::WaitForMessage(WORD wCode, DWORD dwId, DWORD dwTimeOu
 {
    if (m_dwFlags & NXC_SF_CONN_BROKEN)
       return NULL;
-   return m_msgWaitQueue.WaitForMessage(wCode, dwId, 
+   return m_msgWaitQueue.waitForMessage(wCode, dwId, 
       dwTimeOut == 0 ? m_dwCommandTimeout : dwTimeOut);
 }
 
@@ -207,7 +207,7 @@ CSCP_MESSAGE *NXCL_Session::WaitForRawMessage(WORD wCode, DWORD dwId, DWORD dwTi
 {
    if (m_dwFlags & NXC_SF_CONN_BROKEN)
       return NULL;
-   return m_msgWaitQueue.WaitForRawMessage(wCode, dwId, 
+   return m_msgWaitQueue.waitForRawMessage(wCode, dwId, 
       dwTimeOut == 0 ? m_dwCommandTimeout : dwTimeOut);
 }
 
@@ -267,7 +267,7 @@ BOOL NXCL_Session::SendMsg(CSCPMessage *pMsg)
 
    DebugPrintf(_T("SendMsg(\"%s\", id:%d)"), NXCPMessageCodeName(pMsg->GetCode(), szBuffer), pMsg->GetId());
    pRawMsg = pMsg->CreateMessage();
-       MutexLock(m_mutexSendMsg, INFINITE);
+       MutexLock(m_mutexSendMsg);
    if (m_pCtx != NULL)
    {
       pEnMsg = CSCPEncryptMessage(m_pCtx, pRawMsg);
@@ -351,7 +351,7 @@ DWORD NXCL_Session::WaitForSync(int nSyncOp, DWORD dwTimeOut)
 
 void NXCL_Session::PrepareForSync(int nSyncOp)
 {
-   MutexLock(m_mutexSyncOpAccess[nSyncOp], INFINITE);
+   MutexLock(m_mutexSyncOpAccess[nSyncOp]);
    m_dwSyncExitCode[nSyncOp] = RCC_SYSTEM_FAILURE;
 #ifdef _WIN32
    ResetEvent(m_condSyncOp[nSyncOp]);
@@ -505,7 +505,7 @@ DWORD NXCL_Session::LoadEventDB()
    PrepareForSync(SYNC_EVENT_DB);
 
    destroyEventDB();
-   MutexLock(m_mutexEventAccess, INFINITE);
+   MutexLock(m_mutexEventAccess);
 
    msg.SetCode(CMD_LOAD_EVENT_DB);
    msg.SetId(dwRqId);
@@ -552,7 +552,7 @@ void NXCL_Session::DeleteEDBRecord(DWORD dwEventCode)
 {
    DWORD i;
 
-   MutexLock(m_mutexEventAccess, INFINITE);
+   MutexLock(m_mutexEventAccess);
    for(i = 0; i < m_dwNumTemplates; i++)
       if (m_ppEventTemplates[i]->dwCode == dwEventCode)
       {
@@ -575,7 +575,7 @@ void NXCL_Session::DeleteEDBRecord(DWORD dwEventCode)
 void NXCL_Session::AddEventTemplate(NXC_EVENT_TEMPLATE *pEventTemplate, BOOL bLock)
 {
    if (bLock)
-      MutexLock(m_mutexEventAccess, INFINITE);
+      MutexLock(m_mutexEventAccess);
    m_ppEventTemplates = (NXC_EVENT_TEMPLATE **)realloc(m_ppEventTemplates, 
       sizeof(NXC_EVENT_TEMPLATE *) * (m_dwNumTemplates + 1));
    m_ppEventTemplates[m_dwNumTemplates] = pEventTemplate;
@@ -605,7 +605,7 @@ const TCHAR *NXCL_Session::GetEventName(DWORD dwId)
 {
    DWORD i;
 
-   MutexLock(m_mutexEventAccess, INFINITE);
+   MutexLock(m_mutexEventAccess);
    for(i = 0; i < m_dwNumTemplates; i++)
       if (m_ppEventTemplates[i]->dwCode == dwId)
       {
@@ -625,7 +625,7 @@ BOOL NXCL_Session::GetEventNameEx(DWORD dwId, TCHAR *pszBuffer, DWORD dwBufSize)
 {
    DWORD i;
 
-   MutexLock(m_mutexEventAccess, INFINITE);
+   MutexLock(m_mutexEventAccess);
    for(i = 0; i < m_dwNumTemplates; i++)
       if (m_ppEventTemplates[i]->dwCode == dwId)
       {
@@ -647,7 +647,7 @@ int NXCL_Session::GetEventSeverity(DWORD dwId)
 {
    DWORD i;
 
-   MutexLock(m_mutexEventAccess, INFINITE);
+   MutexLock(m_mutexEventAccess);
    for(i = 0; i < m_dwNumTemplates; i++)
       if (m_ppEventTemplates[i]->dwCode == dwId)
       {
@@ -668,7 +668,7 @@ BOOL NXCL_Session::GetEventText(DWORD dwId, TCHAR *pszBuffer, DWORD dwBufSize)
 {
    DWORD i;
 
-   MutexLock(m_mutexEventAccess, INFINITE);
+   MutexLock(m_mutexEventAccess);
    for(i = 0; i < m_dwNumTemplates; i++)
       if (m_ppEventTemplates[i]->dwCode == dwId)
       {
@@ -889,7 +889,7 @@ DWORD NXCL_Session::PrepareFileTransfer(const TCHAR *pszFile, DWORD dwRqId)
 {
    DWORD dwResult;
 
-   MutexLock(m_mutexFileRq, INFINITE);
+   MutexLock(m_mutexFileRq);
    if (m_hCurrFile == -1)
    {
       m_hCurrFile = _topen(pszFile, O_CREAT | O_TRUNC | O_WRONLY | O_BINARY,
@@ -916,12 +916,12 @@ DWORD NXCL_Session::WaitForFileTransfer(DWORD dwTimeout)
    DWORD dwResult;
    BOOL bSuccess;
 
-   MutexLock(m_mutexFileRq, INFINITE);
+   MutexLock(m_mutexFileRq);
    if (m_hCurrFile != -1)
    {
       MutexUnlock(m_mutexFileRq);
       bSuccess = ConditionWait(m_condFileRq, dwTimeout);
-      MutexLock(m_mutexFileRq, INFINITE);
+      MutexLock(m_mutexFileRq);
       if (bSuccess)
       {
          dwResult = m_dwFileRqCompletion;
@@ -949,7 +949,7 @@ DWORD NXCL_Session::WaitForFileTransfer(DWORD dwTimeout)
 
 void NXCL_Session::AbortFileTransfer(void)
 {
-   MutexLock(m_mutexFileRq, INFINITE);
+   MutexLock(m_mutexFileRq);
    if (m_hCurrFile != -1)
    {
       close(m_hCurrFile);
index 5ff8a66..d56c420 100644 (file)
@@ -95,7 +95,7 @@ void NXMBDispatcher::workerThread()
                if (msg == INVALID_POINTER_VALUE)
                        break;
 
-               MutexLock(m_subscriberListAccess, INFINITE);
+               MutexLock(m_subscriberListAccess);
                for(i = 0; i < m_numSubscribers; i++)
                {
                        if (m_filters[i]->isAllowed(*msg))
@@ -127,7 +127,7 @@ void NXMBDispatcher::addSubscriber(NXMBSubscriber *subscriber, NXMBFilter *filte
 {
        int i;
 
-       MutexLock(m_subscriberListAccess, INFINITE);
+       MutexLock(m_subscriberListAccess);
 
        for(i = 0; i < m_numSubscribers; i++)
        {
@@ -174,7 +174,7 @@ void NXMBDispatcher::removeSubscriber(const TCHAR *id)
 {
        int i;
 
-       MutexLock(m_subscriberListAccess, INFINITE);
+       MutexLock(m_subscriberListAccess);
 
        for(i = 0; i < m_numSubscribers; i++)
        {
index d675112..4d549d6 100644 (file)
@@ -113,7 +113,7 @@ BOOL ValidateUserCertificate(X509 *pCert, const TCHAR *pszLogin, BYTE *pChalleng
 #endif
 
        DbgPrintf(3, _T("Validating certificate \"%s\" for user %s"), certSubject, pszLogin);
-       MutexLock(m_mutexStoreAccess, INFINITE);
+       MutexLock(m_mutexStoreAccess);
 
        if (m_pTrustedCertStore == NULL)
        {
@@ -207,7 +207,7 @@ void ReloadCertificates()
        X509 *pCert;
        TCHAR szBuffer[256], szSubject[256], *pszCertData;
 
-       MutexLock(m_mutexStoreAccess, INFINITE);
+       MutexLock(m_mutexStoreAccess);
 
        if (m_pTrustedCertStore != NULL)
                X509_STORE_free(m_pTrustedCertStore);
index e01acf5..4202781 100644 (file)
 #endif
 
 
-//
-// Test mutex state and print to stdout
-//
-
-void DbgTestMutex(MUTEX hMutex, const TCHAR *szName, CONSOLE_CTX pCtx)
-{
-   ConsolePrintf(pCtx, _T("  %s: "), szName);
-   if (MutexLock(hMutex, 100))
-   {
-      ConsolePrintf(pCtx, _T("unlocked\n"));
-      MutexUnlock(hMutex);
-   }
-   else
-   {
-      ConsolePrintf(pCtx, _T("locked\n"));
-   }
-}
-
-
 //
 // Test read/write lock state and print to stdout
 //
index ca9d5dc..4618fc4 100644 (file)
@@ -412,7 +412,7 @@ DWORD CreateUniqueId(int iGroup)
 {
    DWORD dwId;
 
-   MutexLock(m_mutexTableAccess, INFINITE);
+   MutexLock(m_mutexTableAccess);
    if (m_dwFreeIdTable[iGroup] == m_dwIdLimits[iGroup])
    {
       dwId = 0;   // ID zero means _T("no unique ID available")
@@ -436,7 +436,7 @@ QWORD CreateUniqueEventId()
 {
    QWORD qwId;
 
-   MutexLock(m_mutexTableAccess, INFINITE);
+   MutexLock(m_mutexTableAccess);
    qwId = m_qwFreeEventId++;
    MutexUnlock(m_mutexTableAccess);
    return qwId;
index 19eac4b..44fefdf 100644 (file)
@@ -99,7 +99,7 @@ void ServerJob::notifyClients(bool isStatusChange)
                return; // Don't send progress notifications often then every 3 seconds
        m_lastNotification = t;
 
-       MutexLock(m_notificationLock, INFINITE);
+       MutexLock(m_notificationLock);
        m_notificationMessage.SetCode(CMD_JOB_CHANGE_NOTIFICATION);
        fillMessage(&m_notificationMessage);
        EnumerateClientSessions(ServerJob::sendNotification, this);
index 634f89f..8bca061 100644 (file)
@@ -60,7 +60,7 @@ ServerJobQueue::~ServerJobQueue()
 
 void ServerJobQueue::add(ServerJob *job)
 {
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        m_jobList = (ServerJob **)realloc(m_jobList, sizeof(ServerJob *) * (m_jobCount + 1));
        m_jobList[m_jobCount] = job;
        m_jobCount++;
@@ -82,7 +82,7 @@ void ServerJobQueue::runNext()
 {
        int i;
 
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        for(i = 0; i < m_jobCount; i++)
                if ((m_jobList[i]->getStatus() != JOB_ON_HOLD) &&
                         ((m_jobList[i]->getStatus() != JOB_FAILED) || m_jobList[i]->isBlockNextJobsOnFailure()))
@@ -101,7 +101,7 @@ void ServerJobQueue::jobCompleted(ServerJob *job)
 {
        int i;
 
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        for(i = 0; i < m_jobCount; i++)
                if (m_jobList[i] == job)
                {
@@ -130,7 +130,7 @@ bool ServerJobQueue::cancel(DWORD jobId)
        int i;
        bool success = false;
 
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        for(i = 0; i < m_jobCount; i++)
                if (m_jobList[i]->getId()  == jobId)
                {
@@ -166,7 +166,7 @@ bool ServerJobQueue::hold(DWORD jobId)
        int i;
        bool success = false;
 
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        for(i = 0; i < m_jobCount; i++)
                if (m_jobList[i]->getId()  == jobId)
                {
@@ -195,7 +195,7 @@ bool ServerJobQueue::unhold(DWORD jobId)
        int i;
        bool success = false;
 
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        for(i = 0; i < m_jobCount; i++)
                if (m_jobList[i]->getId()  == jobId)
                {
@@ -224,7 +224,7 @@ void ServerJobQueue::cleanup()
        int i;
        time_t now;
 
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        now = time(NULL);
        for(i = 0; i < m_jobCount; i++)
        {
@@ -259,7 +259,7 @@ ServerJob *ServerJobQueue::findJob(DWORD jobId)
        int i;
        ServerJob *job = NULL;
 
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        for(i = 0; i < m_jobCount; i++)
                if (m_jobList[i]->getId()  == jobId)
                {
@@ -282,7 +282,7 @@ DWORD ServerJobQueue::fillMessage(CSCPMessage *msg, DWORD *varIdBase)
        DWORD id = *varIdBase;
        int i;
 
-       MutexLock(m_accessMutex, INFINITE);
+       MutexLock(m_accessMutex);
        for(i = 0; i < m_jobCount; i++, id += 2)
        {
                msg->SetVariable(id++, m_jobList[i]->getId());
index d394f6f..bbfbce8 100644 (file)
@@ -139,7 +139,7 @@ BOOL LockComponent(DWORD dwId, DWORD dwLockBy, const TCHAR *pszOwnerInfo,
 
    DbgPrintf(5, _T("*Locks* Attempting to lock component \"%s\" by %d (%s)"),
              m_locks[dwId].pszName, dwLockBy, pszOwnerInfo != NULL ? pszOwnerInfo : _T("NULL"));
-   MutexLock(m_hMutexLockerAccess, INFINITE);
+   MutexLock(m_hMutexLockerAccess);
    if (m_locks[dwId].dwLockStatus == UNLOCKED)
    {
       m_locks[dwId].dwLockStatus = dwLockBy;
@@ -167,7 +167,7 @@ BOOL LockComponent(DWORD dwId, DWORD dwLockBy, const TCHAR *pszOwnerInfo,
 
 void UnlockComponent(DWORD dwId)
 {
-   MutexLock(m_hMutexLockerAccess, INFINITE);
+   MutexLock(m_hMutexLockerAccess);
    m_locks[dwId].dwLockStatus = UNLOCKED;
    m_locks[dwId].szOwnerInfo[0] = 0;
    MutexUnlock(m_hMutexLockerAccess);
@@ -183,7 +183,7 @@ void RemoveAllSessionLocks(DWORD dwSessionId)
 {
    DWORD i;
 
-   MutexLock(m_hMutexLockerAccess, INFINITE);
+   MutexLock(m_hMutexLockerAccess);
    for(i = 0; i < NUMBER_OF_LOCKS; i++)
       if (m_locks[i].dwLockStatus == dwSessionId)
       {
index a037bfc..4fd816b 100644 (file)
@@ -86,7 +86,7 @@ static int RegisterLogHandle(LogHandle *handle, ClientSession *session)
 {
        int i;
 
-       MutexLock(s_regListMutex, INFINITE);
+       MutexLock(s_regListMutex);
 
        for(i = 0; i < s_regListSize; i++)
                if (s_regList[i].handle == NULL)
@@ -141,7 +141,7 @@ DWORD CloseLog(ClientSession *session, int logHandle)
 {
        DWORD rcc = RCC_INVALID_LOG_HANDLE;
 
-       MutexLock(s_regListMutex, INFINITE);
+       MutexLock(s_regListMutex);
 
        if ((logHandle >= 0) && (logHandle < s_regListSize) &&
            (s_regList[logHandle].sessionId == session->getIndex()) &&
@@ -168,7 +168,7 @@ LogHandle *AcquireLogHandleObject(ClientSession *session, int logHandle)
 {
        LogHandle *object = NULL;
 
-       MutexLock(s_regListMutex, INFINITE);
+       MutexLock(s_regListMutex);
 
        if ((logHandle >= 0) && (logHandle < s_regListSize) &&
            (s_regList[logHandle].sessionId == session->getIndex()) &&
index 688f1ee..f2599d3 100644 (file)
@@ -3954,7 +3954,7 @@ nxmap_ObjList *Node::GetL2Topology()
        DWORD dwExpTime;
 
        dwExpTime = ConfigReadULong(_T("TopologyExpirationTime"), 900);
-       MutexLock(m_mutexTopoAccess, INFINITE);
+       MutexLock(m_mutexTopoAccess);
        if ((m_pTopology == NULL) || (m_topologyRebuildTimestamp + (time_t)dwExpTime < time(NULL)))
        {
                pResult = NULL;
@@ -3977,7 +3977,7 @@ nxmap_ObjList *Node::BuildL2Topology(DWORD *pdwStatus)
        nxmap_ObjList *pResult;
        int nDepth = ConfigReadInt(_T("TopologyDiscoveryRadius"), 5);
 
-       MutexLock(m_mutexTopoAccess, INFINITE);
+       MutexLock(m_mutexTopoAccess);
        if ((m_linkLayerNeighbors != NULL) && (m_linkLayerNeighbors->getSize() > 0))
        {
                MutexUnlock(m_mutexTopoAccess);
@@ -3985,7 +3985,7 @@ nxmap_ObjList *Node::BuildL2Topology(DWORD *pdwStatus)
                pResult = new nxmap_ObjList;
                ::BuildL2Topology(*pResult, this, nDepth);
 
-               MutexLock(m_mutexTopoAccess, INFINITE);
+               MutexLock(m_mutexTopoAccess);
                delete m_pTopology;
                m_pTopology = new nxmap_ObjList(pResult);
                m_topologyRebuildTimestamp = time(NULL);
@@ -4019,7 +4019,7 @@ void Node::topologyPoll(ClientSession *pSession, DWORD dwRqId, int nPoller)
                SendPollerMsg(dwRqId, POLLER_INFO _T("Link layer topology retrieved (%d connections found)\r\n"), nbs->getSize());
                DbgPrintf(4, _T("Link layer topology retrieved for node %s [%d] (%d connections found)"), m_szName, (int)m_dwId, nbs->getSize());
 
-               MutexLock(m_mutexTopoAccess, INFINITE);
+               MutexLock(m_mutexTopoAccess);
                if (m_linkLayerNeighbors != NULL)
                        m_linkLayerNeighbors->decRefCount();
                m_linkLayerNeighbors = nbs;
@@ -4060,7 +4060,7 @@ void Node::topologyPoll(ClientSession *pSession, DWORD dwRqId, int nPoller)
        }
 
        ForwardingDatabase *fdb = GetSwitchForwardingDatabase(this);
-       MutexLock(m_mutexTopoAccess, INFINITE);
+       MutexLock(m_mutexTopoAccess);
        if (m_fdb != NULL)
                m_fdb->decRefCount();
        m_fdb = fdb;
@@ -4084,7 +4084,7 @@ void Node::topologyPoll(ClientSession *pSession, DWORD dwRqId, int nPoller)
                        VlanList *vlanList = m_driver->getVlans(snmp, &m_customAttributes);
                        delete snmp;
 
-                       MutexLock(m_mutexTopoAccess, INFINITE);
+                       MutexLock(m_mutexTopoAccess);
                        if (vlanList != NULL)
                        {
                                resolveVlanPorts(vlanList);
@@ -4391,7 +4391,7 @@ ForwardingDatabase *Node::getSwitchForwardingDatabase()
 {
        ForwardingDatabase *fdb;
 
-       MutexLock(m_mutexTopoAccess, INFINITE);
+       MutexLock(m_mutexTopoAccess);
        if (m_fdb != NULL)
                m_fdb->incRefCount();
        fdb = m_fdb;
@@ -4408,7 +4408,7 @@ LinkLayerNeighbors *Node::getLinkLayerNeighbors()
 {
        LinkLayerNeighbors *nbs;
 
-       MutexLock(m_mutexTopoAccess, INFINITE);
+       MutexLock(m_mutexTopoAccess);
        if (m_linkLayerNeighbors != NULL)
                m_linkLayerNeighbors->incRefCount();
        nbs = m_linkLayerNeighbors;
@@ -4425,7 +4425,7 @@ VlanList *Node::getVlans()
 {
        VlanList *vlans;
 
-       MutexLock(m_mutexTopoAccess, INFINITE);
+       MutexLock(m_mutexTopoAccess);
        if (m_vlans != NULL)
                m_vlans->incRefCount();
        vlans = m_vlans;
index 2d1762f..1db3787 100644 (file)
@@ -320,7 +320,7 @@ THREAD_RESULT THREAD_CALL DeploymentManager(void *pArg)
    THREAD *pThreadList;
 
    // Wait for parent initialization completion
-   MutexLock(pStartup->mutex, INFINITE);
+   MutexLock(pStartup->mutex);
    MutexUnlock(pStartup->mutex);
 
    // Sanity check
index ba856db..1654448 100644 (file)
@@ -631,13 +631,13 @@ void ClientSession::updateThread()
       switch(pUpdate->dwCategory)
       {
          case INFO_CAT_EVENT:
-            MutexLock(m_mutexSendEvents, INFINITE);
+            MutexLock(m_mutexSendEvents);
             sendMessage((CSCPMessage *)pUpdate->pData);
             MutexUnlock(m_mutexSendEvents);
             delete (CSCPMessage *)pUpdate->pData;
             break;
          case INFO_CAT_SYSLOG_MSG:
-            MutexLock(m_mutexSendSyslog, INFINITE);
+            MutexLock(m_mutexSendSyslog);
             msg.SetCode(CMD_SYSLOG_RECORDS);
             CreateMessageFromSyslogMsg(&msg, (NX_SYSLOG_RECORD *)pUpdate->pData);
             sendMessage(&msg);
@@ -645,19 +645,19 @@ void ClientSession::updateThread()
             free(pUpdate->pData);
             break;
          case INFO_CAT_SNMP_TRAP:
-            MutexLock(m_mutexSendTrapLog, INFINITE);
+            MutexLock(m_mutexSendTrapLog);
             sendMessage((CSCPMessage *)pUpdate->pData);
             MutexUnlock(m_mutexSendTrapLog);
             delete (CSCPMessage *)pUpdate->pData;
             break;
          case INFO_CAT_AUDIT_RECORD:
-            MutexLock(m_mutexSendAuditLog, INFINITE);
+            MutexLock(m_mutexSendAuditLog);
             sendMessage((CSCPMessage *)pUpdate->pData);
             MutexUnlock(m_mutexSendAuditLog);
             delete (CSCPMessage *)pUpdate->pData;
             break;
          case INFO_CAT_OBJECT_CHANGE:
-            MutexLock(m_mutexSendObjects, INFINITE);
+            MutexLock(m_mutexSendObjects);
             msg.SetCode(CMD_OBJECT_UPDATE);
             ((NetObj *)pUpdate->pData)->CreateMessage(&msg);
             if (m_dwFlags & CSF_SYNC_OBJECT_COMMENTS)
@@ -668,7 +668,7 @@ void ClientSession::updateThread()
             ((NetObj *)pUpdate->pData)->DecRefCount();
             break;
          case INFO_CAT_ALARM:
-            MutexLock(m_mutexSendAlarms, INFINITE);
+            MutexLock(m_mutexSendAlarms);
             msg.SetCode(CMD_ALARM_UPDATE);
             msg.SetVariable(VID_NOTIFICATION_CODE, pUpdate->dwCode);
             FillAlarmInfoMessage(&msg, (NXC_ALARM *)pUpdate->pData);
@@ -678,7 +678,7 @@ void ClientSession::updateThread()
             free(pUpdate->pData);
             break;
          case INFO_CAT_ACTION:
-            MutexLock(m_mutexSendActions, INFINITE);
+            MutexLock(m_mutexSendActions);
             msg.SetCode(CMD_ACTION_DB_UPDATE);
             msg.SetVariable(VID_NOTIFICATION_CODE, pUpdate->dwCode);
             msg.SetVariable(VID_ACTION_ID, ((NXC_ACTION *)pUpdate->pData)->dwId);
@@ -690,7 +690,7 @@ void ClientSession::updateThread()
             free(pUpdate->pData);
             break;
          case INFO_CAT_SITUATION:
-            MutexLock(m_mutexSendSituations, INFINITE);
+            MutexLock(m_mutexSendSituations);
             sendMessage((CSCPMessage *)pUpdate->pData);
             MutexUnlock(m_mutexSendSituations);
             delete (CSCPMessage *)pUpdate->pData;
@@ -1872,7 +1872,7 @@ void ClientSession::sendAllObjects(CSCPMessage *pRequest)
 
    // Send objects, one per message
        ObjectArray<NetObj> *objects = g_idxObjectById.getObjects();
-   MutexLock(m_mutexSendObjects, INFINITE);
+   MutexLock(m_mutexSendObjects);
        for(int i = 0; i < objects->size(); i++)
        {
                NetObj *object = objects->get(i);
@@ -1924,7 +1924,7 @@ void ClientSession::sendSelectedObjects(CSCPMessage *pRequest)
        pRequest->GetVariableInt32Array(VID_OBJECT_LIST, numObjects, objects);
        DWORD options = pRequest->GetVariableShort(VID_FLAGS);
 
-   MutexLock(m_mutexSendObjects, INFINITE);
+   MutexLock(m_mutexSendObjects);
 
    // Prepare message
        msg.SetCode((options & OBJECT_SYNC_SEND_UPDATES) ? CMD_OBJECT_UPDATE : CMD_OBJECT);
@@ -1979,7 +1979,7 @@ void ClientSession::SendEventLog(CSCPMessage *pRequest)
    msg.SetCode(CMD_REQUEST_COMPLETED);
    msg.SetId(dwRqId);
 
-   MutexLock(m_mutexSendEvents, INFINITE);
+   MutexLock(m_mutexSendEvents);
 
    // Retrieve events from database
    switch(g_nDBSyntax)
@@ -4266,7 +4266,7 @@ void ClientSession::onAlarmUpdate(DWORD dwCode, NXC_ALARM *pAlarm)
 
 void ClientSession::SendAllAlarms(DWORD dwRqId, BOOL bIncludeAck)
 {
-   MutexLock(m_mutexSendAlarms, INFINITE);
+   MutexLock(m_mutexSendAlarms);
    g_alarmMgr.SendAlarmsToClient(dwRqId, bIncludeAck, this);
    MutexUnlock(m_mutexSendAlarms);
 }
@@ -4544,7 +4544,7 @@ void ClientSession::SendAllActions(DWORD dwRqId)
    {
       msg.SetVariable(VID_RCC, RCC_SUCCESS);
       sendMessage(&msg);
-      MutexLock(m_mutexSendActions, INFINITE);
+      MutexLock(m_mutexSendActions);
       SendActionsToClient(this, dwRqId);
       MutexUnlock(m_mutexSendActions);
    }
@@ -4597,7 +4597,7 @@ void ClientSession::ForcedNodePoll(CSCPMessage *pRequest)
 
    pData = (POLLER_START_DATA *)malloc(sizeof(POLLER_START_DATA));
    pData->pSession = this;
-   MutexLock(m_mutexPollerInit, INFINITE);
+   MutexLock(m_mutexPollerInit);
 
    // Prepare response message
    pData->dwRqId = pRequest->GetId();
@@ -4677,7 +4677,7 @@ void ClientSession::pollerThread(Node *pNode, int iPollType, DWORD dwRqId)
    CSCPMessage msg;
 
    // Wait while parent thread finishes initialization
-   MutexLock(m_mutexPollerInit, INFINITE);
+   MutexLock(m_mutexPollerInit);
    MutexUnlock(m_mutexPollerInit);
 
    switch(iPollType)
@@ -5464,7 +5464,7 @@ void ClientSession::DeployPackage(CSCPMessage *pRequest)
          DT_STARTUP_INFO *pInfo;
 
          hMutex = MutexCreate();
-         MutexLock(hMutex, INFINITE);
+         MutexLock(hMutex);
 
          pInfo = (DT_STARTUP_INFO *)malloc(sizeof(DT_STARTUP_INFO));
          pInfo->dwNumNodes = dwNumNodes;
@@ -7044,7 +7044,7 @@ void ClientSession::SendSyslog(CSCPMessage *pRequest)
    msg.SetCode(CMD_REQUEST_COMPLETED);
    msg.SetId(pRequest->GetId());
 
-   MutexLock(m_mutexSendSyslog, INFINITE);
+   MutexLock(m_mutexSendSyslog);
 
    // Retrieve events from database
    switch(g_nDBSyntax)
@@ -7178,7 +7178,7 @@ void ClientSession::SendTrapLog(CSCPMessage *pRequest)
       msg.DeleteAllVariables();
       msg.SetCode(CMD_TRAP_LOG_RECORDS);
 
-      MutexLock(m_mutexSendTrapLog, INFINITE);
+      MutexLock(m_mutexSendTrapLog);
 
       // Retrieve trap log records from database
       switch(g_nDBSyntax)
@@ -9428,7 +9428,7 @@ void ClientSession::SendSituationList(DWORD dwRqId)
 
        if (m_dwSystemAccess & SYSTEM_ACCESS_MANAGE_SITUATIONS)
        {
-               MutexLock(m_mutexSendSituations, INFINITE);
+               MutexLock(m_mutexSendSituations);
                SendSituationListToClient(this, &msg);
                MutexUnlock(m_mutexSendSituations);
        }
index 2da08e9..3c069c1 100644 (file)
@@ -312,7 +312,7 @@ static void ProcessTrap(SNMP_PDU *pdu, struct sockaddr_in *pOrigin)
                                }
 
       // Find if we have this trap in our list
-      MutexLock(m_mutexTrapCfgAccess, INFINITE);
+      MutexLock(m_mutexTrapCfgAccess);
 
       // Try to find closest match
       for(i = 0, dwMatchLen = 0; i < m_dwNumTraps; i++)
@@ -492,7 +492,7 @@ void SendTrapsToClient(ClientSession *pSession, DWORD dwRqId)
    msg.SetCode(CMD_TRAP_CFG_RECORD);
    msg.SetId(dwRqId);
 
-   MutexLock(m_mutexTrapCfgAccess, INFINITE);
+   MutexLock(m_mutexTrapCfgAccess);
    for(i = 0; i < m_dwNumTraps; i++)
    {
                FillTrapConfigDataMsg(msg, &m_pTrapCfg[i]);
@@ -514,7 +514,7 @@ void CreateTrapCfgMessage(CSCPMessage &msg)
 {
    DWORD i, dwId;
 
-   MutexLock(m_mutexTrapCfgAccess, INFINITE);
+   MutexLock(m_mutexTrapCfgAccess);
        msg.SetVariable(VID_NUM_TRAPS, m_dwNumTraps);
    for(i = 0, dwId = VID_TRAP_INFO_BASE; i < m_dwNumTraps; i++, dwId += 5)
    {
@@ -568,7 +568,7 @@ DWORD DeleteTrap(DWORD dwId)
    DWORD i, j, dwResult = RCC_INVALID_TRAP_ID;
    TCHAR szQuery[256];
 
-   MutexLock(m_mutexTrapCfgAccess, INFINITE);
+   MutexLock(m_mutexTrapCfgAccess);
    
    for(i = 0; i < m_dwNumTraps; i++)
    {
@@ -650,7 +650,7 @@ DWORD CreateNewTrap(DWORD *pdwTrapId)
    DWORD dwResult = RCC_SUCCESS;
    TCHAR szQuery[256];
 
-   MutexLock(m_mutexTrapCfgAccess, INFINITE);
+   MutexLock(m_mutexTrapCfgAccess);
    
    *pdwTrapId = CreateUniqueId(IDG_SNMP_TRAP);
    m_pTrapCfg = (NXC_TRAP_CFG_ENTRY *)realloc(m_pTrapCfg, sizeof(NXC_TRAP_CFG_ENTRY) * (m_dwNumTraps + 1));
@@ -682,7 +682,7 @@ DWORD CreateNewTrap(NXC_TRAP_CFG_ENTRY *pTrap)
    TCHAR szQuery[4096], szOID[1024];
        BOOL bSuccess;
 
-   MutexLock(m_mutexTrapCfgAccess, INFINITE);
+   MutexLock(m_mutexTrapCfgAccess);
    
    m_pTrapCfg = (NXC_TRAP_CFG_ENTRY *)realloc(m_pTrapCfg, sizeof(NXC_TRAP_CFG_ENTRY) * (m_dwNumTraps + 1));
    memcpy(&m_pTrapCfg[m_dwNumTraps], pTrap, sizeof(NXC_TRAP_CFG_ENTRY));
@@ -743,7 +743,7 @@ DWORD UpdateTrapFromMsg(CSCPMessage *pMsg)
 
    dwTrapId = pMsg->GetVariableLong(VID_TRAP_ID);
 
-   MutexLock(m_mutexTrapCfgAccess, INFINITE);
+   MutexLock(m_mutexTrapCfgAccess);
    for(i = 0; i < m_dwNumTraps; i++)
    {
       if (m_pTrapCfg[i].dwId == dwTrapId)
@@ -827,7 +827,7 @@ void CreateNXMPTrapRecord(String &str, DWORD dwId)
        DWORD i, j;
        TCHAR szBuffer[1024];
 
-   MutexLock(m_mutexTrapCfgAccess, INFINITE);
+   MutexLock(m_mutexTrapCfgAccess);
    for(i = 0; i < m_dwNumTraps; i++)
    {
       if (m_pTrapCfg[i].dwId == dwId)
index 808ca61..663237d 100644 (file)
@@ -325,7 +325,7 @@ static void ProcessSyslogMessage(char *psMsg, int nMsgLen, DWORD dwSourceIP)
       // Send message to all connected clients
       EnumerateClientSessions(BroadcastSyslogMessage, &record);
 
-               MutexLock(m_mutexParserAccess, INFINITE);
+               MutexLock(m_mutexParserAccess);
                if ((record.dwSourceObject != 0) && (m_parser != NULL))
                {
                        m_parser->matchEvent(record.szTag, record.nFacility, 1 << record.nSeverity,
@@ -444,7 +444,7 @@ static void CreateParserFromConfig()
 {
        char *xml;
 
-       MutexLock(m_mutexParserAccess, INFINITE);
+       MutexLock(m_mutexParserAccess);
        delete_and_null(m_parser);
 #ifdef UNICODE
        WCHAR *wxml = ConfigReadCLOB(_T("SyslogParser"), _T("<parser></parser>"));
index cd7734c..4a88485 100644 (file)
@@ -116,7 +116,10 @@ NetworkPath *TraceRoute(Node *pSrc, Node *pDest)
       }
    }
        if (pCurr == pDest)
+       {
+               pTrace->addHop(0, pCurr, 0, false);
                pTrace->setComplete();
+       }
 
    return pTrace;
 }
index bb85a97..d449384 100644 (file)
@@ -88,7 +88,7 @@ bool FileUploadJob::run()
        \r
        while(true)\r
        {\r
-               MutexLock(m_sharedDataMutex, INFINITE);\r
+               MutexLock(m_sharedDataMutex);\r
                if (m_activeJobs < m_maxActiveJobs)\r
                {\r
                        m_activeJobs++;\r
@@ -118,7 +118,7 @@ bool FileUploadJob::run()
                setFailureMessage(_T("Agent connection not available"));\r
        }\r
        \r
-       MutexLock(m_sharedDataMutex, INFINITE);\r
+       MutexLock(m_sharedDataMutex);\r
        m_activeJobs--;\r
        MutexUnlock(m_sharedDataMutex);\r
 \r
index 4c8181c..9f8cedb 100644 (file)
@@ -65,7 +65,7 @@ static THREAD_RESULT THREAD_CALL AccountStatusUpdater(void *arg)
 
                time_t blockInactiveAccounts = (time_t)ConfigReadInt(_T("BlockInactiveUserAccounts"), 0) * 86400;
 
-               MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+               MutexLock(m_mutexUserDatabaseAccess);
                time_t now = time(NULL);
                for(int i = 0; i < m_userCount; i++)
                {
@@ -198,7 +198,7 @@ void SaveUsers(DB_HANDLE hdb)
    int i;
 
    // Save users
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
    for(i = 0; i < m_userCount; i++)
    {
       if (m_users[i]->isDeleted())
@@ -235,7 +235,7 @@ DWORD AuthenticateUser(TCHAR *pszName, TCHAR *pszPassword,
    DWORD dwResult = RCC_ACCESS_DENIED;
    BOOL bPasswordValid;
 
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
    for(i = 0; i < m_userCount; i++)
    {
                if ((!(m_users[i]->getId() & GROUP_FLAG)) &&
@@ -396,7 +396,7 @@ bool NXCORE_EXPORTABLE CheckUserMembership(DWORD dwUserId, DWORD dwGroupId)
    if (dwGroupId == GROUP_EVERYONE)
                return true;
 
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
    for(int i = 0; i < m_userCount; i++)
                if (m_users[i]->getId() == dwGroupId)
                {
@@ -416,7 +416,7 @@ bool NXCORE_EXPORTABLE ResolveUserId(DWORD id, TCHAR *buffer, int bufSize)
 {
        bool found = false;
 
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
    for(int i = 0; i < m_userCount; i++)
                if (m_users[i]->getId() == id)
                {
@@ -441,7 +441,7 @@ void DumpUsers(CONSOLE_CTX pCtx)
 
    ConsolePrintf(pCtx, _T("Login name           GUID                                 System rights\n")
                        _T("-----------------------------------------------------------------------\n"));
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
    for(i = 0; i < m_userCount; i++)
                if (!(m_users[i]->getId() & GROUP_FLAG))
                        ConsolePrintf(pCtx, _T("%-20s %-36s 0x%08X\n"), m_users[i]->getName(),
@@ -462,7 +462,7 @@ DWORD NXCORE_EXPORTABLE DeleteUserDatabaseObject(DWORD id)
 
    DeleteUserFromAllObjects(id);
 
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
 
    for(i = 0; i < m_userCount; i++)
        {
@@ -501,7 +501,7 @@ DWORD NXCORE_EXPORTABLE CreateNewUser(TCHAR *pszName, BOOL bIsGroup, DWORD *pdwI
        UserDatabaseObject *object;
        int i;
 
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
 
    // Check for duplicate name
    for(i = 0; i < m_userCount; i++)
@@ -549,7 +549,7 @@ DWORD NXCORE_EXPORTABLE ModifyUserDatabaseObject(CSCPMessage *msg)
 
        id = msg->GetVariableLong(VID_USER_ID);
 
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
 
    // Find object to be modified in list
    for(i = 0; i < m_userCount; i++)
@@ -666,7 +666,7 @@ DWORD NXCORE_EXPORTABLE SetUserPassword(DWORD id, const TCHAR *newPassword, cons
        if (id & GROUP_FLAG)
                return RCC_INVALID_USER_ID;
 
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
 
    // Find user
    for(i = 0; i < m_userCount; i++)
@@ -785,7 +785,7 @@ DWORD NXCORE_EXPORTABLE SetUserPassword(DWORD id, const TCHAR *newPassword, cons
 
 UserDatabaseObject NXCORE_EXPORTABLE **OpenUserDatabase(int *count)
 {
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
        *count = m_userCount;
        return m_users;
 }
@@ -809,7 +809,7 @@ const TCHAR NXCORE_EXPORTABLE *GetUserDbObjectAttr(DWORD id, const TCHAR *name)
 {
        const TCHAR *value = NULL;
 
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
 
    for(int i = 0; i < m_userCount; i++)
                if (m_users[i]->getId() == id)
@@ -835,7 +835,7 @@ DWORD NXCORE_EXPORTABLE GetUserDbObjectAttrAsULong(DWORD id, const TCHAR *name)
 
 void NXCORE_EXPORTABLE SetUserDbObjectAttr(DWORD id, const TCHAR *name, const TCHAR *value)
 {
-   MutexLock(m_mutexUserDatabaseAccess, INFINITE);
+   MutexLock(m_mutexUserDatabaseAccess);
 
    for(int i = 0; i < m_userCount; i++)
                if (m_users[i]->getId() == id)
index 9d987f6..112e903 100644 (file)
@@ -54,7 +54,7 @@ DWORD WatchdogAddThread(const TCHAR *szName, time_t tNotifyInterval)
 {
    DWORD dwId;
 
-   MutexLock(m_mutexWatchdogAccess, INFINITE);
+   MutexLock(m_mutexWatchdogAccess);
    _tcscpy(m_threadInfo[m_dwNumThreads].szName, szName);
    m_threadInfo[m_dwNumThreads].tNotifyInterval = tNotifyInterval;
    m_threadInfo[m_dwNumThreads].tLastCheck = time(NULL);
@@ -85,7 +85,7 @@ void WatchdogNotify(DWORD dwId)
    if (IsShutdownInProgress())
       return;
 
-   MutexLock(m_mutexWatchdogAccess, INFINITE);
+   MutexLock(m_mutexWatchdogAccess);
    if (dwId < m_dwNumThreads)
    {
       if (m_threadInfo[dwId].bNotResponding)
@@ -106,7 +106,7 @@ void WatchdogPrintStatus(CONSOLE_CTX pCtx)
    DWORD i;
 
    ConsolePrintf(pCtx, _T("\x1b[1m%-48s Interval Status\x1b[0m\n----------------------------------------------------------------------------\n"), _T("Thread"));
-   MutexLock(m_mutexWatchdogAccess, INFINITE);
+   MutexLock(m_mutexWatchdogAccess);
    for(i = 0; i < m_dwNumThreads; i++)
       ConsolePrintf(pCtx, _T("%-48s %-8ld \x1b[%s;1m%s\x1b[0m\n"), m_threadInfo[i].szName, (long)m_threadInfo[i].tNotifyInterval,
                              (m_threadInfo[i].bNotResponding ? _T("31") : _T("32")),
@@ -130,7 +130,7 @@ THREAD_RESULT THREAD_CALL WatchdogThread(void *arg)
          break;      // Shutdown has arrived
 
       // Walk through threads and check if they are alive
-      MutexLock(m_mutexWatchdogAccess, INFINITE);
+      MutexLock(m_mutexWatchdogAccess);
       currTime = time(NULL);
       for(i = 0; i < m_dwNumThreads; i++)
          if ((currTime - m_threadInfo[i].tLastCheck > m_threadInfo[i].tNotifyInterval) &&
index fe7f2a2..401fbec 100644 (file)
@@ -39,7 +39,7 @@ private:
        CONDITION m_condShutdown;
        THREAD m_hWatchdogThread;
 
-   void Lock() { MutexLock(m_mutex, INFINITE); }
+   void Lock() { MutexLock(m_mutex); }
    void Unlock() { MutexUnlock(m_mutex); }
 
    static void SendAlarmNotification(ClientSession *pSession, void *pArg);
index fe6a967..16907e8 100644 (file)
@@ -777,7 +777,6 @@ void ReloadCertificates();
 THREAD_RESULT NXCORE_EXPORTABLE THREAD_CALL SignalHandler(void *);
 #endif   /* not _WIN32 */
 
-void DbgTestMutex(MUTEX hMutex, const TCHAR *szName, CONSOLE_CTX pCtx);
 void DbgTestRWLock(RWLOCK hLock, const TCHAR *szName, CONSOLE_CTX pCtx);
 void DumpSessions(CONSOLE_CTX pCtx);
 void ShowPollerState(CONSOLE_CTX pCtx);
index a45f2b5..5e9ab4b 100644 (file)
@@ -214,7 +214,7 @@ private:
        WORD m_snmpRawValueType;                // Actual SNMP raw value type for input transformation
        WORD m_snmpPort;                                        // Custom SNMP port or 0 for node default
 
-   void lock() { MutexLock(m_hMutex, INFINITE); }
+   void lock() { MutexLock(m_hMutex); }
    void unlock() { MutexUnlock(m_hMutex); }
 
    void transform(ItemValue &value, time_t nElapsedTime);
index 5271e1c..2330a2f 100644 (file)
@@ -257,9 +257,9 @@ protected:
        
        StringMap m_customAttributes;
 
-   void LockData() { MutexLock(m_mutexData, INFINITE); }
+   void LockData() { MutexLock(m_mutexData); }
    void UnlockData() { MutexUnlock(m_mutexData); }
-   void LockACL() { MutexLock(m_mutexACL, INFINITE); }
+   void LockACL() { MutexLock(m_mutexACL); }
    void UnlockACL() { MutexUnlock(m_mutexACL); }
    void LockParentList(BOOL bWrite) 
    { 
@@ -378,7 +378,7 @@ inline DWORD NetObj::RefCount()
 { 
    DWORD dwRefCount;
 
-   MutexLock(m_mutexRefCount, INFINITE);
+   MutexLock(m_mutexRefCount);
    dwRefCount = m_dwRefCount;
    MutexUnlock(m_mutexRefCount);
    return dwRefCount; 
@@ -386,14 +386,14 @@ inline DWORD NetObj::RefCount()
 
 inline void NetObj::IncRefCount()
 { 
-   MutexLock(m_mutexRefCount, INFINITE);
+   MutexLock(m_mutexRefCount);
    m_dwRefCount++;
    MutexUnlock(m_mutexRefCount);
 }
 
 inline void NetObj::DecRefCount()
 { 
-   MutexLock(m_mutexRefCount, INFINITE);
+   MutexLock(m_mutexRefCount);
    if (m_dwRefCount > 0) 
       m_dwRefCount--; 
    MutexUnlock(m_mutexRefCount);
@@ -422,7 +422,7 @@ protected:
    void loadItemsFromDB();
    void destroyItems();
 
-       void lockDciAccess() { MutexLock(m_mutexDciAccess, INFINITE); }
+       void lockDciAccess() { MutexLock(m_mutexDciAccess); }
        void unlockDciAccess() { MutexUnlock(m_mutexDciAccess); }
 
 public:
@@ -745,13 +745,13 @@ protected:
        time_t m_topologyRebuildTimestamp;
        ServerJobQueue *m_jobQueue;
 
-   void pollerLock() { MutexLock(m_hPollerMutex, INFINITE); }
+   void pollerLock() { MutexLock(m_hPollerMutex); }
    void pollerUnlock() { MutexUnlock(m_hPollerMutex); }
 
-   void agentLock() { MutexLock(m_hAgentAccessMutex, INFINITE); }
+   void agentLock() { MutexLock(m_hAgentAccessMutex); }
    void agentUnlock() { MutexUnlock(m_hAgentAccessMutex); }
 
-   void routingTableLock() { MutexLock(m_mutexRTAccess, INFINITE); }
+   void routingTableLock() { MutexLock(m_mutexRTAccess); }
    void routingTableUnlock() { MutexUnlock(m_mutexRTAccess); }
 
    BOOL CheckSNMPIntegerValue(SNMP_Transport *pTransport, const TCHAR *pszOID, int nValue);
index 333fbbc..5e4582a 100644 (file)
@@ -197,7 +197,7 @@ private:
    ACL_ELEMENT *m_pElements;
    MUTEX m_hMutex;
 
-   void Lock(void) { MutexLock(m_hMutex, INFINITE); }
+   void Lock(void) { MutexLock(m_hMutex); }
    void Unlock(void) { MutexUnlock(m_hMutex); }
 
 public:
index 5b25439..a9acaac 100644 (file)
@@ -171,7 +171,7 @@ public:
        LogHandle(NXCORE_LOG *log);
        ~LogHandle();
 
-       void lock() { MutexLock(m_lock, INFINITE); }
+       void lock() { MutexLock(m_lock); }
        void unlock() { MutexUnlock(m_lock); }
 
        bool query(LogFilter *filter, INT64 *rowCount);
index 9a66c86..566db55 100644 (file)
@@ -65,7 +65,7 @@ private:
        SituationInstance **m_instanceList;
        MUTEX m_accessMutex;
        
-       void Lock() { MutexLock(m_accessMutex, INFINITE); }
+       void Lock() { MutexLock(m_accessMutex); }
        void Unlock() { MutexUnlock(m_accessMutex); }
 
 public:
index 531caa4..01555fb 100644 (file)
@@ -415,7 +415,7 @@ private:
 protected:
    void destroyResultData();
    BOOL sendMessage(CSCPMessage *pMsg);
-   CSCPMessage *waitForMessage(WORD wCode, DWORD dwId, DWORD dwTimeOut) { return m_pMsgWaitQueue->WaitForMessage(wCode, dwId, dwTimeOut); }
+   CSCPMessage *waitForMessage(WORD wCode, DWORD dwId, DWORD dwTimeOut) { return m_pMsgWaitQueue->waitForMessage(wCode, dwId, dwTimeOut); }
    DWORD waitForRCC(DWORD dwRqId, DWORD dwTimeOut);
    DWORD setupEncryption(RSA *pServerKey);
    DWORD authenticate(BOOL bProxyData);
@@ -429,7 +429,7 @@ protected:
        virtual bool processCustomMessage(CSCPMessage *pMsg);
        virtual void onFileDownload(BOOL success);
 
-   void Lock() { MutexLock(m_mutexDataLock, INFINITE); }
+   void Lock() { MutexLock(m_mutexDataLock); }
    void Unlock() { MutexUnlock(m_mutexDataLock); }
        NXCPEncryptionContext *acquireEncryptionContext();
 
@@ -537,7 +537,7 @@ private:
    NXCPEncryptionContext *m_ctx;
        DWORD m_commandTimeout;
 
-   void ReceiverThread(void);
+   void ReceiverThread();
    static THREAD_RESULT THREAD_CALL ReceiverThreadStarter(void *);
 
 protected:
@@ -545,8 +545,8 @@ protected:
    DWORD SetupEncryption(RSA *pServerKey);
        DWORD ConnectToService(DWORD service);
 
-   void Lock(void) { MutexLock(m_mutexDataLock, INFINITE); }
-   void Unlock(void) { MutexUnlock(m_mutexDataLock); }
+   void Lock() { MutexLock(m_mutexDataLock); }
+   void Unlock() { MutexUnlock(m_mutexDataLock); }
 
    virtual void PrintMsg(const TCHAR *format, ...);
 
@@ -559,7 +559,7 @@ public:
        void Disconnect();
 
    BOOL SendMessage(CSCPMessage *msg);
-   CSCPMessage *WaitForMessage(WORD code, DWORD id, DWORD timeOut) { return m_msgWaitQueue->WaitForMessage(code, id, timeOut); }
+   CSCPMessage *WaitForMessage(WORD code, DWORD id, DWORD timeOut) { return m_msgWaitQueue->waitForMessage(code, id, timeOut); }
    DWORD WaitForRCC(DWORD rqId, DWORD timeOut);
 
    DWORD Nop(void);
index b881ee7..8b64c40 100644 (file)
@@ -303,13 +303,13 @@ void AgentConnection::ReceiverThread()
                                        delete pMsg;
                                        break;
                                case CMD_REQUEST_COMPLETED:
-                                       m_pMsgWaitQueue->Put(pMsg);
+                                       m_pMsgWaitQueue->put(pMsg);
                                        break;
                                default:
                                        if (processCustomMessage(pMsg))
                                                delete pMsg;
                                        else
-                                               m_pMsgWaitQueue->Put(pMsg);
+                                               m_pMsgWaitQueue->put(pMsg);
                                        break;
                        }
                }
@@ -785,7 +785,7 @@ DWORD AgentConnection::waitForRCC(DWORD dwRqId, DWORD dwTimeOut)
    CSCPMessage *pMsg;
    DWORD dwRetCode;
 
-   pMsg = m_pMsgWaitQueue->WaitForMessage(CMD_REQUEST_COMPLETED, dwRqId, dwTimeOut);
+   pMsg = m_pMsgWaitQueue->waitForMessage(CMD_REQUEST_COMPLETED, dwRqId, dwTimeOut);
    if (pMsg != NULL)
    {
       dwRetCode = pMsg->GetVariableLong(VID_RCC);
index 34e2f2d..5253e7a 100644 (file)
@@ -245,7 +245,7 @@ void ISC::ReceiverThread()
                {
                        // Create message object from raw message
                        pMsg = new CSCPMessage(pRawMsg, m_protocolVersion);
-                       m_msgWaitQueue->Put(pMsg);
+                       m_msgWaitQueue->put(pMsg);
                }
    }
 
@@ -477,7 +477,7 @@ DWORD ISC::WaitForRCC(DWORD rqId, DWORD timeOut)
    CSCPMessage *pMsg;
    DWORD dwRetCode;
 
-   pMsg = m_msgWaitQueue->WaitForMessage(CMD_REQUEST_COMPLETED, rqId, timeOut);
+   pMsg = m_msgWaitQueue->waitForMessage(CMD_REQUEST_COMPLETED, rqId, timeOut);
    if (pMsg != NULL)
    {
       dwRetCode = pMsg->GetVariableLong(VID_RCC);
index e691b3d..6213a80 100644 (file)
@@ -57,7 +57,7 @@ static THREAD_RESULT THREAD_CALL RecvThread(void *arg)
    CSCP_MESSAGE *pRawMsg;
    CSCPMessage *pMsg;
        CSCP_BUFFER *pMsgBuffer;
-       CSCP_ENCRYPTION_CONTEXT *pCtx = NULL;
+       NXCPEncryptionContext *pCtx = NULL;
    BYTE *pDecryptionBuffer = NULL;
    int iErr;
    char *xml;