ACE_RMCast::Retransmit Class Reference

#include <Retransmit.h>

Inheritance diagram for ACE_RMCast::Retransmit:

[legend]Collaboration diagram for ACE_RMCast::Retransmit:

[legend]List of all members.

Public Member Functions
	Retransmit (Parameters const &params)
virtual void	out_start (Out_Element *out)
virtual void	out_stop ()
virtual void	send (Message_ptr m)
virtual void	recv (Message_ptr m)
Private Types
typedef ACE_Hash_Map_Manager< u64, Descr, ACE_Null_Mutex >	Queue
Private Member Functions
void	track ()
Static Private Member Functions
static ACE_THR_FUNC_RETURN	track_thunk (void *obj)
Private Attributes
Parameters const &	params_
Queue	queue_
Mutex	mutex_
Condition	cond_
bool	stop_
ACE_Thread_Manager	tracker_mgr_
Classes
struct	Descr

---

Detailed Description

Definition at line 18 of file Retransmit.h.

---

Member Typedef Documentation

typedef ACE_Hash_Map_Manager<u64, Descr, ACE_Null_Mutex> ACE_RMCast::Retransmit::Queue [private]

Definition at line 76 of file Retransmit.h.

---

Constructor & Destructor Documentation

ACE_RMCast::Retransmit::Retransmit

(

Parameters const &

params

)

Definition at line 20 of file Retransmit.cpp.

      : params_ (params),
        cond_ (mutex_),
        stop_ (false)
  {
  }

---

Member Function Documentation

void ACE_RMCast::Retransmit::out_start

(

Out_Element *

out

)

[virtual]

Reimplemented from ACE_RMCast::Out_Element.

Definition at line 28 of file Retransmit.cpp.

References ACE_RMCast::Out_Element::out_start(), ACE_Thread_Manager::spawn(), track_thunk(), and tracker_mgr_.

  {
    Element::out_start (out);

    tracker_mgr_.spawn (track_thunk, this);
  }

void ACE_RMCast::Retransmit::out_stop

(

)

[virtual]

Reimplemented from ACE_RMCast::Out_Element.

Definition at line 36 of file Retransmit.cpp.

References cond_, mutex_, ACE_RMCast::Out_Element::out_stop(), stop_, tracker_mgr_, and ACE_Thread_Manager::wait().

  {
    {
      Lock l (mutex_);
      stop_ = true;
      cond_.signal ();
    }

    tracker_mgr_.wait ();

    Element::out_stop ();
  }

void ACE_RMCast::Retransmit::recv

(

Message_ptr

m

)

[virtual]

Reimplemented from ACE_RMCast::In_Element.

Definition at line 62 of file Retransmit.cpp.

References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::find(), ACE_RMCast::Profile::id(), ACE_RMCast::In_Element::in_, mutex_, ACE_RMCast::Out_Element::out_, queue_, ACE_RMCast::In_Element::recv(), ACE_Strong_Bound_Ptr< X, ACE_LOCK >::reset(), and ACE_RMCast::Out_Element::send().

  {
    if (NAK const* nak = static_cast<NAK const*> (m->find (NAK::id)))
    {
      Address to (static_cast<To const*> (m->find (To::id))->address ());

      if (nak->address () == to)
      {
        Lock l (mutex_);

        for (NAK::iterator j (const_cast<NAK*> (nak)->begin ());
             !j.done ();
             j.advance ())
        {
          u64* psn;
          j.next (psn);

          Message_ptr m;

          Queue::ENTRY* pair;

          if (queue_.find (*psn, pair) == 0)
          {
            //cerr << 5 << "PRTM " << to << " " << pair->ext_id_ << endl;

            m = pair->int_id_.message ();

            pair->int_id_.reset ();
          }
          else
          {
            //cerr << 4 << "message " << *psn << " not available" << endl;

            m = Message_ptr (new Message);
            m->add (Profile_ptr (new SN (*psn)));
            m->add (Profile_ptr (new NoData));
          }

          out_->send (m);
        }
      }
    }

    in_->recv (m);
  }

void ACE_RMCast::Retransmit::send

(

Message_ptr

m

)

[virtual]

Reimplemented from ACE_RMCast::Out_Element.

Definition at line 49 of file Retransmit.cpp.

References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::bind(), ACE_RMCast::Profile::id(), mutex_, ACE_RMCast::Out_Element::out_, queue_, and ACE_RMCast::Out_Element::send().

  {
    if (m->find (Data::id) != 0)
    {
      SN const* sn = static_cast<SN const*> (m->find (SN::id));

      Lock l (mutex_);
      queue_.bind (sn->num (), Descr (m->clone ()));
    }

    out_->send (m);
  }

void ACE_RMCast::Retransmit::track

(

)

[private]

Definition at line 116 of file Retransmit.cpp.

References ACE_OS::abort(), cond_, ACE_Hash_Map_Iterator_Base_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::done(), ACE_OS::gettimeofday(), mutex_, params_, queue_, ACE_RMCast::Parameters::retention_timeout(), stop_, ACE_RMCast::Parameters::tick(), and time().

Referenced by track_thunk().

  {
    while (true)
    {
      Lock l (mutex_);

      for (Queue::iterator i (queue_); !i.done ();)
      {
        if ((*i).int_id_.inc () >= params_.retention_timeout ())
        {
          u64 sn ((*i).ext_id_);
          i.advance ();
          queue_.unbind (sn);
        }
        else
        {
          i.advance ();
        }
      }

      //FUZZ: disable check_for_lack_ACE_OS
      // Go to sleep but watch for "manual cancellation" request.
      //
      ACE_Time_Value time (ACE_OS::gettimeofday ());
      //FUZZ: enable check_for_lack_ACE_OS

      time += params_.tick ();

      while (!stop_)
      {
        if (cond_.wait (&time) == -1)
        {
          if (errno != ETIME)
            ACE_OS::abort ();
          else
            break;
        }
      }

      if (stop_)
        break;
    }
  }

ACE_THR_FUNC_RETURN ACE_RMCast::Retransmit::track_thunk

(

void *

obj

)

[static, private]

Definition at line 109 of file Retransmit.cpp.

References track().

Referenced by out_start().

  {
    reinterpret_cast<Retransmit*> (obj)->track ();
    return 0;
  }

---

Member Data Documentation

Condition ACE_RMCast::Retransmit::cond_ [private]

Definition at line 90 of file Retransmit.h.

Referenced by out_stop(), and track().

Mutex ACE_RMCast::Retransmit::mutex_ [private]

Definition at line 89 of file Retransmit.h.

Referenced by out_stop(), recv(), send(), and track().

Parameters const& ACE_RMCast::Retransmit::params_ [private]

Definition at line 86 of file Retransmit.h.

Referenced by track().

Queue ACE_RMCast::Retransmit::queue_ [private]

Definition at line 88 of file Retransmit.h.

Referenced by recv(), send(), and track().

bool ACE_RMCast::Retransmit::stop_ [private]

Definition at line 92 of file Retransmit.h.

Referenced by out_stop(), and track().

ACE_Thread_Manager ACE_RMCast::Retransmit::tracker_mgr_ [private]

Definition at line 93 of file Retransmit.h.

Referenced by out_start(), and out_stop().

---

The documentation for this class was generated from the following files:

• Retransmit.h
• Retransmit.cpp

---