---

HCAL_HLX::TCPReceiver Class Reference

#include <RecoLuminosity/TCPReceiver/interface/TCPReceiver.h>

List of all members.

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 (unsigned short int, std::string, unsigned char)
	TCPReceiver ()
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 46 of file TCPReceiver.h.

---

Constructor & Destructor Documentation

HCAL_HLX::TCPReceiver::TCPReceiver

(

)

Definition at line 14 of file TCPReceiver.cc.

References acquireMode, Connected, GenMuonPlsPt100GeV_cfg::cout, lat::endl(), 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 27 of file TCPReceiver.cc.

References acquireMode, Connected, GenMuonPlsPt100GeV_cfg::cout, lat::endl(), mode, 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 41 of file TCPReceiver.cc.

References Disconnect().

                           {
    Disconnect();
  }

---

Member Function Documentation

int HCAL_HLX::TCPReceiver::Connect

(

)

Definition at line 214 of file TCPReceiver.cc.

References acquireMode, HLT_VtxMuL3::connect, Connected, GenMuonPlsPt100GeV_cfg::cout, lat::endl(), servAddr, servIP, servPort, socket, and tcpSocket.

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

                          {
#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 aquire mode
    }
    
#ifdef DEBUG
    std::cout << "End " << __PRETTY_FUNCTION__ << " " << errorCode << std::endl;
#endif
    return errorCode;
  }

int HCAL_HLX::TCPReceiver::Disconnect

(

)

Definition at line 270 of file TCPReceiver.cc.

References Connected, GenMuonPlsPt100GeV_cfg::cout, lat::endl(), and tcpSocket.

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

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

    int errorCode;

    if(Connected){
      if(shutdown(tcpSocket,SHUT_RDWR)<0){
        perror("Shutdown Error");
        errorCode = 601; // Disconnect Failed
        Connected = false;
      } else {
        Connected = false;
        errorCode = 1;  // Successful Disconnect
      }
    } 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 296 of file TCPReceiver.cc.

References GenMuonPlsPt100GeV_cfg::cout, lat::endl(), i, j, and k.

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;
    
    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 370 of file TCPReceiver.cc.

References GenMuonPlsPt100GeV_cfg::cout, lat::endl(), i, j, k, and NULL.

Referenced by ReceiveLumiSection().

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

    srand(time(NULL));
    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 157 of file TCPReceiver.cc.

References Connected, GenMuonPlsPt100GeV_cfg::cout, and lat::endl().

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

                               {
#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 66 of file TCPReceiver.cc.

References acquireMode, Connected, GenMuonPlsPt100GeV_cfg::cout, lat::endl(), GenerateFakeData(), GenerateRandomData(), dummy::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;
        struct timeval tv;

        tv.tv_sec = 1;
        tv.tv_usec = 0;

        //      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, 0, &fdsExcept, 0)> 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 204 of file TCPReceiver.cc.

References GenMuonPlsPt100GeV_cfg::cout, lat::endl(), and servIP.

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

                                     {
#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 184 of file TCPReceiver.cc.

References acquireMode, GenMuonPlsPt100GeV_cfg::cout, and lat::endl().

Referenced by HLXMonitor::beginJob().

                                            {
#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 164 of file TCPReceiver.cc.

References GenMuonPlsPt100GeV_cfg::cout, lat::endl(), and servPort.

Referenced by HLXMonitor::beginJob().

                                                 {
#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 444 of file TCPReceiver.cc.

References GenerateFakeData(), L, and HLT_VtxMuL3::result.

                                                                     {

    HCAL_HLX::LUMI_SECTION L;
    GenerateFakeData(L);
    int result;

    result = memcmp(&L, &localSection, sizeof(L));

    if(result = 0){
      return true;
    }else{
      return false;
    }
  }

---

Member Data Documentation

unsigned char HCAL_HLX::TCPReceiver::acquireMode [private]

Definition at line 65 of file TCPReceiver.h.

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

bool HCAL_HLX::TCPReceiver::Connected [private]

Definition at line 66 of file TCPReceiver.h.

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

struct sockaddr_in HCAL_HLX::TCPReceiver::servAddr [read, private]

Definition at line 71 of file TCPReceiver.h.

Referenced by Connect().

std::string HCAL_HLX::TCPReceiver::servIP [private]

Definition at line 69 of file TCPReceiver.h.

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

unsigned short HCAL_HLX::TCPReceiver::servPort [private]

Definition at line 68 of file TCPReceiver.h.

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

int HCAL_HLX::TCPReceiver::tcpSocket [private]

Definition at line 70 of file TCPReceiver.h.

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

---

The documentation for this class was generated from the following files:

• RecoLuminosity/TCPReceiver/interface/TCPReceiver.h
• RecoLuminosity/TCPReceiver/src/TCPReceiver.cc

---