|
Packit |
ae235b |
/* GIO - GLib Input, Output and Streaming Library
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Copyright © 2009 Codethink Limited
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* This library is free software; you can redistribute it and/or
|
|
Packit |
ae235b |
* modify it under the terms of the GNU Lesser General Public
|
|
Packit |
ae235b |
* License as published by the Free Software Foundation; either
|
|
Packit |
ae235b |
* version 2.1 of the License, or (at your option) any later version.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* See the included COPYING file for more information.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Authors: Ryan Lortie <desrt@desrt.ca>
|
|
Packit |
ae235b |
*/
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/**
|
|
Packit |
ae235b |
* SECTION:gunixfdmessage
|
|
Packit |
ae235b |
* @title: GUnixFDMessage
|
|
Packit |
ae235b |
* @short_description: A GSocketControlMessage containing a GUnixFDList
|
|
Packit |
ae235b |
* @include: gio/gunixfdmessage.h
|
|
Packit |
ae235b |
* @see_also: #GUnixConnection, #GUnixFDList, #GSocketControlMessage
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* This #GSocketControlMessage contains a #GUnixFDList.
|
|
Packit |
ae235b |
* It may be sent using g_socket_send_message() and received using
|
|
Packit |
ae235b |
* g_socket_receive_message() over UNIX sockets (ie: sockets in the
|
|
Packit |
ae235b |
* %G_SOCKET_ADDRESS_UNIX family). The file descriptors are copied
|
|
Packit |
ae235b |
* between processes by the kernel.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* For an easier way to send and receive file descriptors over
|
|
Packit |
ae235b |
* stream-oriented UNIX sockets, see g_unix_connection_send_fd() and
|
|
Packit |
ae235b |
* g_unix_connection_receive_fd().
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Note that `<gio/gunixfdmessage.h>` belongs to the UNIX-specific GIO
|
|
Packit |
ae235b |
* interfaces, thus you have to use the `gio-unix-2.0.pc` pkg-config
|
|
Packit |
ae235b |
* file when using it.
|
|
Packit |
ae235b |
*/
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/**
|
|
Packit |
ae235b |
* GUnixFDMessage:
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* #GUnixFDMessage is an opaque data structure and can only be accessed
|
|
Packit |
ae235b |
* using the following functions.
|
|
Packit |
ae235b |
**/
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#include "config.h"
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#include <unistd.h>
|
|
Packit |
ae235b |
#include <string.h>
|
|
Packit |
ae235b |
#include <fcntl.h>
|
|
Packit |
ae235b |
#include <errno.h>
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#include "gunixfdmessage.h"
|
|
Packit |
ae235b |
#include "gunixfdlist.h"
|
|
Packit |
ae235b |
#include "gnetworking.h"
|
|
Packit |
ae235b |
#include "gioerror.h"
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
struct _GUnixFDMessagePrivate
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GUnixFDList *list;
|
|
Packit |
ae235b |
};
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
G_DEFINE_TYPE_WITH_PRIVATE (GUnixFDMessage, g_unix_fd_message, G_TYPE_SOCKET_CONTROL_MESSAGE)
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static gsize
|
|
Packit |
ae235b |
g_unix_fd_message_get_size (GSocketControlMessage *message)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GUnixFDMessage *fd_message = G_UNIX_FD_MESSAGE (message);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
return g_unix_fd_list_get_length (fd_message->priv->list) * sizeof (gint);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static int
|
|
Packit |
ae235b |
g_unix_fd_message_get_level (GSocketControlMessage *message)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
return SOL_SOCKET;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static int
|
|
Packit |
ae235b |
g_unix_fd_message_get_msg_type (GSocketControlMessage *message)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
return SCM_RIGHTS;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static GSocketControlMessage *
|
|
Packit |
ae235b |
g_unix_fd_message_deserialize (int level,
|
|
Packit |
ae235b |
int type,
|
|
Packit |
ae235b |
gsize size,
|
|
Packit |
ae235b |
gpointer data)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GSocketControlMessage *message;
|
|
Packit |
ae235b |
GUnixFDList *list;
|
|
Packit |
ae235b |
gint n, s, i;
|
|
Packit |
ae235b |
gint *fds;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (level != SOL_SOCKET ||
|
|
Packit |
ae235b |
type != SCM_RIGHTS)
|
|
Packit |
ae235b |
return NULL;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (size % 4 > 0)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_warning ("Kernel returned non-integral number of fds");
|
|
Packit |
ae235b |
return NULL;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
fds = data;
|
|
Packit |
ae235b |
n = size / sizeof (gint);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/* Note we probably handled this in gsocket.c already if we're on
|
|
Packit |
ae235b |
* Linux and have MSG_CMSG_CLOEXEC, but this code remains as a fallback
|
|
Packit |
ae235b |
* in case the kernel is too old for MSG_CMSG_CLOEXEC.
|
|
Packit |
ae235b |
*/
|
|
Packit |
ae235b |
for (i = 0; i < n; i++)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
int errsv;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
do
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
s = fcntl (fds[i], F_SETFD, FD_CLOEXEC);
|
|
Packit |
ae235b |
errsv = errno;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
while (s < 0 && errsv == EINTR);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (s < 0)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_warning ("Error setting close-on-exec flag on incoming fd: %s",
|
|
Packit |
ae235b |
g_strerror (errsv));
|
|
Packit |
ae235b |
return NULL;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
list = g_unix_fd_list_new_from_array (fds, n);
|
|
Packit |
ae235b |
message = g_unix_fd_message_new_with_fd_list (list);
|
|
Packit |
ae235b |
g_object_unref (list);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
return message;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_unix_fd_message_serialize (GSocketControlMessage *message,
|
|
Packit |
ae235b |
gpointer data)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GUnixFDMessage *fd_message = G_UNIX_FD_MESSAGE (message);
|
|
Packit |
ae235b |
const gint *fds;
|
|
Packit |
ae235b |
gint n_fds;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
fds = g_unix_fd_list_peek_fds (fd_message->priv->list, &n_fds);
|
|
Packit |
ae235b |
memcpy (data, fds, sizeof (gint) * n_fds);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_unix_fd_message_set_property (GObject *object, guint prop_id,
|
|
Packit |
ae235b |
const GValue *value, GParamSpec *pspec)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GUnixFDMessage *message = G_UNIX_FD_MESSAGE (object);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
g_assert (message->priv->list == NULL);
|
|
Packit |
ae235b |
g_assert_cmpint (prop_id, ==, 1);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
message->priv->list = g_value_dup_object (value);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (message->priv->list == NULL)
|
|
Packit |
ae235b |
message->priv->list = g_unix_fd_list_new ();
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/**
|
|
Packit |
ae235b |
* g_unix_fd_message_get_fd_list:
|
|
Packit |
ae235b |
* @message: a #GUnixFDMessage
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Gets the #GUnixFDList contained in @message. This function does not
|
|
Packit |
ae235b |
* return a reference to the caller, but the returned list is valid for
|
|
Packit |
ae235b |
* the lifetime of @message.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Returns: (transfer none): the #GUnixFDList from @message
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Since: 2.24
|
|
Packit |
ae235b |
**/
|
|
Packit |
ae235b |
GUnixFDList *
|
|
Packit |
ae235b |
g_unix_fd_message_get_fd_list (GUnixFDMessage *message)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
return message->priv->list;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_unix_fd_message_get_property (GObject *object, guint prop_id,
|
|
Packit |
ae235b |
GValue *value, GParamSpec *pspec)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GUnixFDMessage *message = G_UNIX_FD_MESSAGE (object);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
g_assert_cmpint (prop_id, ==, 1);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
g_value_set_object (value, g_unix_fd_message_get_fd_list (message));
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_unix_fd_message_init (GUnixFDMessage *message)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
message->priv = g_unix_fd_message_get_instance_private (message);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_unix_fd_message_finalize (GObject *object)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GUnixFDMessage *message = G_UNIX_FD_MESSAGE (object);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
g_object_unref (message->priv->list);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
G_OBJECT_CLASS (g_unix_fd_message_parent_class)
|
|
Packit |
ae235b |
->finalize (object);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_unix_fd_message_class_init (GUnixFDMessageClass *class)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GSocketControlMessageClass *scm_class = G_SOCKET_CONTROL_MESSAGE_CLASS (class);
|
|
Packit |
ae235b |
GObjectClass *object_class = G_OBJECT_CLASS (class);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
scm_class->get_size = g_unix_fd_message_get_size;
|
|
Packit |
ae235b |
scm_class->get_level = g_unix_fd_message_get_level;
|
|
Packit |
ae235b |
scm_class->get_type = g_unix_fd_message_get_msg_type;
|
|
Packit |
ae235b |
scm_class->serialize = g_unix_fd_message_serialize;
|
|
Packit |
ae235b |
scm_class->deserialize = g_unix_fd_message_deserialize;
|
|
Packit |
ae235b |
object_class->finalize = g_unix_fd_message_finalize;
|
|
Packit |
ae235b |
object_class->set_property = g_unix_fd_message_set_property;
|
|
Packit |
ae235b |
object_class->get_property = g_unix_fd_message_get_property;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
g_object_class_install_property (object_class, 1,
|
|
Packit |
ae235b |
g_param_spec_object ("fd-list", "file descriptor list",
|
|
Packit |
ae235b |
"The GUnixFDList object to send with the message",
|
|
Packit |
ae235b |
G_TYPE_UNIX_FD_LIST, G_PARAM_STATIC_STRINGS |
|
|
Packit |
ae235b |
G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY));
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/**
|
|
Packit |
ae235b |
* g_unix_fd_message_new:
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Creates a new #GUnixFDMessage containing an empty file descriptor
|
|
Packit |
ae235b |
* list.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Returns: a new #GUnixFDMessage
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Since: 2.22
|
|
Packit |
ae235b |
**/
|
|
Packit |
ae235b |
GSocketControlMessage *
|
|
Packit |
ae235b |
g_unix_fd_message_new (void)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
return g_object_new (G_TYPE_UNIX_FD_MESSAGE, NULL);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/**
|
|
Packit |
ae235b |
* g_unix_fd_message_new_with_fd_list:
|
|
Packit |
ae235b |
* @fd_list: a #GUnixFDList
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Creates a new #GUnixFDMessage containing @list.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Returns: a new #GUnixFDMessage
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Since: 2.24
|
|
Packit |
ae235b |
**/
|
|
Packit |
ae235b |
GSocketControlMessage *
|
|
Packit |
ae235b |
g_unix_fd_message_new_with_fd_list (GUnixFDList *fd_list)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
return g_object_new (G_TYPE_UNIX_FD_MESSAGE,
|
|
Packit |
ae235b |
"fd-list", fd_list,
|
|
Packit |
ae235b |
NULL);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/**
|
|
Packit |
ae235b |
* g_unix_fd_message_steal_fds:
|
|
Packit |
ae235b |
* @message: a #GUnixFDMessage
|
|
Packit |
ae235b |
* @length: (out) (optional): pointer to the length of the returned
|
|
Packit |
ae235b |
* array, or %NULL
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Returns the array of file descriptors that is contained in this
|
|
Packit |
ae235b |
* object.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* After this call, the descriptors are no longer contained in
|
|
Packit |
ae235b |
* @message. Further calls will return an empty list (unless more
|
|
Packit |
ae235b |
* descriptors have been added).
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* The return result of this function must be freed with g_free().
|
|
Packit |
ae235b |
* The caller is also responsible for closing all of the file
|
|
Packit |
ae235b |
* descriptors.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* If @length is non-%NULL then it is set to the number of file
|
|
Packit |
ae235b |
* descriptors in the returned array. The returned array is also
|
|
Packit |
ae235b |
* terminated with -1.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* This function never returns %NULL. In case there are no file
|
|
Packit |
ae235b |
* descriptors contained in @message, an empty array is returned.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Returns: (array length=length) (transfer full): an array of file
|
|
Packit |
ae235b |
* descriptors
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Since: 2.22
|
|
Packit |
ae235b |
**/
|
|
Packit |
ae235b |
gint *
|
|
Packit |
ae235b |
g_unix_fd_message_steal_fds (GUnixFDMessage *message,
|
|
Packit |
ae235b |
gint *length)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_return_val_if_fail (G_UNIX_FD_MESSAGE (message), NULL);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
return g_unix_fd_list_steal_fds (message->priv->list, length);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/**
|
|
Packit |
ae235b |
* g_unix_fd_message_append_fd:
|
|
Packit |
ae235b |
* @message: a #GUnixFDMessage
|
|
Packit |
ae235b |
* @fd: a valid open file descriptor
|
|
Packit |
ae235b |
* @error: a #GError pointer
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Adds a file descriptor to @message.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* The file descriptor is duplicated using dup(). You keep your copy
|
|
Packit |
ae235b |
* of the descriptor and the copy contained in @message will be closed
|
|
Packit |
ae235b |
* when @message is finalized.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* A possible cause of failure is exceeding the per-process or
|
|
Packit |
ae235b |
* system-wide file descriptor limit.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Returns: %TRUE in case of success, else %FALSE (and @error is set)
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Since: 2.22
|
|
Packit |
ae235b |
**/
|
|
Packit |
ae235b |
gboolean
|
|
Packit |
ae235b |
g_unix_fd_message_append_fd (GUnixFDMessage *message,
|
|
Packit |
ae235b |
gint fd,
|
|
Packit |
ae235b |
GError **error)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_return_val_if_fail (G_UNIX_FD_MESSAGE (message), FALSE);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
return g_unix_fd_list_append (message->priv->list, fd, error) >= 0;
|
|
Packit |
ae235b |
}
|