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

SNMP编程

开发平台:

Visual C++

  1. /*_############################################################################
  2.   _## 
  3.   _##  notifyqueue.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.       N O T I F Y Q U E U E. H
  43.       CNotifyEventQueue 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 holding sessions waiting for notifiactions
  50. =====================================================================*/
  51. // $Id: notifyqueue.h 332 2007-12-22 20:42:51Z katz $
  52. #ifndef _NOTIFYQUEUE
  53. #define _NOTIFYQUEUE
  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/oid.h"
  68. #include "snmp_pp/target.h"
  69. #include "snmp_pp/eventlist.h"
  70. #ifdef SNMP_PP_NAMESPACE
  71. namespace Snmp_pp {
  72. #endif
  73. class Snmp; // instead of snmp_pp.h
  74. class msec;
  75. class EventListHolder;
  76. //----[ defines ]------------------------------------------------------
  77. //----[ CNotifyEvent class ]-------------------------------------------
  78. /*----------------------------------------------------------------*/
  79. /* CNotifyEvent                                                   */
  80. /*   a description of a sessions waiting for async notifiactions. */
  81. /*----------------------------------------------------------------*/
  82. class DLLOPT CNotifyEvent
  83. {
  84.  public:
  85.   CNotifyEvent(Snmp* snmp,
  86.        const OidCollection &trapids,
  87.        const TargetCollection &targets,
  88.        const AddressCollection &addresses);
  89.   ~CNotifyEvent();
  90.   Snmp * GetId() { return m_snmp; };
  91.   int notify_filter(const Oid &trapid, SnmpTarget &target) const;
  92.   int Callback(SnmpTarget &target, Pdu &pdu, SnmpSocket fd, int status);
  93.   void get_filter(OidCollection &o, TargetCollection &t,
  94.   AddressCollection &a)
  95.     { o = *notify_ids; t = *notify_targets; a = *notify_addresses; };
  96.  protected:
  97.   Snmp              *m_snmp;
  98.   TargetCollection  *notify_targets;
  99.   OidCollection     *notify_ids;
  100.   AddressCollection *notify_addresses;
  101. };
  102.   /*-----------------------------------------------------------*/
  103.   /* CNotifyEventQueue                                         */
  104.   /*   class describing a collection of outstanding SNMP msgs. */
  105.   /*-----------------------------------------------------------*/
  106. class DLLOPT CNotifyEventQueue: public CEvents
  107. {
  108.   public:
  109.     CNotifyEventQueue(EventListHolder *holder, Snmp *session);
  110.     ~CNotifyEventQueue();
  111.     int AddEntry(Snmp * snmp,
  112.  const OidCollection &trapids,
  113.  const TargetCollection &targets,
  114.  const AddressCollection &addresses);
  115.     CNotifyEvent * GetEntry(Snmp * snmp);
  116.     void DeleteEntry(Snmp * snmp);
  117.     // find the next timeout
  118.     int GetNextTimeout(msec &/*timeout*/) { return 1; }; // we have no timeouts
  119.     // set up parameters for select
  120. #ifdef HAVE_POLL_SYSCALL
  121.     int GetFdCount();
  122.     bool GetFdArray(struct pollfd *readfds, int &remaining);
  123.     int HandleEvents(const struct pollfd *readfds, const int fds);
  124. #else
  125.     void GetFdSets(int &maxfds, fd_set &readfds, fd_set &writefds,
  126.    fd_set &exceptfds);
  127.     int HandleEvents(const int maxfds,
  128.                      const fd_set &readfds,
  129.                      const fd_set &writefds,
  130.                      const fd_set &exceptfds);
  131. #endif
  132.     // return number of outstanding messages
  133.     int GetCount() { return m_msgCount; };
  134.     int DoRetries(const msec &/*sendtime*/) { return 0; }; // nothing to retry
  135.     int Done() { return 0; }; // we are never done
  136.     void set_listen_port(int port) { m_listen_port = port; };
  137.     int get_listen_port() { return m_listen_port; };
  138.     SnmpSocket get_notify_fd(const UdpAddress match_addr) const;
  139.     SnmpSocket get_notify_fd(const int i = 0) const;
  140.   protected:
  141.     /*-----------------------------------------------------------*/
  142.     /* CNotifyEventQueueElt                                      */
  143.     /*   a container for a single item on a linked lists of      */
  144.     /*  CNotifyEvents.                                           */
  145.     /*-----------------------------------------------------------*/
  146.     class DLLOPT CNotifyEventQueueElt
  147.     {
  148.      public:
  149.       CNotifyEventQueueElt(CNotifyEvent *notifyevent,
  150.    CNotifyEventQueueElt *next,
  151.    CNotifyEventQueueElt *previous);
  152.       ~CNotifyEventQueueElt();
  153.       CNotifyEventQueueElt *GetNext() { return m_Next; };
  154.       CNotifyEvent *GetNotifyEvent() { return m_notifyevent; };
  155.       CNotifyEvent *TestId(Snmp * snmp);
  156.     private:
  157.       CNotifyEvent *m_notifyevent;
  158.       class CNotifyEventQueueElt *m_Next;
  159.       class CNotifyEventQueueElt *m_previous;
  160.     };
  161.     CNotifyEventQueueElt m_head;
  162.     int                  m_msgCount;
  163.     SnmpSocket          *m_notify_fds;
  164.     int                  m_notify_fd_count;
  165.     int                  m_listen_port;
  166.     EventListHolder *my_holder;
  167.     Snmp *m_snmpSession;
  168.     AddressCollection m_notify_addrs;
  169. };
  170. #ifdef SNMP_PP_NAMESPACE
  171. } // end of namespace Snmp_pp
  172. #endif 
  173. #endif // NOTIFYQUEUE