#include <DTSpyHelper.h>

Inheritance diagram for DTCtcp:

Public Member Functions
DTCtcp *	Accept ()

unsigned long	addr ()

void	Connect (const char *hostaddr, int port)

void	Connect (unsigned long hostaddr, int port)

int	Disconnect ()

	DTCtcp ()

	DTCtcp (int port)

	DTCtcp (int sock, int opt)

	DTCtcp (DTCtcp *)

short	Id ()

int	Receive (char *buffer, int size)

int	Send (char *buffer, int size)

int	WaitData (int timeout)

	~DTCtcp ()

Protected Attributes
struct sockaddr_in	clientAddr

int	connected

struct sockaddr_in	myaddr

int	port

int	sock

Detailed Description

Definition at line 19 of file DTSpyHelper.h.

Constructor & Destructor Documentation

DTCtcp::DTCtcp ( )

Definition at line 15 of file DTSpyHelper.cc.

Referenced by Accept().

 {
    DTCtcp(0);
 }

DTCtcp::DTCtcp ( int port )

Definition at line 20 of file DTSpyHelper.cc.

References connected, myaddr, port, and sock.

 {
 //  struct sockaddr_in myaddr;
  
     connected=false;
 
      printf("zeroing...\n");
     bzero ((char *) &myaddr, sizeof(myaddr));
      printf("zeroing done..\n");
 
 
    sock = socket (AF_INET, SOCK_STREAM, 0);
      printf("create socket..\n");
 
    if (sock < 0)
    {
      printf("no socket...\n");
       throw DTtcpExcp(errno);
    }
   
 
     myaddr.sin_family       = AF_INET;
     myaddr.sin_port         = htons (localport);
  
     //int blen = 65536;
     int blen = 65536*8;
 
 //     printf("setting socket opts buf...\n");
 //    if(setsockopt(sock,SOL_SOCKET,SO_SNDBUF,(char *)&blen,sizeof(blen))<0)
 //      throw DTtcpExcp(errno);
 //    if(setsockopt(sock,SOL_SOCKET,SO_RCVBUF,(char *)&blen,sizeof(blen))<0)
 //      throw DTtcpExcp(errno);
      printf("setting socket opts reuse...\n");
     if(setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(char *)&blen,sizeof(blen))<0)
       throw DTtcpExcp(errno);
 //     printf("setting socket opts nodelay...\n");
 //    if(setsockopt(sock,SOL_SOCKET,TCP_NODELAY,(char *)&blen,sizeof(blen))<0)
 //      throw;
      printf("binding...\n");
 
     port = localport;
 
     if (port)
         if(bind(sock,(struct sockaddr *)&myaddr,sizeof (myaddr)) < 0)
         { perror ("bind failed");
           throw DTtcpExcp(errno);
         }
 
           
 }

DTCtcp::DTCtcp	(	int	sock,
		int	opt
	)

Definition at line 71 of file DTSpyHelper.cc.

References connected, port, and sock.

 {
 
    connected = true;
    port =0;
 
    sock = snew;
 }

DTCtcp::DTCtcp ( DTCtcp * aconn )

Definition at line 80 of file DTSpyHelper.cc.

References connected, port, and sock.

 {
 
    connected = aconn->connected;
    port = aconn->port;
 
    sock = aconn->sock;
 }

DTCtcp::~DTCtcp ( )

Definition at line 89 of file DTSpyHelper.cc.

References sock.

 {
   printf("deleting DTCtcp\n");
   //if (connected) shutdown(sock,2);
   shutdown(sock,SHUT_RDWR);
   close (sock);
 }

Member Function Documentation

DTCtcp * DTCtcp::Accept ( )

Definition at line 121 of file DTSpyHelper.cc.

References accept(), clientAddr, DTCtcp(), and sock.

 {
 
  //   struct sockaddr_in  clientAddr; /* client's address */    
 
     bzero ((char *) &clientAddr, sizeof (clientAddr));
 
     if (listen (sock, 2) < 0)
         {
         perror ("listen failed");
         throw DTtcpExcp(errno);
         }
 
     int len = sizeof (clientAddr);
 
     int snew = accept (sock, (struct sockaddr *) &clientAddr,(socklen_t *) &len);
     if (snew <=0) 
     {
         perror ("accept failed");
         throw DTtcpExcp(errno);
     }
  
     return new DTCtcp(snew,0);
 }

