OpenDDS::DCPS::TransportReassembly::FragInfo Struct Reference

Collaboration diagram for OpenDDS::DCPS::TransportReassembly::FragInfo:

Public Member Functions
typedef	OPENDDS_LIST (FragSample) FragSampleList
typedef	OPENDDS_MAP (FragmentNumber, FragSampleList::iterator) FragSampleListIterMap
typedef	OPENDDS_LIST (FragmentRange) FragGapList
typedef	OPENDDS_MAP (FragmentNumber, FragGapList::iterator) FragGapListIterMap
	FragInfo ()
	FragInfo (bool hf, const FragSampleList &rl, ACE_UINT32 tf, const MonotonicTimePoint &expiration)
	FragInfo (const FragInfo &val)
FragInfo &	operator= (const FragInfo &rhs)
bool	insert (const FragmentRange &fragRange, ReceivedDataSample &data)

Public Attributes
bool	have_first_
FragSampleList	sample_list_
FragSampleListIterMap	sample_finder_
FragGapList	gap_list_
FragGapListIterMap	gap_finder_
ACE_UINT32	total_frags_
MonotonicTimePoint	expiration_

Detailed Description

Definition at line 124 of file TransportReassembly.h.

Constructor & Destructor Documentation

FragInfo() [1/3]

OpenDDS::DCPS::TransportReassembly::FragInfo::FragInfo

(

)

Definition at line 311 of file TransportReassembly.cpp.

  : have_first_(false)
  , total_frags_(0)
{}

FragInfo() [2/3]

OpenDDS::DCPS::TransportReassembly::FragInfo::FragInfo	(	bool	hf,
		const FragSampleList &	rl,
		ACE_UINT32	tf,
		const MonotonicTimePoint &	expiration
	)

Definition at line 316 of file TransportReassembly.cpp.

References gap_finder_, gap_list_, sample_finder_, and sample_list_.

  : have_first_(hf)
  , sample_list_(rl)
  , total_frags_(tf)
  , expiration_(expiration)
{
  for (FragSampleList::iterator it = sample_list_.begin(), prev = it; it != sample_list_.end(); ++it) {
    sample_finder_[it->frag_range_.second] = it;
    if (it != sample_list_.begin()) {
      gap_list_.push_back(FragmentRange(prev->frag_range_.second + 1, it->frag_range_.first - 1));
    }
    prev = it;
  }
  for (FragGapList::iterator it = gap_list_.begin(); it != gap_list_.end(); ++it) {
    gap_finder_[it->second] = it;
  }
}

FragInfo() [3/3]

OpenDDS::DCPS::TransportReassembly::FragInfo::FragInfo

(

const FragInfo &

val

)

Definition at line 334 of file TransportReassembly.cpp.

{
  *this = val;
}

Member Function Documentation

insert()

bool OpenDDS::DCPS::TransportReassembly::FragInfo::insert	(	const FragmentRange &	fragRange,
		ReceivedDataSample &	data
	)

Definition at line 370 of file TransportReassembly.cpp.

References OpenDDS::DCPS::ReceivedDataSample::append(), OpenDDS::DCPS::ReceivedDataSample::clear(), OpenDDS::XTypes::copy(), OpenDDS::DCPS::TransportReassembly::FragSample::frag_range_, OpenDDS::DCPS::ReceivedDataSample::get_fragment_range(), OpenDDS::DCPS::SequenceNumber::getValue(), OpenDDS::DCPS::ReceivedDataSample::has_data(), OpenDDS::DCPS::ReceivedDataSample::header_, OpenDDS::DCPS::DataSampleHeader::join(), LM_DEBUG, OpenDDS::DCPS::DataSampleHeader::more_fragments_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::ReceivedDataSample::prepend(), OpenDDS::DCPS::TransportReassembly::FragSample::rec_ds_, sample_finder_, sample_list_, OpenDDS::DCPS::DataSampleHeader::sequence_, and VDBG.

Referenced by OpenDDS::DCPS::TransportReassembly::data_unavailable(), and OpenDDS::DCPS::TransportReassembly::reassemble_i().

