ipc_frame_unix.cpp File Reference

#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <array>
#include <string>
#include <memory>
#include <sys/types.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <netinet/in.h>
#include <cerrno>
#include "ipc_frame_unix.h"

Include dependency graph for ipc_frame_unix.cpp:

Go to the source code of this file.

Classes
struct	Ipc_frame_reader
struct	Ipc_frame_writer

Macros
#define	CLOSESOCKET   close
#define	INVALID_SOCKET   -1
#define	MSG_NOSIGNAL   0
#define	UNLINK   unlink

Functions
static size_t	blocking_read (fd_t fd, char *dst, size_t size)
static bool	do_frame_read (Ipc_frame_reader *reader, Ipc_frame *dst)
void	ipc_frame_reader_free (struct Ipc_frame_reader *reader)
bool	ipc_frame_reader_has_frame (struct Ipc_frame_reader *reader)
bool	ipc_frame_reader_is_connected (struct Ipc_frame_reader *reader)
Ipc_frame_reader *	ipc_frame_reader_new (const char *path)
bool	ipc_frame_reader_read (Ipc_frame_reader *reader, Ipc_frame *dst)
void	ipc_frame_reader_wait_connect (struct Ipc_frame_reader *reader)
void	ipc_frame_writer_free (struct Ipc_frame_writer *writer)
Ipc_frame_writer *	ipc_frame_writer_new (const char *path)
bool	ipc_frame_writer_write (struct Ipc_frame_writer *writer, const struct Ipc_frame *f)
static bool	socket_read_avail (fd_t fd)
static bool	try_accept (struct Ipc_frame_reader *reader)

Macro Definition Documentation

CLOSESOCKET

#define CLOSESOCKET   close

Definition at line 15 of file ipc_frame_unix.cpp.

Referenced by ipc_frame_reader_free(), ipc_frame_reader_new(), ipc_frame_reader_read(), ipc_frame_writer_free(), and ipc_frame_writer_new().

INVALID_SOCKET

#define INVALID_SOCKET   -1

Definition at line 16 of file ipc_frame_unix.cpp.

Referenced by ipc_frame_reader_free(), ipc_frame_reader_is_connected(), ipc_frame_reader_new(), ipc_frame_reader_read(), ipc_frame_reader_wait_connect(), ipc_frame_writer_free(), ipc_frame_writer_new(), and socket_read_avail().

MSG_NOSIGNAL

#define MSG_NOSIGNAL   0

Definition at line 31 of file ipc_frame_unix.cpp.

UNLINK

#define UNLINK   unlink

Definition at line 17 of file ipc_frame_unix.cpp.

Referenced by ipc_frame_reader_free(), and ipc_frame_reader_new().

Function Documentation

blocking_read()

static size_t blocking_read ( fd_t fd, char * dst, size_t size )

static

Definition at line 103 of file ipc_frame_unix.cpp.

                                                            {
        size_t bytes_read = 0;
 
        while(bytes_read < size){
                int read_now = recv(fd, dst + bytes_read, size - bytes_read, 0);
                if(read_now <= 0)
                        break;
 
                bytes_read += read_now;
        }
 
        return bytes_read;
}

Referenced by do_frame_read().

do_frame_read()

static bool do_frame_read ( Ipc_frame_reader * reader, Ipc_frame * dst )

static

Definition at line 160 of file ipc_frame_unix.cpp.

                                                                   {
        char header_buf[IPC_FRAME_HEADER_LEN];
 
        if(blocking_read(reader->data_fd, header_buf, IPC_FRAME_HEADER_LEN) != IPC_FRAME_HEADER_LEN)
                return false;
 
        if(!ipc_frame_parse_header(&dst->header, header_buf))
                return false;
 
        if(!ipc_frame_reserve(dst, dst->header.data_len))
                return false;
 
        int read_data = blocking_read(reader->data_fd, dst->data, dst->header.data_len);
 
        return read_data == dst->header.data_len;
}

References blocking_read(), Ipc_frame::data, Ipc_frame_reader::data_fd, Ipc_frame_header::data_len, Ipc_frame::header, IPC_FRAME_HEADER_LEN, ipc_frame_parse_header(), and ipc_frame_reserve().

