*/
#define KDBUS_MSG_DECODE_DEBUG 0
-#define MSG_ITEM_BUILD_VEC(data, datasize) \
- item->type = KDBUS_ITEM_PAYLOAD_VEC; \
- item->size = KDBUS_ITEM_HEADER_SIZE + sizeof (struct kdbus_vec); \
- item->vec.address = (unsigned long) data; \
- item->vec.size = datasize;
-
/**
* Opaque object representing a transport.
*/
* @returns 0 on success, otherwise -1
*/
static int
-kdbus_acquire_memfd (DBusTransportKdbus *kdbus_transport,
- uint64_t fsize)
+kdbus_acquire_memfd ( void )
{
int fd;
/* check whether we can and should use memfd */
if ((dst_id != KDBUS_DST_ID_BROADCAST) && (ret_size > MEMFD_SIZE_THRESHOLD))
- memfd = kdbus_acquire_memfd (transport, ret_size);
+ memfd = kdbus_acquire_memfd ();
_dbus_message_get_unix_fds (message, &unix_fds, &fds_count);
return FALSE;
}
- transport->my_DBus_unique_name = create_unique_name_from_unique_id (_kdbus_id (transport->kdbus));
+ transport->my_DBus_unique_name = create_unique_name_from_unique_id (_kdbus_get_id (transport->kdbus));
if (NULL == transport->my_DBus_unique_name)
{
dbus_set_error (error, DBUS_ERROR_NO_MEMORY, "Hello post failed: %d", -ret);
return FALSE;
}
- _dbus_verbose ("-- Our peer ID is: %llu\n", (unsigned long long)_kdbus_id (transport->kdbus));
+ _dbus_verbose ("-- Our peer ID is: %llu\n", (unsigned long long)_kdbus_get_id (transport->kdbus));
return TRUE;
}
if (*result == -EPERM)
{
dbus_set_error (error, DBUS_ERROR_ACCESS_DENIED,
- "Kdbus don't allow %s to own the service \"%s\"",
+ "Kdbus doesn't allow %s to own the service \"%s\"",
transport->my_DBus_unique_name, _dbus_string_get_const_data (service_name));
return FALSE;
}
DBusMessage *message,
DBusError *error)
{
- dbus_uint64_t bus_id_size = _kdbus_bus_id_size ();
+ dbus_uint64_t bus_id_size = _kdbus_get_bus_id_size ();
char bus_id[bus_id_size*2+1];
char *bus_id_ptr = bus_id;
- char *bus_id_original = _kdbus_bus_id (transport->kdbus);
+ char *bus_id_original = _kdbus_get_bus_id (transport->kdbus);
int i = 0;
for (; i < bus_id_size; i++)
sprintf (bus_id + 2*i, "%02x", bus_id_original[i]);
item->name_change.new_id.id, item->name_change.old_id.flags,
item->name_change.new_id.flags);
- if (item->name_change.new_id.id == _kdbus_id (kdbus_transport->kdbus))
+ if (item->name_change.new_id.id == _kdbus_get_id (kdbus_transport->kdbus))
ret_size = generate_NameSignal ("NameAcquired", item->name_change.name, kdbus_transport);
- else if (item->name_change.old_id.id == _kdbus_id (kdbus_transport->kdbus))
+ else if (item->name_change.old_id.id == _kdbus_get_id (kdbus_transport->kdbus))
ret_size = generate_NameSignal ("NameLost", item->name_change.name, kdbus_transport);
if (ret_size == -1)
_dbus_verbose ("check_write_watch (): needed = %d on connection %p watch %p fd = %d outgoing messages exist %d\n",
needed, transport->connection, kdbus_transport->write_watch,
- _kdbus_fd (kdbus_transport->kdbus),
+ _kdbus_get_fd (kdbus_transport->kdbus),
_dbus_connection_has_messages_to_send_unlocked (transport->connection));
_dbus_connection_toggle_watch_unlocked (transport->connection,
dbus_bool_t need_read_watch;
DBusTransport *transport = &kdbus_transport->base;
- _dbus_verbose ("fd = %d\n", _kdbus_fd (kdbus_transport->kdbus));
+ _dbus_verbose ("fd = %d\n",_kdbus_get_fd (kdbus_transport->kdbus));
if (transport->connection == NULL)
return;
}
_dbus_verbose ("do_writing (), have_messages = %d, fd = %d\n",
- _dbus_connection_has_messages_to_send_unlocked (transport->connection), _kdbus_fd (kdbus_transport->kdbus));
+ _dbus_connection_has_messages_to_send_unlocked (transport->connection),
+ _kdbus_get_fd (kdbus_transport->kdbus));
while (!transport->disconnected && _dbus_connection_has_messages_to_send_unlocked (transport->connection))
{
int *fds, n_fds;
int total = 0;
- _dbus_verbose ("fd = %d\n",_kdbus_fd (kdbus_transport->kdbus));
+ _dbus_verbose ("fd = %d\n", _kdbus_get_fd (kdbus_transport->kdbus));
again:
timeout_milliseconds,
kdbus_transport->read_watch,
kdbus_transport->write_watch,
- _kdbus_fd (kdbus_transport->kdbus));
+ _kdbus_get_fd (kdbus_transport->kdbus));
- poll_fd.fd = _kdbus_fd (kdbus_transport->kdbus);
+ poll_fd.fd = _kdbus_get_fd (kdbus_transport->kdbus);
poll_fd.events = 0;
/*
{
DBusTransportKdbus *kdbus_transport = (DBusTransportKdbus*) transport;
- fd_p->fd = _kdbus_fd (kdbus_transport->kdbus);
+ fd_p->fd = _kdbus_get_fd (kdbus_transport->kdbus);
return TRUE;
}
int ret;
ret = _kdbus_connection_info_by_id (transport->kdbus,
- _kdbus_id (transport->kdbus),
+ _kdbus_get_id (transport->kdbus),
FALSE,
&conn_info);
if (ret != 0)
kdbus_transport->kdbus = kdbus;
- kdbus_transport->write_watch = _dbus_watch_new (_kdbus_fd (kdbus),
+ kdbus_transport->write_watch = _dbus_watch_new (_kdbus_get_fd (kdbus),
DBUS_WATCH_WRITABLE,
FALSE,
NULL, NULL, NULL);
if (kdbus_transport->write_watch == NULL)
goto failed_2;
- kdbus_transport->read_watch = _dbus_watch_new (_kdbus_fd (kdbus),
+ kdbus_transport->read_watch = _dbus_watch_new (_kdbus_get_fd (kdbus),
DBUS_WATCH_READABLE,
FALSE,
NULL, NULL, NULL);
};
/** temporary accessors - to delete soon */
-int _kdbus_fd (kdbus_t *kdbus) { return kdbus->fd; }
-void *_kdbus_mmap_ptr (kdbus_t *kdbus) { return kdbus->mmap_ptr; }
-dbus_uint64_t _kdbus_id (kdbus_t *kdbus) { return kdbus->id; }
-char *_kdbus_bus_id (kdbus_t *kdbus) { return kdbus->bus_id; }
-dbus_uint64_t _kdbus_bus_id_size (void) { return sizeof (((struct kdbus_t *)(0))->bus_id); }
struct kdbus_bloom_parameter *_kdbus_bloom (kdbus_t *kdbus) { return &kdbus->bloom; }
}
int
+_kdbus_get_fd (kdbus_t *kdbus)
+{
+ return kdbus->fd;
+}
+
+__u64
+_kdbus_get_id (kdbus_t *kdbus)
+{
+ return kdbus->id;
+}
+
+char *
+_kdbus_get_bus_id (kdbus_t *kdbus)
+{
+ return kdbus->bus_id;
+}
+
+__u64
+_kdbus_get_bus_id_size (void)
+{
+ return sizeof (((struct kdbus_t *)(0))->bus_id);
+}
+
+int
_kdbus_hello (kdbus_t *kdbus,
__u64 flags,
__u64 attach_flags_send,
{
struct kdbus_cmd *cmd_name;
size_t len = strlen (name) + 1;
-
__u64 size = sizeof (*cmd_name) + KDBUS_ITEM_SIZE (len);
__u64 flags_kdbus = 0;
const char *name)
{
struct kdbus_cmd *cmd_name;
-
size_t len = strlen (name)+1;
__u64 size = sizeof (*cmd_name) + KDBUS_ITEM_SIZE (len);