/* -*-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 ACE_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

 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_