CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
Macros | Functions
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 conddblib::_getCMSFrontierConnectionString(), cmsswVersionTools.PickRelValInputFiles::apply(), o2o::get_iovs(), DQMNet::start(), and edmIntegrityCheck.IntegrityCheck::testFile().

1247 {
1248  sigset_t sigs;
1249  sigfillset (&sigs);
1250  pthread_sigmask (SIG_BLOCK, &sigs, 0);
1251  ((DQMNet *)obj)->run();
1252  return 0;
1253 }
Definition: DQMNet.h:22
static const Regexp s_rxmeval ( )
static