blob: 994ac016a281e1f7fc664d63f4040d89b3408e65 (
plain)
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
|
#include <assert.h>
#include "xmalloc.h"
#include "polyplib-internal.h"
#include "polyplib-operation.h"
struct pa_operation *pa_operation_new(struct pa_context *c, struct pa_stream *s) {
struct pa_operation *o;
assert(c);
o = pa_xmalloc(sizeof(struct pa_operation));
o->ref = 1;
o->context = pa_context_ref(c);
o->stream = s ? pa_stream_ref(s) : NULL;
o->state = PA_OPERATION_RUNNING;
o->userdata = NULL;
o->callback = NULL;
PA_LLIST_PREPEND(struct pa_operation, o->context->operations, o);
return pa_operation_ref(o);
}
struct pa_operation *pa_operation_ref(struct pa_operation *o) {
assert(o && o->ref >= 1);
o->ref++;
return o;
}
void pa_operation_unref(struct pa_operation *o) {
assert(o && o->ref >= 1);
if ((--(o->ref)) == 0) {
assert(!o->context);
assert(!o->stream);
free(o);
}
}
static void operation_set_state(struct pa_operation *o, enum pa_operation_state st) {
assert(o && o->ref >= 1);
if (st == o->state)
return;
if (!o->context)
return;
o->state = st;
if ((o->state == PA_OPERATION_DONE) || (o->state == PA_OPERATION_CANCELED)) {
PA_LLIST_REMOVE(struct pa_operation, o->context->operations, o);
pa_context_unref(o->context);
if (o->stream)
pa_stream_unref(o->stream);
o->context = NULL;
o->stream = NULL;
o->callback = NULL;
o->userdata = NULL;
pa_operation_unref(o);
}
}
void pa_operation_cancel(struct pa_operation *o) {
assert(o && o->ref >= 1);
operation_set_state(o, PA_OPERATION_CANCELED);
}
void pa_operation_done(struct pa_operation *o) {
assert(o && o->ref >= 1);
operation_set_state(o, PA_OPERATION_DONE);
}
enum pa_operation_state pa_operation_get_state(struct pa_operation *o) {
assert(o && o->ref >= 1);
return o->state;
}
|