ipc_frame_unix.h File Reference

#include "ipc_frame.h"
#include <memory>

Include dependency graph for ipc_frame_unix.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	Ipc_frame_reader_deleter
struct	Ipc_frame_writer_deleter

Typedefs
using	Ipc_frame_reader_uniq = std::unique_ptr<Ipc_frame_reader, Ipc_frame_reader_deleter>
using	Ipc_frame_writer_uniq = std::unique_ptr<Ipc_frame_writer, Ipc_frame_writer_deleter>

Functions
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 (struct Ipc_frame_reader *reader, struct 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)

Typedef Documentation

Ipc_frame_reader_uniq

using Ipc_frame_reader_uniq = std::unique_ptr<Ipc_frame_reader, Ipc_frame_reader_deleter>

Definition at line 29 of file ipc_frame_unix.h.

Ipc_frame_writer_uniq

using Ipc_frame_writer_uniq = std::unique_ptr<Ipc_frame_writer, Ipc_frame_writer_deleter>

Definition at line 34 of file ipc_frame_unix.h.

Function Documentation

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	(	struct Ipc_frame_reader *	reader,
		struct 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: