aa66b5d62f
This patch adjusts the implementation of the base library and core such that the code no longer relies on deprecated APIs except for very few cases, mainly to keep those deprecated APIs in tact for now. The most prominent changes are: - Removing the use of base/printf.h - Removing of the log backend for printf. The 'Console' with the format-string parser is still there along with 'snprintf.h' because the latter is still used at a few places, most prominently the 'Connection' classes. - Removing the notion of a RAM session, which does not exist in Genode anymore. Still the types were preserved (by typedefs to PD session) to keep up compatibility. But this transition should come to an end now. - Slight rennovation of core's tracing service, e.g., the use of an Attached_dataspace as the Argument_buffer. - Reducing the reliance on global accessors like deprecated_env() or core_env(). Still there is a longish way to go to eliminate all such calls. A useful pattern (or at least a stop-gap solution) is to pass the 'Env' to the individual compilation units via init functions. - Avoiding the use of the old 'Child_policy::resolve_session_request' interface that returned a 'Service' instead of a 'Route'. Issue #1987
112 lines
2.8 KiB
C++
112 lines
2.8 KiB
C++
/*
|
|
* \brief Support for communication over Unix domain sockets
|
|
* \author Norman Feske
|
|
* \date 2012-08-10
|
|
*/
|
|
|
|
/*
|
|
* Copyright (C) 2011-2017 Genode Labs GmbH
|
|
*
|
|
* This file is part of the Genode OS framework, which is distributed
|
|
* under the terms of the GNU Affero General Public License version 3.
|
|
*/
|
|
|
|
#ifndef _CORE__INCLUDE__SERVER_SOCKET_PAIR_H_
|
|
#define _CORE__INCLUDE__SERVER_SOCKET_PAIR_H_
|
|
|
|
/* Linux syscall bindings */
|
|
#include <core_linux_syscalls.h>
|
|
#include <sys/socket.h>
|
|
#include <sys/un.h>
|
|
|
|
/* base-internal includes */
|
|
#include <base/internal/socket_descriptor_registry.h>
|
|
#include <base/internal/server_socket_pair.h>
|
|
|
|
/* core-local includes */
|
|
#include <resource_path.h>
|
|
|
|
|
|
/**
|
|
* Utility: Create socket address for server entrypoint at thread ID
|
|
*/
|
|
struct Uds_addr : sockaddr_un
|
|
{
|
|
Uds_addr(long thread_id)
|
|
:
|
|
sockaddr_un({.sun_family = AF_UNIX, .sun_path = { }})
|
|
{
|
|
Genode::snprintf(sun_path, sizeof(sun_path), "%s/ep-%ld",
|
|
resource_path(), thread_id);
|
|
}
|
|
};
|
|
|
|
|
|
/**
|
|
* Utility: Create named socket pair for given unique ID
|
|
*/
|
|
static inline Genode::Socket_pair create_server_socket_pair(long id)
|
|
{
|
|
Genode::Socket_pair socket_pair;
|
|
|
|
using Genode::raw;
|
|
|
|
/*
|
|
* Main thread uses 'Ipc_server' for 'sleep_forever()' only. No need for
|
|
* binding.
|
|
*/
|
|
if (id == -1)
|
|
return socket_pair;
|
|
|
|
Uds_addr addr(id);
|
|
|
|
/*
|
|
* Create server-side socket
|
|
*/
|
|
socket_pair.server_sd = lx_socket(AF_UNIX, SOCK_DGRAM | SOCK_CLOEXEC, 0);
|
|
if (socket_pair.server_sd < 0) {
|
|
raw("Error: Could not create server-side socket (ret=", socket_pair.server_sd, ")");
|
|
class Server_socket_failed { };
|
|
throw Server_socket_failed();
|
|
}
|
|
|
|
/* make sure bind succeeds */
|
|
lx_unlink(addr.sun_path);
|
|
|
|
int const bind_ret = lx_bind(socket_pair.server_sd, (sockaddr *)&addr, sizeof(addr));
|
|
if (bind_ret < 0) {
|
|
raw("Error: Could not bind server socket (ret=", bind_ret, ")");
|
|
class Bind_failed { };
|
|
throw Bind_failed();
|
|
}
|
|
|
|
/*
|
|
* Create client-side socket
|
|
*/
|
|
socket_pair.client_sd = lx_socket(AF_UNIX, SOCK_DGRAM | SOCK_CLOEXEC, 0);
|
|
if (socket_pair.client_sd < 0) {
|
|
raw("Error: Could not create client-side socket (ret=", socket_pair.client_sd, ")");
|
|
class Client_socket_failed { };
|
|
throw Client_socket_failed();
|
|
}
|
|
|
|
int const conn_ret = lx_connect(socket_pair.client_sd, (sockaddr *)&addr, sizeof(addr));
|
|
if (conn_ret < 0) {
|
|
raw("Error: Could not connect client-side socket (ret=", conn_ret, ")");
|
|
class Connect_failed { };
|
|
throw Connect_failed();
|
|
}
|
|
|
|
socket_pair.client_sd = Genode::ep_sd_registry().try_associate(socket_pair.client_sd, id);
|
|
|
|
/*
|
|
* Wipe Unix domain socket from the file system. It will live as long as
|
|
* there exist references to it in the form of file descriptors.
|
|
*/
|
|
lx_unlink(addr.sun_path);
|
|
|
|
return socket_pair;
|
|
}
|
|
|
|
#endif /* _CORE__INCLUDE__SERVER_SOCKET_PAIR_H_ */
|