Referenced by ipc_frame_reader_read().

Here is the call graph for this function:

ipc_frame_reader_free()

void ipc_frame_reader_free

(

struct Ipc_frame_reader *

reader

)

Definition at line 92 of file ipc_frame_unix.cpp.

                                                           {
        if(reader->data_fd != INVALID_SOCKET)
                CLOSESOCKET(reader->data_fd);
        if(reader->listen_fd != INVALID_SOCKET)
                CLOSESOCKET(reader->listen_fd);
 
        UNLINK(reader->path.c_str());
 
        delete reader;
}

References CLOSESOCKET, Ipc_frame_reader::data_fd, INVALID_SOCKET, Ipc_frame_reader::listen_fd, Ipc_frame_reader::path, and UNLINK.

Referenced by Ipc_frame_reader_deleter::operator()().

ipc_frame_reader_has_frame()

bool ipc_frame_reader_has_frame

(

struct Ipc_frame_reader *

reader

)

Definition at line 142 of file ipc_frame_unix.cpp.

                                                                {
        if(!ipc_frame_reader_is_connected(reader))
                return false;
 
        return socket_read_avail(reader->data_fd);
}

References Ipc_frame_reader::data_fd, ipc_frame_reader_is_connected(), and socket_read_avail().

Referenced by PreviewWidget::loadFrame().

Here is the call graph for this function:

ipc_frame_reader_is_connected()

bool ipc_frame_reader_is_connected

(

struct Ipc_frame_reader *

reader

)

Definition at line 149 of file ipc_frame_unix.cpp.

                                                                   {
        return reader->data_fd != INVALID_SOCKET || try_accept(reader);
}

References Ipc_frame_reader::data_fd, INVALID_SOCKET, and try_accept().

Referenced by ipc_frame_reader_has_frame(), and PreviewWidget::loadFrame().

Here is the call graph for this function:

ipc_frame_reader_new()

Ipc_frame_reader * ipc_frame_reader_new

(

const char *

path

)

Definition at line 59 of file ipc_frame_unix.cpp.

                                                        {
        auto reader = std::make_unique<Ipc_frame_reader>();
        reader->path = path;
        reader->data_fd = INVALID_SOCKET;
 
        reader->listen_fd = socket(AF_UNIX, SOCK_STREAM, 0);
        if(reader->listen_fd == INVALID_SOCKET){
                return nullptr;
        }
 
        sockaddr_un addr;
        memset(&addr, 0, sizeof(addr));
        addr.sun_family = AF_UNIX;
        strncpy(addr.sun_path, path, sizeof(addr.sun_path));
        addr.sun_path[sizeof(addr.sun_path) - 1] = '\0';
        UNLINK(path);
 
        int ret = 0;
        ret = bind(reader->listen_fd, (const sockaddr *) &addr, sizeof(addr.sun_path));
        if(ret == -1){
                CLOSESOCKET(reader->listen_fd);
                return nullptr;
        }
 
        ret = listen(reader->listen_fd, 5);
        if(ret == -1){
                CLOSESOCKET(reader->listen_fd);
                return nullptr;
        }
 
        return reader.release();
}

References CLOSESOCKET, INVALID_SOCKET, and UNLINK.

Referenced by main(), and PreviewWidget::setKey().

ipc_frame_reader_read()

bool ipc_frame_reader_read	(	Ipc_frame_reader *	reader,
		Ipc_frame *	dst )

Definition at line 177 of file ipc_frame_unix.cpp.

                                                                    {
        bool ret = do_frame_read(reader, dst);
        if(!ret){
                CLOSESOCKET(reader->data_fd);
                reader->data_fd = INVALID_SOCKET;
        }
 
        return ret;
}

References CLOSESOCKET, Ipc_frame_reader::data_fd, do_frame_read(), and INVALID_SOCKET.

Referenced by PreviewWidget::loadFrame(), and main().

Here is the call graph for this function:

ipc_frame_reader_wait_connect()

void ipc_frame_reader_wait_connect

