dbus/dbus-transport-unix.c

   1 /* -*- mode: C; c-file-style: "gnu" -*- */
   2 /* dbus-transport-unix.c UNIX socket subclasses of DBusTransport
   3  *
   4  * Copyright (C) 2002, 2003, 2004  Red Hat Inc.
   5  *
   6  * Licensed under the Academic Free License version 2.1
   7  *
   8  * This program is free software; you can redistribute it and/or modify
   9  * it under the terms of the GNU General Public License as published by
  10  * the Free Software Foundation; either version 2 of the License, or
  11  * (at your option) any later version.
  12  *
  13  * This program is distributed in the hope that it will be useful,
  14  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  15  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16  * GNU General Public License for more details.
  17  *
  18  * You should have received a copy of the GNU General Public License
  19  * along with this program; if not, write to the Free Software
  20  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  21  *
  22  */
  23
  24 #include "dbus-internals.h"
  25 #include "dbus-connection-internal.h"
  26 #include "dbus-transport-unix.h"
  27 #include "dbus-transport-socket.h"
  28 #include "dbus-transport-protected.h"
  29 #include "dbus-watch.h"
  30 #include "dbus-sysdeps-unix.h"
  31
  32 /**
  33  * @defgroup DBusTransportUnix DBusTransport implementations for UNIX
  34  * @ingroup  DBusInternals
  35  * @brief Implementation details of DBusTransport on UNIX
  36  *
  37  * @{
  38  */
  39
  40 /**
  41  * Creates a new transport for the given Unix domain socket
  42  * path. This creates a client-side of a transport.
  43  *
  44  * @todo once we add a way to escape paths in a dbus
  45  * address, this function needs to do escaping.
  46  *
  47  * @param path the path to the domain socket.
  48  * @param abstract #TRUE to use abstract socket namespace
  49  * @param error address where an error can be returned.
  50  * @returns a new transport, or #NULL on failure.
  51  */
  52 DBusTransport*
  53 _dbus_transport_new_for_domain_socket (const char     *path,
  54                                        dbus_bool_t     abstract,
  55                                        DBusError      *error)
  56 {
  57   int fd;
  58   DBusTransport *transport;
  59   DBusString address;
  60
  61   _DBUS_ASSERT_ERROR_IS_CLEAR (error);
  62
  63   if (!_dbus_string_init (&address))
  64     {
  65       dbus_set_error (error, DBUS_ERROR_NO_MEMORY, NULL);
  66       return NULL;
  67     }
  68
  69   fd = -1;
  70
  71   if ((abstract &&
  72        !_dbus_string_append (&address, "unix:abstract=")) ||
  73       (!abstract &&
  74        !_dbus_string_append (&address, "unix:path=")) ||
  75       !_dbus_string_append (&address, path))
  76     {
  77       dbus_set_error (error, DBUS_ERROR_NO_MEMORY, NULL);
  78       goto failed_0;
  79     }
  80
  81   fd = _dbus_connect_unix_socket (path, abstract, error);
  82   if (fd < 0)
  83     {
  84       _DBUS_ASSERT_ERROR_IS_SET (error);
  85       goto failed_0;
  86     }
  87
  88   _dbus_fd_set_close_on_exec (fd);
  89
  90   _dbus_verbose ("Successfully connected to unix socket %s\n",
  91                  path);
  92
  93   transport = _dbus_transport_new_for_socket (fd, NULL, &address);
  94   if (transport == NULL)
  95     {
  96       dbus_set_error (error, DBUS_ERROR_NO_MEMORY, NULL);
  97       goto failed_1;
  98     }
  99
 100   _dbus_string_free (&address);
 101
 102   return transport;
 103
 104  failed_1:
 105   _dbus_close_socket (fd, NULL);
 106  failed_0:
 107   _dbus_string_free (&address);
 108   return NULL;
 109 }
 110
 111 DBusTransportOpenResult
 112 _dbus_transport_open_platform_specific (DBusAddressEntry  *entry,
 113                                         DBusTransport    **transport_p,
 114                                         DBusError         *error)
 115 {
 116   const char *method;
 117
 118   method = dbus_address_entry_get_method (entry);
 119   _dbus_assert (method != NULL);
 120
 121   if (strcmp (method, "unix") == 0)
 122     {
 123       const char *path = dbus_address_entry_get_value (entry, "path");
 124       const char *tmpdir = dbus_address_entry_get_value (entry, "tmpdir");
 125       const char *abstract = dbus_address_entry_get_value (entry, "abstract");
 126
 127       if (tmpdir != NULL)
 128         {
 129           _dbus_set_bad_address (error, NULL, NULL,
 130                                  "cannot use the \"tmpdir\" option for an address to connect to, only in an address to listen on");
 131           return DBUS_TRANSPORT_OPEN_BAD_ADDRESS;
 132         }
 133
 134       if (path == NULL && abstract == NULL)
 135         {
 136           _dbus_set_bad_address (error, "unix",
 137                                  "path or abstract",
 138                                  NULL);
 139           return DBUS_TRANSPORT_OPEN_BAD_ADDRESS;
 140         }
 141
 142       if (path != NULL && abstract != NULL)
 143         {
 144           _dbus_set_bad_address (error, NULL, NULL,
 145                                  "can't specify both \"path\" and \"abstract\" options in an address");
 146           return DBUS_TRANSPORT_OPEN_BAD_ADDRESS;
 147         }
 148
 149       if (path)
 150         *transport_p = _dbus_transport_new_for_domain_socket (path, FALSE,
 151                                                            error);
 152       else
 153         *transport_p = _dbus_transport_new_for_domain_socket (abstract, TRUE,
 154                                                            error);
 155       if (*transport_p == NULL)
 156         {
 157           _DBUS_ASSERT_ERROR_IS_SET (error);
 158           return DBUS_TRANSPORT_OPEN_DID_NOT_CONNECT;
 159         }
 160       else
 161         {
 162           _DBUS_ASSERT_ERROR_IS_CLEAR (error);
 163           return DBUS_TRANSPORT_OPEN_OK;
 164         }
 165     }
 166   else
 167     {
 168       _DBUS_ASSERT_ERROR_IS_CLEAR (error);
 169       return DBUS_TRANSPORT_OPEN_NOT_HANDLED;
 170     }
 171 }
 172
 173 /** @} */