Merge most of elmarco/rtclock2
[platform/upstream/pulseaudio.git] / src / modules / module-default-device-restore.c
1 /***
2   This file is part of PulseAudio.
3
4   Copyright 2006-2008 Lennart Poettering
5
6   PulseAudio is free software; you can redistribute it and/or modify
7   it under the terms of the GNU Lesser General Public License as published
8   by the Free Software Foundation; either version 2.1 of the License,
9   or (at your option) any later version.
10
11   PulseAudio is distributed in the hope that it will be useful, but
12   WITHOUT ANY WARRANTY; without even the implied warranty of
13   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14   General Public License for more details.
15
16   You should have received a copy of the GNU Lesser General Public License
17   along with PulseAudio; if not, write to the Free Software
18   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
19   USA.
20 ***/
21
22 #ifdef HAVE_CONFIG_H
23 #include <config.h>
24 #endif
25
26 #include <errno.h>
27 #include <stdio.h>
28
29 #include <pulse/rtclock.h>
30 #include <pulse/timeval.h>
31 #include <pulse/util.h>
32
33 #include <pulsecore/core-util.h>
34 #include <pulsecore/module.h>
35 #include <pulsecore/log.h>
36 #include <pulsecore/namereg.h>
37 #include <pulsecore/core-error.h>
38
39 #include "module-default-device-restore-symdef.h"
40
41 PA_MODULE_AUTHOR("Lennart Poettering");
42 PA_MODULE_DESCRIPTION("Automatically restore the default sink and source");
43 PA_MODULE_VERSION(PACKAGE_VERSION);
44 PA_MODULE_LOAD_ONCE(TRUE);
45
46 #define SAVE_INTERVAL (5 * PA_USEC_PER_SEC)
47
48 struct userdata {
49     pa_core *core;
50     pa_subscription *subscription;
51     pa_time_event *time_event;
52     char *sink_filename, *source_filename;
53     pa_bool_t modified;
54 };
55
56 static void load(struct userdata *u) {
57     FILE *f;
58
59     /* We never overwrite manually configured settings */
60
61     if (u->core->default_sink)
62         pa_log_info("Manually configured default sink, not overwriting.");
63     else if ((f = fopen(u->sink_filename, "r"))) {
64         char ln[256] = "";
65         pa_sink *s;
66
67         (void) fgets(ln, sizeof(ln)-1, f);
68         pa_strip_nl(ln);
69         fclose(f);
70
71         if (!ln[0])
72             pa_log_info("No previous default sink setting, ignoring.");
73         else if ((s = pa_namereg_get(u->core, ln, PA_NAMEREG_SINK))) {
74             pa_namereg_set_default_sink(u->core, s);
75             pa_log_info("Restored default sink '%s'.", ln);
76         } else
77             pa_log_info("Saved default sink '%s' not existant, not restoring default sink setting.", ln);
78
79     } else if (errno != ENOENT)
80         pa_log("Failed to load default sink: %s", pa_cstrerror(errno));
81
82     if (u->core->default_source)
83         pa_log_info("Manually configured default source, not overwriting.");
84     else if ((f = fopen(u->source_filename, "r"))) {
85         char ln[256] = "";
86         pa_source *s;
87
88         (void) fgets(ln, sizeof(ln)-1, f);
89         pa_strip_nl(ln);
90         fclose(f);
91
92         if (!ln[0])
93             pa_log_info("No previous default source setting, ignoring.");
94         else if ((s = pa_namereg_get(u->core, ln, PA_NAMEREG_SOURCE))) {
95             pa_namereg_set_default_source(u->core, s);
96             pa_log_info("Restored default source '%s'.", ln);
97         } else
98             pa_log_info("Saved default source '%s' not existant, not restoring default source setting.", ln);
99
100     } else if (errno != ENOENT)
101             pa_log("Failed to load default sink: %s", pa_cstrerror(errno));
102 }
103
104 static void save(struct userdata *u) {
105     FILE *f;
106
107     if (!u->modified)
108         return;
109
110     if (u->sink_filename) {
111         if ((f = fopen(u->sink_filename, "w"))) {
112             pa_sink *s = pa_namereg_get_default_sink(u->core);
113             fprintf(f, "%s\n", s ? s->name : "");
114             fclose(f);
115         } else
116             pa_log("Failed to save default sink: %s", pa_cstrerror(errno));
117     }
118
119     if (u->source_filename) {
120         if ((f = fopen(u->source_filename, "w"))) {
121             pa_source *s = pa_namereg_get_default_source(u->core);
122             fprintf(f, "%s\n", s ? s->name : "");
123             fclose(f);
124         } else
125             pa_log("Failed to save default source: %s", pa_cstrerror(errno));
126     }
127
128     u->modified = FALSE;
129 }
130
131 static void time_cb(pa_mainloop_api *a, pa_time_event *e, const struct timeval *t, void *userdata) {
132     struct userdata *u = userdata;
133
134     pa_assert(u);
135     save(u);
136
137     if (u->time_event) {
138         u->core->mainloop->time_free(u->time_event);
139         u->time_event = NULL;
140     }
141 }
142
143 static void subscribe_cb(pa_core *c, pa_subscription_event_type_t t, uint32_t idx, void *userdata) {
144     struct userdata *u = userdata;
145
146     pa_assert(u);
147
148     u->modified = TRUE;
149
150     if (!u->time_event)
151         u->time_event = pa_core_rttime_new(u->core, pa_rtclock_now() + SAVE_INTERVAL, time_cb, u);
152 }
153
154 int pa__init(pa_module *m) {
155     struct userdata *u;
156
157     pa_assert(m);
158
159     m->userdata = u = pa_xnew0(struct userdata, 1);
160     u->core = m->core;
161
162     if (!(u->sink_filename = pa_state_path("default-sink", TRUE)))
163         goto fail;
164
165     if (!(u->source_filename = pa_state_path("default-source", TRUE)))
166         goto fail;
167
168     load(u);
169
170     u->subscription = pa_subscription_new(u->core, PA_SUBSCRIPTION_MASK_SERVER, subscribe_cb, u);
171
172     return 0;
173
174 fail:
175     pa__done(m);
176
177     return -1;
178 }
179
180 void pa__done(pa_module*m) {
181     struct userdata *u;
182
183     pa_assert(m);
184
185     if (!(u = m->userdata))
186         return;
187
188     save(u);
189
190     if (u->subscription)
191         pa_subscription_free(u->subscription);
192
193     if (u->time_event)
194         m->core->mainloop->time_free(u->time_event);
195
196     pa_xfree(u->sink_filename);
197     pa_xfree(u->source_filename);
198     pa_xfree(u);
199 }