#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)

	~DTCtcp ()

Protected Attributes
struct sockaddr_in	clientAddr

int	connected

struct sockaddr_in	myaddr

int	port

int	sock

Detailed Description

Definition at line 18 of file DTSpyHelper.h.

Constructor & Destructor Documentation

DTCtcp::DTCtcp ( )

Definition at line 15 of file DTSpyHelper.cc.

Referenced by Accept().

15 { DTCtcp(0); }

DTCtcp::DTCtcp

DTCtcp()

Definition: DTSpyHelper.cc:15

DTCtcp::DTCtcp ( int port )

Definition at line 17 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 62 of file DTSpyHelper.cc.

References connected, port, and sock.

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

DTCtcp::DTCtcp ( DTCtcp * aconn )

Definition at line 69 of file DTSpyHelper.cc.

References connected, port, and sock.

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

DTCtcp::~DTCtcp ( )

Definition at line 76 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 100 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 89 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 133 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 121 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 95 of file DTSpyHelper.cc.

References connected, and sock.

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

short DTCtcp::Id ( )

Definition at line 83 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 145 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 165 of file DTSpyHelper.cc.

References connected, sock, and writeEcalDQMStatus::write.

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