Fixed incorrect data type constants usage; confusing DT_xxx and DTYPE_xxx constants...
authorVictor Kirhenshtein <victor@netxms.org>
Fri, 3 Sep 2004 12:48:19 +0000 (12:48 +0000)
committerVictor Kirhenshtein <victor@netxms.org>
Fri, 3 Sep 2004 12:48:19 +0000 (12:48 +0000)
12 files changed:
include/nms_cscp.h
include/nxclapi.h
include/nxcscpapi.h
src/console/win32/DCIDataView.cpp
src/console/win32/DCIThresholdsPage.cpp
src/console/win32/Graph.cpp
src/libnxcl/datacoll.cpp
src/server/core/dcitem.cpp
src/server/core/dcithreshold.cpp
src/server/core/discovery.cpp
src/server/core/np.cpp
src/server/core/session.cpp

index 680b5ef..e60411a 100644 (file)
@@ -144,12 +144,12 @@ typedef struct
 // Data types
 //
 
-#define DT_INTEGER   0
-#define DT_STRING    1
-#define DT_INT64     2
-#define DT_INT16     3
-#define DT_BINARY    4
-#define DT_FLOAT     5
+#define CSCP_DT_INTEGER    0
+#define CSCP_DT_STRING     1
+#define CSCP_DT_INT64      2
+#define CSCP_DT_INT16      3
+#define CSCP_DT_BINARY     4
+#define CSCP_DT_FLOAT      5
 
 
 //
index 0f1a9ad..96cffc1 100644 (file)
@@ -288,10 +288,10 @@ typedef unsigned long HREQUEST;
 // Data types
 //
 
-#define DTYPE_INTEGER   0
-#define DTYPE_INT64     1
-#define DTYPE_STRING    2
-#define DTYPE_FLOAT     3
+#define DCI_DT_INTEGER     0
+#define DCI_DT_INT64       1
+#define DCI_DT_STRING      2
+#define DCI_DT_FLOAT       3
 
 
 //
index 4457944..29dda9e 100644 (file)
@@ -79,12 +79,12 @@ public:
 
    BOOL IsVariableExist(DWORD dwVarId) { return (FindVariable(dwVarId) != INVALID_INDEX) ? TRUE : FALSE; }
 
-   void SetVariable(DWORD dwVarId, WORD wValue) { Set(dwVarId, DT_INT16, &wValue); }
-   void SetVariable(DWORD dwVarId, DWORD dwValue) { Set(dwVarId, DT_INTEGER, &dwValue); }
-   void SetVariable(DWORD dwVarId, QWORD qwValue) { Set(dwVarId, DT_INT64, &qwValue); }
-   void SetVariable(DWORD dwVarId, double dValue) { Set(dwVarId, DT_FLOAT, &dValue); }
-   void SetVariable(DWORD dwVarId, char *szValue) { Set(dwVarId, DT_STRING, szValue); }
-   void SetVariable(DWORD dwVarId, BYTE *pValue, DWORD dwSize) { Set(dwVarId, DT_BINARY, pValue, dwSize); }
+   void SetVariable(DWORD dwVarId, WORD wValue) { Set(dwVarId, CSCP_DT_INT16, &wValue); }
+   void SetVariable(DWORD dwVarId, DWORD dwValue) { Set(dwVarId, CSCP_DT_INTEGER, &dwValue); }
+   void SetVariable(DWORD dwVarId, QWORD qwValue) { Set(dwVarId, CSCP_DT_INT64, &qwValue); }
+   void SetVariable(DWORD dwVarId, double dValue) { Set(dwVarId, CSCP_DT_FLOAT, &dValue); }
+   void SetVariable(DWORD dwVarId, char *szValue) { Set(dwVarId, CSCP_DT_STRING, szValue); }
+   void SetVariable(DWORD dwVarId, BYTE *pValue, DWORD dwSize) { Set(dwVarId, CSCP_DT_BINARY, pValue, dwSize); }
    void SetVariableToInt32Array(DWORD dwVarId, DWORD dwNumElements, DWORD *pdwData);
 
    DWORD GetVariableLong(DWORD dwVarId);