unsigned long DTCtcp::addr ( )

Definition at line 106 of file DTSpyHelper.cc.

References clientAddr.

 {
     unsigned long maddr = clientAddr.sin_addr.s_addr;
     maddr = htonl (maddr);
     return maddr;
 }

void DTCtcp::Connect	(	const char *	hostaddr,
		int	port
	)

Definition at line 162 of file DTSpyHelper.cc.

References clientAddr, DBConfiguration_cff::connect, connected, and sock.

Referenced by DTSpy::DTSpy(), and DTSpyReader::DTSpyReader().

 {
     clientAddr.sin_family      = AF_INET;
     clientAddr.sin_addr.s_addr = inet_addr (host);
     clientAddr.sin_port        = htons (toport);
   
  if (connect (sock, (struct sockaddr  *)&clientAddr, sizeof (clientAddr)) < 0)
 {
         perror ("connect failed");
         throw DTtcpExcp(errno);
 }
   connected = true;
 }

void DTCtcp::Connect	(	unsigned long	hostaddr,
		int	port
	)

Definition at line 147 of file DTSpyHelper.cc.

References clientAddr, DBConfiguration_cff::connect, connected, and sock.

 {
     clientAddr.sin_family      = AF_INET;
     clientAddr.sin_addr.s_addr = htonl (in);
     clientAddr.sin_port        = htons (toport);
   
  if (connect (sock, (struct sockaddr  *)&clientAddr, sizeof (clientAddr)) < 0)
 {
         perror ("connect failed");
         throw DTtcpExcp(errno);
 }
   connected = true;
 }

int DTCtcp::Disconnect ( )

Definition at line 114 of file DTSpyHelper.cc.

References connected, and sock.

 {
   connected = false;
   return shutdown(sock,SHUT_RDWR);
 }

short DTCtcp::Id ( )

Definition at line 98 of file DTSpyHelper.cc.

References clientAddr.

 {
     long maddr = clientAddr.sin_addr.s_addr;
     maddr = htonl (maddr);
     return maddr&0xff;
 }

int DTCtcp::Receive	(	char *	buffer,
		int	size
	)

Definition at line 197 of file DTSpyHelper.cc.

References findQualityFiles::size, and sock.

Referenced by DTSpy::getNextBuffer().

 {
 //    return  read (sock, buffer,size) ;
  
     int howmany = 0;
     int toberead = size;
     do
     {
       //int readnow = recv (sock, &buffer[howmany], toberead,MSG_WAITALL) ;
       int readnow = recv (sock, &buffer[howmany], toberead,0) ;
       //if (readnow < 0 ) {printf("some rrorrs...%d\n",errno); return -1;}
       if (readnow <= 0 ) 
            {printf("some rrorrs...%d\n",errno); throw DTtcpExcp(errno);}
       else { 
         howmany+=readnow; toberead-=readnow;}
     } while (toberead>0);
     return howmany;
 }

int DTCtcp::Send	(	char *	buffer,
		int	size
	)

Definition at line 217 of file DTSpyHelper.cc.

References connected, sock, and TriggerAnalyzer::write().

 {
   if (connected==false) throw DTtcpExcp(EPIPE);
     int myret =  write (sock, buffer, size) ;
     if (myret<0) throw DTtcpExcp(errno);
     return myret;
 }

int DTCtcp::WaitData ( int timeout )

Definition at line 177 of file DTSpyHelper.cc.

References TauGenJetsDecayModeSelectorAllHadrons_cfi::select, sock, and mps_check::timeout.

 {
 //    return  read (sock, buffer,size) ;
      fd_set rfds;
      struct timeval tv;
    
     FD_ZERO(&rfds);
     FD_SET(sock,&rfds);
 
     tv.tv_sec = timeout;
     tv.tv_usec = 0;
  
      int retva = select (1,&rfds,nullptr,&rfds,&tv);
      if (retva)
          if (FD_ISSET(0,&rfds)) return 1;
          else return -1;
      else return 0; 
 }