{
  const FragmentNumber prev = fragRange.first - 1, next = fragRange.second + 1;

  FragSampleList::iterator start = sample_list_.begin();
  FragSampleListIterMap::iterator fit = sample_finder_.begin();
  if (!sample_list_.empty()) {
    fit = sample_finder_.lower_bound(prev);
    if (fit != sample_finder_.end()) {
      start = fit->second;
      if (start->frag_range_.second != prev && start != sample_list_.begin()) {
        --start;
        --fit;
      }
    } else {
      start = sample_list_.end();
      --start;
      --fit;
    }
  }

  const SequenceNumber::Value sn = data.header_.sequence_.getValue();

  for (FragSampleList::iterator it = start; it != sample_list_.end(); ++it) {
    FragSample& fr = *it;
    if (next < fr.frag_range_.first) {
      // insert before 'it'
      sample_finder_[fragRange.second] = sample_list_.insert(it, FragSample(fragRange, data));
      data.clear();
      VDBG((LM_DEBUG, "(%P|%t) TransportReassembly::insert: (SN: %q) inserted %q-%q on the left of %q-%q\n", sn, fragRange.first, fragRange.second, fr.frag_range_.first, fr.frag_range_.second));
      return true;

    } else if (next == fr.frag_range_.first) {
      // combine on left of fr
      DataSampleHeader joined;
      if (!DataSampleHeader::join(data.header_, fr.rec_ds_.header_, joined)) {
        join_err("left");
        return false;
      }
      fr.rec_ds_.header_ = joined;
      if (fr.rec_ds_.has_data() && data.has_data()) {
        fr.rec_ds_.prepend(data);
      } else {
        fr.rec_ds_.clear();
        data.clear();
      }
      VDBG((LM_DEBUG, "(%P|%t) TransportReassembly::insert: (SN: %q) combined %q-%q with %q-%q on the left\n", sn, fragRange.first, fragRange.second, fr.frag_range_.first, fr.frag_range_.second));
      fr.frag_range_.first = fragRange.first;
      return true;

    } else if (fragRange.first < fr.frag_range_.first) {
      // split and recursively insert both parts
      VDBG((LM_DEBUG, "(%P|%t) TransportReassembly::insert: (SN: %q) splitting %q-%q into %q-%q and %q-%q and recursively inserting both\n", sn, fragRange.first, fragRange.second, fragRange.first, fr.frag_range_.first - 1, fr.frag_range_.first, fragRange.second));
      ReceivedDataSample front_split = data.get_fragment_range(0, fr.frag_range_.first - fragRange.first - 1);
      ReceivedDataSample back_split = data.get_fragment_range(fr.frag_range_.first - fragRange.first);
      data.clear();
      const bool r1 = insert(FragmentRange(fragRange.first, fr.frag_range_.first - 1), front_split);
      const bool r2 = insert(FragmentRange(fr.frag_range_.first, fragRange.second), back_split);
      return r1 || r2; // r1 will likely always be true, but check both

    } else if (fragRange.first < fr.frag_range_.second && fr.frag_range_.second < fragRange.second) {
      // split and recursively insert just the back
      VDBG((LM_DEBUG, "(%P|%t) TransportReassembly::insert: (SN: %q) splitting %q-%q in order to recursively insert %q-%q\n", sn, fragRange.first, fragRange.second, fr.frag_range_.second + 1, fragRange.second));
      ReceivedDataSample back_split = data.get_fragment_range(fr.frag_range_.second - fragRange.first);
      data.clear();
      return insert(FragmentRange(fr.frag_range_.second + 1, fragRange.second), back_split);

    } else if (prev == fr.frag_range_.second) {
      // combine on right of fr
      if (!fr.rec_ds_.has_data()) {
        fr.rec_ds_.header_.more_fragments_ = true;
      }
      DataSampleHeader joined;
      if (!DataSampleHeader::join(fr.rec_ds_.header_, data.header_, joined)) {
        join_err("right");
        return false;
      }
      fr.rec_ds_.header_ = joined;
      if (fr.rec_ds_.has_data() && data.has_data()) {
        fr.rec_ds_.append(data);
      } else {
        fr.rec_ds_.clear();
        data.clear();
      }

      VDBG((LM_DEBUG, "(%P|%t) TransportReassembly::insert: (SN: %q) combined %q-%q with %q-%q on the right, removing and recursingly inserting\n", sn, fragRange.first, fragRange.second, fr.frag_range_.first, fr.frag_range_.second));

      FragmentRange range(fr.frag_range_.first, fragRange.second);
      ReceivedDataSample copy(fr.rec_ds_);

      sample_list_.erase(it);
      sample_finder_.erase(fit);

      return insert(range, copy);

    } else if (fr.frag_range_.first <= fragRange.first && fr.frag_range_.second >= fragRange.second) {
      VDBG((LM_DEBUG, "(%P|%t) TransportReassembly::insert: (SN: %q) duplicate fragment range %q-%q, dropping\n", sn, fragRange.first, fragRange.second));
      return false;
    }
    ++fit;
  }

  // add to end of list
  sample_finder_[fragRange.second] = sample_list_.insert(sample_list_.end(), FragSample(fragRange, data));
  VDBG((LM_DEBUG, "(%P|%t) TransportReassembly::insert: (SN: %q) inserting %q-%q at the end of the fragment buffer list\n", sn, fragRange.first, fragRange.second));
  data.clear();
  return true;
}

OPENDDS_LIST() [1/2]

typedef OpenDDS::DCPS::TransportReassembly::FragInfo::OPENDDS_LIST

(

FragSample

)

OPENDDS_LIST() [2/2]

typedef OpenDDS::DCPS::TransportReassembly::FragInfo::OPENDDS_LIST

(

FragmentRange

)

OPENDDS_MAP() [1/2]

typedef OpenDDS::DCPS::TransportReassembly::FragInfo::OPENDDS_MAP	(	FragmentNumber	,
		FragSampleList::iterator
	)

OPENDDS_MAP() [2/2]

typedef OpenDDS::DCPS::TransportReassembly::FragInfo::OPENDDS_MAP	(	FragmentNumber	,
		FragGapList::iterator
	)

operator=()

TransportReassembly::FragInfo & OpenDDS::DCPS::TransportReassembly::FragInfo::operator=

(

const FragInfo &

rhs

)

Definition at line 340 of file TransportReassembly.cpp.

References ACE_ERROR, ACE_TEXT(), expiration_, gap_finder_, gap_list_, have_first_, LM_ERROR, sample_finder_, sample_list_, and total_frags_.

{
  if (this != &rhs) {
    have_first_ = rhs.have_first_;
    sample_list_ = rhs.sample_list_;
    gap_list_ = rhs.gap_list_;
    total_frags_ = rhs.total_frags_;
    expiration_ = rhs.expiration_;
    sample_finder_.clear();
    gap_finder_.clear();
    for (FragSampleList::iterator it = sample_list_.begin(); it != sample_list_.end(); ++it) {
      sample_finder_[it->frag_range_.second] = it;
    }
    for (FragGapList::iterator it = gap_list_.begin(); it != gap_list_.end(); ++it) {
      gap_finder_[it->second] = it;
    }
  }
  return *this;
}

Member Data Documentation

expiration_

MonotonicTimePoint OpenDDS::DCPS::TransportReassembly::FragInfo::expiration_

Definition at line 145 of file TransportReassembly.h.

Referenced by operator=().

gap_finder_

FragGapListIterMap OpenDDS::DCPS::TransportReassembly::FragInfo::gap_finder_

Definition at line 143 of file TransportReassembly.h.

Referenced by FragInfo(), and operator=().

gap_list_

FragGapList OpenDDS::DCPS::TransportReassembly::FragInfo::gap_list_

Definition at line 142 of file TransportReassembly.h.

Referenced by FragInfo(), and operator=().

have_first_

bool OpenDDS::DCPS::TransportReassembly::FragInfo::have_first_

Definition at line 139 of file TransportReassembly.h.

Referenced by OpenDDS::DCPS::TransportReassembly::data_unavailable(), and operator=().

sample_finder_

FragSampleListIterMap OpenDDS::DCPS::TransportReassembly::FragInfo::sample_finder_

Definition at line 141 of file TransportReassembly.h.

Referenced by FragInfo(), insert(), and operator=().

sample_list_

FragSampleList OpenDDS::DCPS::TransportReassembly::FragInfo::sample_list_

Definition at line 140 of file TransportReassembly.h.

Referenced by OpenDDS::DCPS::TransportReassembly::data_unavailable(), FragInfo(), insert(), and operator=().

total_frags_

ACE_UINT32 OpenDDS::DCPS::TransportReassembly::FragInfo::total_frags_

Definition at line 144 of file TransportReassembly.h.

Referenced by operator=().

---

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

• TransportReassembly.h
• TransportReassembly.cpp