src/libsystemd-bus/bus-internal.h

   1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
   2
   3 #pragma once
   4
   5 /***
   6   This file is part of systemd.
   7
   8   Copyright 2013 Lennart Poettering
   9
  10   systemd is free software; you can redistribute it and/or modify it
  11   under the terms of the GNU Lesser General Public License as published by
  12   the Free Software Foundation; either version 2.1 of the License, or
  13   (at your option) any later version.
  14
  15   systemd is distributed in the hope that it will be useful, but
  16   WITHOUT ANY WARRANTY; without even the implied warranty of
  17   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  18   Lesser General Public License for more details.
  19
  20   You should have received a copy of the GNU Lesser General Public License
  21   along with systemd; If not, see <http://www.gnu.org/licenses/>.
  22 ***/
  23
  24 #include <sys/socket.h>
  25 #include <sys/un.h>
  26 #include <netinet/in.h>
  27
  28 #include "hashmap.h"
  29 #include "prioq.h"
  30 #include "list.h"
  31 #include "util.h"
  32 #include "refcnt.h"
  33
  34 #include "sd-bus.h"
  35 #include "bus-error.h"
  36 #include "bus-match.h"
  37 #include "bus-kernel.h"
  38
  39 struct reply_callback {
  40         sd_bus_message_handler_t callback;
  41         void *userdata;
  42         usec_t timeout;
  43         uint64_t serial;
  44         unsigned prioq_idx;
  45 };
  46
  47 struct filter_callback {
  48         sd_bus_message_handler_t callback;
  49         void *userdata;
  50
  51         unsigned last_iteration;
  52
  53         LIST_FIELDS(struct filter_callback, callbacks);
  54 };
  55
  56 struct object_callback {
  57         sd_bus_message_handler_t callback;
  58         void *userdata;
  59
  60         char *path;
  61         bool is_fallback;
  62
  63         unsigned last_iteration;
  64 };
  65
  66 enum bus_state {
  67         BUS_UNSET,
  68         BUS_OPENING,
  69         BUS_AUTHENTICATING,
  70         BUS_HELLO,
  71         BUS_RUNNING,
  72         BUS_CLOSED
  73 };
  74
  75 static inline bool BUS_IS_OPEN(enum bus_state state) {
  76         return state > BUS_UNSET && state < BUS_CLOSED;
  77 }
  78
  79 enum bus_auth {
  80         _BUS_AUTH_INVALID,
  81         BUS_AUTH_EXTERNAL,
  82         BUS_AUTH_ANONYMOUS
  83 };
  84
  85 struct sd_bus {
  86         /* We use atomic ref counting here since sd_bus_message
  87            objects retain references to their originating sd_bus but
  88            we want to allow them to be processed in a different
  89            thread. We won't provide full thread safety, but only the
  90            bare minimum that makes it possible to use sd_bus and
  91            sd_bus_message objects independently and on different
  92            threads as long as each object is used only once at the
  93            same time. */
  94         RefCount n_ref;
  95
  96         enum bus_state state;
  97         int input_fd, output_fd;
  98         int message_version;
  99
 100         bool is_kernel:1;
 101         bool negotiate_fds:1;
 102         bool can_fds:1;
 103         bool bus_client:1;
 104         bool ucred_valid:1;
 105         bool is_server:1;
 106         bool anonymous_auth:1;
 107         bool prefer_readv:1;
 108         bool prefer_writev:1;
 109         bool processing:1;
 110         bool match_callbacks_modified:1;
 111         bool filter_callbacks_modified:1;
 112         bool object_callbacks_modified:1;
 113
 114         void *rbuffer;
 115         size_t rbuffer_size;
 116
 117         sd_bus_message **rqueue;
 118         unsigned rqueue_size;
 119
 120         sd_bus_message **wqueue;
 121         unsigned wqueue_size;
 122         size_t windex;
 123
 124         uint64_t serial;
 125
 126         char *unique_name;
 127
 128         struct bus_match_node match_callbacks;
 129         Prioq *reply_callbacks_prioq;
 130         Hashmap *reply_callbacks;
 131         LIST_HEAD(struct filter_callback, filter_callbacks);
 132         Hashmap *object_callbacks;
 133
 134         union {
 135                 struct sockaddr sa;
 136                 struct sockaddr_un un;
 137                 struct sockaddr_in in;
 138                 struct sockaddr_in6 in6;
 139         } sockaddr;
 140         socklen_t sockaddr_size;
 141
 142         char *kernel;
 143
 144         sd_id128_t server_id;
 145
 146         char *address;
 147         unsigned address_index;
 148
 149         int last_connect_error;
 150
 151         enum bus_auth auth;
 152         size_t auth_rbegin;
 153         struct iovec auth_iovec[3];
 154         unsigned auth_index;
 155         char *auth_buffer;
 156         usec_t auth_timeout;
 157
 158         struct ucred ucred;
 159         char label[NAME_MAX];
 160
 161         int *fds;
 162         unsigned n_fds;
 163
 164         char *exec_path;
 165         char **exec_argv;
 166
 167         uint64_t hello_serial;
 168         unsigned iteration_counter;
 169
 170         void *kdbus_buffer;
 171
 172         struct memfd_cache memfd_cache[MEMFD_CACHE_MAX];
 173         unsigned n_memfd_cache;
 174
 175         pid_t original_pid;
 176 };
 177
 178 static inline void bus_unrefp(sd_bus **b) {
 179         sd_bus_unref(*b);
 180 }
 181
 182 #define _cleanup_bus_unref_ __attribute__((cleanup(bus_unrefp)))
 183 #define _cleanup_bus_error_free_ __attribute__((cleanup(sd_bus_error_free)))
 184
 185 #define BUS_DEFAULT_TIMEOUT ((usec_t) (25 * USEC_PER_SEC))
 186
 187 #define BUS_WQUEUE_MAX 128
 188 #define BUS_RQUEUE_MAX 128
 189
 190 #define BUS_MESSAGE_SIZE_MAX (64*1024*1024)
 191 #define BUS_AUTH_SIZE_MAX (64*1024)
 192
 193 #define BUS_CONTAINER_DEPTH 128
 194
 195 /* Defined by the specification as maximum size of an array in
 196  * bytes */
 197 #define BUS_ARRAY_MAX_SIZE 67108864
 198
 199 #define BUS_FDS_MAX 1024
 200
 201 #define BUS_EXEC_ARGV_MAX 256
 202
 203 bool object_path_is_valid(const char *p);
 204 bool interface_name_is_valid(const char *p);
 205 bool service_name_is_valid(const char *p);
 206 bool member_name_is_valid(const char *p);
 207
 208 bool namespace_complex_pattern(const char *pattern, const char *value);
 209 bool path_complex_pattern(const char *pattern, const char *value);
 210
 211 bool namespace_simple_pattern(const char *pattern, const char *value);
 212 bool path_simple_pattern(const char *pattern, const char *value);
 213
 214 int bus_message_type_from_string(const char *s, uint8_t *u);
 215 const char *bus_message_type_to_string(uint8_t u);
 216
 217 #define error_name_is_valid interface_name_is_valid
 218
 219 int bus_ensure_running(sd_bus *bus);
 220 int bus_start_running(sd_bus *bus);
 221 int bus_next_address(sd_bus *bus);
 222
 223 bool bus_pid_changed(sd_bus *bus);