(

struct Ipc_frame_reader *

reader

)

Definition at line 153 of file ipc_frame_unix.cpp.

                                                                   {
        if(reader->data_fd != INVALID_SOCKET)
                return;
 
        reader->data_fd = accept(reader->listen_fd, nullptr, 0);
}

References Ipc_frame_reader::data_fd, INVALID_SOCKET, and Ipc_frame_reader::listen_fd.

Referenced by main().

ipc_frame_writer_free()

void ipc_frame_writer_free

(

struct Ipc_frame_writer *

writer

)

Definition at line 217 of file ipc_frame_unix.cpp.

                                                           {
        if(writer->data_fd != INVALID_SOCKET)
                CLOSESOCKET(writer->data_fd);
 
        delete writer;
}

References CLOSESOCKET, INVALID_SOCKET, and writer().

Referenced by Ipc_frame_writer_deleter::operator()().

Here is the call graph for this function:

ipc_frame_writer_new()

Ipc_frame_writer * ipc_frame_writer_new

(

const char *

path

)

Definition at line 191 of file ipc_frame_unix.cpp.

                                                        {
        auto writer = std::make_unique<Ipc_frame_writer>();
        writer->data_fd = INVALID_SOCKET;
 
        sockaddr_un addr;
        memset(&addr, 0, sizeof(addr));
        addr.sun_family = AF_UNIX;
        strncpy(addr.sun_path, path, sizeof(addr.sun_path));
        addr.sun_path[sizeof(addr.sun_path) - 1] = '\0';
 
        writer->data_fd = socket(AF_UNIX, SOCK_STREAM, 0);
        if(writer->data_fd == INVALID_SOCKET){
                perror("ipc_frame_writer_new socket");
                return nullptr;
        }
 
        int ret = connect(writer->data_fd, (const struct sockaddr *) &addr, sizeof(addr));
        if(ret == -1){
                perror("ipc_frame_writer_new connect");
                CLOSESOCKET(writer->data_fd);
                return nullptr;
        }
 
        return writer.release();
}

References CLOSESOCKET, INVALID_SOCKET, and writer().

Referenced by display_unix_sock_init(), and worker().

Here is the call graph for this function:

ipc_frame_writer_write()

bool ipc_frame_writer_write	(	struct Ipc_frame_writer *	writer,
		const struct Ipc_frame *	f )

Definition at line 240 of file ipc_frame_unix.cpp.

                                                                                       {
        std::array<char, IPC_FRAME_HEADER_LEN> header;
 
        ipc_frame_write_header(&f->header, header.data());
 
        errno = 0;
        block_write(writer->data_fd, header.data(), header.size());
        block_write(writer->data_fd, f->data, f->header.data_len);
 
        return errno == 0;
}

References Ipc_frame::data, Ipc_frame_header::data_len, Ipc_frame::header, ipc_frame_write_header(), and writer().

Referenced by display_unix_sock_run(), and worker().

Here is the call graph for this function:

socket_read_avail()

static bool socket_read_avail ( fd_t fd )

static

Definition at line 117 of file ipc_frame_unix.cpp.

                                      {
        if(fd == INVALID_SOCKET)
                return false;
 
        fd_set fds;
        FD_ZERO(&fds);
        FD_SET(fd, &fds);
 
        struct timeval tv;
        tv.tv_sec = 0;
        tv.tv_usec = 0;
 
        int ret = select(fd + 1, &fds, nullptr, nullptr, &tv);
 
        return ret > 0;
}

References INVALID_SOCKET.

Referenced by ipc_frame_reader_has_frame(), and try_accept().

try_accept()

static bool try_accept ( struct Ipc_frame_reader * reader )

static

Definition at line 134 of file ipc_frame_unix.cpp.

                                                       {
        if(!socket_read_avail(reader->listen_fd))
                return false;
 
        reader->data_fd = accept(reader->listen_fd, nullptr, 0);
        return true;
}

References Ipc_frame_reader::data_fd, Ipc_frame_reader::listen_fd, and socket_read_avail().

Referenced by ipc_frame_reader_is_connected().

Here is the call graph for this function: