Search  

---

C:/temp/src/j2k/Net/TcpSocket.cpp

Go to the documentation of this file.

// Wolf for J2K Library
// LGPL Licensed.
// http://j2k.sourceforge.net/
// Revision #1: Fred P. - Oct 2nd, 2001

#ifndef __J2K__NET__TCPSOCKET_cPP__
#define __J2K__NET__TCPSOCKET_cPP__

#include <j2k/Net/TcpSocket.hpp>

//
// CONSTRUCTORS
//

TcpSocket::TcpSocket(int port = 0)  throw(int)
  : Socket((struct sockaddr *)NULL, PF_INET, SOCK_STREAM, 0)
{
  struct sockaddr_in *s_in = (struct sockaddr_in *)lsa;
  remoteAddress = NULL;
  remotePort = 0;
  localPort = port;
  s_in->sin_family = AF_INET;
  s_in->sin_port = htons(localPort);
  s_in->sin_addr.s_addr = htonl(INADDR_ANY);
  memset(&(s_in->sin_zero), '\0', 8);
  bind();
}

TcpSocket::TcpSocket(Socket &original) throw(int)
  : Socket( original.getSocket(), PF_INET, SOCK_STREAM, 0 )
{
  
}
  
TcpSocket::TcpSocket(InetAddress& address, int port = 0) throw(int)
  : Socket((struct sockaddr *)NULL, PF_INET, SOCK_STREAM, 0)
{
  struct sockaddr_in *s_in = (struct sockaddr_in *)lsa;
  remoteAddress = NULL;
  remotePort = 0;
  localPort = port;
  s_in->sin_family = AF_INET;
  s_in->sin_port = htons(localPort);
  s_in->sin_addr.s_addr = address.getAddress2();
  memset(&(s_in->sin_zero), '\0', 8);
  bind();
}

TcpSocket::TcpSocket(InetAddress& remoteAddr, int remotePort, InetAddress& localAddress, int localPort) throw(int)
  : Socket((struct sockaddr *)NULL, PF_INET, SOCK_STREAM, 0)
{
  struct sockaddr_in *ls_in = (struct sockaddr_in *)lsa, *rs_in = (struct sockaddr_in *)rsa;
  this->localPort = localPort;
  ls_in->sin_family = AF_INET;
  ls_in->sin_port = htons(this->localPort);
  ls_in->sin_addr.s_addr = localAddress.getAddress2();
  memset(&(ls_in->sin_zero), '\0', 8);
  bind();
  remoteAddress = new InetAddress(remoteAddr);
  this->remotePort = remotePort;
   ls_in->sin_family = AF_INET;
  ls_in->sin_port = htons(this->remotePort);
  ls_in->sin_addr.s_addr = remoteAddress->getAddress2();
  memset(&(ls_in->sin_zero), '\0', 8);
  connect();
}

#ifdef USE_JSTRING
TcpSocket::TcpSocket(JString &host, int port) throw(int)
  : Socket((struct sockaddr *)NULL, PF_INET, SOCK_STREAM, 0)
{
  struct sockaddr_in *s_in = (struct sockaddr_in *)lsa;
  InetAddress *I = new InetAddress(host);
  remoteAddress = NULL;
  remotePort = 0;
  localPort = port;
  s_in->sin_family = AF_INET;
  s_in->sin_port = htons(localPort);
  s_in->sin_addr.s_addr = I->getAddress2();
  memset(&(s_in->sin_zero), '\0', 8);
  bind();
  delete I;
}

