---

DQMNet.cc File Reference

#include "DQMServices/Core/interface/DQMNet.h"
#include "DQMServices/Core/interface/DQMStore.h"
#include "DQMServices/Core/interface/MonitorElement.h"
#include "FWCore/Utilities/interface/EDMException.h"
#include "classlib/sysapi/InetSocket.h"
#include "classlib/iobase/Filename.h"
#include "classlib/utils/TimeInfo.h"
#include "classlib/utils/StringList.h"
#include "classlib/utils/StringFormat.h"
#include "classlib/utils/StringOps.h"
#include "classlib/utils/SystemError.h"
#include "classlib/utils/Regexp.h"
#include "DQMRootBuffer.h"
#include "TObjString.h"
#include "TObject.h"
#include "TProfile2D.h"
#include "TProfile.h"
#include "TH3F.h"
#include "TH2F.h"
#include "TH2S.h"
#include "TH1F.h"
#include "TH1S.h"
#include <unistd.h>
#include <fcntl.h>
#include <sys/wait.h>
#include <stdio.h>
#include <stdint.h>
#include <iostream>
#include <cassert>

Go to the source code of this file.

Defines
#define	MESSAGE_SIZE_LIMIT   (2*1024*1024)
#define	SOCKET_BUF_SIZE   (8*1024*1024)
#define	SOCKET_READ_GROWTH   (SOCKET_BUF_SIZE)
#define	SOCKET_READ_SIZE   (SOCKET_BUF_SIZE/8)
Functions
static bool	abortReconstructObject (DQMNet::Object &o)
static void *	communicate (void *obj)
	A thread to communicate with the distributed memory cache peers.
static TObject *	extractNextObject (DQMRootBuffer &buf)
static bool	parseInt (const char *&p, const char *name, size_t len, int &value)
static const Regexp	s_rxmeval ("<(.*)>(i|f|s|qr)=(.*)</\\1>")
Variables
static const Regexp	s_rxmeqr ("^st\\.(\\d+)\\.(.*)$")

---

Define Documentation

#define MESSAGE_SIZE_LIMIT   (2*1024*1024)

Definition at line 31 of file DQMNet.cc.

Referenced by VisNet::onPeerData(), DQMNet::onPeerData(), and IgNet::onPeerData().

#define SOCKET_BUF_SIZE   (8*1024*1024)

Definition at line 32 of file DQMNet.cc.

Referenced by VisNet::run(), IgNet::run(), DQMNet::run(), DQMNet::startLocalServer(), VisNet::startLocalServer(), and IgNet::startLocalServer().

#define SOCKET_READ_GROWTH   (SOCKET_BUF_SIZE)

Definition at line 34 of file DQMNet.cc.

Referenced by VisNet::onPeerData(), DQMNet::onPeerData(), and IgNet::onPeerData().

#define SOCKET_READ_SIZE   (SOCKET_BUF_SIZE/8)

Definition at line 33 of file DQMNet.cc.

Referenced by VisNet::onPeerData(), DQMNet::onPeerData(), and IgNet::onPeerData().

---

Function Documentation

static bool abortReconstructObject

(

DQMNet::Object &

o

)

[static]

Definition at line 207 of file DQMNet.cc.

References DQMNet::CoreObject::object, and DQMNet::CoreObject::qreports.

Referenced by DQMNet::reconstructObject().

{
  o.qreports.clear();
  delete o.object;
  o.object = 0;
  return false;
}

static void* communicate

(

void *

obj

)

[static]

A thread to communicate with the distributed memory cache peers.

All this does is run the loop to respond to new connections. Much of the actual work is done when a new connection is received, and in pumping data around in response to actual requests.

Definition at line 1210 of file DQMNet.cc.

References sigfillset.

Referenced by IgNet::start(), DQMNet::start(), and VisNet::start().

{
  sigset_t sigs;
  sigfillset (&sigs);
  pthread_sigmask (SIG_BLOCK, &sigs, 0);
  ((DQMNet *)obj)->run();
  return 0;
}

static TObject* extractNextObject

(

DQMRootBuffer &

buf

)

[static]

Definition at line 192 of file DQMNet.cc.

References c.

Referenced by DQMNet::extractScalarData(), and DQMNet::reconstructObject().

{
  if (buf.Length() == buf.BufferSize())
    return 0;

  buf.InitMap();
  Int_t pos = buf.Length();
  TClass *c = buf.ReadClass();
  buf.SetBufferOffset(pos);
  buf.ResetMap();
  return c ? buf.ReadObject(c) : 0;
}

static bool parseInt	(	const char *&	p,
		const char *	name,
		size_t	len,
		int &	value
	)			[static]

Definition at line 47 of file DQMNet.cc.

Referenced by MuonAlignmentInputXML::getCSCnode(), MuonAlignmentInputXML::getDTnode(), and DQMNet::reconstructObject().

{
  if (! strncmp(p, name, len))
  {
    value = strtol(p+len, (char **) &p, 10);
    return true;
  }
  return false;
}

static const Regexp s_rxmeval

(

)

[static]

Referenced by DQMStore::extract(), stor::DQMInstance::getSafeMEName(), DQMNet::reconstructObject(), and DQMNet::reinstateObject().

---

Variable Documentation

const Regexp s_rxmeqr("^st\\.(\\d+)\\.(.*)$") [static]

Referenced by DQMStore::extract(), and DQMNet::reconstructObject().

---