#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>") |
#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().
|
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().
|
static |