notifyqueue.h
上传用户:ets1996
上传日期:2014-09-30
资源大小:353k
文件大小:7k
源码类别:

SNMP编程

开发平台:

Visual C++

  1. /*_############################################################################
  2.   _## 
  3.   _##  notifyqueue.h  
  4.   _##
  5.   _##  SNMP++v3.2.22
  6.   _##  -----------------------------------------------
  7.   _##  Copyright (c) 2001-2007 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, Wed May  2 23:22:30 CEST 2007 
  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:
  48.         Tom Murray
  49.       LANGUAGE:
  50.         ANSI C++
  51.       DESCRIPTION:
  52.         Queue for holding sessions waiting for notifiactions
  53. =====================================================================*/
  54. // $Id: notifyqueue.h 287 2007-03-22 22:37:09Z katz $
  55. #ifndef _NOTIFYQUEUE
  56. #define _NOTIFYQUEUE
  57. //----[ includes ]-----------------------------------------------------
  58. #include <sys/types.h>          // NOTE: due to 10.10 bug, order is important
  59.                                 //   in that all routines must include types.h
  60.                                 //   and time.h in same order otherwise you
  61.                                 //   will get conflicting definitions of
  62.                                 //   "fd_set" resulting in link time errors.
  63. #ifndef WIN32
  64. #if !(defined CPU && CPU == PPC603)
  65. #include <sys/time.h> // time stuff and fd_set
  66. #endif
  67. #else
  68. #include <winsock.h>
  69. #endif
  70. //----[ snmp++ includes ]----------------------------------------------
  71. #include "snmp_pp/oid.h"
  72. #include "snmp_pp/target.h"
  73. #include "snmp_pp/eventlist.h"
  74. #ifdef SNMP_PP_NAMESPACE
  75. namespace Snmp_pp {
  76. #endif
  77. class Snmp; // instead of snmp_pp.h
  78. class msec;
  79. class EventListHolder;
  80. //----[ defines ]------------------------------------------------------
  81. //----[ CNotifyEvent class ]-------------------------------------------
  82. /*----------------------------------------------------------------*/
  83. /* CNotifyEvent                                                   */
  84. /*   a description of a sessions waiting for async notifiactions. */
  85. /*----------------------------------------------------------------*/
  86. class DLLOPT CNotifyEvent
  87. {
  88.  public:
  89.   CNotifyEvent(Snmp* snmp,
  90.        const OidCollection &trapids,
  91.        const TargetCollection &targets,
  92.        const AddressCollection &addresses);
  93.   ~CNotifyEvent();
  94.   Snmp * GetId() { return m_snmp; };
  95.   int notify_filter(const Oid &trapid, SnmpTarget &target) const;
  96.   int Callback(SnmpTarget &target, Pdu &pdu, SnmpSocket fd, int status);
  97.   void get_filter(OidCollection &o, TargetCollection &t,
  98.   AddressCollection &a)
  99.     { o = *notify_ids; t = *notify_targets; a = *notify_addresses; };
  100.  protected:
  101.   Snmp              *m_snmp;
  102.   TargetCollection  *notify_targets;
  103.   OidCollection     *notify_ids;
  104.   AddressCollection *notify_addresses;
  105. };
  106.   /*-----------------------------------------------------------*/
  107.   /* CNotifyEventQueue                                         */
  108.   /*   class describing a collection of outstanding SNMP msgs. */
  109.   /*-----------------------------------------------------------*/
  110. class DLLOPT CNotifyEventQueue: public CEvents
  111. {
  112.   public:
  113.     CNotifyEventQueue(EventListHolder *holder, Snmp *session);
  114.     ~CNotifyEventQueue();
  115.     int AddEntry(Snmp * snmp,
  116.  const OidCollection &trapids,
  117.  const TargetCollection &targets,
  118.  const AddressCollection &addresses);
  119.     CNotifyEvent * GetEntry(Snmp * snmp);
  120.     void DeleteEntry(Snmp * snmp);
  121.     // find the next timeout
  122.     int GetNextTimeout(msec &/*timeout*/) { return 1; }; // we have no timeouts
  123.     // set up parameters for select
  124.     void GetFdSets(int &maxfds, fd_set &readfds, fd_set &writefds,
  125.    fd_set &exceptfds);
  126.     // return number of outstanding messages
  127.     int GetCount() { return m_msgCount; };
  128.     int HandleEvents(const int maxfds,
  129.                      const fd_set &readfds,
  130.                      const fd_set &writefds,
  131.                      const fd_set &exceptfds);
  132.     int DoRetries(const msec &/*sendtime*/) { return 0; }; // nothing to retry
  133.     int Done() { return 0; }; // we are never done
  134.     void set_listen_port(int port) { m_listen_port = port; };
  135.     int get_listen_port() { return m_listen_port; };
  136.     SnmpSocket get_notify_fd(const UdpAddress match_addr) const;
  137.     SnmpSocket get_notify_fd(const int i = 0) const;
  138.   protected:
  139.     /*-----------------------------------------------------------*/
  140.     /* CNotifyEventQueueElt                                      */
  141.     /*   a container for a single item on a linked lists of      */
  142.     /*  CNotifyEvents.                                           */
  143.     /*-----------------------------------------------------------*/
  144.     class DLLOPT CNotifyEventQueueElt
  145.     {
  146.      public:
  147.       CNotifyEventQueueElt(CNotifyEvent *notifyevent,
  148.    CNotifyEventQueueElt *next,
  149.    CNotifyEventQueueElt *previous);
  150.       ~CNotifyEventQueueElt();
  151.       CNotifyEventQueueElt *GetNext() { return m_Next; };
  152.       CNotifyEvent *GetNotifyEvent() { return m_notifyevent; };
  153.       CNotifyEvent *TestId(Snmp * snmp);
  154.     private:
  155.       CNotifyEvent *m_notifyevent;
  156.       class CNotifyEventQueueElt *m_Next;
  157.       class CNotifyEventQueueElt *m_previous;
  158.     };
  159.     CNotifyEventQueueElt m_head;
  160.     int                  m_msgCount;
  161.     SnmpSocket          *m_notify_fds;
  162.     int                  m_notify_fd_count;
  163.     int                  m_listen_port;
  164.     EventListHolder *my_holder;
  165.     Snmp *m_snmpSession;
  166.     AddressCollection m_notify_addrs;
  167. };
  168. #ifdef SNMP_PP_NAMESPACE
  169. } // end of namespace Snmp_pp
  170. #endif 
  171. #endif // NOTIFYQUEUE