+2003-01-25 Anders Carlsson <andersca@codefactory.se>
+
+ * dbus/dbus-connection.c: (dbus_connection_send_message):
+ Unlock the message in case it was sent earlier.
+
+ (dbus_connection_send_message_with_reply_and_block):
+ Remove the reply message from the list.
+
+ * dbus/dbus-marshal.c: (_dbus_demarshal_string_array):
+ Set array_len and new_pos correctly.
+
+ (_dbus_marshal_test):
+ Remove debug output.
+
+ * dbus/dbus-message-internal.h:
+ * dbus/dbus-message.c: (_dbus_message_get_reply_serial):
+ New function that returns the reply serial.
+
+ (_dbus_message_unlock):
+ New function that unlocks a message and resets its header.
+
+ (dbus_message_append_string_array),
+ (dbus_message_get_fields_valist),
+ (dbus_message_iter_get_field_type),
+ (dbus_message_iter_get_string_array),
+ (dbus_message_get_fields),
+ (dbus_message_append_fields_valist):
+ Handle string arrays.
+
+ (dbus_message_set_sender):
+ Make this function public since the bus daemon needs it.
+
+ (decode_header_data):
+ Set the reply serial to -1 initially.
+
+ * dbus/dbus-message.h:
+ Add dbus_message_set_sender.
+
2003-01-24 Havoc Pennington <hp@pobox.com>
* doc/dbus-specification.sgml: add some stuff
dbus_int32_t
_dbus_message_get_reply_serial (DBusMessage *message)
{
- return message->client_serial;
-}
-
-/**
- * Sets the message sender. This can only
- * be done once on a message.
- *
- * @param message the message
- * @param sender the sender
- */
-void
-_dbus_message_set_sender (DBusMessage *message,
- const char *sender)
-{
- _dbus_assert (message->sender == NULL);
-
- message->sender = _dbus_strdup (sender);
+ return message->reply_serial;
}
/**
}
/**
+ * Unlocks a message so that it can be re-sent to another client.
+ *
+ * @see _dbus_message_lock
+ * @param message the message to unlock.
+ */
+void
+_dbus_message_unlock (DBusMessage *message)
+{
+ if (!message->locked)
+ return;
+
+ /* Restore header */
+ _dbus_string_set_length (&message->header, 0);
+
+ message->client_serial = -1;
+ message->locked = FALSE;
+}
+
+/**
* Locks a message. Allows checking that applications don't keep a
* reference to a message in the outgoing queue and change it
* underneath us. Messages are locked when they enter the outgoing
goto enomem;
}
break;
+ case DBUS_TYPE_STRING_ARRAY:
+ {
+ int len;
+ const char **data;
+
+ data = va_arg (var_args, const char **);
+ len = va_arg (var_args, int);
+
+ if (!dbus_message_append_string_array (message, data, len))
+ goto enomem;
+ }
+ break;
+
default:
_dbus_warn ("Unknown field type %d\n", type);
}
}
/**
+ * Appends a string array to the message.
+ *
+ * @param message the message
+ * @param value the array
+ * @param len the length of the array
+ * @returns #TRUE on success
+ */
+dbus_bool_t
+dbus_message_append_string_array (DBusMessage *message,
+ const char **value,
+ int len)
+{
+ _dbus_assert (!message->locked);
+
+ if (!_dbus_string_append_byte (&message->body, DBUS_TYPE_STRING_ARRAY))
+ {
+ _dbus_string_shorten (&message->body, 1);
+ return FALSE;
+ }
+
+ return _dbus_marshal_string_array (&message->body,
+ DBUS_COMPILER_BYTE_ORDER, value, len);
+}
+
+/**
* Gets fields from a message given a variable argument list.
* The variable argument list should contain the type of the
* field followed by a pointer to where the value should be
DBusResultCode retval;
va_list var_args;
+ _dbus_verbose_bytes_of_string (&message->header, 0,
+ _dbus_string_get_length (&message->header));
va_start (var_args, first_field_type);
retval = dbus_message_get_fields_valist (message, first_field_type, var_args);
va_end (var_args);
iter = dbus_message_get_fields_iter (message);
if (iter == NULL)
- return FALSE;
+ return DBUS_RESULT_NO_MEMORY;
spec_type = first_field_type;
i = 0;
case DBUS_TYPE_BYTE_ARRAY:
{
- char **ptr;
+ unsigned char **ptr;
int *len;
- ptr = va_arg (var_args, char **);
+ ptr = va_arg (var_args, unsigned char **);
len = va_arg (var_args, int *);
*ptr = dbus_message_iter_get_byte_array (iter, len);
break;
}
+ case DBUS_TYPE_STRING_ARRAY:
+ {
+ char ***ptr;
+ int *len;
+
+ ptr = va_arg (var_args, char ***);
+ len = va_arg (var_args, int *);
+
+ *ptr = dbus_message_iter_get_string_array (iter, len);
+
+ if (!*ptr)
+ return DBUS_RESULT_NO_MEMORY;
+
+ break;
+ }
default:
_dbus_warn ("Unknown field type %d\n", spec_type);
}
_dbus_string_get_const_data_len (&iter->message->body, &data, iter->pos, 1);
- if (*data > DBUS_TYPE_INVALID && *data <= DBUS_TYPE_STRING)
+ if (*data > DBUS_TYPE_INVALID && *data <= DBUS_TYPE_STRING_ARRAY)
return *data;
return DBUS_TYPE_INVALID;
iter->pos + 1, NULL, len);
}
+/**
+ * Returns the string array that the iterator may point to.
+ * Note that you need to check that the iterator points
+ * to a byte array prior to using this function.
+ *
+ * @todo this function should probably take "char **" as
+ * an out param argument, and return boolean or result code.
+ *
+ * @param iter the iterator
+ * @param len return location for length of byte array
+ * @returns the byte array
+ */
+char **
+dbus_message_iter_get_string_array (DBusMessageIter *iter,
+ int *len)
+{
+ _dbus_assert (dbus_message_iter_get_field_type (iter) == DBUS_TYPE_STRING_ARRAY);
+
+ return _dbus_demarshal_string_array (&iter->message->body, iter->message->byte_order,
+ iter->pos + 1, NULL, len);
+}
+
+/**
+ * Sets the message sender.
+ *
+ * @param message the message
+ * @param sender the sender
+ */
+void
+dbus_message_set_sender (DBusMessage *message,
+ const char *sender)
+{
+ _dbus_assert (!message->locked);
+
+ message->sender = _dbus_strdup (sender);
+}
+
/** @} */
/**
/* First demarshal the client serial */
*client_serial = _dbus_demarshal_int32 (data, byte_order, 12, &pos);
+ *reply_serial = -1;
*service = NULL;
*name = NULL;
*sender = NULL;
return;
}
-
message = dbus_message_new (service, name);
message->reply_serial = reply_serial;
message->client_serial = client_serial;
- _dbus_message_set_sender (message, sender);
+ dbus_message_set_sender (message, sender);
dbus_free (service);
dbus_free (name);
void dbus_message_ref (DBusMessage *message);
void dbus_message_unref (DBusMessage *message);
-const char* dbus_message_get_name (DBusMessage *message);
-const char* dbus_message_get_service (DBusMessage *message);
+const char* dbus_message_get_name (DBusMessage *message);
+const char* dbus_message_get_service (DBusMessage *message);
+void dbus_message_set_sender (DBusMessage *message,
+ const char *sender);
-dbus_bool_t dbus_message_append_fields (DBusMessage *message,
- int first_field_type,
+
+dbus_bool_t dbus_message_append_fields (DBusMessage *message,
+ int first_field_type,
...);
-dbus_bool_t dbus_message_append_fields_valist (DBusMessage *message,
- int first_field_type,
- va_list var_args);
-dbus_bool_t dbus_message_append_int32 (DBusMessage *message,
- dbus_int32_t value);
-dbus_bool_t dbus_message_append_uint32 (DBusMessage *message,
- dbus_uint32_t value);
-dbus_bool_t dbus_message_append_double (DBusMessage *message,
- double value);
-dbus_bool_t dbus_message_append_string (DBusMessage *message,
- const char *value);
-dbus_bool_t dbus_message_append_byte_array (DBusMessage *message,
- unsigned const char *value,
- int len);
+dbus_bool_t dbus_message_append_fields_valist (DBusMessage *message,
+ int first_field_type,
+ va_list var_args);
+dbus_bool_t dbus_message_append_int32 (DBusMessage *message,
+ dbus_int32_t value);
+dbus_bool_t dbus_message_append_uint32 (DBusMessage *message,
+ dbus_uint32_t value);
+dbus_bool_t dbus_message_append_double (DBusMessage *message,
+ double value);
+dbus_bool_t dbus_message_append_string (DBusMessage *message,
+ const char *value);
+dbus_bool_t dbus_message_append_byte_array (DBusMessage *message,
+ unsigned const char *value,
+ int len);
+dbus_bool_t dbus_message_append_string_array (DBusMessage *message,
+ const char **value,
+ int len);
+
DBusMessageIter *dbus_message_get_fields_iter (DBusMessage *message);
char * dbus_message_iter_get_string (DBusMessageIter *iter);
unsigned char * dbus_message_iter_get_byte_array (DBusMessageIter *iter,
int *len);
+char ** dbus_message_iter_get_string_array (DBusMessageIter *iter,
+ int *len)
projects / platform / upstream / dbus.git / commitdiff