DTCtcp Class Reference

#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() [1/4]

DTCtcp::DTCtcp

(

)

Definition at line 15 of file DTSpyHelper.cc.

Referenced by Accept().

{ DTCtcp(0); }

DTCtcp() [2/4]

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() [3/4]

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() [4/4]

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::~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

Accept()

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);
}

addr()

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;
}

Connect() [1/2]

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

Definition at line 133 of file DTSpyHelper.cc.

References clientAddr, GlobalPosition_Frontier_DevDB_cff::connect, connected, query::host, 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;
}

Connect() [2/2]

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

Definition at line 121 of file DTSpyHelper.cc.

References clientAddr, GlobalPosition_Frontier_DevDB_cff::connect, connected, recoMuon::in, 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;
}

Disconnect()

int DTCtcp::Disconnect

(

)

Definition at line 95 of file DTSpyHelper.cc.

References connected, and sock.

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

Id()

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;
}

Receive()

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

Definition at line 145 of file DTSpyHelper.cc.

References edmScanValgrind::buffer, 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;
}

Send()

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

Definition at line 165 of file DTSpyHelper.cc.

References edmScanValgrind::buffer, connected, findQualityFiles::size, sock, and writeEcalDQMStatus::write.

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

Member Data Documentation

clientAddr

struct sockaddr_in DTCtcp::clientAddr

protected

Definition at line 24 of file DTSpyHelper.h.

Referenced by Accept(), addr(), Connect(), and Id().

connected

int DTCtcp::connected

protected

Definition at line 23 of file DTSpyHelper.h.

Referenced by Connect(), Disconnect(), DTCtcp(), DTSpy::getNextBuffer(), and Send().

myaddr

struct sockaddr_in DTCtcp::myaddr

protected

Definition at line 25 of file DTSpyHelper.h.

Referenced by DTCtcp().

port

int DTCtcp::port

protected

Definition at line 20 of file DTSpyHelper.h.

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

sock

int DTCtcp::sock

protected

Definition at line 21 of file DTSpyHelper.h.

Referenced by Accept(), Connect(), Disconnect(), DTCtcp(), Receive(), Send(), and ~DTCtcp().