index 2c75ee6..656ff3e 100644 (file)
@@ -144,7 +144,7 @@ void CDCIDataView::OnViewRefresh()
          iItem = m_wndListCtrl.InsertItem(0x7FFFFFFF, szBuffer);
          if (iItem != -1)
          {
-            if (pData->wDataType == DTYPE_STRING)
+            if (pData->wDataType == DCI_DT_STRING)
             {
                m_wndListCtrl.SetItemText(iItem, 1, pRow->value.szString);
             }
@@ -152,13 +152,13 @@ void CDCIDataView::OnViewRefresh()
             {
                switch(pData->wDataType)
                {
-                  case DTYPE_INTEGER:
+                  case DCI_DT_INTEGER:
                      sprintf(szBuffer, "%ld", pRow->value.dwInt32);
                      break;
-                  case DTYPE_INT64:
+                  case DCI_DT_INT64:
                      sprintf(szBuffer, "%I64", pRow->value.qwInt64);
                      break;
-                  case DTYPE_FLOAT:
+                  case DCI_DT_FLOAT:
                      sprintf(szBuffer, "%f", pRow->value.dFloat);
                      break;
                   default:
index 34b2696..f12bbb2 100644 (file)
@@ -124,16 +124,16 @@ void CDCIThresholdsPage::UpdateListEntry(int iItem, DWORD dwIndex)
 
    switch(m_pItem->iDataType)
    {
-      case DTYPE_INTEGER:
+      case DCI_DT_INTEGER:
          sprintf(szValue, "%d", m_pItem->pThresholdList[dwIndex].value.dwInt32);
          break;
-      case DTYPE_INT64:
+      case DCI_DT_INT64:
          sprintf(szValue, "%64I", m_pItem->pThresholdList[dwIndex].value.qwInt64);
          break;
-      case DTYPE_FLOAT:
+      case DCI_DT_FLOAT:
          sprintf(szValue, "%f", m_pItem->pThresholdList[dwIndex].value.dFloat);
          break;
-      case DTYPE_STRING:
+      case DCI_DT_STRING:
          sprintf(szValue, "\"%s\"", m_pItem->pThresholdList[dwIndex].value.szString);
          break;
    }
@@ -165,19 +165,19 @@ BOOL CDCIThresholdsPage::EditThreshold(NXC_DCI_THRESHOLD *pThreshold)
    dlg.m_dwArg1 = pThreshold->dwArg1;
    switch(m_pItem->iDataType)
    {
-      case DTYPE_INTEGER:
+      case DCI_DT_INTEGER:
          sprintf(szBuffer, "%d", pThreshold->value.dwInt32);
          dlg.m_strValue = szBuffer;
          break;
-      case DTYPE_INT64:
+      case DCI_DT_INT64:
          sprintf(szBuffer, "%64I", pThreshold->value.qwInt64);
          dlg.m_strValue = szBuffer;
          break;
-      case DTYPE_FLOAT:
+      case DCI_DT_FLOAT:
          sprintf(szBuffer, "%f", pThreshold->value.dFloat);
          dlg.m_strValue = szBuffer;
          break;
-      case DTYPE_STRING:
+      case DCI_DT_STRING:
          dlg.m_strValue = pThreshold->value.szString;
          break;
    }
@@ -188,16 +188,16 @@ BOOL CDCIThresholdsPage::EditThreshold(NXC_DCI_THRESHOLD *pThreshold)
       pThreshold->wOperation = (WORD)dlg.m_iOperation;
       switch(m_pItem->iDataType)
       {
-         case DTYPE_INTEGER:
+         case DCI_DT_INTEGER:
             pThreshold->value.dwInt32 = strtol((LPCTSTR)dlg.m_strValue, NULL, 0);
             break;
-         case DTYPE_INT64:
+         case DCI_DT_INT64:
             /* TODO: add conversion for 64 bit integers */
             break;
-         case DTYPE_FLOAT:
+         case DCI_DT_FLOAT:
             pThreshold->value.dFloat = strtod((LPCTSTR)dlg.m_strValue, NULL);
             break;
-         case DTYPE_STRING:
+         case DCI_DT_STRING:
             strcpy(pThreshold->value.szString, (LPCTSTR)dlg.m_strValue);
             break;
       }
index 551bb4e..4018eb8 100644 (file)
@@ -6,10 +6,10 @@
 #include "Graph.h"
 #include <math.h>
 
-#define ROW_DATA(row, dt)  ((dt == DTYPE_STRING) ? strtod(row->value.szString, NULL) : \
-                            ((dt == DTYPE_INTEGER) ? row->value.dwInt32 : \
-                             ((dt == DTYPE_INT64) ? row->value.qwInt64 : \
-                              ((dt == DTYPE_FLOAT) ? row->value.dFloat : 0) \
+#define ROW_DATA(row, dt)  ((dt == DCI_DT_STRING) ? strtod(row->value.szString, NULL) : \
+                            ((dt == DCI_DT_INTEGER) ? row->value.dwInt32 : \
+                             ((dt == DCI_DT_INT64) ? row->value.qwInt64 : \
+                              ((dt == DCI_DT_FLOAT) ? row->value.dFloat : 0) \
                              ) \
                             ) \
                            )
index afe691c..e6e5426 100644 (file)
@@ -73,16 +73,16 @@ void ProcessDCI(CSCPMessage *pMsg)
                m_pItemList->pItems[i].pThresholdList[j].wOperation = ntohs(dct.wOperation);
                switch(m_pItemList->pItems[i].iDataType)
                {
-                  case DT_INTEGER:
+                  case DCI_DT_INTEGER:
                      m_pItemList->pItems[i].pThresholdList[j].value.dwInt32 = ntohl(dct.value.dwInt32);
                      break;
-                  case DT_INT64:
+                  case DCI_DT_INT64:
                      m_pItemList->pItems[i].pThresholdList[j].value.qwInt64 = ntohq(dct.value.qwInt64);
                      break;
-                  case DT_FLOAT:
+                  case DCI_DT_FLOAT:
                      m_pItemList->pItems[i].pThresholdList[j].value.dFloat = ntohd(dct.value.dFloat);
                      break;
-                  case DT_STRING:
+                  case DCI_DT_STRING:
                      strcpy(m_pItemList->pItems[i].pThresholdList[j].value.szString, dct.value.szString);
                      break;
                   default:
@@ -252,16 +252,16 @@ DWORD LIBNXCL_EXPORTABLE NXCUpdateDCI(DWORD dwNodeId, NXC_DCI *pItem)
       dct.wOperation = htons(pItem->pThresholdList[i].wOperation);
       switch(pItem->iDataType)
       {
-         case DT_INTEGER:
+         case DCI_DT_INTEGER:
             dct.value.dwInt32 = htonl(pItem->pThresholdList[i].value.dwInt32);
             break;
-         case DT_INT64:
+         case DCI_DT_INT64:
             dct.value.qwInt64 = htonq(pItem->pThresholdList[i].value.qwInt64);
             break;
-         case DT_FLOAT:
+         case DCI_DT_FLOAT:
             dct.value.dFloat = htond(pItem->pThresholdList[i].value.dFloat);
             break;
-         case DT_STRING:
+         case DCI_DT_STRING:
             strcpy(dct.value.szString, pItem->pThresholdList[i].value.szString);
             break;
          default:
@@ -410,13 +410,13 @@ DWORD LIBNXCL_EXPORTABLE NXCGetDCIData(DWORD dwNodeId, DWORD dwItemId, DWORD dwM
             pDst->dwTimeStamp = ntohl(pSrc->dwTimeStamp);
             switch((*ppData)->wDataType)
             {
-               case DTYPE_INTEGER:
+               case DCI_DT_INTEGER:
                   pDst->value.dwInt32 = ntohl(pSrc->value.dwInteger);
                   break;
-               case DTYPE_FLOAT:
+               case DCI_DT_FLOAT:
                   pDst->value.dFloat = ntohd(pSrc->value.dFloat);
                   break;
-               case DTYPE_STRING:
+               case DCI_DT_STRING:
                   strcpy(pDst->value.szString, pSrc->value.szString);
                   break;
             }
index 4b4c3c6..1830ddc 100644 (file)
@@ -33,7 +33,7 @@ DCItem::DCItem()
    m_dwNumThresholds = 0;
    m_ppThresholdList = NULL;
    m_iBusy = 0;
-   m_iDataType = DTYPE_INTEGER;
+   m_iDataType = DCI_DT_INTEGER;
    m_iPollingInterval = 3600;
    m_iRetentionTime = 0;
    m_iSource = DS_INTERNAL;
index d3e784d..cac88bb 100644 (file)
@@ -64,13 +64,13 @@ Threshold::Threshold(DB_RESULT hResult, int iRow, DCItem *pRelatedItem)
 
    switch(m_iDataType)
    {
-      case DTYPE_INTEGER:
+      case DCI_DT_INTEGER:
          m_value.iInteger = strtol(m_pszValueStr, NULL, 0);
          break;
-      case DTYPE_INT64:
+      case DCI_DT_INT64:
          /* TODO: add 64-bit string to binary conversion */
          break;
-      case DTYPE_FLOAT:
+      case DCI_DT_FLOAT:
          m_value.dFloat = strtod(m_pszValueStr, NULL);
          break;
       default:
@@ -162,16 +162,16 @@ int Threshold::Check(const char *pszValue)
       case F_LAST:         // Check last value only
          switch(m_iDataType)
          {
-            case DTYPE_INTEGER:
+            case DCI_DT_INTEGER:
                fvalue.iInteger = strtol(pszValue, NULL, 0);
                break;
-            case DTYPE_INT64:
+            case DCI_DT_INT64:
                /* TODO: add 64-bit conversion code */
                break;
-            case DTYPE_FLOAT:
+            case DCI_DT_FLOAT:
                fvalue.dFloat = strtod(pszValue, NULL);
                break;
-            case DTYPE_STRING:
+            case DCI_DT_STRING:
                fvalue.pszStr = pszValue;
                break;
             default:
@@ -195,13 +195,13 @@ int Threshold::Check(const char *pszValue)
       case OP_LE:    // Less
          switch(m_iDataType)
          {
-            case DTYPE_INTEGER:
+            case DCI_DT_INTEGER:
                bMatch = (fvalue.iInteger < m_value.iInteger);
                break;
-            case DTYPE_INT64:
+            case DCI_DT_INT64:
                bMatch = (fvalue.qwInt64 < m_value.qwInt64);
                break;
-            case DTYPE_FLOAT:
+            case DCI_DT_FLOAT:
                bMatch = (fvalue.dFloat < m_value.dFloat);
                break;
          }
@@ -209,13 +209,13 @@ int Threshold::Check(const char *pszValue)
       case OP_LE_EQ: // Less or equal
          switch(m_iDataType)
          {
-            case DTYPE_INTEGER:
+            case DCI_DT_INTEGER:
                bMatch = (fvalue.iInteger <= m_value.iInteger);
                break;
-            case DTYPE_INT64:
+            case DCI_DT_INT64:
                bMatch = (fvalue.qwInt64 <= m_value.qwInt64);
                break;
-            case DTYPE_FLOAT:
+            case DCI_DT_FLOAT:
                bMatch = (fvalue.dFloat <= m_value.dFloat);
                break;
          }
@@ -223,16 +223,16 @@ int Threshold::Check(const char *pszValue)
       case OP_EQ:    // Equal
          switch(m_iDataType)
          {
-            case DTYPE_INTEGER:
+            case DCI_DT_INTEGER:
                bMatch = (fvalue.iInteger == m_value.iInteger);
                break;
-            case DTYPE_INT64:
+            case DCI_DT_INT64:
                bMatch = (fvalue.qwInt64 == m_value.qwInt64);
                break;
-            case DTYPE_FLOAT:
+            case DCI_DT_FLOAT:
                bMatch = (fvalue.dFloat == m_value.dFloat);
                break;
-            case DTYPE_STRING:
+            case DCI_DT_STRING:
                bMatch = !strcmp(fvalue.pszStr, m_pszValueStr);
                break;
          }
@@ -240,13 +240,13 @@ int Threshold::Check(const char *pszValue)
       case OP_GT_EQ: // Greater or equal
          switch(m_iDataType)
          {
-            case DTYPE_INTEGER:
+            case DCI_DT_INTEGER:
                bMatch = (fvalue.iInteger >= m_value.iInteger);
                break;
-            case DTYPE_INT64:
+            case DCI_DT_INT64:
                bMatch = (fvalue.qwInt64 >= m_value.qwInt64);
                break;
-            case DTYPE_FLOAT:
+            case DCI_DT_FLOAT:
                bMatch = (fvalue.dFloat >= m_value.dFloat);
                break;
          }
@@ -254,13 +254,13 @@ int Threshold::Check(const char *pszValue)
       case OP_GT:    // Greater
          switch(m_iDataType)
          {
-            case DTYPE_INTEGER:
+            case DCI_DT_INTEGER:
                bMatch = (fvalue.iInteger > m_value.iInteger);
                break;
-            case DTYPE_INT64:
+            case DCI_DT_INT64:
                bMatch = (fvalue.qwInt64 > m_value.qwInt64);
                break;
-            case DTYPE_FLOAT:
+            case DCI_DT_FLOAT:
                bMatch = (fvalue.dFloat > m_value.dFloat);
                break;
          }
@@ -268,28 +268,28 @@ int Threshold::Check(const char *pszValue)
       case OP_NE:    // Not equal
          switch(m_iDataType)
          {
-            case DTYPE_INTEGER:
+            case DCI_DT_INTEGER:
                bMatch = (fvalue.iInteger != m_value.iInteger);
                break;
-            case DTYPE_INT64:
+            case DCI_DT_INT64:
                bMatch = (fvalue.qwInt64 != m_value.qwInt64);
                break;
-            case DTYPE_FLOAT:
+            case DCI_DT_FLOAT:
                bMatch = (fvalue.dFloat != m_value.dFloat);
                break;
-            case DTYPE_STRING:
+            case DCI_DT_STRING:
                bMatch = strcmp(fvalue.pszStr, m_pszValueStr);
                break;
          }
          break;
       case OP_LIKE:
          // This operation can be performed only on strings
-         if (m_iDataType == DTYPE_STRING)
+         if (m_iDataType == DCI_DT_STRING)
             bMatch = MatchString(m_pszValueStr, fvalue.pszStr, TRUE);
          break;
       case OP_NOTLIKE:
          // This operation can be performed only on strings
-         if (m_iDataType == DTYPE_STRING)
+         if (m_iDataType == DCI_DT_STRING)
             bMatch = !MatchString(m_pszValueStr, fvalue.pszStr, TRUE);
          break;
       default:
@@ -317,16 +317,16 @@ void Threshold::CreateMessage(DCI_THRESHOLD *pData)
    pData->dwArg2 = htonl(m_iParam2);
    switch(m_iDataType)
    {
-      case DTYPE_INTEGER:
+      case DCI_DT_INTEGER:
          pData->value.dwInt32 = htonl(m_value.iInteger);
          break;
-      case DTYPE_INT64:
+      case DCI_DT_INT64:
          pData->value.qwInt64 = htonq(m_value.qwInt64);
          break;
-      case DTYPE_FLOAT:
+      case DCI_DT_FLOAT:
          pData->value.dFloat = htond(m_value.dFloat);
          break;
-      case DTYPE_STRING:
+      case DCI_DT_STRING:
          strcpy(pData->value.szString,  m_pszValueStr);
          break;
       default:
@@ -349,12 +349,12 @@ void Threshold::UpdateFromMessage(DCI_THRESHOLD *pData)
    safe_free(m_pszValueStr);
    switch(m_iDataType)
    {
-      case DTYPE_INTEGER:
+      case DCI_DT_INTEGER:
          m_value.iInteger = ntohl(pData->value.dwInt32);
          m_pszValueStr = (char *)malloc(32);
          sprintf(m_pszValueStr, "%ld", m_value.iInteger);
          break;
-      case DTYPE_INT64:
+      case DCI_DT_INT64:
          m_value.qwInt64 = ntohq(pData->value.qwInt64);
          m_pszValueStr = (char *)malloc(32);
 #ifdef _WIN32
@@ -363,12 +363,12 @@ void Threshold::UpdateFromMessage(DCI_THRESHOLD *pData)
          sprintf(m_pszValueStr, "%lld", m_value.qwInt64);
 #endif
          break;
-      case DTYPE_FLOAT:
+      case DCI_DT_FLOAT:
          m_value.dFloat = ntohd(pData->value.dFloat);
          m_pszValueStr = (char *)malloc(32);
          sprintf(m_pszValueStr, "%f", m_value.dFloat);
          break;
-      case DTYPE_STRING:
+      case DCI_DT_STRING:
          m_pszValueStr = strdup(pData->value.szString);
          break;
       default:
index 881f488..032d8e1 100644 (file)
@@ -61,7 +61,7 @@ void CheckForMgmtNode(void)
                {
                   g_dwMgmtNode = pNode->Id();   // Set local management node ID
                   /* DEBUG */
-                  pNode->AddItem(new DCItem(CreateUniqueId(IDG_ITEM), "Status", DS_INTERNAL, DTYPE_INTEGER, 60, 30, pNode));
+                  pNode->AddItem(new DCItem(CreateUniqueId(IDG_ITEM), "Status", DS_INTERNAL, DCI_DT_INTEGER, 60, 30, pNode));
                }
                break;
             }
index 3cee634..6359dba 100644 (file)
@@ -58,7 +58,7 @@ NetObj *PollNewNode(DWORD dwIpAddr, DWORD dwNetMask, DWORD dwFlags)
    }
 
    // DEBUG
-   pNode->AddItem(new DCItem(CreateUniqueId(IDG_ITEM), "Status", DS_INTERNAL, DTYPE_INTEGER, 60, 30, pNode));
+   pNode->AddItem(new DCItem(CreateUniqueId(IDG_ITEM), "Status", DS_INTERNAL, DCI_DT_INTEGER, 60, 30, pNode));
    return pNode;
 }
 
index 006ce1e..0fd300f 100644 (file)
@@ -1461,7 +1461,7 @@ void ClientSession::ModifyNodeDCI(CSCPMessage *pRequest)
                   case CMD_CREATE_NEW_DCI:
                      // Create dummy DCI
                      pItem = new DCItem(CreateUniqueId(IDG_ITEM), "no name", DS_INTERNAL, 
-                                        DTYPE_INTEGER, 60, 30, (Node *)pObject);
+                                        DCI_DT_INTEGER, 60, 30, (Node *)pObject);
                      pItem->SetStatus(ITEM_STATUS_DISABLED);
                      if (((Node *)pObject)->AddItem(pItem))
                      {
@@ -1618,13 +1618,13 @@ void ClientSession::GetCollectedData(CSCPMessage *pRequest)
                pCurr->dwTimeStamp = htonl(DBGetFieldAsyncULong(hResult, 0));
                switch(iType)
                {
-                  case DTYPE_INTEGER:
+                  case DCI_DT_INTEGER:
                      pCurr->value.dwInteger = htonl(DBGetFieldAsyncULong(hResult, 1));
                      break;
-                  case DTYPE_FLOAT:
+                  case DCI_DT_FLOAT:
                      pCurr->value.dFloat = htond(DBGetFieldAsyncDouble(hResult, 1));
                      break;
-                  case DTYPE_STRING:
+                  case DCI_DT_STRING:
                      DBGetFieldAsync(hResult, 1, pCurr->value.szString, MAX_DCI_STRING_VALUE);
                      break;
                }