TcpSocket::TcpSocket(JString &remoteHost, int remotePort, InetAddress& localAddress, int localPort) throw(int)
  : Socket((struct sockaddr *)NULL, PF_INET, SOCK_STREAM, 0)
{
  struct sockaddr_in *ls_in = (struct sockaddr_in *)lsa, *rs_in = (struct sockaddr_in *)rsa;
  InetAddress *remoteAddr = new InetAddress(remoteHost);
  this->localPort = localPort;
  ls_in->sin_family = AF_INET;
  ls_in->sin_port = htons(this->localPort);
  ls_in->sin_addr.s_addr = localAddress.getAddress2();
  memset(&(ls_in->sin_zero), '\0', 8);
  bind();
  this->remotePort = remotePort;
  ls_in->sin_family = AF_INET;
  ls_in->sin_port = htons(this->remotePort);
  ls_in->sin_addr.s_addr = remoteAddress->getAddress2();
  memset(&(ls_in->sin_zero), '\0', 8);
  connect();
  delete remoteAddr;
}
#else
TcpSocket::TcpSocket(char *host, int port) throw(int)
  : Socket((struct sockaddr *)NULL, PF_INET, SOCK_STREAM, 0)
{
  struct sockaddr_in *s_in = (struct sockaddr_in *)lsa;
  InetAddress *I = new InetAddress(host);
  remoteAddress = NULL;
  remotePort = 0;
  localPort = port;
  s_in->sin_family = AF_INET;
  s_in->sin_port = htons(localPort);
  s_in->sin_addr.s_addr = I->getAddress2();
  memset(&(s_in->sin_zero), '\0', 8);
  bind();
  delete I;
}
  
TcpSocket::TcpSocket(char *remoteHost, int remotePort, InetAddress& localAddress, int localPort) throw(int)
  : Socket((struct sockaddr *)NULL, PF_INET, SOCK_STREAM, 0)
{
  struct sockaddr_in *ls_in = (struct sockaddr_in *)lsa, *rs_in = (struct sockaddr_in *)rsa;
  InetAddress *remoteAddr = new InetAddress(remoteHost);
  this->localPort = localPort;
  ls_in->sin_family = AF_INET;
  ls_in->sin_port = htons(this->localPort);
  ls_in->sin_addr.s_addr = localAddress.getAddress2();
  memset(&(ls_in->sin_zero), '\0', 8);
  bind();
  this->remotePort = remotePort;
  ls_in->sin_family = AF_INET;
  ls_in->sin_port = htons(this->remotePort);
  ls_in->sin_addr.s_addr = remoteAddress->getAddress2();
  memset(&(ls_in->sin_zero), '\0', 8);
  connect();
  delete remoteAddr;
}
#endif    

//
// METHODS
//

InetAddress TcpSocket::getLocalAddress() const
{  
  InetAddress I(inet_ntoa(((struct sockaddr_in*)lsa)->sin_addr));
  return I;
}
    
InetAddress TcpSocket::getInetAddress() const
{  
  return *remoteAddress;
}

#ifdef USE_JSTRING
JString TcpSocket::getLocalHost() const
{
  JString S(inet_ntoa(((struct sockaddr_in*)lsa)->sin_addr));
   return S;
}

inline JString TcpSocket::getHost() const
{
  return remoteAddress->getHostName();
}
#else
const char* TcpSocket::getLocalHost() const
{
  return inet_ntoa(((struct sockaddr_in*)lsa)->sin_addr);
}

inline const char*  TcpSocket::getHost() const
{
  return remoteAddress->getHostName();
}
#endif

inline int TcpSocket::getLocalPort() const
{
  return localPort;
}

inline int TcpSocket::getPort() const
{
  return remotePort;
}


int TcpSocket::setTcpNoDelay(BOOL on)
{
  struct protoent *pe;
   
  pe = getprotobyname("TCP");
  if(setSockOpt(pe->p_proto,TCP_NODELAY,(void *)&on,sizeof(int)) != 0) {
//    perror("TcpSocket::setTcpNoDelay() FAIL");
     return -1;
  }
  return 0;
}
  
int TcpSocket::setSoLinger(BOOL on, int linger)
{
  struct linger lin;
  lin.l_onoff = on;
  lin.l_linger = linger;
  if(setSockOpt(SOL_SOCKET,SO_LINGER,(void *)&lin,sizeof(struct linger)) != 0)
     return -1;
//     perror("TcpSocket::setSoLinger() FAIL");
  
  return 0;
}  

