platform_pipe.h File Reference

#include "config_unix.h"
#include "config_win32.h"

Include dependency graph for platform_pipe.h:

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

Go to the source code of this file.

Macros
#define	PLATFORM_PIPE_READ   read
#define	PLATFORM_PIPE_WRITE   write

Functions
void	platform_pipe_close (fd_t pipe)
int	platform_pipe_init (fd_t pipe[2])

Detailed Description

Author

Martin Pulec pulec.nosp@m.@ces.nosp@m.net.c.nosp@m.z

Definition in file platform_pipe.h.

Macro Definition Documentation

PLATFORM_PIPE_READ

#define PLATFORM_PIPE_READ   read

Definition at line 62 of file platform_pipe.h.

Referenced by control_thread(), and state_root::should_exit_watcher().

PLATFORM_PIPE_WRITE

#define PLATFORM_PIPE_WRITE   write

Definition at line 63 of file platform_pipe.h.

Referenced by state_root::broadcast_should_exit(), and udp_exit().

Function Documentation

platform_pipe_close()

void platform_pipe_close

(

fd_t

pipe

)

Definition at line 227 of file platform_pipe.cpp.

{
        CLOSESOCKET(pipe);
#ifdef _WIN32
        WSACleanup();
#endif
}

References CLOSESOCKET.

Referenced by state_root::~state_root(), control_done(), control_thread(), udp_exit(), udp_reader(), and ug_control_connection_done().

platform_pipe_init()

int platform_pipe_init

(

fd_t

pipe[2]

)

Definition at line 155 of file platform_pipe.cpp.

{
#ifdef _WIN32
        // This needs to be called twice, indeed, since WSACleanup will be run
        // on both ends. This call is also required because not all pipes are
        // destroyed before common_cleanup which calls WSACleanup
        WSADATA wsaData;
        int err = WSAStartup(MAKEWORD(2, 2), &wsaData);
        if (err != 0) {
                fprintf(stderr, "WSAStartup failed with error %d.", err);
                return -1;
        }
        if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2) {
                fprintf(stderr, "Counld not found usable version of Winsock.\n");
                WSACleanup();
                return -1;
        }
        err = WSAStartup(MAKEWORD(2, 2), &wsaData);
        if (err != 0) {
                fprintf(stderr, "WSAStartup failed with error %d.", err);
                WSACleanup();
                return -1;
        }
        if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2) {
                fprintf(stderr, "Counld not found usable version of Winsock.\n");
                WSACleanup();
                WSACleanup();
                return -1;
        }
#endif
 
        struct params par{};
        fd_t sock = open_socket(&par.port);
        if (sock == INVALID_SOCKET) {
                perror("open_socket");
                return system_pipe(p);
        }
 
        DECLARE_TIMEOUT(timeout, 1);
        DECLARE_TIMEOUT(old_timeout, 0);
        socklen_t old_timeout_len = sizeof old_timeout;
        if (getsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, reinterpret_cast<sockopt_t>(&old_timeout), &old_timeout_len) != 0) {
                socket_error("pipe getsockopt");
        }
        if (setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, reinterpret_cast<sockopt_t>(&timeout), sizeof timeout) != 0) {
                socket_error("pipe setsockopt");
        }
 
        thread thr(worker, &par);
 
        p[0] = accept(sock, NULL, NULL);
        if (p[0] == INVALID_SOCKET) {
                perror("pipe accept");
                thr.join();
                CLOSESOCKET(sock);
                return system_pipe(p);
        }
        thr.join();
        if (setsockopt(p[0], SOL_SOCKET, SO_RCVTIMEO, reinterpret_cast<sockopt_t>(&old_timeout), old_timeout_len) != 0) {
                socket_error("pipe setsockopt");
        }
        p[1] = par.sock;
        if (p[1] == INVALID_SOCKET) {
                CLOSESOCKET(sock);
                perror("accept");
                return system_pipe(p);
        }
        CLOSESOCKET(sock);
 
        return 0;
}

References CLOSESOCKET, DECLARE_TIMEOUT, INVALID_SOCKET, open_socket(), params::port, params::sock, socket_error, system_pipe(), and worker().

Referenced by state_root::state_root(), control_start(), udp_init_if(), and ug_control_connection_init().

Here is the call graph for this function: