SocketTCP.cpp

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2007 by Pierre Schmitt, Ludovic Giacomello, Nhi Ly   *
 *      *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/

#include "SocketTCP.h"

SocketTCP::SocketTCP(int socket){
        mSocket=socket;
}

SocketTCP::SocketTCP(unsigned int port) throw(SocketException) : Socket(port){
        int retour;
        struct sockaddr_in adresse;
        mSocket=socket(AF_INET,SOCK_STREAM,0);
        if (mSocket<0) throw(SocketException(1));
        adresse.sin_family=AF_INET;
        adresse.sin_port = htons((u_short)port);
        adresse.sin_addr.s_addr=INADDR_ANY;
        retour = bind(mSocket,(struct sockaddr *)&adresse,sizeof(adresse));
        if (retour<0) throw(SocketException(2));
        listen(mSocket,7);
}

SocketTCP::SocketTCP(string ad, unsigned int port) throw(SocketException) : Socket(ad,port){
        struct sockaddr_in adresse;
        struct hostent *recup;
        mSocket=socket(AF_INET, SOCK_STREAM, 0);
        if (mSocket < 0) throw(SocketException(1));
        recup = gethostbyname(ad.c_str());
        if (recup == NULL) throw(SocketException(3));
        memcpy((char *)&adresse.sin_addr, (char *)recup->h_addr, recup->h_length);
        adresse.sin_family = AF_INET;
        adresse.sin_port = htons((u_short) port);
        if (connect(mSocket, (struct sockaddr *)&adresse, sizeof(adresse)) == -1) throw(SocketException(4));
}

Socket* SocketTCP::Accept() throw(SocketException){
        int socket;
        struct sockaddr_in socketEntrante;
        socklen_t taille=sizeof(socketEntrante);
        socket=accept(mSocket,(struct sockaddr*) &socketEntrante,&taille);
        if(socket==-1) throw(SocketException(5));
        Socket *s=new SocketTCP(socket);
        return s;
}

SocketTCP::SocketTCP(Socket *s) : Socket(s){
}


SocketTCP::SocketTCP(const SocketTCP &s){
        mSocket=s.mSocket;
        mCryptage=s.mCryptage;  
}

void SocketTCP::operator=(const SocketTCP &s){
        mSocket=s.mSocket;
        mCryptage=s.mCryptage;  
}

SocketTCP::~SocketTCP(){
        close(mSocket);
}

void SocketTCP::Envoyer(string msg) const throw(SocketException){
        int s=send(mSocket,(mCryptage->Crypter(msg)).c_str(),msg.length(),0);
        if(s==-1){
                throw(SocketException(6));
        }
}

string SocketTCP::Ecouter() throw(SocketException){
        char buffer[BUFSIZ];
        int s=recv(mSocket,buffer,BUFSIZ,0);
        if (s==-1) throw(SocketException(7));
        else if(s==0) throw(SocketException(9));
        else {
                buffer[s]=0;
                return mCryptage->Decrypter(buffer);
        }       
}

---