Method add_entry

dds/DCPS/FileSystemStorage.cpp:693–740

}

ACE_TString Directory::add_entry()
{
  if (overflow_.empty()) {
    overflow_[0] = 1;
    return ACE_TEXT("");
  }

  typedef OPENDDS_MAP(unsigned int, unsigned int)::iterator iterator;
  // find existing overflow bucket with capacity
  bool found_gap(false);
  unsigned int last_seen(0), unused_bucket(0);

  for (iterator iter = overflow_.begin(), end = overflow_.end();
       iter != end; ++iter) {
    if (iter->second < OPENDDS_FILESYSTEMSTORAGE_MAX_FILES_PER_DIR) {
      ++iter->second;

      if (iter->first == 0) return ACE_TEXT("");

      return overflow_dir_name(iter->first);
    }

    if (!found_gap && iter->first > last_seen + 1) {
      found_gap = true;
      unused_bucket = last_seen + 1;
    }

    last_seen = iter->first;
  }

  if (!found_gap) {
    if (last_seen == FSS_MAX_OVERFLOW_DIR) {
      throw std::runtime_error("Overflow serial # out of range.");
    }

    unused_bucket = last_seen + 1;
  }

  overflow_[unused_bucket] = 1;
  ACE_TString dir_name = overflow_dir_name(unused_bucket);
  CwdGuard cg(physical_dirname_);

  if (dds_mkdir(dir_name.c_str()) == -1) {
    throw std::runtime_error("Can't create overflow directory");
  }

  return dir_name;
}

void Directory::remove()
{