int TcpSocket::setSoTimeout(int timeout)
{
#if 0
  if(setSockOpt(SOL_SOCKET,SO_TIMEOUT,(void *)&timeout,sizeof(int)) != 0)
     return -1;
//     perror("TcpSocket::setSoTimeout() FAIL");
  
  return 0;
#else
   errno = EBADF;
   return -1;
#endif
   
}

int TcpSocket::setSendBufferSize(int size)
{
  if(setSockOpt(SOL_SOCKET,SO_SNDBUF,(void *)&size,sizeof(int)) != 0) {
//    perror("TcpSocket::setTcpNoDelay() FAIL");
     return -1;
  }
  return 0;
}

int TcpSocket::setRecieveBufferSize(int size)
{
  if(setSockOpt(SOL_SOCKET,SO_RCVBUF,(void *)&size,sizeof(int)) != 0) {
//    perror("TcpSocket::setTcpNoDelay() FAIL");
     return -1;
  }
  return 0;
}

int TcpSocket::setKeepAlive(BOOL on)
{
  if(setSockOpt(SOL_SOCKET,SO_KEEPALIVE,(void *)&on,sizeof(int)) != 0) {
//    perror("TcpSocket::setTcpNoDelay() FAIL");
     return -1;
  }
  return 0;
}
  


BOOL TcpSocket::getTcpNoDelay()
{
  struct protoent *pe;
  BOOL ret = false;
  int rets = sizeof(int);
   
  pe = getprotobyname("TCP");
  if(getSockOpt(pe->p_proto,TCP_NODELAY,(void *)&ret,(socklen_t*)&rets) != 0) {
//    perror("TcpSocket::setTcpNoDelay() FAIL");
     return false; 
  }
  return ret;
}

int TcpSocket::getSoLinger()
{
  struct linger ret;
  ret.l_onoff = 0;
  ret.l_linger = 0;
  int rets =  sizeof(int);
  if(setSockOpt(SOL_SOCKET,SO_LINGER,(void *)&ret,rets) != 0)
    return -1;
//     perror("TcpSocket::setSoLinger() FAIL");
  if(rets != sizeof(struct linger))
    return 0;
  if((BOOL)ret.l_onoff == false)
     return 0;
  return ret.l_linger;;
}

int TcpSocket::getSoTimeout()
{
   return -1;
}

int TcpSocket::getSendBufferSize()
{
  int ret = 0;
  int rets = sizeof(int);
  if(getSockOpt(SOL_SOCKET,SO_SNDBUF,(void *)&ret,(socklen_t *) &rets) != 0) {
//    perror("TcpSocket::setTcpNoDelay() FAIL");
     return -1;
  }
  return ret;   
}

int TcpSocket::getRecieveBufferSize()
{
  int ret = 0;
  int rets = sizeof(int);
  if(getSockOpt(SOL_SOCKET,SO_RCVBUF,(void *)&ret,(socklen_t *) &rets) != 0) {
//    perror("TcpSocket::setTcpNoDelay() FAIL");
     return -1;
  }
  return ret;   
}

BOOL TcpSocket::getKeepAlive()
{
  int ret = 0;
  int rets = sizeof(int);
  if(getSockOpt(SOL_SOCKET,SO_KEEPALIVE,(void *)&ret,(socklen_t *) &rets) != 0) {
//    perror("TcpSocket::setTcpNoDelay() FAIL");
     return -1;
  }
  return ret;   
}

int TcpSocket::read(char * buffer, size_t len, int flags = 0)
{
   int l  = len;
   l = recv(sck,(void  *)buffer, len, flags);
   return l;
}

// return -1 and set errno on error 
int TcpSocket::send(char * buffer, size_t len, int flags = 0)
{
   int l  = len;
   l = ::send(sck,(void  *)buffer, len, flags);
   return l;
}

#endif //__J2K__NET__TCPSOCKET_cPP__

---