blob: 98d5890913ee3c028f2b8e175a2c94b64a47e894 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
/* -*-C++-*- */
// $Id$
#ifndef TRANSACTION_
#define TRANSACTION_
// ============================================================================
//
// = LIBRARY
// asnmp
//
// = FILENAME
// transaction.h
//
// = DESCRIPTION
//
// = AUTHOR
// Michael R. MacFaden port to ACE / use Reactor pattern
//
// ============================================================================
#include "ace/Event_Handler.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "asnmp/target.h"
#include "asnmp/pdu.h"
#include "asnmp/transaction_result.h"
#include "asnmp/wpdu.h" // cmu adapter class
#include "ace/SOCK_Dgram.h"
class ASNMP_Export transaction : public ACE_Event_Handler
// = TITLE
// Used to manage the details of a particular transaction betwen
// two SNMP agents. Uses SnmpTarget class to implement retry/timeout
{
int retry_counter_;
transaction_result * result_;
public:
transaction(const Pdu& pdu, const UdpTarget& target, ACE_SOCK_Dgram& io);
transaction(ACE_SOCK_Dgram& io);
// constructor
~transaction();
// destructor
int run();
int run(transaction_result *r); // Async interface, with callback object
// begin polling for values
int result(Pdu& pdu, char *comm_str = 0, ACE_INET_Addr *from_addr = 0);
// return pdu with result from agent after run() is completed rc = 0
// optionally get community str
virtual int handle_input (ACE_HANDLE fd);
// called by reactor when data is ready to be read in from OS memory
virtual int handle_timeout (const ACE_Time_Value &, const void *);
// used for resend in asynchronous run()
int send();
// transmit buffer command to network...
const ACE_INET_Addr& get_from_addr() const;
// pre: handle_input called
// retrieve the sender's from address from the last pkt
ACE_HANDLE get_handle () const;
// Return session_ handle.
private:
transaction(const transaction&);
// disallow copy construction
wpdu wp_; // wire pdu
UdpTarget params_; // params
ACE_INET_Addr addr_; // to address
ACE_SOCK_Dgram session_; // io object
iovec receive_iovec_; // receive buffer
ACE_INET_Addr receive_addr_; // from address
};
#endif // TRANSACTION_
|
