JSocket_Linux.cpp

Go to the documentation of this file.

/***************************** License **********************************

 Copyright (C) 2008 by Communicative Machines
 http://www.cmlabs.com   All rights reserved.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Lesser General Public
 License as published by the Free Software Foundation; either
 version 2.1 of the License, or (at your option) any later version.

 This library 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
 Lesser General Public License for more details.

 You should have received a copy of the GNU Lesser General Public
 License along with this library; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

************************************************************************/



/* This file contains the following OS specific functions

        bool createSocket()

        void dealWithSocketError(int saError, JString intro)
        int getLastOSErrorNumber()

*/


#ifndef WIN32
#include "JSocket.h"

namespace cmlabs {

void JSocket::osCloseSocket(SOCKET thisSocket) {
//      printf("------------------------------ DELETE socket %d\n", thisSocket);
        shutdown(thisSocket, 2);
        close(thisSocket);
}

bool JSocket::isSocketValid() {
        if (mySocket == 0)
                return false;
        else
                return true;
}

bool JSocket::setSocketNotValid() {
        mySocket = 0;
        return true;
}


void JSocket::setNonBlockingMode() {
        // Always choose non-blocking IO
        long parm = fcntl(mySocket, F_GETFL);
        parm |= O_NONBLOCK;
        fcntl(mySocket, F_SETFL, parm);
}

void JSocket::setBlockingMode() {
        long parm = fcntl(mySocket, F_GETFL);
        parm &= (!O_NONBLOCK);
        fcntl(mySocket, F_SETFL, parm);
}


bool JSocket::createSocket() {
        if (!isSocketValid()) {
                mySocket = socket(AF_INET, SOCK_STREAM, 0);        /* create the socket */
          //mySocket = socket(AF_INET, SOCK_STREAM,IPPROTO_TCP);        /* create the socket */
                if (mySocket == INVALID_SOCKET) {
                        // We might not have run WSAStartup yet
                        dealWithSocketError(getLastOSErrorNumber());
                        setSocketNotValid();
                        return false;
                }
        }

        setNonBlockingMode();

//      struct linger tmp = {0, 0}; /* On, 0 delay */
        struct linger tmp = {1, 0}; /* On, 0 delay */
//      struct linger tmp = {1, 1}; /* On, 0 delay */
        setsockopt(mySocket, SOL_SOCKET, SO_LINGER, (char *)&tmp, sizeof(tmp));

        char delay = 1;
        //setsockopt(mySocket, SOL_TCP, TCP_NODELAY, (char*) &delay, sizeof(delay));
        setsockopt(mySocket, IPPROTO_TCP, TCP_NODELAY, (char*) &delay, sizeof(delay));


//      printf("------------------------------ new mySocket is %d\n", mySocket);
        // When we get here the socket is OK
        return true;
}


void JSocket::dealWithSocketError(int wsaError, JString intro) {

        if (wsaError == 100) {
                lastErrorMessage = "Cannot initialize WinSock!";
                lastErrorRecoverable = false;
        }
        else {
                lastErrorMessage = JString("TCP error with no description: ") + JString(wsaError);
                lastErrorRecoverable = false;
        }

        if (intro.length() > 0)
                lastErrorMessage = intro + JString(": ") + lastErrorMessage;
}


int JSocket::getLastOSErrorNumber() {
        return errno;
}












} // namespace cmlabs


#endif // WIN32

---