uxcom.cpp

/*
    Socle - Socket Library Ecosystem
    Copyright (c) 2014, Ales Stibal <astib@mag0.net>, 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 3.0 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.
*/

#include <uxcom.hpp>
#include <privileged_socket.hpp>

UxCom::~UxCom() = default;

// obviously, port is ignored
int UxCom::connect(const char* host, const char* noop_port) {

    const char* port = "";
    int sfd = socle::socket(connect_sock_family, connect_sock_type, 0);

    if (sfd == -1) {
        _deb("UxCom::connect[%s:%s]: socket[%d]: failed to create socket", host, port, sfd);
        return sfd;
    }

    sockaddr_un server{};
    server.sun_family = connect_sock_family;
    strncpy(server.sun_path, host, sizeof(server.sun_path)-1);
    
    if (not GLOBAL_IO_BLOCKING()) {
        unblock(sfd);

        if (::connect(sfd, (struct sockaddr *) &server, sizeof(struct sockaddr_un)) < 0) {
            if ( errno == EINPROGRESS ) {
                _deb("UxCom::connect[%s:%s]: socket[%d]: connnect errno: EINPROGRESS", host, port, sfd);
                
            } else {
                close(sfd);
                sfd = 0;
                _not("UxCom::connect[%s:%s]: socket[%d]: connnect errno: %s", host, port, sfd, string_error().c_str());
            }

        }
        
    } else {
        if (::connect(sfd, (struct sockaddr *) &server, sizeof(struct sockaddr_un)) != 0) {
            close(sfd);
            sfd = 0;
        }
    }

    if(sfd == 0) {
        _err("UxCom::connect[%s:%s]: socket[%d]: connect failed", host, port, sfd);
    } else {
        _dum("UxCom::connect[%s:%s]: socket[%d]: connect ok", host, port, sfd);
    }

    return socket(sfd);

}

int UxCom::bind(short unsigned int port) {
    _err("UxCom::bind(int): bind failed, cannot bind to any port number", port);
    return -1;
}

int UxCom::bind(const char* name) {
    int s;

    sockaddr_un server{};
    server.sun_family = bind_sock_family;
    strncpy(server.sun_path, name, sizeof(server.sun_path)-1);

    if ((s = socle::socket(bind_sock_family, bind_sock_type, bind_sock_protocol)) == -1) return -129;

    so_reuseaddr(s);

    if (socle::bind(s, reinterpret_cast<sockaddr*>(&server), sizeof(server)) == -1) {
        ::close(s);
        return -130;
    }
    if (socle::listen(s, 10) == -1) {
        ::close(s);
        return -131;
    }
    
    return s;
}