summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRick Bell <richard.s.bell@intel.com>2016-09-30 18:21:45 -0700
committerGitHub <noreply@github.com>2016-09-30 18:21:45 -0700
commit1ecb8b05913df34445a98b19d5e19da9472949f6 (patch)
tree1fba6fdb8f47240242495ea4dd0f5c99357b1580
parent06ffef23dd9c4547edc36b6f02d40322458e7e2a (diff)
parent1de3325c201dc0e1132bd34ea6f952ff8acbcf80 (diff)
downloaddleyna-core-1ecb8b05913df34445a98b19d5e19da9472949f6.tar.gz
Merge pull request #49 from debarshiray/remove-queues
Remove all queues before dleyna_task_processor_t->on_quit_cb is run
-rw-r--r--libdleyna/core/task-processor.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/libdleyna/core/task-processor.c b/libdleyna/core/task-processor.c
index 6d7f5b8..89f0386 100644
--- a/libdleyna/core/task-processor.c
+++ b/libdleyna/core/task-processor.c
@@ -257,6 +257,7 @@ void dleyna_task_processor_set_quitting(dleyna_task_processor_t *processor)
g_idle_add(processor->on_quit_cb, NULL);
prv_cancel_all_queues(processor);
+ g_hash_table_remove_all(processor->task_queues);
DLEYNA_LOG_DEBUG("Exit");
}
@@ -460,6 +461,7 @@ void dleyna_task_queue_task_completed(const dleyna_task_queue_key_t *queue_id)
if (processor->quitting && !processor->running_tasks) {
g_idle_add(processor->on_quit_cb, NULL);
+ g_hash_table_remove_all(processor->task_queues);
} else if (queue->defer_remove) {
DLEYNA_LOG_DEBUG("Removing queue <%s,%s>",
queue_id->source, queue_id->sink);