HCAL_HLX::TCPReceiver Class Reference

#include <TCPReceiver.h>

Public Member Functions
int	Connect ()
int	Disconnect ()
void	GenerateFakeData (HCAL_HLX::LUMI_SECTION &localSection)
void	GenerateRandomData (HCAL_HLX::LUMI_SECTION &localSection)
bool	IsConnected ()
int	ReceiveLumiSection (HCAL_HLX::LUMI_SECTION &localSection)
void	SetIP (std::string IP)
int	SetMode (unsigned char)
int	SetPort (unsigned short int)
	TCPReceiver ()
	TCPReceiver (unsigned short int, std::string, unsigned char)
bool	VerifyFakeData (HCAL_HLX::LUMI_SECTION &localSection)
	~TCPReceiver ()

Private Attributes
unsigned char	acquireMode
bool	Connected
struct sockaddr_in	servAddr
std::string	servIP
unsigned short	servPort
int	tcpSocket

Detailed Description

Definition at line 35 of file TCPReceiver.h.

Constructor & Destructor Documentation

HCAL_HLX::TCPReceiver::TCPReceiver

(

)

Definition at line 34 of file TCPReceiver.cc.

References acquireMode, Connected, gather_cfg::cout, servIP, and servPort.

                           {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif

    acquireMode = 0;
    servPort = 0;
    servIP = "127.0.0.1";
    Connected = false;

#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << std::endl;
#endif
  }

HCAL_HLX::TCPReceiver::TCPReceiver	(	unsigned short int	port,
		std::string	IP,
		unsigned char	mode = 0
	)

Definition at line 49 of file TCPReceiver.cc.

References acquireMode, Connected, gather_cfg::cout, listHistos::IP, universalConfigTemplate::mode, query::port, servIP, and servPort.

                                                                                        {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif
    acquireMode = mode;
    servPort = port;
    servIP = IP;
    Connected = false;

#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif
  }

HCAL_HLX::TCPReceiver::~TCPReceiver

(

)

Definition at line 63 of file TCPReceiver.cc.

References Disconnect().

{ Disconnect(); }

Member Function Documentation

int HCAL_HLX::TCPReceiver::Connect

(

)

Definition at line 229 of file TCPReceiver.cc.

References acquireMode, convertSQLitetoXML_cfg::connect, Connected, gather_cfg::cout, servAddr, servIP, servPort, and tcpSocket.

