---

ServerSocket.cpp

Go to the documentation of this file.

/*
 * $Id: ServerSocket.cpp,v 1.3 2002/07/11 16:56:12 mindstorm2600 Exp $
 */
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<netdb.h>
#include<errno.h>
#include<iostream.h>
#include<signal.h>
#include"ServerSocket.h"
#include"Exception.h"

namespace clawsoft{

extern void addSigpipeHandler();
 
ServerSocket::ServerSocket(const int p, const int m){
 setClassName("ServerSocket");
 CreateSocket(p, m);
}

int ServerSocket::CreateSocket(const int p, const int m){
 int ret;
 sock = -1;
 port = p;
 maxConn = m;
 struct sockaddr_in name;
 struct linger opt;
#ifdef SOLARIS
 char *ptr;
#endif
 addSigpipeHandler();
 sock = socket (PF_INET, SOCK_STREAM, 0);
 if (sock < 0){
         switch(errno){
                case EMFILE:
                        throw ProcOutOfFileDescriptorsException();
                break;
                case ENFILE:
                        throw SysOutOfFileDescriptorsException();
                break;
                default:
                        throw IOException();
         }
 }
 name.sin_family = AF_INET;
 name.sin_port = htons (port);
 name.sin_addr.s_addr = htonl (INADDR_ANY);
 
 opt.l_onoff = 1;
 opt.l_linger = 0; 
#ifdef SOLARIS
 ptr = (char *)&opt;
 ret = setsockopt(sock, SOL_SOCKET, SO_LINGER, ptr, sizeof(opt)); 
#else
 ret = setsockopt(sock, SOL_SOCKET, SO_LINGER, (struct linger*)&opt, sizeof(opt)); 
#endif
 if(ret == -1){
         throw NetworkException();
 }
 
 if (bind (sock, (struct sockaddr *) &name, sizeof (name)) < 0){
         switch(errno){
                 case EINVAL:
                         throw SocketAlreadyBoundedException();
                         break;
                 default:
                         throw NetworkException();
         }
 }
 return 1;
}

Socket *ServerSocket::accept(){
 int ss;
 struct sockaddr_in client;
#ifdef SOLARIS
 int size;
#else
 size_t size;
#endif
 if(listen(sock, maxConn) != 0){
         switch(errno){
                 case EADDRINUSE:
                         throw SocketAlreadyUsedException();
                         break;
                 default:
                         throw NetworkException();
         }
 }
 size = sizeof(client);
 if((ss = ::accept(sock, (sockaddr *)&client, &size)) == -1)
  return NULL;
 Socket *r = new Socket(ss, port);
 return r;
}

void ServerSocket::close(){
 if(sock >= 0){
  ::close(sock);         
  sock = -1;
 }
}


}; //end of namespace directive

Powered by: