Method transfer_objects

src/proxy/logging/LogObject.cc:1226–1280

}

void
LogObjectManager::transfer_objects(LogObjectManager &old_mgr)
{
  Dbg(dbg_ctl_log_config_transfer, "transferring objects from LogObjectManager %p, to %p", &old_mgr, this);

  if (dbg_ctl_log_config_transfer.on()) {
    Dbg(dbg_ctl_log_config_transfer, "TRANSFER OBJECTS: list of old objects");
    for (auto &_object : old_mgr._objects) {
      Dbg(dbg_ctl_log_config_transfer, "%s", _object->get_original_filename());
    }

    Dbg(dbg_ctl_log_config_transfer, "TRANSFER OBJECTS : list of new objects");
    for (unsigned i = 0; i < this->_objects.size(); i++) {
      Dbg(dbg_ctl_log_config_transfer, "%s", _objects[i]->get_original_filename());
    }
  }

  // Transfer the API objects from the old manager. The old manager will retain its refcount.
  for (auto &_APIobject : old_mgr._APIobjects) {
    manage_api_object(_APIobject);
  }

  for (auto old_obj : old_mgr._objects) {
    LogObject *new_obj;

    Dbg(dbg_ctl_log_config_transfer, "examining existing object %s", old_obj->get_base_filename());

    // See if any of the new objects is just a copy of an old one. If so, transfer the
    // old one to the new manager and delete the new one. We don't use Vec::in here because
    // we need to compare the object hash, not the pointers.
    for (unsigned j = 0; j < _objects.size(); j++) {
      new_obj = _objects[j];

      Dbg(dbg_ctl_log_config_transfer, "comparing existing object %s to new object %s", old_obj->get_base_filename(),
          new_obj->get_base_filename());

      if (*new_obj == *old_obj) {
        Dbg(dbg_ctl_log_config_transfer, "keeping existing object %s", old_obj->get_base_filename());

        old_obj->refcount_inc();
        this->_objects[j] = old_obj;

        if (new_obj->refcount_dec() == 0) {
          delete new_obj;
        }
        break;
      }
    }
  }

  if (dbg_ctl_log_config_transfer.on()) {
    Dbg(dbg_ctl_log_config_transfer, "Log Object List after transfer:");
    display();
  }
}

unsigned
LogObjectManager::roll_files(long time_now)