DQMNet.cc File Reference

#include "DQMServices/Core/interface/DQMNet.h"
#include "DQMServices/Core/interface/DQMDefinitions.h"
#include "DQMServices/Core/src/DQMError.h"
#include "classlib/iobase/InetServerSocket.h"
#include "classlib/iobase/LocalServerSocket.h"
#include "classlib/iobase/Filename.h"
#include "classlib/sysapi/InetSocket.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 <unistd.h>
#include <fcntl.h>
#include <sys/wait.h>
#include <stdio.h>
#include <stdint.h>
#include <iostream>
#include <sstream>
#include <cassert>
#include <cfloat>
#include <inttypes.h>

Go to the source code of this file.

Macros
#define	MESSAGE_SIZE_LIMIT   (8*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 void *	communicate (void *obj)
static const Regexp	s_rxmeval ("<(.*)>(i|f|s|qr)=(.*)</\\1>")

Macro Definition Documentation

#define MESSAGE_SIZE_LIMIT   (8*1024*1024)

Definition at line 29 of file DQMNet.cc.

Referenced by DQMNet::onPeerData().

#define SOCKET_BUF_SIZE   (8*1024*1024)

Definition at line 30 of file DQMNet.cc.

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

#define SOCKET_READ_GROWTH   (SOCKET_BUF_SIZE)

Definition at line 33 of file DQMNet.cc.

Referenced by DQMNet::onPeerData().

#define SOCKET_READ_SIZE   (SOCKET_BUF_SIZE/8)

Definition at line 32 of file DQMNet.cc.

Referenced by DQMNet::onPeerData().

Function Documentation

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 1246 of file DQMNet.cc.

Referenced by cmsswVersionTools.PickRelValInputFiles::apply(), o2o::get_iovs(), and DQMNet::start().

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

static const Regexp s_rxmeval ( )

static