ace/RMCast/RMCast_Ack_Worker.cpp


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

//
// $Id$
//

#include "RMCast_Ack_Worker.h"
#include "ace/Message_Block.h"

#if !defined (__ACE_INLINE__)
# include "RMCast_Ack_Worker.i"
#endif /* ! __ACE_INLINE__ */

ACE_RCSID(RMCast, RMCast_Ack_Worker, "$Id$")

int
ACE_RMCast_Ack_Worker::work (ACE_UINT32 const & key,
                             ACE_RMCast::Data const &item)
{
  if (key >= this->ack_.next_expected)
    return 0;
  // ACE_DEBUG ((LM_DEBUG,
  //            "  Retransmission::ack - message %d erased\n",
  //            key));
  ACE_Message_Block::release (item.payload);
  return this->messages_->unbind_i (this->ace_mon_, key);
}