pipe_listen.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_listen.h"
#include "pipe_connection.h"
#include "exception.h"
#include "event.h"
#include "string_help.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_PipeListen Construction:

CL_PipeListen::CL_PipeListen(const CL_String &name)
: accept_event(0), socket_event_handler(0), handle(-1)
{
#ifdef WIN32
#else
        CL_StringA name_local8 = CL_StringHelp::text_to_local8(name);
        if (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("Unable to create unix socket"));

        // Create pipe name in the abstract namespace:
        // (abstract namespace starts with first character in sun_path 
        // being the null character)
        sockaddr_un addr;
        memset(&addr, 0, sizeof(sockaddr_un));
        addr.sun_family = AF_UNIX;
        memcpy(addr.sun_path+1, name_local8.data(), name_local8.length());
        
        int result = bind(handle, (sockaddr *) &addr, sizeof(sockaddr_un));
        if (result != -1)
                result = listen(handle, 5);
        if (result == -1)
        {
                ::close(handle);
                throw CL_Exception(TEXT("Unable to bind pipe to ") + name);
        }
        
        socket_event_handler = new CL_SocketEventHandler(handle);
        accept_event = new CL_Event(socket_event_handler, CL_Event::type_socket_read);
#endif
}

CL_PipeListen::~CL_PipeListen()
{
        delete accept_event;
        delete socket_event_handler;
#ifdef WIN32
#else
        if (handle != -1)
                ::close(handle);
#endif
}

// CL_PipeListen Attributes:

CL_Event *CL_PipeListen::get_accept_event()
{
        return accept_event;
}

// CL_PipeListen Operations:

CL_PipeConnection *CL_PipeListen::accept(bool send_credentials, int timeout)
{
#ifdef WIN32
        return 0;
#else
        // EAGAIN
        // O_NONBLOCK
        
        sockaddr_un name;
        memset(&name, 0, sizeof(sockaddr_un));
        name.sun_family = AF_UNIX;
        
        socklen_t size = sizeof(sockaddr_un);
        int sock = ::accept(handle, (sockaddr *) &name, &size);
        if (sock == -1)
                return 0;

        return new CL_PipeConnection(sock, send_credentials);
#endif
}

// CL_PipeListen Implementation:

---