Referenced by HLXMonitor::analyze(), and HLXMonitor::connectHLXTCP().

                           {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif

    int errorCode;

    if (acquireMode == 0) {
      struct hostent *hostInfo = gethostbyname(servIP.c_str());

      if (servPort < 1024) {
        errorCode = 101;  // Protected ports
      } else {
#ifdef DEBUG
        std::cout << "Requesting connection" << std::endl;
#endif
        if ((tcpSocket = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
          perror("Socket Error");
          errorCode = 301;  // Socket failed
        } else {
          memset(&servAddr, 0, sizeof(servAddr));
          servAddr.sin_family = hostInfo->h_addrtype;
          memcpy((char *)&servAddr.sin_addr.s_addr, hostInfo->h_addr_list[0], hostInfo->h_length);
          //  servAddr.sin_addr.s_addr = inet_addr(servIP.c_str());
          servAddr.sin_port = htons(servPort);
#ifdef DEBUG
          std::cout << "Connecting" << std::endl;
#endif
          if (connect(tcpSocket, (struct sockaddr *)&servAddr, sizeof(servAddr)) < 0) {
            perror("Connect Error");
            errorCode = 302;  // connect failed
            close(tcpSocket);
          } else {
            Connected = true;
            errorCode = 1;  // Successful connection
          }
        }
      }
    } else if (acquireMode == 1) {
      Connected = true;
      errorCode = 1;  // do nothing for fake data
    } else if (acquireMode == 2) {
      Connected = true;
      errorCode = 1;  // do nothing for random data
    } else {
      errorCode = 201;  // Invalid acquire mode
    }

#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << " " << errorCode << std::endl;
#endif
    return errorCode;
  }

int HCAL_HLX::TCPReceiver::Disconnect

(

)

Definition at line 283 of file TCPReceiver.cc.

References acquireMode, Connected, gather_cfg::cout, and tcpSocket.

Referenced by HLXMonitor::analyze(), HLXMonitor::~HLXMonitor(), and ~TCPReceiver().

                              {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif

    int errorCode = 0;

    if (Connected) {
      if (acquireMode == 0) {
        if (shutdown(tcpSocket, SHUT_RDWR) < 0) {
          perror("Shutdown Error");
          errorCode = 601;  // Disconnect Failed
        } else {
          errorCode = 1;  // Successful Disconnect
        }
      }
      Connected = false;
    } else {
      errorCode = 401;  // Not Connected
    }

#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << " " << errorCode << std::endl;
#endif
    return errorCode;
  }

void HCAL_HLX::TCPReceiver::GenerateFakeData

(

HCAL_HLX::LUMI_SECTION &

localSection

)

Definition at line 310 of file TCPReceiver.cc.

References HCAL_HLX::LUMI_SECTION_HEADER::bCMSLive, HCAL_HLX::LUMI_SECTION_SUB_HEADER::bIsComplete, gather_cfg::cout, HCAL_HLX::ET_SUM_SECTION::data, HCAL_HLX::OCCUPANCY_SECTION::data, HCAL_HLX::LHC_SECTION::data, HCAL_HLX::LUMI_DETAIL::ETBXNormalization, HCAL_HLX::LUMI_DETAIL::ETLumi, HCAL_HLX::LUMI_DETAIL::ETLumiErr, HCAL_HLX::LUMI_DETAIL::ETLumiQlty, HCAL_HLX::LUMI_SUMMARY::ETNormalization, HCAL_HLX::LUMI_SECTION::etSum, HCAL_HLX::ET_SUM_SECTION::hdr, HCAL_HLX::OCCUPANCY_SECTION::hdr, HCAL_HLX::LHC_SECTION::hdr, HCAL_HLX::LUMI_SECTION::hdr, mps_fire::i, HCAL_HLX::LUMI_SUMMARY::InstantETLumi, HCAL_HLX::LUMI_SUMMARY::InstantETLumiErr, HCAL_HLX::LUMI_SUMMARY::InstantETLumiQlty, HCAL_HLX::LUMI_SUMMARY::InstantLumi, HCAL_HLX::LUMI_SUMMARY::InstantLumiErr, HCAL_HLX::LUMI_SUMMARY::InstantLumiQlty, HCAL_HLX::LUMI_SUMMARY::InstantOccLumi, HCAL_HLX::LUMI_SUMMARY::InstantOccLumiErr, HCAL_HLX::LUMI_SUMMARY::InstantOccLumiQlty, dqmiolumiharvest::j, isotrackApplyRegressor::k, HCAL_HLX::LUMI_SECTION::lhc, HCAL_HLX::LUMI_DETAIL::LHCLumi, HCAL_HLX::LUMI_SUMMARY::LHCNormalization, HCAL_HLX::LUMI_SECTION::lumiDetail, HCAL_HLX::LUMI_SUMMARY::lumiNoise, HCAL_HLX::LUMI_SECTION::lumiSummary, HCAL_HLX::LUMI_SECTION_HEADER::numBunches, HCAL_HLX::LUMI_SECTION_HEADER::numHLXs, HCAL_HLX::LUMI_SECTION_SUB_HEADER::numNibbles, HCAL_HLX::LUMI_SECTION_HEADER::numOrbits, HCAL_HLX::LUMI_DETAIL::OccBXNormalization, HCAL_HLX::LUMI_DETAIL::OccLumi, HCAL_HLX::LUMI_DETAIL::OccLumiErr, HCAL_HLX::LUMI_DETAIL::OccLumiQlty, HCAL_HLX::LUMI_SUMMARY::OccNormalization, HCAL_HLX::LUMI_SECTION::occupancy, HCAL_HLX::LUMI_SECTION_HEADER::runNumber, HCAL_HLX::LUMI_SECTION_HEADER::sectionNumber, HCAL_HLX::LUMI_SECTION_HEADER::startOrbit, HCAL_HLX::LUMI_SECTION_HEADER::timestamp, and HCAL_HLX::LUMI_SECTION_HEADER::timestamp_micros.

Referenced by ReceiveLumiSection(), and VerifyFakeData().

                                                                       {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif
    int i, j, k;

    localSection.hdr.runNumber = 1;
    localSection.hdr.startOrbit = 2;
    localSection.hdr.numOrbits = 3;
    localSection.hdr.numBunches = 4;
    localSection.hdr.numHLXs = 5;
    localSection.hdr.bCMSLive = true;
    localSection.hdr.sectionNumber = 120;

    timeval tvTemp;
    gettimeofday(&tvTemp, nullptr);
    localSection.hdr.timestamp = tvTemp.tv_sec;
    localSection.hdr.timestamp_micros = tvTemp.tv_usec;

    localSection.lumiSummary.DeadtimeNormalization = 0.7;
    localSection.lumiSummary.LHCNormalization = 0.75;
    localSection.lumiSummary.OccNormalization[0] = 0.8;
    localSection.lumiSummary.OccNormalization[1] = 0.85;
    localSection.lumiSummary.ETNormalization = 0.8;
    localSection.lumiSummary.InstantLumi = 0.9;
    localSection.lumiSummary.InstantLumiErr = 0.10;
    localSection.lumiSummary.InstantLumiQlty = 11;
    localSection.lumiSummary.InstantETLumi = 0.12;
    localSection.lumiSummary.InstantETLumiErr = 0.13;
    localSection.lumiSummary.InstantETLumiQlty = 14;
    localSection.lumiSummary.InstantOccLumi[0] = 0.15;
    localSection.lumiSummary.InstantOccLumiErr[0] = 0.16;
    localSection.lumiSummary.InstantOccLumiQlty[0] = 17;
    localSection.lumiSummary.lumiNoise[0] = 0.18;
    localSection.lumiSummary.InstantOccLumi[1] = 0.19;
    localSection.lumiSummary.InstantOccLumiErr[1] = 0.20;
    localSection.lumiSummary.InstantOccLumiQlty[1] = 21;
    localSection.lumiSummary.lumiNoise[1] = 0.22;

    for (j = 0; j < 3564; j++) {
      localSection.lumiDetail.ETBXNormalization[j] = 0.25 * j / 35640.0;
      localSection.lumiDetail.OccBXNormalization[0][j] = 0.5 * j / 35640.0;
      localSection.lumiDetail.OccBXNormalization[1][j] = 0.75 * j / 35640.0;
      localSection.lumiDetail.LHCLumi[j] = 1 * j / 35640.0;
      localSection.lumiDetail.ETLumi[j] = 2 * j / 35640.0;
      localSection.lumiDetail.ETLumiErr[j] = 3 * j / 35640.0;
      localSection.lumiDetail.ETLumiQlty[j] = 4 * j;
      localSection.lumiDetail.OccLumi[0][j] = 5 * j / 35640.0;
      localSection.lumiDetail.OccLumiErr[0][j] = 6 * j / 35640.0;
      localSection.lumiDetail.OccLumiQlty[0][j] = 7 * j;
      localSection.lumiDetail.OccLumi[1][j] = 8 * j / 35640.0;
      localSection.lumiDetail.OccLumiErr[1][j] = 9 * j / 35640.0;
      localSection.lumiDetail.OccLumiQlty[1][j] = 10 * j;
    }

    for (i = 0; i < 36; i++) {
      localSection.etSum[i].hdr.numNibbles = 7;
      localSection.occupancy[i].hdr.numNibbles = 8;
      localSection.lhc[i].hdr.numNibbles = 9;

      localSection.etSum[i].hdr.bIsComplete = true;
      localSection.occupancy[i].hdr.bIsComplete = true;
      localSection.lhc[i].hdr.bIsComplete = true;

      for (j = 0; j < 3564; j++) {
        localSection.etSum[i].data[j] = 6 * j + 10 * i;
        for (k = 0; k < 6; k++) {
          localSection.occupancy[i].data[k][j] = k * j + 11 * i;
        }
        localSection.lhc[i].data[j] = 7 * j + 12 * i;
      }
    }

#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << std::endl;
#endif
  }

void HCAL_HLX::TCPReceiver::GenerateRandomData

(

HCAL_HLX::LUMI_SECTION &

localSection

)

Definition at line 388 of file TCPReceiver.cc.

References HCAL_HLX::LUMI_SECTION_HEADER::bCMSLive, HCAL_HLX::LUMI_SECTION_SUB_HEADER::bIsComplete, gather_cfg::cout, HCAL_HLX::ET_SUM_SECTION::data, HCAL_HLX::OCCUPANCY_SECTION::data, HCAL_HLX::LHC_SECTION::data, HCAL_HLX::LUMI_DETAIL::ETBXNormalization, HCAL_HLX::LUMI_DETAIL::ETLumi, HCAL_HLX::LUMI_DETAIL::ETLumiErr, HCAL_HLX::LUMI_DETAIL::ETLumiQlty, HCAL_HLX::LUMI_SUMMARY::ETNormalization, HCAL_HLX::LUMI_SECTION::etSum, HCAL_HLX::ET_SUM_SECTION::hdr, HCAL_HLX::OCCUPANCY_SECTION::hdr, HCAL_HLX::LHC_SECTION::hdr, HCAL_HLX::LUMI_SECTION::hdr, mps_fire::i, HCAL_HLX::LUMI_SUMMARY::InstantETLumi, HCAL_HLX::LUMI_SUMMARY::InstantETLumiErr, HCAL_HLX::LUMI_SUMMARY::InstantETLumiQlty, HCAL_HLX::LUMI_SUMMARY::InstantLumi, HCAL_HLX::LUMI_SUMMARY::InstantLumiErr, HCAL_HLX::LUMI_SUMMARY::InstantLumiQlty, HCAL_HLX::LUMI_SUMMARY::InstantOccLumi, HCAL_HLX::LUMI_SUMMARY::InstantOccLumiErr, HCAL_HLX::LUMI_SUMMARY::InstantOccLumiQlty, dqmiolumiharvest::j, isotrackApplyRegressor::k, HCAL_HLX::LUMI_SECTION::lhc, HCAL_HLX::LUMI_DETAIL::LHCLumi, HCAL_HLX::LUMI_SUMMARY::LHCNormalization, HCAL_HLX::LUMI_SECTION::lumiDetail, HCAL_HLX::LUMI_SUMMARY::lumiNoise, HCAL_HLX::LUMI_SECTION::lumiSummary, HCAL_HLX::LUMI_SECTION_HEADER::numBunches, HCAL_HLX::LUMI_SECTION_HEADER::numHLXs, HCAL_HLX::LUMI_SECTION_SUB_HEADER::numNibbles, HCAL_HLX::LUMI_SECTION_HEADER::numOrbits, HCAL_HLX::LUMI_DETAIL::OccBXNormalization, HCAL_HLX::LUMI_DETAIL::OccLumi, HCAL_HLX::LUMI_DETAIL::OccLumiErr, HCAL_HLX::LUMI_DETAIL::OccLumiQlty, HCAL_HLX::LUMI_SUMMARY::OccNormalization, HCAL_HLX::LUMI_SECTION::occupancy, HCAL_HLX::LUMI_SECTION_HEADER::runNumber, HCAL_HLX::LUMI_SECTION_HEADER::sectionNumber, and HCAL_HLX::LUMI_SECTION_HEADER::startOrbit.

Referenced by ReceiveLumiSection().

                                                                         {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif
    int i, j, k;

    srand(time(nullptr));
    localSection.hdr.runNumber = 55;  //(rand() % 100);
    localSection.hdr.startOrbit = (rand() % 100);
    localSection.hdr.numOrbits = (rand() % 100);
    localSection.hdr.numBunches = (rand() % 100);
    localSection.hdr.numHLXs = (rand() % 100);
    localSection.hdr.bCMSLive = true;
    localSection.hdr.sectionNumber = (rand() % 100);

    localSection.lumiSummary.DeadtimeNormalization = (float)(rand() % 100) / 100;
    localSection.lumiSummary.LHCNormalization = (float)(rand() % 100) / 100;
    localSection.lumiSummary.OccNormalization[0] = (float)(rand() % 100) / 100;
    localSection.lumiSummary.OccNormalization[1] = (float)(rand() % 100) / 100;
    localSection.lumiSummary.ETNormalization = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantLumi = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantLumiErr = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantLumiQlty = (rand() % 100);
    localSection.lumiSummary.InstantETLumi = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantETLumiErr = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantETLumiQlty = (rand() % 100);
    localSection.lumiSummary.InstantOccLumi[0] = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantOccLumiErr[0] = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantOccLumiQlty[0] = (rand() % 100);
    localSection.lumiSummary.lumiNoise[0] = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantOccLumi[1] = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantOccLumiErr[1] = (float)(rand() % 100) / 100;
    localSection.lumiSummary.InstantOccLumiQlty[1] = (rand() % 100);
    localSection.lumiSummary.lumiNoise[1] = (float)(rand() % 100) / 100;

    for (j = 0; j < 3564; j++) {
      localSection.lumiDetail.ETBXNormalization[j] = 0.25 * j / 35640.0;
      localSection.lumiDetail.OccBXNormalization[0][j] = 0.5 * j / 35640.0;
      localSection.lumiDetail.OccBXNormalization[1][j] = 0.75 * j / 35640.0;
      localSection.lumiDetail.LHCLumi[j] = (float)(rand() % 100) / 100.0;
      localSection.lumiDetail.ETLumi[j] = (float)(rand() % 100) / 100.0;
      localSection.lumiDetail.ETLumiErr[j] = (float)(rand() % 100) / 100.0;
      localSection.lumiDetail.ETLumiQlty[j] = (rand() % 100);
      localSection.lumiDetail.OccLumi[0][j] = (float)(rand() % 100) / 100.0;
      localSection.lumiDetail.OccLumiErr[0][j] = (float)(rand() % 100) / 100.0;
      localSection.lumiDetail.OccLumiQlty[0][j] = (rand() % 100);
      localSection.lumiDetail.OccLumi[1][j] = (float)(rand() % 100) / 100.0;
      localSection.lumiDetail.OccLumiErr[1][j] = (float)(rand() % 100) / 100.0;
      localSection.lumiDetail.OccLumiQlty[1][j] = (rand() % 100);
    }

    for (i = 0; i < 36; i++) {
      localSection.etSum[i].hdr.numNibbles = (rand() % 100);
      localSection.occupancy[i].hdr.numNibbles = 8 * (rand() % 100);
      localSection.lhc[i].hdr.numNibbles = 9 * (rand() % 100);

      localSection.etSum[i].hdr.bIsComplete = true;
      localSection.occupancy[i].hdr.bIsComplete = true;
      localSection.lhc[i].hdr.bIsComplete = true;

      for (j = 0; j < 3564; j++) {
        localSection.etSum[i].data[j] = 6 * (rand() % 3564);
        for (k = 0; k < 6; k++) {
          localSection.occupancy[i].data[k][j] = k * (rand() % 3564);
        }
        localSection.lhc[i].data[j] = 7 * (rand() % 3564);
      }
    }

#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << std::endl;
#endif
  }

bool HCAL_HLX::TCPReceiver::IsConnected

(

)

Definition at line 172 of file TCPReceiver.cc.

References Connected, and gather_cfg::cout.

Referenced by HLXMonitor::analyze(), and HLXMonitor::connectHLXTCP().

                                {
#ifdef DEBUG
    std::cout << "Begin and End  " << __PRETTY_FUNCTION__ << " " << Connected << std::endl;
#endif
    return Connected;
  }

int HCAL_HLX::TCPReceiver::ReceiveLumiSection

(

HCAL_HLX::LUMI_SECTION &

localSection

)

Definition at line 87 of file TCPReceiver.cc.

References acquireMode, Connected, gather_cfg::cout, GenerateFakeData(), GenerateRandomData(), PixelPluginsPhase0_cfi::select, HCAL_HLX::SetupFDSets(), and tcpSocket.

Referenced by HLXMonitor::analyze().

                                                                        {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif

    int errorCode = 0;

    if (acquireMode == 0) {  // real data
      if (Connected == false) {
        errorCode = 701;  // not connected
      } else {
        unsigned int bytesRcvd, bytesToReceive, totalBytesRcvd;
        const unsigned int Buffer_Size = 8192;
        char *Buffer;
        char *BigBuffer;

        // From John's code

        fd_set fdsRead, fdsWrite, fdsExcept;

        //  int outputcode;
        //int z = 0, localCount = 0;
        time_t tempTime, curTime;
        //int ret;

        time(&curTime);

        bytesToReceive = sizeof(localSection);
        Buffer = new char[Buffer_Size];
        BigBuffer = new char[bytesToReceive];
        totalBytesRcvd = 0;

        memset(reinterpret_cast<char *>(&localSection), 0, Buffer_Size);
        memset(Buffer, 0, Buffer_Size);
        memset(BigBuffer, 0, bytesToReceive);

        usleep(10000);

        while ((totalBytesRcvd < bytesToReceive) && (errorCode == 0)) {
          SetupFDSets(fdsRead, fdsWrite, fdsExcept, -1, tcpSocket);

          if (select(tcpSocket + 1, &fdsRead, nullptr, &fdsExcept, nullptr) > 0) {
            if (FD_ISSET(tcpSocket, &fdsRead)) {
              if ((bytesRcvd = recv(tcpSocket, Buffer, Buffer_Size, 0)) <= 0) {
                perror("Recv Error");
                errorCode = 501;
              } else {
                if ((totalBytesRcvd + bytesRcvd) <= bytesToReceive) {
                  memcpy(&BigBuffer[totalBytesRcvd], Buffer, bytesRcvd);
                } else {
                  std::cout << "***** MEM OVER FLOW: Did someone forget to update LumiStructures.hh? *****"
                            << std::endl;
                  errorCode = 502;
                }
                totalBytesRcvd += bytesRcvd;
                time(&tempTime);
              }
            }
          }
        }

        if (errorCode == 0) {
          memcpy(reinterpret_cast<char *>(&localSection), BigBuffer, sizeof(localSection));
          errorCode = 1;  // success
        }
        delete[] Buffer;
        delete[] BigBuffer;
      }
    } else if (acquireMode == 1) {  // fill with fake data. Should be unique.
      GenerateFakeData(localSection);
      errorCode = 1;
    } else if (acquireMode == 2) {  // fill with random fake data.
      GenerateRandomData(localSection);
      errorCode = 1;
    } else {
      errorCode = 201;
    }

#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << " " << errorCode << std::endl;
#endif

    return errorCode;
  }

void HCAL_HLX::TCPReceiver::SetIP

(

std::string

IP

)

Definition at line 219 of file TCPReceiver.cc.

References gather_cfg::cout, listHistos::IP, and servIP.

Referenced by HLXMonitor::analyze(), and HLXMonitor::connectHLXTCP().

                                      {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif
    servIP = IP;
#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << std::endl;
#endif
  }

int HCAL_HLX::TCPReceiver::SetMode

(

unsigned char

mode

)

Definition at line 199 of file TCPReceiver.cc.

References acquireMode, gather_cfg::cout, and universalConfigTemplate::mode.

Referenced by HLXMonitor::connectHLXTCP().

                                             {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif

    int errorCode;

    if (mode > 2) {
      errorCode = 201;
    } else {
      acquireMode = mode;
      errorCode = 1;
    }

#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << " " << errorCode << std::endl;
#endif
    return errorCode;
  }

int HCAL_HLX::TCPReceiver::SetPort

(

unsigned short int

port

)

Definition at line 179 of file TCPReceiver.cc.

References gather_cfg::cout, query::port, and servPort.

Referenced by HLXMonitor::connectHLXTCP().

                                                  {
#ifdef DEBUG
    std::cout << "Begin " << __PRETTY_FUNCTION__ << std::endl;
#endif

    int errorCode;

    if (port < 1024) {
      errorCode = 101;
    } else {
      servPort = port;
      errorCode = 1;
    }

#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << " " << errorCode << std::endl;
#endif
    return errorCode;
  }

bool HCAL_HLX::TCPReceiver::VerifyFakeData

(

HCAL_HLX::LUMI_SECTION &

localSection

)

Definition at line 462 of file TCPReceiver.cc.

References GenerateFakeData(), and dttmaxenums::L.

                                                                     {
    HCAL_HLX::LUMI_SECTION L;
    GenerateFakeData(L);
    return !(memcmp(&L, &localSection, sizeof(L)));
  }

Member Data Documentation

unsigned char HCAL_HLX::TCPReceiver::acquireMode

private

Definition at line 53 of file TCPReceiver.h.

Referenced by Connect(), Disconnect(), ReceiveLumiSection(), SetMode(), and TCPReceiver().

bool HCAL_HLX::TCPReceiver::Connected

private

Definition at line 54 of file TCPReceiver.h.

Referenced by Connect(), Disconnect(), IsConnected(), ReceiveLumiSection(), and TCPReceiver().

struct sockaddr_in HCAL_HLX::TCPReceiver::servAddr

private

Definition at line 59 of file TCPReceiver.h.

Referenced by Connect().

std::string HCAL_HLX::TCPReceiver::servIP

private

Definition at line 57 of file TCPReceiver.h.

Referenced by Connect(), SetIP(), and TCPReceiver().

unsigned short HCAL_HLX::TCPReceiver::servPort

private

Definition at line 56 of file TCPReceiver.h.

Referenced by Connect(), SetPort(), and TCPReceiver().

int HCAL_HLX::TCPReceiver::tcpSocket

private

Definition at line 58 of file TCPReceiver.h.

Referenced by Connect(), Disconnect(), and ReceiveLumiSection().