1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
/* -*- Mode: C ; c-basic-offset: 2 -*- */
/*
* LADI Session Handler (ladish)
*
* Copyright (C) 2010,2011 Nedko Arnaudov <nedko@arnaudov.name>
*
**************************************************************************
* This file contains implementation of the "remove app" command
**************************************************************************
*
* LADI Session Handler is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* LADI Session Handler is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with LADI Session Handler. If not, see <http://www.gnu.org/licenses/>
* or write to the Free Software Foundation, Inc.,
* 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*/
#include <ctype.h>
#include "cmd.h"
#include "studio.h"
#include "../proxies/notify_proxy.h"
#include "virtualizer.h"
struct ladish_command_remove_app
{
struct ladish_command command; /* must be the first member */
char * opath;
uint64_t id;
};
#define cmd_ptr ((struct ladish_command_remove_app *)context)
static bool run(void * context)
{
ladish_app_supervisor_handle supervisor;
ladish_app_handle app;
const char * app_name;
uuid_t app_uuid;
ASSERT(cmd_ptr->command.state == LADISH_COMMAND_STATE_PENDING);
log_info("remove app command. opath='%s'", cmd_ptr->opath);
supervisor = ladish_studio_find_app_supervisor(cmd_ptr->opath);
if (supervisor == NULL)
{
log_error("cannot find supervisor '%s' to remove app from", cmd_ptr->opath);
ladish_notify_simple(LADISH_NOTIFY_URGENCY_HIGH, "Cannot remove app because of internal error (unknown supervisor)", NULL);
return false;
}
app = ladish_app_supervisor_find_app_by_id(supervisor, cmd_ptr->id);
if (app == NULL)
{
log_error("App with ID %"PRIu64" not found and (remove)", cmd_ptr->id);
ladish_notify_simple(LADISH_NOTIFY_URGENCY_HIGH, "Cannot remove app because it is not found", NULL);
return false;
}
app_name = ladish_app_get_name(app);
ladish_app_get_uuid(app, app_uuid);
if (ladish_app_is_running(app))
{
if (cmd_ptr->command.state == LADISH_COMMAND_STATE_PENDING)
{
log_info("App %s is not stopped as it should", app_name);
ladish_notify_simple(LADISH_NOTIFY_URGENCY_HIGH, "Cannot remove app because it is not stopped (because of internal error)", NULL);
}
return false;
}
/* remove jclient and vclient for this app */
log_info("Removing graph objects for app '%s'", app_name);
ladish_virtualizer_remove_app(ladish_studio_get_jack_graph(), app_uuid, app_name);
ladish_app_supervisor_remove_app(supervisor, app);
cmd_ptr->command.state = LADISH_COMMAND_STATE_DONE;
return true;
}
static void destructor(void * context)
{
log_info("remove_app command destructor");
free(cmd_ptr->opath);
}
#undef cmd_ptr
bool ladish_command_remove_app(void * call_ptr, struct ladish_cqueue * queue_ptr, const char * opath, uint64_t id)
{
struct ladish_command_remove_app * cmd_ptr;
char * opath_dup;
if (!ladish_command_change_app_state(call_ptr, queue_ptr, opath, id, LADISH_APP_STATE_STOPPED))
{
goto fail;
}
opath_dup = strdup(opath);
if (opath_dup == NULL)
{
cdbus_error(call_ptr, DBUS_ERROR_FAILED, "strdup('%s') failed.", opath);
goto fail_drop_stop_command;
}
cmd_ptr = ladish_command_new(sizeof(struct ladish_command_remove_app));
if (cmd_ptr == NULL)
{
cdbus_error(call_ptr, DBUS_ERROR_FAILED, "ladish_command_new() failed.");
goto fail_free_opath;
}
cmd_ptr->command.run = run;
cmd_ptr->command.destructor = destructor;
cmd_ptr->opath = opath_dup;
cmd_ptr->id = id;
if (!ladish_cqueue_add_command(queue_ptr, &cmd_ptr->command))
{
cdbus_error(call_ptr, DBUS_ERROR_FAILED, "ladish_cqueue_add_command() failed.");
goto fail_destroy_command;
}
return true;
fail_destroy_command:
free(cmd_ptr);
fail_free_opath:
free(opath_dup);
fail_drop_stop_command:
ladish_cqueue_drop_command(queue_ptr);
fail:
return false;
}
|
