pipe_connection.cpp

Go to the documentation of this file.

/*
**  ClanLib SDK
**  Copyright (c) 1997-2005 The ClanLib Team
**
**  This software is provided 'as-is', without any express or implied
**  warranty.  In no event will the authors be held liable for any damages
**  arising from the use of this software.
**
**  Permission is granted to anyone to use this software for any purpose,
**  including commercial applications, and to alter it and redistribute it
**  freely, subject to the following restrictions:
**
**  1. The origin of this software must not be misrepresented; you must not
**     claim that you wrote the original software. If you use this software
**     in a product, an acknowledgment in the product documentation would be
**     appreciated but is not required.
**  2. Altered source versions must be plainly marked as such, and must not be
**     misrepresented as being the original software.
**  3. This notice may not be removed or altered from any source distribution.
**
**  Note: Some of the libraries ClanLib link to may have additional
**  requirements or restrictions.
**
**  File Author(s):
**
**    Magnus Norddahl
*/

#include "precomp.h"
#include "pipe_connection.h"
#include "exception.h"
#include "string_help.h"
#include "event.h"
#include "socket_event_handler.h"
#ifndef WIN32
#include <sys/socket.h>
#include <sys/un.h>
#endif

#ifndef UNIX_PATH_MAX
#define UNIX_PATH_MAX 108
#endif

// CL_PipeConnection Construction:

CL_PipeConnection::CL_PipeConnection(const CL_String &pipe_name, bool pass_credentials)
: handle(-1), socket_event_handler(0), read_event(0), write_event(0), exception_event(0)
{
#ifdef WIN32
#else
        CL_StringA pipe_name_local8 = CL_StringHelp::text_to_local8(pipe_name);
        if (pipe_name_local8.length() >= UNIX_PATH_MAX)
                throw CL_Exception(TEXT("Pipe name too long"));

        handle = socket(PF_UNIX, SOCK_STREAM, 0);
        if (handle == -1)
                throw CL_Exception(TEXT("Socket create failed"));

        sockaddr_un name;
        memset(&name, 0, sizeof(sockaddr_un));
        name.sun_family = AF_UNIX;
        memcpy(name.sun_path+1, pipe_name_local8.data(), pipe_name_local8.length());

        int res = ::connect(handle, (sockaddr *) &name, sizeof(sockaddr_un));
        if (res == -1)
        {
                ::close(handle);
                throw CL_Exception(TEXT("Could not connect to server"));
        }

        socket_event_handler = new CL_SocketEventHandler(handle);
        read_event = new CL_Event(socket_event_handler, CL_Event::type_socket_read);
        write_event = new CL_Event(socket_event_handler, CL_Event::type_socket_write);
        exception_event = new CL_Event(socket_event_handler, CL_Event::type_socket_exception);

        if (pass_credentials)
        {
                int flag = 1;
                setsockopt(handle, SOL_SOCKET, SO_PASSCRED, &flag, sizeof(int));
        }
#endif
}

CL_PipeConnection::CL_PipeConnection(int pipe_handle, bool pass_credentials)
: handle(pipe_handle), socket_event_handler(0), read_event(0), write_event(0), exception_event(0)
{
#ifdef WIN32
#else
        if (handle == -1)
                throw CL_Exception(TEXT("Invalid socket value"));

        socket_event_handler = new CL_SocketEventHandler(handle);
        read_event = new CL_Event(socket_event_handler, CL_Event::type_socket_read);
        write_event = new CL_Event(socket_event_handler, CL_Event::type_socket_write);
        exception_event = new CL_Event(socket_event_handler, CL_Event::type_socket_exception);

        if (pass_credentials)
        {
                int flag = 1;
                setsockopt(handle, SOL_SOCKET, SO_PASSCRED, &flag, sizeof(int));
        }
#endif
}
        
CL_PipeConnection::~CL_PipeConnection()
{
#ifdef WIN32
#else
        delete read_event;
        delete write_event;
        delete exception_event;
        delete socket_event_handler;
        ::close(handle);
#endif
}

// CL_PipeConnection Attributes:

CL_Event *CL_PipeConnection::get_read_event()
{
        return read_event;
}
        
CL_Event *CL_PipeConnection::get_write_event()
{
        return write_event;
}

CL_Event *CL_PipeConnection::get_exception_event()
{
        return exception_event;
}

// CL_PipeConnection Operations:

int CL_PipeConnection::send(const void *_data, int length, int timeout)
{
#ifdef WIN32
        return 0;
#else
        const char *data = (const char *) _data;
        int pos = 0;
        while (pos < length)
        {
                int res = ::send(handle, data+pos, length-pos, 0);
                if (res == -1)
                        throw CL_Exception(TEXT("Write failed to socket!"));

                pos += res;
        }
        return pos;
#endif
}

int CL_PipeConnection::receive(void *_data, int len, int timeout)
{
#ifdef WIN32
        return 0;
#else
        char *data = (char *) _data;
        int received = 0;
        while (received < len)
        {
                int res = ::recv(handle, data+received, len-received, 0);
                if (res == -1)
                        throw CL_Exception(TEXT("Read failed on socket!"));

                received += res;
        }
        return received;
#endif
}

int CL_PipeConnection::peek(void *_data, int len, int timeout)
{
#ifdef WIN32
        return 0;
#else
        char *data = (char *) _data;
        int received = 0;
        int res = ::recv(handle, data+received, len-received, MSG_PEEK);
        if (res == -1)
                throw CL_Exception(TEXT("Read peek failed on socket!"));
        received += res;
        return received;
#endif
}

CL_String CL_PipeConnection::receive_user_credentials()
{
        return CL_String(TEXT("mbn"));
}

void CL_PipeConnection::send_user_credentials()
{
}

// CL_PipeConnection Implementation:

---