static HASH DBUS;
// D-Bus variables
-static DBusMessage* msg;
+static DBusMessage *msg;
static DBusMessageIter args;
-static DBusConnection* conn;
+static DBusConnection *conn;
static DBusError err;
-static DBusPendingCall* pending;
+static DBusPendingCall *pending;
static void read_MetaData()
{
- // put pairs to hash table
- int current_type;
- // TODO: check size of char arrays
- char str_key[255];
- char str_value[2048];
- DBusMessageIter subiter1;
-
- dbus_message_iter_recurse (&args, &subiter1);
- while ((current_type = dbus_message_iter_get_arg_type (&subiter1)) != DBUS_TYPE_INVALID)
- {
- DBusMessageIter subiter2;
- DBusMessageIter subiter3;
-
- strcpy(str_key,"");
- strcpy(str_value,"");
- dbus_message_iter_recurse (&subiter1, &subiter2);
- current_type = dbus_message_iter_get_arg_type (&subiter2);
-
- if (current_type == DBUS_TYPE_INVALID)
- break;
- if (current_type == DBUS_TYPE_STRING)
+ // put pairs to hash table
+ int current_type;
+ // TODO: check size of char arrays
+ char str_key[255];
+ char str_value[2048];
+ DBusMessageIter subiter1;
+
+ dbus_message_iter_recurse(&args, &subiter1);
+ while ((current_type = dbus_message_iter_get_arg_type(&subiter1)) != DBUS_TYPE_INVALID) {
+ DBusMessageIter subiter2;
+ DBusMessageIter subiter3;
+
+ strcpy(str_key, "");
+ strcpy(str_value, "");
+ dbus_message_iter_recurse(&subiter1, &subiter2);
+ current_type = dbus_message_iter_get_arg_type(&subiter2);
+
+ if (current_type == DBUS_TYPE_INVALID)
+ break;
+ if (current_type == DBUS_TYPE_STRING) {
+ void *str_tmp1;
+ void *str_tmp2;
+ dbus_message_iter_get_basic(&subiter2, &str_tmp1);
+ strcpy(str_key, str_tmp1);
+ dbus_message_iter_next(&subiter2);
+ dbus_message_iter_recurse(&subiter2, &subiter3);
+ current_type = dbus_message_iter_get_arg_type(&subiter3);
+ switch (current_type) {
+ case DBUS_TYPE_STRING:
{
- void *str_tmp1;
- void *str_tmp2;
- dbus_message_iter_get_basic (&subiter2, &str_tmp1);
- strcpy(str_key,str_tmp1);
- dbus_message_iter_next (&subiter2);
- dbus_message_iter_recurse (&subiter2, &subiter3);
- current_type = dbus_message_iter_get_arg_type (&subiter3);
- switch (current_type)
- {
- case DBUS_TYPE_STRING:
- {
- dbus_message_iter_get_basic (&subiter3, &str_tmp2);
- strcpy(str_value,str_tmp2);
- break;
- }
- case DBUS_TYPE_INT32:
- {
- dbus_int32_t val;
- dbus_message_iter_get_basic (&subiter3, &val);
- sprintf (str_value,"%d", val);
- break;
- }
- case DBUS_TYPE_INT64:
- {
- dbus_int64_t val;
- dbus_message_iter_get_basic (&subiter3, &val);
- sprintf (str_value,"%Ld", val);
- break;
- }
- default:
- // unexpected type
- //printf (" (2-dbus-monitor too dumb to decipher arg type '%c')\n", current_type);
- break;
- }
- // add key-value pair to hash
- hash_put(&DBUS,str_key,str_value);
- //printf("Key: %s , Value: %s\t",str_key,str_value);
+ dbus_message_iter_get_basic(&subiter3, &str_tmp2);
+ strcpy(str_value, str_tmp2);
+ break;
}
- //else
- // unexpected type
- //printf (" (2-dbus-monitor too dumb to decipher arg type '%c')\n", current_type);
- dbus_message_iter_next (&subiter1);
- }
-}
-
-static int listen_TrackChange(void)
-{
- // non blocking read of the next available message
- dbus_connection_read_write(conn, 0);
- msg = dbus_connection_pop_message(conn);
-
- // nothing to do if we haven't read a message
- if (NULL == msg)
- return 0;
-
- // check if the message is a signal from the correct interface and with the correct name
- if (dbus_message_is_signal(msg, "org.freedesktop.MediaPlayer", "TrackChange")) {
- // read the parameters
- // TrackChange signal returns an array of string-variant pairs
- if (!dbus_message_iter_init(msg, &args)) {
- // No parameter !
- //fprintf(stderr, "Message Has No Parameters\n");
- return 0;
+ case DBUS_TYPE_INT32:
+ {
+ dbus_int32_t val;
+ dbus_message_iter_get_basic(&subiter3, &val);
+ sprintf(str_value, "%d", val);
+ break;
}
- else if (DBUS_TYPE_ARRAY != dbus_message_iter_get_arg_type(&args)) {
- // Argument is not array
- //fprintf(stderr, "Argument is not array!\n");
- return 0;
+ case DBUS_TYPE_INT64:
+ {
+ dbus_int64_t val;
+ dbus_message_iter_get_basic(&subiter3, &val);
+ sprintf(str_value, "%Ld", val);
+ break;
}
- else
- read_MetaData();
- //printf("Got Signal\n");
+ default:
+ // unexpected type
+ //printf (" (2-dbus-monitor too dumb to decipher arg type '%c')\n", current_type);
+ break;
+ }
+ // add key-value pair to hash
+ hash_put(&DBUS, str_key, str_value);
+ //printf("Key: %s , Value: %s\t",str_key,str_value);
}
- // free message
- dbus_message_unref(msg);
- return 1;
+ //else
+ // unexpected type
+ //printf (" (2-dbus-monitor too dumb to decipher arg type '%c')\n", current_type);
+ dbus_message_iter_next(&subiter1);
+ }
}
-static unsigned long int call_PositionGet(char* target)
+static int listen_TrackChange(void)
{
- unsigned long int value=0;
-
- // create a new method call and check for errors
- msg = dbus_message_new_method_call(target, //target for the method call e.g "org.kde.amarok"
- "/Player", // object to call on
- "org.freedesktop.MediaPlayer", // interface to call on
- "PositionGet"); // method name
- if (NULL == msg) {
- //fprintf(stderr, "Message Null\n");
- return 0;
- }
-
- // send message and get a handle for a reply
- if (!dbus_connection_send_with_reply (conn, msg, &pending, -1)) { // -1 is default timeout
- //fprintf(stderr, "Out Of Memory!\n");
- return 0;
- }
- if (NULL == pending) {
- //fprintf(stderr, "Pending Call Null\n");
- return 0;
- }
- dbus_connection_flush(conn);
-
- //printf("Request Sent\n");
-
- // free message
- dbus_message_unref(msg);
-
- // block until we recieve a reply
- dbus_pending_call_block(pending);
-
- // get the reply message
- msg = dbus_pending_call_steal_reply(pending);
- if (NULL == msg) {
- //fprintf(stderr, "Reply Null\n");
- return 0;
- }
- // free the pending message handle
- dbus_pending_call_unref(pending);
-
+ // non blocking read of the next available message
+ dbus_connection_read_write(conn, 0);
+ msg = dbus_connection_pop_message(conn);
+
+ // nothing to do if we haven't read a message
+ if (NULL == msg)
+ return 0;
+
+ // check if the message is a signal from the correct interface and with the correct name
+ if (dbus_message_is_signal(msg, "org.freedesktop.MediaPlayer", "TrackChange")) {
// read the parameters
+ // TrackChange signal returns an array of string-variant pairs
if (!dbus_message_iter_init(msg, &args)) {
- //fprintf(stderr, "Message has no arguments!\n");
- return 0;
- }
- if (DBUS_TYPE_INT32 != dbus_message_iter_get_arg_type(&args)) {
- //fprintf(stderr, "Argument is not INT32!\n");
- return 0;
- }
- else
- dbus_message_iter_get_basic(&args, &value);
- //printf("\nGot Reply: %d", value);
-
- // free message
- dbus_message_unref(msg);
-
- return value;
+ // No parameter !
+ //fprintf(stderr, "Message Has No Parameters\n");
+ return 0;
+ } else if (DBUS_TYPE_ARRAY != dbus_message_iter_get_arg_type(&args)) {
+ // Argument is not array
+ //fprintf(stderr, "Argument is not array!\n");
+ return 0;
+ } else
+ read_MetaData();
+ //printf("Got Signal\n");
+ }
+ // free message
+ dbus_message_unref(msg);
+ return 1;
+}
+
+static unsigned long int call_PositionGet(char *target)
+{
+ unsigned long int value = 0;
+
+ // create a new method call and check for errors
+ msg = dbus_message_new_method_call(target, //target for the method call e.g "org.kde.amarok"
+ "/Player", // object to call on
+ "org.freedesktop.MediaPlayer", // interface to call on
+ "PositionGet"); // method name
+ if (NULL == msg) {
+ //fprintf(stderr, "Message Null\n");
+ return 0;
+ }
+ // send message and get a handle for a reply
+ if (!dbus_connection_send_with_reply(conn, msg, &pending, -1)) { // -1 is default timeout
+ //fprintf(stderr, "Out Of Memory!\n");
+ return 0;
+ }
+ if (NULL == pending) {
+ //fprintf(stderr, "Pending Call Null\n");
+ return 0;
+ }
+ dbus_connection_flush(conn);
+
+ //printf("Request Sent\n");
+
+ // free message
+ dbus_message_unref(msg);
+
+ // block until we recieve a reply
+ dbus_pending_call_block(pending);
+
+ // get the reply message
+ msg = dbus_pending_call_steal_reply(pending);
+ if (NULL == msg) {
+ //fprintf(stderr, "Reply Null\n");
+ return 0;
+ }
+ // free the pending message handle
+ dbus_pending_call_unref(pending);
+
+ // read the parameters
+ if (!dbus_message_iter_init(msg, &args)) {
+ //fprintf(stderr, "Message has no arguments!\n");
+ return 0;
+ }
+ if (DBUS_TYPE_INT32 != dbus_message_iter_get_arg_type(&args)) {
+ //fprintf(stderr, "Argument is not INT32!\n");
+ return 0;
+ } else
+ dbus_message_iter_get_basic(&args, &value);
+ //printf("\nGot Reply: %d", value);
+
+ // free message
+ dbus_message_unref(msg);
+
+ return value;
}
static void signal_TrackChange(RESULT * result, RESULT * arg1)
{
- char *str_tmp;
- /*
- if (listen_TrackChange() < 0) {
- SetResult(&result, R_STRING, "");
- return;
- }
- */
- listen_TrackChange();
- str_tmp = hash_get(&DBUS, R2S(arg1), NULL);
- if (str_tmp == NULL)
- str_tmp = "";
-
- SetResult(&result, R_STRING, str_tmp);
+ char *str_tmp;
+ /*
+ if (listen_TrackChange() < 0) {
+ SetResult(&result, R_STRING, "");
+ return;
+ }
+ */
+ listen_TrackChange();
+ str_tmp = hash_get(&DBUS, R2S(arg1), NULL);
+ if (str_tmp == NULL)
+ str_tmp = "";
+
+ SetResult(&result, R_STRING, str_tmp);
}
static void method_PositionGet(RESULT * result, RESULT * arg1)
{
- unsigned long int mtime=0;
- unsigned long int value=0;
- double ratio=0;
- char *str_tmp;
-
- value = call_PositionGet(R2S(arg1));
- //printf("\ncalled :call_PositionGet %d",value);
-
- if (value < 0)
- value=0;
-
- str_tmp = hash_get(&DBUS, "mtime", NULL);
- if (str_tmp != NULL)
- mtime = atoi(str_tmp);
- if (mtime > 0)
- ratio = (double)(((float)value / mtime)*100);
-
- //printf("\nvalue:%d mtime:%d ratio:%f",value,mtime,ratio);
- // return actual position as percentage of total length
- SetResult(&result, R_NUMBER, &ratio);
+ unsigned long int mtime = 0;
+ unsigned long int value = 0;
+ double ratio = 0;
+ char *str_tmp;
+
+ value = call_PositionGet(R2S(arg1));
+ //printf("\ncalled :call_PositionGet %d",value);
+
+ if (value < 0)
+ value = 0;
+
+ str_tmp = hash_get(&DBUS, "mtime", NULL);
+ if (str_tmp != NULL)
+ mtime = atoi(str_tmp);
+ if (mtime > 0)
+ ratio = (double) (((float) value / mtime) * 100);
+
+ //printf("\nvalue:%d mtime:%d ratio:%f",value,mtime,ratio);
+ // return actual position as percentage of total length
+ SetResult(&result, R_NUMBER, &ratio);
}
/* plugin initialization */
/* MUST NOT be declared 'static'! */
int plugin_init_mpris_dbus(void)
{
- hash_create(&DBUS);
-
- int ret;
+ hash_create(&DBUS);
- //printf("Listening for signals\n");
+ int ret;
+
+ //printf("Listening for signals\n");
+
+ // initialise the errors
+ dbus_error_init(&err);
+
+ // connect to the bus and check for errors
+ conn = dbus_bus_get(DBUS_BUS_SESSION, &err);
+ /*
+ if (dbus_error_is_set(&err)) {
+ fprintf(stderr, "Connection Error (%s)\n", err.message);
+ dbus_error_free(&err);
+ }
+ */
+ if (NULL == conn)
+ return 0;
+
+ // request our name on the bus and check for errors
+ ret = dbus_bus_request_name(conn, "org.lcd4linux.mpris_dbus", DBUS_NAME_FLAG_REPLACE_EXISTING, &err);
+ /*
+ if (dbus_error_is_set(&err)) {
+ fprintf(stderr, "Name Error (%s)\n", err.message);
+ dbus_error_free(&err);
+ }
+ */
+ if (DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER != ret)
+ return 0;
+
+ // add a rule for which messages we want to see
+ dbus_bus_add_match(conn, "type='signal',interface='org.freedesktop.MediaPlayer'", &err); // see signals from the given interface
+ dbus_connection_flush(conn);
+ /*
+ if (dbus_error_is_set(&err)) {
+ fprintf(stderr, "Match Error (%s)\n", err.message);
+ return 0;
+ }
+ */
+ //printf("Match rule sent\n");
- // initialise the errors
- dbus_error_init(&err);
- // connect to the bus and check for errors
- conn = dbus_bus_get(DBUS_BUS_SESSION, &err);
- /*
- if (dbus_error_is_set(&err)) {
- fprintf(stderr, "Connection Error (%s)\n", err.message);
- dbus_error_free(&err);
- }
- */
- if (NULL == conn)
- return 0;
-
- // request our name on the bus and check for errors
- ret = dbus_bus_request_name(conn, "org.lcd4linux.mpris_dbus", DBUS_NAME_FLAG_REPLACE_EXISTING , &err);
- /*
- if (dbus_error_is_set(&err)) {
- fprintf(stderr, "Name Error (%s)\n", err.message);
- dbus_error_free(&err);
- }
- */
- if (DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER != ret)
- return 0;
-
- // add a rule for which messages we want to see
- dbus_bus_add_match(conn, "type='signal',interface='org.freedesktop.MediaPlayer'", &err); // see signals from the given interface
- dbus_connection_flush(conn);
- /*
- if (dbus_error_is_set(&err)) {
- fprintf(stderr, "Match Error (%s)\n", err.message);
- return 0;
- }
- */
- //printf("Match rule sent\n");
-
-
/* register all our cool functions */
/* the second parameter is the number of arguments */
/* -1 stands for variable argument list */
- AddFunction("mpris_dbus::signal_TrackChange", 1, signal_TrackChange);
- AddFunction("mpris_dbus::method_PositionGet", 1, method_PositionGet);
+ AddFunction("mpris_dbus::signal_TrackChange", 1, signal_TrackChange);
+ AddFunction("mpris_dbus::method_PositionGet", 1, method_PositionGet);
return 0;
}
{
/* free any allocated memory */
/* close filedescriptors */
- hash_destroy(&DBUS);
-
- if (NULL != msg)
- dbus_message_unref(msg);
- dbus_error_free(&err);
+ hash_destroy(&DBUS);
+
+ if (NULL != msg)
+ dbus_message_unref(msg);
+ dbus_error_free(&err);
}
projects / lcd4linux.git / commitdiff