---

DQMBasicNet Class Reference

#include <DQMServices/Core/interface/DQMNet.h>

Inheritance diagram for DQMBasicNet:

List of all members.

Public Member Functions
	DQMBasicNet (const std::string &appname="")
virtual int	receive (DQMStore *store)
Protected Member Functions
virtual void	removeLocalObject (const std::string &name)
	Delete the local object.
virtual void	requestFullUpdatesFromPeers (void)
virtual void	updateLocalObject (Object &o)
	Update the network cache for an object.
Private Attributes
ImplPeer *	local_

---

Detailed Description

Definition at line 507 of file DQMNet.h.

---

Constructor & Destructor Documentation

DQMBasicNet::DQMBasicNet

(

const std::string &

appname = ""

)

Definition at line 1424 of file DQMNet.cc.

References DQMImplNet< DQMNet::Object >::createPeer(), and local_.

  : DQMImplNet<DQMNet::Object>(appname)
{
  local_ = static_cast<ImplPeer *>(createPeer((Socket *) -1));
}

---

Member Function Documentation

int DQMBasicNet::receive

(

DQMStore *

store

)

[virtual]

Reimplemented from DQMNet.

Definition at line 1431 of file DQMNet.cc.

References DQMNet::DQM_FLAG_DEAD, DQMNet::DQM_FLAG_RECEIVED, DQMNet::CoreObject::flags, local_, DQMNet::lock(), name, DQMNet::CoreObject::name, p, DQMImplNet< DQMNet::Object >::peers_, pi, DQMNet::reinstateObject(), DQMStore::removeElement(), DQMStore::setCurrentFolder(), and DQMNet::unlock().

{
  int updates = 0;

  lock();
  PeerMap::iterator pi, pe;
  ObjectMap::iterator oi, oe;
  for (pi = peers_.begin(), pe = peers_.end(); pi != pe; ++pi)
  {
    ImplPeer &p = pi->second;
    if (&p == local_)
      continue;

    updates += p.updates;

    for (oi = p.objs.begin(), oe = p.objs.end(); oi != oe; )
    {
      Object &o = oi->second;
      if (o.flags & DQM_FLAG_DEAD)
      {
        std::string folder = o.name;
        std::string name = o.name;
        folder.erase(folder.rfind('/'), std::string::npos);
        name.erase(0, name.rfind('/')+1);
        store->setCurrentFolder(folder);
        store->removeElement(name);
        p.objs.erase(oi++);
      }
      else if ((o.flags & DQM_FLAG_RECEIVED) && reinstateObject(store, o))
      {
        o.flags &= ~DQM_FLAG_RECEIVED;
        ++oi;
      }
    }
  }
  unlock();

  return updates;
}

void DQMBasicNet::removeLocalObject

(

const std::string &

path

)

[protected, virtual]

Delete the local object.

The caller must call sendLocalChanges() later to push out the changes.

Reimplemented from DQMNet.

Definition at line 1498 of file DQMNet.cc.

References local_.

{
  local_->objs.erase(path);
}

void DQMBasicNet::requestFullUpdatesFromPeers

(

void

)

[protected, virtual]

Reimplemented from DQMImplNet< DQMNet::Object >.

Definition at line 1504 of file DQMNet.cc.

References DQMNet::copydata(), DQMNet::DQM_MSG_UPDATE_ME, e, i, alivecheck_mergeAndRegister::msg, DQMNet::Bucket::next, p, and DQMImplNet< DQMNet::Object >::peers_.

{
  for (PeerMap::iterator i = peers_.begin(), e = peers_.end(); i != e; ++i)
  {
    ImplPeer &p = i->second;
    if (! p.source)
      continue;

    Bucket **msg = &p.sendq;
    while (*msg)
      msg = &(*msg)->next;
    *msg = new Bucket;
    (*msg)->next = 0;

    uint32_t words[3] = { 3*sizeof(uint32_t), DQM_MSG_UPDATE_ME, 1 };
    copydata(*msg, words, sizeof(words));
  }
}

void DQMBasicNet::updateLocalObject

(

Object &

o

)

[protected, virtual]

Update the network cache for an object.

The caller must call sendLocalChanges() later to push out the changes.

Reimplemented from DQMNet.

Definition at line 1474 of file DQMNet.cc.

References DQMNet::CoreObject::flags, local_, DQMNet::CoreObject::name, DQMNet::CoreObject::qreports, DQMNet::Object::rawdata, std::swap(), DQMNet::CoreObject::tags, and DQMNet::CoreObject::version.

{
  ObjectMap::iterator pos = local_->objs.find(o.name);
  if (pos == local_->objs.end())
    local_->objs.insert(ObjectMap::value_type(o.name, o));
  else
  {
    std::swap(pos->second.version,   o.version);
    std::swap(pos->second.tags,      o.tags);
    std::swap(pos->second.qreports,  o.qreports);
    std::swap(pos->second.flags,     o.flags);
    std::swap(pos->second.rawdata,   o.rawdata);

    delete pos->second.object;
    pos->second.object = 0;
    delete pos->second.reference;
    pos->second.reference = 0;
    pos->second.lastreq = 0;
  }
}

---

Member Data Documentation

ImplPeer* DQMBasicNet::local_ [private]

Definition at line 520 of file DQMNet.h.

Referenced by DQMBasicNet(), receive(), removeLocalObject(), and updateLocalObject().

---

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

• DQMServices/Core/interface/DQMNet.h
• DQMServices/Core/src/DQMNet.cc

---