msgqueue.h
上传用户:uncom666
上传日期:2020-03-30
资源大小:1426k
文件大小:7k
源码类别:

SNMP编程

开发平台:

Visual C++

  1. /*_############################################################################
  2.   _## 
  3.   _##  msgqueue.h  
  4.   _##
  5.   _##  SNMP++v3.2.24
  6.   _##  -----------------------------------------------
  7.   _##  Copyright (c) 2001-2009 Jochen Katz, Frank Fock
  8.   _##
  9.   _##  This software is based on SNMP++2.6 from Hewlett Packard:
  10.   _##  
  11.   _##    Copyright (c) 1996
  12.   _##    Hewlett-Packard Company
  13.   _##  
  14.   _##  ATTENTION: USE OF THIS SOFTWARE IS SUBJECT TO THE FOLLOWING TERMS.
  15.   _##  Permission to use, copy, modify, distribute and/or sell this software 
  16.   _##  and/or its documentation is hereby granted without fee. User agrees 
  17.   _##  to display the above copyright notice and this license notice in all 
  18.   _##  copies of the software and any documentation of the software. User 
  19.   _##  agrees to assume all liability for the use of the software; 
  20.   _##  Hewlett-Packard and Jochen Katz make no representations about the 
  21.   _##  suitability of this software for any purpose. It is provided 
  22.   _##  "AS-IS" without warranty of any kind, either express or implied. User 
  23.   _##  hereby grants a royalty-free license to any and all derivatives based
  24.   _##  upon this software code base. 
  25.   _##  
  26.   _##  Stuttgart, Germany, Fri May 29 22:35:14 CEST 2009 
  27.   _##  
  28.   _##########################################################################*/
  29. /*===================================================================
  30.   Copyright (c) 1999
  31.   Hewlett-Packard Company
  32.   ATTENTION: USE OF THIS SOFTWARE IS SUBJECT TO THE FOLLOWING TERMS.
  33.   Permission to use, copy, modify, distribute and/or sell this software
  34.   and/or its documentation is hereby granted without fee. User agrees
  35.   to display the above copyright notice and this license notice in all
  36.   copies of the software and any documentation of the software. User
  37.   agrees to assume all liability for the use of the software; Hewlett-Packard
  38.   makes no representations about the suitability of this software for any
  39.   purpose. It is provided "AS-IS without warranty of any kind,either express
  40.   or implied. User hereby grants a royalty-free license to any and all
  41.   derivatives based upon this software code base.
  42.       M S G Q U E U E . H
  43.       CSNMPMessageQueue CLASS DEFINITION
  44.       COPYRIGHT HEWLETT PACKARD COMPANY 1999
  45.       INFORMATION NETWORKS DIVISION
  46.       NETWORK MANAGEMENT SECTION
  47.       DESIGN + AUTHOR:     Tom Murray
  48.       DESCRIPTION:
  49. Queue for holing SNMP event sources (outstanding snmp messages)
  50. =====================================================================*/
  51. // $Id: msgqueue.h 1541 2009-05-29 11:29:22Z katz $
  52. #ifndef _MSGQUEUE
  53. #define _MSGQUEUE
  54. //----[ includes ]-----------------------------------------------------
  55. #include <sys/types.h> // NOTE:  due to 10.10 bug, order is important
  56. //   in that all routines must include types.h
  57. //   and time.h in same order otherwise you
  58. //   will get conflicting definitions of
  59. //   "fd_set" resulting in link time errors.
  60. #ifndef WIN32
  61. #if !(defined CPU && CPU == PPC603)
  62. #include <sys/time.h> // time stuff and fd_set
  63. #endif
  64. #endif
  65. //----[ snmp++ includes ]----------------------------------------------
  66. #include "snmp_pp/config_snmp_pp.h"
  67. #include "snmp_pp/address.h"
  68. #include "snmp_pp/target.h"
  69. #include "snmp_pp/pdu.h"
  70. #include "snmp_pp/msec.h"
  71. #include "snmp_pp/uxsnmp.h"
  72. #include "snmp_pp/eventlist.h"
  73. #ifdef SNMP_PP_NAMESPACE
  74. namespace Snmp_pp {
  75. #endif
  76. //----[ defines ]------------------------------------------------------
  77. //----[ CSNMPMessage class ]-------------------------------------------
  78.   /*-----------------------------------------------------------*/
  79.   /* CSNMPMessage        */
  80.   /*   a description of a single MIB access operation.        */
  81.   /*-----------------------------------------------------------*/
  82. class DLLOPT CSNMPMessage
  83. {
  84.  public:
  85.   CSNMPMessage(unsigned long id,
  86.        Snmp * snmp,
  87.        SnmpSocket socket,
  88.        const SnmpTarget &target,
  89.        Pdu &pdu,
  90.        unsigned char * rawPdu,
  91.        size_t rawPduLen,
  92.        const Address & address,
  93.        snmp_callback callBack,
  94.        void * callData);
  95.   virtual ~CSNMPMessage();
  96.   unsigned long GetId() const { return m_uniqueId; };
  97.   void ResetId(const unsigned long newId) { m_uniqueId = newId; };
  98.   void SetSendTime();
  99.   void GetSendTime(msec &sendTime) const { sendTime = m_sendTime; };
  100.   SnmpSocket GetSocket() const { return m_socket; };
  101.   int SetPdu(const int reason, const Pdu &pdu, const UdpAddress &fromaddress);
  102.   int GetPdu(int &reason, Pdu &pdu)
  103.                                  { pdu = m_pdu; reason = m_reason; return 0; };
  104.   int GetReceived() const { return m_received; };
  105.   int ResendMessage();
  106.   int Callback(const int reason);
  107.   SnmpTarget *GetTarget() { return m_target; };
  108.  protected:
  109.   unsigned long   m_uniqueId;
  110.   msec   m_sendTime;
  111.   Snmp *   m_snmp;
  112.   SnmpSocket   m_socket;
  113.   SnmpTarget *   m_target;
  114.   Pdu   m_pdu;
  115.   unsigned char * m_rawPdu;
  116.   size_t   m_rawPduLen;
  117.   Address *   m_address;
  118.   snmp_callback   m_callBack;
  119.   void *   m_callData;
  120.   int   m_reason;
  121.   int   m_received;
  122. };
  123.   /*-----------------------------------------------------------*/
  124.   /* CSNMPMessageQueue        */
  125.   /*   class describing a collection of outstanding SNMP msgs. */
  126.   /*-----------------------------------------------------------*/
  127. class DLLOPT CSNMPMessageQueue: public CEvents
  128. {
  129.  public:
  130.     CSNMPMessageQueue(EventListHolder *holder, Snmp *session);
  131.     virtual ~CSNMPMessageQueue();
  132.     CSNMPMessage *AddEntry(unsigned long id, Snmp *snmp, SnmpSocket socket,
  133.    const SnmpTarget &target, Pdu &pdu, unsigned char * rawPdu,
  134.    size_t rawPduLen, const Address & address,
  135.    snmp_callback callBack, void * callData);
  136.     CSNMPMessage *GetEntry(const unsigned long uniqueId);
  137.     int DeleteEntry(const unsigned long uniqueId);
  138.     void DeleteSocketEntry(const SnmpSocket socket);
  139.   // find the next msg that will timeout
  140.     CSNMPMessage *GetNextTimeoutEntry();
  141.   // find the next timeout
  142.     int GetNextTimeout(msec &sendTime);
  143. #ifdef HAVE_POLL_SYSCALL
  144.     int GetFdCount();
  145.     bool GetFdArray(struct pollfd *readfds, int &remaining);
  146.     int HandleEvents(const struct pollfd *readfds, const int fds);
  147. #else
  148.   // set up parameters for select
  149.     void GetFdSets(int &maxfds, fd_set &readfds, fd_set &writefds,
  150.   fd_set &exceptfds);
  151.     int HandleEvents(const int maxfds,
  152.      const fd_set &readfds,
  153.      const fd_set &writefds,
  154.      const fd_set &exceptfds);
  155. #endif
  156.   // return number of outstanding messages
  157.     int GetCount() { return m_msgCount; };
  158.     int DoRetries(const msec &sendtime);
  159.     int Done();
  160.     int Done(unsigned long);
  161.  protected:
  162.     /*---------------------------------------------------------*/
  163.     /* CSNMPMessageQueueElt        */
  164.     /*   a container for a single item on a linked lists of    */
  165.     /*  CSNMPMessages.        */
  166.     /*---------------------------------------------------------*/
  167.     class DLLOPT CSNMPMessageQueueElt
  168.     {
  169.      public:
  170.       CSNMPMessageQueueElt(CSNMPMessage *message,
  171.    CSNMPMessageQueueElt *next,
  172.    CSNMPMessageQueueElt *previous);
  173.       ~CSNMPMessageQueueElt();
  174.       CSNMPMessageQueueElt *GetNext() { return m_Next; }
  175.       CSNMPMessage *GetMessage() { return m_message; }
  176.       CSNMPMessage *TestId(const unsigned long uniqueId);
  177.      private:
  178.       CSNMPMessage *m_message;
  179.       class CSNMPMessageQueueElt *m_Next;
  180.       class CSNMPMessageQueueElt *m_previous;
  181.     };
  182.     CSNMPMessageQueueElt m_head;
  183.     int m_msgCount;
  184.     EventListHolder *my_holder;
  185.     Snmp *m_snmpSession;
  186. };
  187. #ifdef SNMP_PP_NAMESPACE
  188. } // end of namespace Snmp_pp
  189. #endif 
  190. #endif