LADI
/
ladish
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

daemon: studio graph clients for rooms

This commit is contained in:
Nedko Arnaudov 2010-03-31 01:50:01 +03:00
parent e082320f58
commit 7c81ae351d
3 changed files with 157 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

88
daemon/room.c
View File

@ -27,6 +27,7 @@
#include "room.h"
#include "../dbus_constants.h"
#include "graph_dict.h"
#include "../lib/wkports.h"
struct ladish_room
{
@ -195,6 +196,93 @@ ladish_graph_handle ladish_room_get_graph(ladish_room_handle room_handle)
return room_ptr->graph;
}
struct ladish_room_iterate_link_ports_context
{
void * context;
bool
(* callback)(
void * context,
ladish_port_handle port_handle,
const char * port_name,
uint32_t port_type,
uint32_t port_flags);
};
#define context_ptr ((struct ladish_room_iterate_link_ports_context *)context)
static
bool
ladish_room_iterate_link_ports_client_callback(
void * context,
ladish_client_handle client_handle,
const char * client_name,
void ** client_iteration_context_ptr_ptr)
{
uuid_t uuid;
ladish_client_get_uuid(client_handle, uuid);
if (uuid_compare(uuid, ladish_wkclient_capture) == 0 ||
uuid_compare(uuid, ladish_wkclient_playback) == 0)
{
*client_iteration_context_ptr_ptr = (void *)1;
}
else
{
*client_iteration_context_ptr_ptr = (void *)0;
}
return true;
}
static
bool
ladish_room_iterate_link_ports_port_callback(
void * context,
void * client_iteration_context_ptr,
ladish_client_handle client_handle,
const char * client_name,
ladish_port_handle port_handle,
const char * port_name,
uint32_t port_type,
uint32_t port_flags)
{
if (client_iteration_context_ptr == (void *)0)
{
/* port of non-link client */
return true;
}
return context_ptr->callback(context_ptr->context, port_handle, port_name, port_type, port_flags);
}
#undef context_ptr
bool
ladish_room_iterate_link_ports(
ladish_room_handle room_handle,
void * callback_context,
bool
(* callback)(
void * context,
ladish_port_handle port_handle,
const char * port_name,
uint32_t port_type,
uint32_t port_flags))
{
struct ladish_room_iterate_link_ports_context context;
context.context = callback_context;
context.callback = callback;
return ladish_graph_iterate_nodes(
room_ptr->graph,
&context,
ladish_room_iterate_link_ports_client_callback,
ladish_room_iterate_link_ports_port_callback,
NULL);
}
#undef room_ptr
ladish_room_handle ladish_room_from_list_node(struct list_head * node_ptr)

12
daemon/room.h
View File

@ -53,4 +53,16 @@ bool ladish_room_get_template_uuid(ladish_room_handle room_handle, uuid_t uuid_p
void ladish_room_get_uuid(ladish_room_handle room_handle, uuid_t uuid_ptr);
ladish_graph_handle ladish_room_get_graph(ladish_room_handle room_handle);
bool
ladish_room_iterate_link_ports(
ladish_room_handle room_handle,
void * callback_context,
bool
(* callback)(
void * context,
ladish_port_handle port_handle,
const char * port_name,
uint32_t port_type,
uint32_t port_flags));
#endif /* #ifndef ROOM_H__9A1CF253_0A17_402A_BDF8_9BD72B467118__INCLUDED */

61
daemon/studio.c
View File

@ -804,12 +804,27 @@ static void ladish_studio_is_started(struct dbus_method_call * call_ptr)
method_return_new_single(call_ptr, DBUS_TYPE_BOOLEAN, &started);
}
static
bool
add_room_ports(
void * context,
ladish_port_handle port_handle,
const char * port_name,
uint32_t port_type,
uint32_t port_flags)
{
//log_info("Studio room port \"%s\"", port_name);
return ladish_graph_add_port(g_studio.studio_graph, context, port_handle, port_name, port_type, port_flags, false);
}
static void ladish_studio_create_room(struct dbus_method_call * call_ptr)
{
const char * room_name;
const char * template_name;
ladish_room_handle room;
char room_dbus_name[1024];
ladish_client_handle room_client;
uuid_t room_uuid;
dbus_error_init(&g_dbus_error);
@ -817,7 +832,7 @@ static void ladish_studio_create_room(struct dbus_method_call * call_ptr)
{
lash_dbus_error(call_ptr, LASH_DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\": %s", call_ptr->method_name, g_dbus_error.message);
dbus_error_free(&g_dbus_error);
return;
goto fail;
}
log_info("Request to create new studio room \"%s\" from template \"%s\".", room_name, template_name);
@ -826,7 +841,7 @@ static void ladish_studio_create_room(struct dbus_method_call * call_ptr)
if (room == NULL)
{
lash_dbus_error(call_ptr, LASH_DBUS_ERROR_INVALID_ARGS, "Unknown room template \"%s\"", template_name);
return;
goto fail;
}
g_studio.room_count++;
@ -836,8 +851,27 @@ static void ladish_studio_create_room(struct dbus_method_call * call_ptr)
if (!ladish_room_create(NULL, room_name, room, room_dbus_name, &room))
{
lash_dbus_error(call_ptr, LASH_DBUS_ERROR_GENERIC, "ladish_room_create() failed.");
g_studio.room_count--;
return;
goto fail_decrement_room_count;
}
ladish_room_get_uuid(room, room_uuid);
if (!ladish_client_create(room_uuid, &room_client))
{
lash_dbus_error(call_ptr, LASH_DBUS_ERROR_GENERIC, "ladish_client_create() failed.");
goto fail_destroy_room;
}
if (!ladish_graph_add_client(g_studio.studio_graph, room_client, room_name, false))
{
lash_dbus_error(call_ptr, LASH_DBUS_ERROR_GENERIC, "ladish_graph_add_client() failed to add room client to studio graph.");
goto fail_destroy_room_client;
}
if (!ladish_room_iterate_link_ports(room, room_client, add_room_ports))
{
lash_dbus_error(call_ptr, LASH_DBUS_ERROR_GENERIC, "Creation of studio room link ports failed.");
goto fail_remove_room_client;
}
list_add_tail(ladish_room_get_list_node(room), &g_studio.rooms);
@ -845,6 +879,18 @@ static void ladish_studio_create_room(struct dbus_method_call * call_ptr)
emit_room_appeared(room);
method_return_new_void(call_ptr);
return;
fail_remove_room_client:
ladish_graph_remove_client(g_studio.studio_graph, room_client, false);
fail_destroy_room_client:
ladish_client_destroy(room_client);
fail_destroy_room:
ladish_room_destroy(room);
fail_decrement_room_count:
g_studio.room_count--;
fail:
return;
}
static void ladish_studio_get_room_list(struct dbus_method_call * call_ptr)
@ -901,6 +947,7 @@ static void ladish_studio_delete_room(struct dbus_method_call * call_ptr)
const char * name;
struct list_head * node_ptr;
ladish_room_handle room;
ladish_client_handle room_client;
dbus_error_init(&g_dbus_error);
@ -921,6 +968,12 @@ static void ladish_studio_delete_room(struct dbus_method_call * call_ptr)
list_del(node_ptr);
g_studio.room_count--;
emit_room_disappeared(room);
room_client = ladish_graph_find_client_by_name(g_studio.studio_graph, ladish_room_get_name(room));
ASSERT(room_client != NULL);
ladish_graph_remove_client(g_studio.studio_graph, room_client, false);
ladish_client_destroy(room_client);
ladish_room_destroy(room);
method_return_new_void(call_ptr);
return;