blob: d9843ebe93b6a7e0cb984eca67fcfc5d34fb57ad (
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
|
//
// $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(ace, 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);
}
|