blob: d114bd40d1f0b1e74709ee51b28ec1ed4c63e418 (
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++-*- */
#ifndef TRANSACTION_
#define TRANSACTION_
//=============================================================================
/**
* @file transaction.h
*
* $Id$
*
* @brief
*
* @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 transaction
*
* @brief Used to manage the details of a particular transaction betwen
* two SNMP agents. Uses SnmpTarget class to implement retry/timeout
*/
class ASNMP_Export transaction : public ACE_Event_Handler
{
int retry_counter_;
transaction_result * result_;
public:
/// constructor
/// destructor
transaction(const Pdu& pdu, const UdpTarget& target, ACE_SOCK_Dgram& io);
transaction(ACE_SOCK_Dgram& io);
~transaction();
/// begin polling for values
int run();
int run(transaction_result *r); // Async interface, with callback object
/// return pdu with result from agent after run() is completed rc = 0
/// optionally get community str
int result(Pdu& pdu, char *comm_str = 0, ACE_INET_Addr *from_addr = 0);
/// called by reactor when data is ready to be read in from OS memory
/// used for resend in asynchronous run()
virtual int handle_input (ACE_HANDLE fd);
virtual int handle_timeout (const ACE_Time_Value &, const void *);
/// transmit buffer command to network...
int send();
/// pre: handle_input called
/// retrieve the sender's from address from the last pkt
const ACE_INET_Addr& get_from_addr() const;
/// Return session_ handle.
ACE_HANDLE get_handle () const;
private:
/// disallow copy construction
transaction(const transaction&);
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_
|
