Blame
Date:
Mon Jun 13 18:03:38 2022 UTC
Message:
use log_warn to report the failure of canonpath
001
2022-02-16
op
/*
002
2022-02-16
op
* Copyright (c) 2022 Omar Polo <op@openbsd.org>
003
2022-06-09
op
* Copyright (c) 2015 Theo de Raadt <deraadt@openbsd.org>
004
2022-02-16
op
*
005
2022-02-16
op
* Permission to use, copy, modify, and distribute this software for any
006
2022-02-16
op
* purpose with or without fee is hereby granted, provided that the above
007
2022-02-16
op
* copyright notice and this permission notice appear in all copies.
008
2022-02-16
op
*
009
2022-02-16
op
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
010
2022-02-16
op
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
011
2022-02-16
op
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
012
2022-02-16
op
* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
013
2022-02-16
op
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
014
2022-02-16
op
* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
015
2022-02-16
op
* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
016
2022-02-16
op
*/
017
2022-02-16
op
018
2022-02-16
op
#include <sys/types.h>
019
2022-02-16
op
#include <sys/socket.h>
020
2022-02-16
op
#include <sys/queue.h>
021
2022-02-16
op
#include <sys/uio.h>
022
2022-02-16
op
#include <sys/un.h>
023
2022-02-16
op
024
2022-02-16
op
#include <errno.h>
025
2022-02-16
op
#include <event.h>
026
2022-03-03
op
#include <fcntl.h>
027
2022-02-16
op
#include <limits.h>
028
2022-02-16
op
#include <stdio.h>
029
2022-02-16
op
#include <stdlib.h>
030
2022-02-16
op
#include <stdint.h>
031
2022-02-16
op
#include <string.h>
032
2022-02-16
op
#include <syslog.h>
033
2022-02-16
op
#include <unistd.h>
034
2022-02-16
op
#include <imsg.h>
035
2022-02-16
op
036
2022-02-16
op
#include "amused.h"
037
2022-02-16
op
#include "log.h"
038
2022-02-16
op
#include "playlist.h"
039
2022-02-16
op
#include "xmalloc.h"
040
2022-02-16
op
041
2022-06-09
op
static struct imsgbuf *ibuf;
042
2022-06-09
op
char cwd[PATH_MAX];
043
2022-02-16
op
044
2022-02-16
op
int ctl_noarg(struct parse_result *, int, char **);
045
2022-02-16
op
int ctl_add(struct parse_result *, int, char **);
046
2022-02-17
op
int ctl_show(struct parse_result *, int, char **);
047
2022-02-17
op
int ctl_load(struct parse_result *, int, char **);
048
2022-02-17
op
int ctl_jump(struct parse_result *, int, char **);
049
2022-02-19
op
int ctl_repeat(struct parse_result *, int, char **);
050
2022-05-14
op
int ctl_monitor(struct parse_result *, int, char **);
051
2022-02-16
op
052
2022-02-16
op
struct ctl_command ctl_commands[] = {
053
2022-02-16
op
{ "play", PLAY, ctl_noarg, "" },
054
2022-02-16
op
{ "pause", PAUSE, ctl_noarg, "" },
055
2022-02-16
op
{ "toggle", TOGGLE, ctl_noarg, "" },
056
2022-02-16
op
{ "stop", STOP, ctl_noarg, "" },
057
2022-02-16
op
{ "restart", RESTART, ctl_noarg, "" },
058
2022-06-09
op
{ "add", ADD, ctl_add, "files..." },
059
2022-02-16
op
{ "flush", FLUSH, ctl_noarg, "" },
060
2022-02-19
op
{ "show", SHOW, ctl_show, "[-p]" },
061
2022-02-16
op
{ "status", STATUS, ctl_noarg, "" },
062
2022-02-17
op
{ "next", NEXT, ctl_noarg, "" },
063
2022-02-17
op
{ "prev", PREV, ctl_noarg, "" },
064
2022-02-17
op
{ "load", LOAD, ctl_load, "[file]", 1 },
065
2022-02-17
op
{ "jump", JUMP, ctl_jump, "pattern" },
066
2022-02-19
op
{ "repeat", REPEAT, ctl_repeat, "one|all on|off" },
067
2022-05-14
op
{ "monitor", MONITOR, ctl_monitor, "[events]" },
068
2022-02-16
op
{ NULL },
069
2022-02-16
op
};
070
2022-02-16
op
071
2022-02-16
op
__dead void
072
2022-02-16
op
usage(void)
073
2022-02-16
op
{
074
2022-02-16
op
fprintf(stderr, "usage: %s [-dv] [-s socket]\n", getprogname());
075
2022-02-16
op
exit(1);
076
2022-02-16
op
}
077
2022-02-16
op
078
2022-02-16
op
static __dead void
079
2022-02-16
op
ctl_usage(struct ctl_command *ctl)
080
2022-02-16
op
{
081
2022-02-16
op
fprintf(stderr, "usage: %s [-v] [-s socket] %s %s\n", getprogname(),
082
2022-02-16
op
ctl->name, ctl->usage);
083
2022-02-16
op
exit(1);
084
2022-02-16
op
}
085
2022-02-16
op
086
2022-06-09
op
/* based on canonpath from kern_pledge.c */
087
2022-02-16
op
static int
088
2022-06-09
op
canonpath(const char *input, char *buf, size_t bufsize)
089
2022-06-09
op
{
090
2022-06-09
op
const char *p;
091
2022-06-09
op
char *q, path[PATH_MAX];
092
2022-06-09
op
093
2022-06-09
op
if (input[0] != '/') {
094
2022-06-09
op
if (snprintf(path, sizeof(path), "%s/%s", cwd, input)
095
2022-06-09
op
>= sizeof(path)) {
096
2022-06-09
op
errno = ENAMETOOLONG;
097
2022-06-09
op
return -1;
098
2022-06-09
op
}
099
2022-06-09
op
input = path;
100
2022-06-09
op
}
101
2022-06-09
op
102
2022-06-09
op
p = input;
103
2022-06-09
op
q = buf;
104
2022-06-09
op
while (*p && (q - buf < bufsize)) {
105
2022-06-09
op
if (p[0] == '/' && (p[1] == '/' || p[1] == '\0')) {
106
2022-06-09
op
p += 1;
107
2022-06-09
op
108
2022-06-09
op
} else if (p[0] == '/' && p[1] == '.' &&
109
2022-06-09
op
(p[2] == '/' || p[2] == '\0')) {
110
2022-06-09
op
p += 2;
111
2022-06-09
op
112
2022-06-09
op
} else if (p[0] == '/' && p[1] == '.' && p[2] == '.' &&
113
2022-06-09
op
(p[3] == '/' || p[3] == '\0')) {
114
2022-06-09
op
p += 3;
115
2022-06-09
op
if (q != buf) /* "/../" at start of buf */
116
2022-06-09
op
while (*--q != '/')
117
2022-06-09
op
continue;
118
2022-06-09
op
119
2022-06-09
op
} else {
120
2022-06-09
op
*q++ = *p++;
121
2022-06-09
op
}
122
2022-06-09
op
}
123
2022-06-09
op
if ((*p == '\0') && (q - buf < bufsize)) {
124
2022-06-09
op
*q = 0;
125
2022-06-09
op
return 0;
126
2022-06-09
op
} else {
127
2022-06-09
op
errno = ENAMETOOLONG;
128
2022-06-09
op
return -1;
129
2022-06-09
op
}
130
2022-06-09
op
}
131
2022-06-09
op
132
2022-06-09
op
static int
133
2022-02-16
op
parse(int argc, char **argv)
134
2022-02-16
op
{
135
2022-02-16
op
struct ctl_command *ctl = NULL;
136
2022-02-16
op
struct parse_result res;
137
2022-03-03
op
const char *argv0;
138
2022-02-16
op
int i, status;
139
2022-02-16
op
140
2022-02-16
op
memset(&res, 0, sizeof(res));
141
2022-02-16
op
142
2022-03-03
op
if ((argv0 = argv[0]) == NULL)
143
2022-03-03
op
argv0 = "status";
144
2022-03-03
op
145
2022-02-16
op
for (i = 0; ctl_commands[i].name != NULL; ++i) {
146
2022-03-03
op
if (strncmp(ctl_commands[i].name, argv0, strlen(argv0))
147
2022-02-16
op
== 0) {
148
2022-02-16
op
if (ctl != NULL) {
149
2022-02-16
op
fprintf(stderr,
150
2022-03-03
op
"ambiguous argument: %s\n", argv0);
151
2022-02-16
op
usage();
152
2022-02-16
op
}
153
2022-02-16
op
ctl = &ctl_commands[i];
154
2022-02-16
op
}
155
2022-02-16
op
}
156
2022-02-16
op
157
2022-02-16
op
if (ctl == NULL) {
158
2022-02-16
op
fprintf(stderr, "unknown argument: %s\n", argv[0]);
159
2022-02-16
op
usage();
160
2022-02-16
op
}
161
2022-02-16
op
162
2022-02-16
op
res.action = ctl->action;
163
2022-02-16
op
res.ctl = ctl;
164
2022-02-16
op
165
2022-02-16
op
if (!ctl->has_pledge) {
166
2022-02-16
op
/* pledge(2) default if command doesn't have its own */
167
2022-02-16
op
if (pledge("stdio", NULL) == -1)
168
2022-02-16
op
fatal("pledge");
169
2022-02-16
op
}
170
2022-02-16
op
171
2022-02-16
op
status = ctl->main(&res, argc, argv);
172
2022-02-16
op
close(ibuf->fd);
173
2022-02-16
op
free(ibuf);
174
2022-02-16
op
return status;
175
2022-02-16
op
}
176
2022-02-16
op
177
2022-02-16
op
static int
178
2022-05-28
op
load_files(struct parse_result *res, int *ret)
179
2022-02-17
op
{
180
2022-02-17
op
FILE *f;
181
2022-02-17
op
const char *file;
182
2022-02-17
op
char *line = NULL;
183
2022-06-09
op
char path[PATH_MAX];
184
2022-06-09
op
size_t linesize = 0, i = 0;
185
2022-03-02
op
ssize_t linelen, curr = -1;
186
2022-02-17
op
187
2022-02-17
op
if (res->file == NULL)
188
2022-02-17
op
f = stdin;
189
2022-02-17
op
else if ((f = fopen(res->file, "r")) == NULL) {
190
2022-02-17
op
log_warn("can't open %s", res->file);
191
2022-02-17
op
*ret = 1;
192
2022-02-17
op
return 1;
193
2022-02-17
op
}
194
2022-03-25
op
195
2022-02-17
op
while ((linelen = getline(&line, &linesize, f)) != -1) {
196
2022-02-17
op
if (linelen == 0)
197
2022-02-17
op
continue;
198
2022-02-17
op
line[linelen-1] = '\0';
199
2022-02-17
op
file = line;
200
2022-03-25
op
if (!strncmp(file, "> ", 2)) {
201
2022-02-17
op
file += 2;
202
2022-03-02
op
curr = i;
203
2022-03-25
op
} else if (!strncmp(file, " ", 2))
204
2022-02-17
op
file += 2;
205
2022-03-25
op
206
2022-06-13
op
memset(path, 0, sizeof(path));
207
2022-06-09
op
if (canonpath(file, path, sizeof(path)) == -1) {
208
2022-06-13
op
log_warn("canonpath %s", file);
209
2022-02-17
op
continue;
210
2022-02-17
op
}
211
2022-02-17
op
212
2022-03-02
op
i++;
213
2022-02-17
op
imsg_compose(ibuf, IMSG_CTL_ADD, 0, 0, -1,
214
2022-02-17
op
path, sizeof(path));
215
2022-02-17
op
}
216
2022-02-17
op
217
2022-02-17
op
free(line);
218
2022-02-17
op
if (ferror(f))
219
2022-02-17
op
fatal("getline");
220
2022-02-17
op
fclose(f);
221
2022-02-17
op
222
2022-03-02
op
if (i == 0) {
223
2022-02-17
op
*ret = 1;
224
2022-02-17
op
return 1;
225
2022-02-17
op
}
226
2022-02-17
op
227
2022-02-17
op
imsg_compose(ibuf, IMSG_CTL_COMMIT, 0, 0, -1,
228
2022-03-02
op
&curr, sizeof(curr));
229
2022-02-17
op
imsg_flush(ibuf);
230
2022-02-17
op
return 0;
231
2022-02-16
op
}
232
2022-02-16
op
233
2022-05-28
op
static const char *
234
2022-05-28
op
imsg_strerror(struct imsg *imsg)
235
2022-02-21
op
{
236
2022-05-28
op
size_t datalen;
237
2022-05-28
op
const char *msg;
238
2022-02-21
op
239
2022-05-28
op
datalen = IMSG_DATA_SIZE(*imsg);
240
2022-05-28
op
msg = imsg->data;
241
2022-05-28
op
if (datalen == 0 || msg[datalen-1] != '\0')
242
2022-05-28
op
fatalx("malformed error message");
243
2022-02-21
op
244
2022-05-28
op
return msg;
245
2022-05-28
op
}
246
2022-05-14
op
247
2022-05-28
op
static const char *
248
2022-05-28
op
imsg_name(int type)
249
2022-05-28
op
{
250
2022-02-21
op
switch (type) {
251
2022-02-21
op
case IMSG_CTL_PLAY:
252
2022-05-28
op
return "play";
253
2022-02-21
op
case IMSG_CTL_TOGGLE_PLAY:
254
2022-05-28
op
return "toggle";
255
2022-02-21
op
case IMSG_CTL_PAUSE:
256
2022-05-28
op
return "pause";
257
2022-02-21
op
case IMSG_CTL_STOP:
258
2022-05-28
op
return "stop";
259
2022-02-21
op
case IMSG_CTL_RESTART:
260
2022-05-28
op
return "restart";
261
2022-02-21
op
case IMSG_CTL_FLUSH:
262
2022-05-28
op
return "flush";
263
2022-02-21
op
case IMSG_CTL_NEXT:
264
2022-05-28
op
return "next";
265
2022-02-21
op
case IMSG_CTL_PREV:
266
2022-05-28
op
return "prev";
267
2022-02-21
op
case IMSG_CTL_JUMP:
268
2022-05-28
op
return "jump";
269
2022-02-21
op
case IMSG_CTL_REPEAT:
270
2022-05-28
op
return "repeat";
271
2022-02-21
op
case IMSG_CTL_ADD:
272
2022-05-28
op
return "add";
273
2022-02-21
op
case IMSG_CTL_COMMIT:
274
2022-05-28
op
return "load";
275
2022-02-21
op
default:
276
2022-05-28
op
return "unknown";
277
2022-02-21
op
}
278
2022-02-21
op
}
279
2022-02-21
op
280
2022-02-21
op
static int
281
2022-02-16
op
ctlaction(struct parse_result *res)
282
2022-02-16
op
{
283
2022-05-28
op
char path[PATH_MAX];
284
2022-02-16
op
struct imsg imsg;
285
2022-05-28
op
struct player_status ps;
286
2022-05-28
op
size_t datalen;
287
2022-02-16
op
ssize_t n;
288
2022-05-28
op
int i, type, ret = 0, done = 1;
289
2022-02-16
op
290
2022-02-16
op
switch (res->action) {
291
2022-02-16
op
case PLAY:
292
2022-02-16
op
imsg_compose(ibuf, IMSG_CTL_PLAY, 0, 0, -1, NULL, 0);
293
2022-02-19
op
if (verbose) {
294
2022-02-19
op
imsg_compose(ibuf, IMSG_CTL_STATUS, 0, 0, -1,
295
2022-02-19
op
NULL, 0);
296
2022-02-19
op
done = 0;
297
2022-02-19
op
}
298
2022-02-16
op
break;
299
2022-02-16
op
case PAUSE:
300
2022-02-16
op
imsg_compose(ibuf, IMSG_CTL_PAUSE, 0, 0, -1, NULL, 0);
301
2022-02-16
op
break;
302
2022-02-16
op
case TOGGLE:
303
2022-02-16
op
imsg_compose(ibuf, IMSG_CTL_TOGGLE_PLAY, 0, 0, -1, NULL, 0);
304
2022-02-19
op
if (verbose) {
305
2022-02-19
op
imsg_compose(ibuf, IMSG_CTL_STATUS, 0, 0, -1,
306
2022-02-19
op
NULL, 0);
307
2022-02-19
op
done = 0;
308
2022-02-19
op
}
309
2022-02-16
op
break;
310
2022-02-16
op
case STOP:
311
2022-02-16
op
imsg_compose(ibuf, IMSG_CTL_STOP, 0, 0, -1, NULL, 0);
312
2022-02-16
op
break;
313
2022-02-16
op
case RESTART:
314
2022-02-16
op
imsg_compose(ibuf, IMSG_CTL_RESTART, 0, 0, -1, NULL, 0);
315
2022-02-19
op
if (verbose) {
316
2022-02-19
op
imsg_compose(ibuf, IMSG_CTL_STATUS, 0, 0, -1,
317
2022-02-19
op
NULL, 0);
318
2022-02-19
op
done = 0;
319
2022-02-19
op
}
320
2022-02-16
op
break;
321
2022-02-16
op
case ADD:
322
2022-02-16
op
done = 0;
323
2022-05-29
op
for (i = 0; res->files[i] != NULL; ++i) {
324
2022-06-13
op
memset(path, 0, sizeof(path));
325
2022-06-09
op
if (canonpath(res->files[i], path, sizeof(path))
326
2022-06-09
op
== -1) {
327
2022-06-09
op
log_warn("canonpath %s", res->files[i]);
328
2022-05-28
op
continue;
329
2022-05-28
op
}
330
2022-05-28
op
331
2022-05-28
op
imsg_compose(ibuf, IMSG_CTL_ADD, 0, 0, -1,
332
2022-05-28
op
path, sizeof(path));
333
2022-05-28
op
}
334
2022-05-28
op
ret = i == 0;
335
2022-02-16
op
break;
336
2022-02-16
op
case FLUSH:
337
2022-02-16
op
imsg_compose(ibuf, IMSG_CTL_FLUSH, 0, 0, -1, NULL, 0);
338
2022-02-16
op
break;
339
2022-02-16
op
case SHOW:
340
2022-02-16
op
done = 0;
341
2022-02-16
op
imsg_compose(ibuf, IMSG_CTL_SHOW, 0, 0, -1, NULL, 0);
342
2022-02-16
op
break;
343
2022-02-16
op
case STATUS:
344
2022-02-16
op
done = 0;
345
2022-02-16
op
imsg_compose(ibuf, IMSG_CTL_STATUS, 0, 0, -1, NULL, 0);
346
2022-02-17
op
break;
347
2022-02-17
op
case NEXT:
348
2022-02-17
op
imsg_compose(ibuf, IMSG_CTL_NEXT, 0, 0, -1, NULL, 0);
349
2022-02-19
op
if (verbose) {
350
2022-02-19
op
imsg_compose(ibuf, IMSG_CTL_STATUS, 0, 0, -1,
351
2022-02-19
op
NULL, 0);
352
2022-02-19
op
done = 0;
353
2022-02-19
op
}
354
2022-02-16
op
break;
355
2022-02-17
op
case PREV:
356
2022-02-17
op
imsg_compose(ibuf, IMSG_CTL_PREV, 0, 0, -1, NULL, 0);
357
2022-02-19
op
if (verbose) {
358
2022-02-19
op
imsg_compose(ibuf, IMSG_CTL_STATUS, 0, 0, -1,
359
2022-02-19
op
NULL, 0);
360
2022-02-19
op
done = 0;
361
2022-02-19
op
}
362
2022-02-17
op
break;
363
2022-02-17
op
case LOAD:
364
2022-02-17
op
done = 0;
365
2022-02-17
op
imsg_compose(ibuf, IMSG_CTL_BEGIN, 0, 0, -1, NULL, 0);
366
2022-02-17
op
break;
367
2022-02-17
op
case JUMP:
368
2022-02-17
op
done = 0;
369
2022-05-28
op
memset(path, 0, sizeof(path));
370
2022-05-28
op
strlcpy(path, res->file, sizeof(path));
371
2022-05-28
op
imsg_compose(ibuf, IMSG_CTL_JUMP, 0, 0, -1,
372
2022-05-28
op
path, sizeof(path));
373
2022-02-17
op
break;
374
2022-02-19
op
case REPEAT:
375
2022-02-19
op
imsg_compose(ibuf, IMSG_CTL_REPEAT, 0, 0, -1,
376
2022-02-19
op
&res->rep, sizeof(res->rep));
377
2022-02-19
op
break;
378
2022-02-21
op
case MONITOR:
379
2022-02-21
op
done = 0;
380
2022-02-21
op
imsg_compose(ibuf, IMSG_CTL_MONITOR, 0, 0, -1,
381
2022-02-21
op
NULL, 0);
382
2022-02-21
op
break;
383
2022-02-16
op
case NONE:
384
2022-02-16
op
/* action not expected */
385
2022-02-16
op
fatalx("invalid action %u", res->action);
386
2022-02-16
op
break;
387
2022-02-16
op
}
388
2022-02-16
op
389
2022-02-16
op
if (ret != 0)
390
2022-02-16
op
goto end;
391
2022-02-16
op
392
2022-02-16
op
imsg_flush(ibuf);
393
2022-02-16
op
394
2022-05-28
op
i = 0;
395
2022-02-16
op
while (!done) {
396
2022-02-16
op
if ((n = imsg_read(ibuf)) == -1 && errno != EAGAIN)
397
2022-02-16
op
fatalx("imsg_read error");
398
2022-02-16
op
if (n == 0)
399
2022-02-16
op
fatalx("pipe closed");
400
2022-02-16
op
401
2022-02-16
op
while (!done) {
402
2022-02-16
op
if ((n = imsg_get(ibuf, &imsg)) == -1)
403
2022-02-16
op
fatalx("imsg_get error");
404
2022-02-16
op
if (n == 0)
405
2022-02-16
op
break;
406
2022-02-16
op
407
2022-05-28
op
if (imsg.hdr.type == IMSG_CTL_ERR) {
408
2022-05-28
op
log_warnx("%s: %s", res->ctl->name,
409
2022-05-28
op
imsg_strerror(&imsg));
410
2022-05-28
op
ret = 1;
411
2022-05-28
op
done = 1;
412
2022-05-28
op
break;
413
2022-05-28
op
}
414
2022-05-28
op
415
2022-05-28
op
datalen = IMSG_DATA_SIZE(imsg);
416
2022-05-28
op
417
2022-02-16
op
switch (res->action) {
418
2022-02-16
op
case ADD:
419
2022-05-29
op
if (res->files[i] == NULL)
420
2022-05-28
op
fatalx("received more replies than "
421
2022-05-28
op
"files enqueued.");
422
2022-05-28
op
423
2022-05-28
op
if (imsg.hdr.type == IMSG_CTL_ADD)
424
2022-05-29
op
log_debug("enqueued %s", res->files[i]);
425
2022-05-28
op
else
426
2022-05-28
op
fatalx("invalid message %d",
427
2022-05-28
op
imsg.hdr.type);
428
2022-05-28
op
i++;
429
2022-05-29
op
done = res->files[i] == NULL;
430
2022-02-16
op
break;
431
2022-02-16
op
case SHOW:
432
2022-05-28
op
if (datalen == 0) {
433
2022-05-28
op
done = 1;
434
2022-05-28
op
break;
435
2022-05-28
op
}
436
2022-05-28
op
if (datalen != sizeof(ps))
437
2022-05-28
op
fatalx("data size mismatch");
438
2022-05-28
op
memcpy(&ps, imsg.data, sizeof(ps));
439
2022-05-28
op
if (ps.path[sizeof(ps.path) - 1] != '\0')
440
2022-05-28
op
fatalx("received corrupted data");
441
2022-05-28
op
if (res->pretty) {
442
2022-05-28
op
char c = ' ';
443
2022-05-28
op
if (ps.status == STATE_PLAYING)
444
2022-05-28
op
c = '>';
445
2022-05-28
op
printf("%c ", c);
446
2022-05-28
op
}
447
2022-05-28
op
puts(ps.path);
448
2022-02-16
op
break;
449
2022-02-17
op
case PLAY:
450
2022-02-17
op
case TOGGLE:
451
2022-02-17
op
case RESTART:
452
2022-02-16
op
case STATUS:
453
2022-02-17
op
case NEXT:
454
2022-02-17
op
case PREV:
455
2022-02-17
op
case JUMP:
456
2022-05-28
op
if (imsg.hdr.type != IMSG_CTL_STATUS)
457
2022-05-28
op
fatalx("invalid message %d",
458
2022-05-28
op
imsg.hdr.type);
459
2022-05-28
op
460
2022-05-28
op
if (datalen != sizeof(ps))
461
2022-05-28
op
fatalx("data size mismatch");
462
2022-05-28
op
memcpy(&ps, imsg.data, sizeof(ps));
463
2022-05-28
op
if (ps.path[sizeof(ps.path) - 1] != '\0')
464
2022-05-28
op
fatalx("received corrupted data");
465
2022-05-28
op
466
2022-05-28
op
if (ps.status == STATE_STOPPED)
467
2022-05-28
op
printf("stopped ");
468
2022-05-28
op
else if (ps.status == STATE_PLAYING)
469
2022-05-28
op
printf("playing ");
470
2022-05-28
op
else if (ps.status == STATE_PAUSED)
471
2022-05-28
op
printf("paused ");
472
2022-05-28
op
else
473
2022-05-28
op
printf("unknown ");
474
2022-05-28
op
475
2022-05-28
op
puts(ps.path);
476
2022-05-28
op
printf("repat one %s\nrepeat all %s\n",
477
2022-05-28
op
ps.rp.repeat_one ? "on" : "off",
478
2022-05-28
op
ps.rp.repeat_all ? "on" : "off");
479
2022-05-28
op
480
2022-05-28
op
done = 1;
481
2022-02-16
op
break;
482
2022-02-17
op
case LOAD:
483
2022-05-28
op
if (imsg.hdr.type == IMSG_CTL_ADD)
484
2022-05-28
op
break;
485
2022-05-28
op
if (imsg.hdr.type == IMSG_CTL_COMMIT) {
486
2022-05-28
op
done = 1;
487
2022-05-28
op
break;
488
2022-05-28
op
}
489
2022-05-28
op
490
2022-05-28
op
if (imsg.hdr.type != IMSG_CTL_BEGIN)
491
2022-05-28
op
fatalx("invalid message %d",
492
2022-05-28
op
imsg.hdr.type);
493
2022-05-28
op
494
2022-05-28
op
load_files(res, &ret);
495
2022-02-17
op
break;
496
2022-02-21
op
case MONITOR:
497
2022-05-28
op
if (imsg.hdr.type != IMSG_CTL_MONITOR)
498
2022-05-28
op
fatalx("invalid message %d",
499
2022-05-28
op
imsg.hdr.type);
500
2022-05-28
op
501
2022-05-28
op
if (datalen != sizeof(type))
502
2022-05-28
op
fatalx("data size mismatch");
503
2022-05-28
op
504
2022-05-28
op
memcpy(&type, imsg.data, sizeof(type));
505
2022-05-28
op
if (type < 0 || type > IMSG__LAST)
506
2022-05-28
op
fatalx("received corrupted data");
507
2022-05-28
op
508
2022-05-28
op
if (!res->monitor[type])
509
2022-05-28
op
break;
510
2022-05-28
op
511
2022-05-28
op
puts(imsg_name(type));
512
2022-05-28
op
fflush(stdout);
513
2022-02-21
op
break;
514
2022-02-16
op
default:
515
2022-02-16
op
done = 1;
516
2022-02-16
op
break;
517
2022-02-16
op
}
518
2022-02-16
op
519
2022-02-16
op
imsg_free(&imsg);
520
2022-02-16
op
}
521
2022-02-16
op
}
522
2022-02-16
op
523
2022-02-16
op
end:
524
2022-02-16
op
return ret;
525
2022-02-16
op
}
526
2022-02-16
op
527
2022-02-16
op
int
528
2022-02-16
op
ctl_noarg(struct parse_result *res, int argc, char **argv)
529
2022-02-16
op
{
530
2022-03-03
op
int ch;
531
2022-03-03
op
532
2022-03-03
op
while ((ch = getopt(argc, argv, "")) != -1)
533
2022-03-03
op
ctl_usage(res->ctl);
534
2022-03-03
op
argc -= optind;
535
2022-03-03
op
argv += optind;
536
2022-03-03
op
537
2022-03-05
op
if (argc > 0)
538
2022-02-16
op
ctl_usage(res->ctl);
539
2022-03-03
op
540
2022-02-16
op
return ctlaction(res);
541
2022-02-16
op
}
542
2022-02-16
op
543
2022-02-16
op
int
544
2022-02-16
op
ctl_add(struct parse_result *res, int argc, char **argv)
545
2022-02-16
op
{
546
2022-03-03
op
int ch;
547
2022-03-03
op
548
2022-03-03
op
while ((ch = getopt(argc, argv, "")) != -1)
549
2022-02-16
op
ctl_usage(res->ctl);
550
2022-03-03
op
argc -= optind;
551
2022-03-03
op
argv += optind;
552
2022-03-03
op
553
2022-03-03
op
if (argc == 0)
554
2022-03-03
op
ctl_usage(res->ctl);
555
2022-03-03
op
res->files = argv;
556
2022-02-17
op
557
2022-02-16
op
return ctlaction(res);
558
2022-02-16
op
}
559
2022-02-17
op
560
2022-02-17
op
int
561
2022-02-17
op
ctl_show(struct parse_result *res, int argc, char **argv)
562
2022-02-17
op
{
563
2022-02-17
op
int ch;
564
2022-02-17
op
565
2022-02-17
op
while ((ch = getopt(argc, argv, "p")) != -1) {
566
2022-02-17
op
switch (ch) {
567
2022-02-17
op
case 'p':
568
2022-02-17
op
res->pretty = 1;
569
2022-02-17
op
break;
570
2022-02-17
op
default:
571
2022-02-17
op
ctl_usage(res->ctl);
572
2022-02-17
op
}
573
2022-02-17
op
}
574
2022-02-17
op
575
2022-02-17
op
return ctlaction(res);
576
2022-02-17
op
}
577
2022-02-17
op
578
2022-02-17
op
int
579
2022-02-17
op
ctl_load(struct parse_result *res, int argc, char **argv)
580
2022-02-17
op
{
581
2022-03-03
op
int ch;
582
2022-03-03
op
583
2022-03-03
op
while ((ch = getopt(argc, argv, "")) != -1)
584
2022-03-03
op
ctl_usage(res->ctl);
585
2022-03-03
op
argc -= optind;
586
2022-03-03
op
argv += optind;
587
2022-03-03
op
588
2022-03-03
op
if (argc == 0)
589
2022-02-17
op
res->file = NULL;
590
2022-03-03
op
else if (argc == 1)
591
2022-03-03
op
res->file = argv[0];
592
2022-02-17
op
else
593
2022-02-17
op
ctl_usage(res->ctl);
594
2022-02-17
op
595
2022-02-17
op
if (pledge("stdio rpath", NULL) == -1)
596
2022-02-17
op
fatal("pledge");
597
2022-02-17
op
598
2022-02-17
op
return ctlaction(res);
599
2022-02-17
op
}
600
2022-02-17
op
601
2022-02-17
op
int
602
2022-02-17
op
ctl_jump(struct parse_result *res, int argc, char **argv)
603
2022-02-17
op
{
604
2022-02-17
op
int ch;
605
2022-02-17
op
606
2022-02-17
op
while ((ch = getopt(argc, argv, "")) != -1)
607
2022-02-17
op
ctl_usage(res->ctl);
608
2022-02-17
op
argc -= optind;
609
2022-02-17
op
argv += optind;
610
2022-02-17
op
611
2022-02-17
op
if (argc != 1)
612
2022-02-17
op
ctl_usage(res->ctl);
613
2022-02-17
op
614
2022-02-17
op
res->file = argv[0];
615
2022-02-19
op
return ctlaction(res);
616
2022-02-19
op
}
617
2022-02-19
op
618
2022-02-19
op
int
619
2022-02-19
op
ctl_repeat(struct parse_result *res, int argc, char **argv)
620
2022-02-19
op
{
621
2022-02-19
op
int ch, b;
622
2022-02-19
op
623
2022-02-19
op
while ((ch = getopt(argc, argv, "")) != -1)
624
2022-02-19
op
ctl_usage(res->ctl);
625
2022-02-19
op
argc -= optind;
626
2022-02-19
op
argv += optind;
627
2022-02-19
op
628
2022-02-19
op
if (argc != 2)
629
2022-02-19
op
ctl_usage(res->ctl);
630
2022-02-19
op
631
2022-02-19
op
if (!strcmp(argv[1], "on"))
632
2022-02-19
op
b = 1;
633
2022-02-19
op
else if (!strcmp(argv[1], "off"))
634
2022-02-19
op
b = 0;
635
2022-02-19
op
else
636
2022-02-19
op
ctl_usage(res->ctl);
637
2022-02-19
op
638
2022-02-19
op
res->rep.repeat_one = -1;
639
2022-02-19
op
res->rep.repeat_all = -1;
640
2022-02-19
op
if (!strcmp(argv[0], "one"))
641
2022-02-19
op
res->rep.repeat_one = b;
642
2022-02-19
op
else if (!strcmp(argv[0], "all"))
643
2022-02-19
op
res->rep.repeat_all = b;
644
2022-02-19
op
else
645
2022-02-19
op
ctl_usage(res->ctl);
646
2022-05-14
op
647
2022-05-14
op
return ctlaction(res);
648
2022-05-14
op
}
649
2022-05-14
op
650
2022-05-14
op
int
651
2022-05-14
op
ctl_monitor(struct parse_result *res, int argc, char **argv)
652
2022-05-14
op
{
653
2022-05-14
op
int ch;
654
2022-05-14
op
const char *events;
655
2022-05-14
op
char *dup, *tmp, *tok;
656
2022-05-14
op
657
2022-05-14
op
while ((ch = getopt(argc, argv, "")) != -1)
658
2022-05-14
op
ctl_usage(res->ctl);
659
2022-05-14
op
argc -= optind;
660
2022-05-14
op
argv += optind;
661
2022-05-14
op
662
2022-05-14
op
if (argc > 1)
663
2022-05-14
op
ctl_usage(res->ctl);
664
2022-05-14
op
665
2022-05-14
op
if (argc == 1)
666
2022-05-14
op
events = *argv;
667
2022-05-14
op
else
668
2022-05-14
op
events = "play,toggle,pause,stop,restart,flush,next,prev,"
669
2022-05-14
op
"jump,repeat,add,load";
670
2022-02-19
op
671
2022-05-14
op
tmp = dup = xstrdup(events);
672
2022-05-14
op
while ((tok = strsep(&tmp, ",")) != NULL) {
673
2022-05-14
op
if (*tok == '\0')
674
2022-05-14
op
continue;
675
2022-05-14
op
676
2022-05-14
op
if (!strcmp(tok, "play"))
677
2022-05-14
op
res->monitor[IMSG_CTL_PLAY] = 1;
678
2022-05-14
op
else if (!strcmp(tok, "toggle"))
679
2022-05-14
op
res->monitor[IMSG_CTL_TOGGLE_PLAY] = 1;
680
2022-05-14
op
else if (!strcmp(tok, "pause"))
681
2022-05-14
op
res->monitor[IMSG_CTL_PAUSE] = 1;
682
2022-05-14
op
else if (!strcmp(tok, "stop"))
683
2022-05-14
op
res->monitor[IMSG_CTL_STOP] = 1;
684
2022-05-14
op
else if (!strcmp(tok, "restart"))
685
2022-05-14
op
res->monitor[IMSG_CTL_RESTART] = 1;
686
2022-05-14
op
else if (!strcmp(tok, "flush"))
687
2022-05-14
op
res->monitor[IMSG_CTL_FLUSH] = 1;
688
2022-05-14
op
else if (!strcmp(tok, "next"))
689
2022-05-14
op
res->monitor[IMSG_CTL_NEXT] = 1;
690
2022-05-14
op
else if (!strcmp(tok, "prev"))
691
2022-05-14
op
res->monitor[IMSG_CTL_PREV] = 1;
692
2022-05-14
op
else if (!strcmp(tok, "jump"))
693
2022-05-14
op
res->monitor[IMSG_CTL_JUMP] = 1;
694
2022-05-14
op
else if (!strcmp(tok, "repeat"))
695
2022-05-14
op
res->monitor[IMSG_CTL_REPEAT] = 1;
696
2022-05-14
op
else if (!strcmp(tok, "add"))
697
2022-05-14
op
res->monitor[IMSG_CTL_ADD] = 1;
698
2022-05-14
op
else if (!strcmp(tok, "load"))
699
2022-05-14
op
res->monitor[IMSG_CTL_COMMIT] = 1;
700
2022-05-14
op
else
701
2022-05-14
op
fatalx("unknown event \"%s\"", tok);
702
2022-05-14
op
}
703
2022-05-14
op
704
2022-05-14
op
free(dup);
705
2022-02-17
op
return ctlaction(res);
706
2022-02-17
op
}
707
2022-02-17
op
708
2022-02-16
op
static int
709
2022-03-03
op
ctl_get_lock(const char *lockfile)
710
2022-02-16
op
{
711
2022-03-03
op
int lockfd;
712
2022-02-16
op
713
2022-03-03
op
if ((lockfd = open(lockfile, O_WRONLY|O_CREAT, 0600)) == -1) {
714
2022-03-03
op
log_debug("open failed: %s", strerror(errno));
715
2022-03-03
op
return -1;
716
2022-03-03
op
}
717
2022-02-16
op
718
2022-03-03
op
if (flock(lockfd, LOCK_EX|LOCK_NB) == -1) {
719
2022-03-03
op
log_debug("flock failed: %s", strerror(errno));
720
2022-03-03
op
if (errno != EAGAIN)
721
2022-03-03
op
return -1;
722
2022-03-03
op
while (flock(lockfd, LOCK_EX) == -1 && errno == EINTR)
723
2022-03-03
op
/* nop */;
724
2022-03-03
op
close(lockfd);
725
2022-03-03
op
return -2;
726
2022-03-03
op
}
727
2022-03-03
op
log_debug("flock succeeded");
728
2022-03-03
op
729
2022-03-03
op
return lockfd;
730
2022-03-03
op
}
731
2022-03-03
op
732
2022-03-03
op
static int
733
2022-03-03
op
ctl_connect(void)
734
2022-03-03
op
{
735
2022-03-03
op
struct timespec ts = { 0, 50000000 }; /* 0.05 seconds */
736
2022-03-03
op
struct sockaddr_un sa;
737
2022-03-03
op
size_t size;
738
2022-03-03
op
int fd, lockfd = -1, locked = 0, spawned = 0;
739
2022-03-03
op
char *lockfile = NULL;
740
2022-03-03
op
741
2022-03-03
op
memset(&sa, 0, sizeof(sa));
742
2022-03-03
op
sa.sun_family = AF_UNIX;
743
2022-03-03
op
size = strlcpy(sa.sun_path, csock, sizeof(sa.sun_path));
744
2022-03-03
op
if (size >= sizeof(sa.sun_path)) {
745
2022-03-03
op
errno = ENAMETOOLONG;
746
2022-02-16
op
return -1;
747
2022-02-16
op
}
748
2022-02-16
op
749
2022-03-03
op
retry:
750
2022-03-03
op
if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1)
751
2022-03-03
op
return -1;
752
2022-03-03
op
753
2022-03-03
op
if (connect(fd, (struct sockaddr *)&sa, sizeof(sa)) == -1) {
754
2022-03-03
op
log_debug("connection failed: %s", strerror(errno));
755
2022-03-03
op
if (errno != ECONNREFUSED && errno != ENOENT)
756
2022-03-03
op
goto failed;
757
2022-03-03
op
close(fd);
758
2022-03-03
op
759
2022-03-03
op
if (!locked) {
760
2022-03-03
op
xasprintf(&lockfile, "%s.lock", csock);
761
2022-03-03
op
if ((lockfd = ctl_get_lock(lockfile)) < 0) {
762
2022-03-03
op
log_debug("didn't get the lock (%d)", lockfd);
763
2022-03-03
op
764
2022-03-03
op
free(lockfile);
765
2022-03-03
op
lockfile = NULL;
766
2022-03-03
op
767
2022-03-03
op
if (lockfd == -1)
768
2022-03-03
op
goto retry;
769
2022-03-03
op
}
770
2022-03-03
op
771
2022-03-03
op
/*
772
2022-03-03
op
* Always retry at least once, even if we got
773
2022-03-03
op
* the lock, because another client could have
774
2022-03-03
op
* taken the lock, started the server and released
775
2022-03-03
op
* the lock between our connect() and flock()
776
2022-03-03
op
*/
777
2022-03-03
op
locked = 1;
778
2022-03-03
op
goto retry;
779
2022-03-03
op
}
780
2022-03-03
op
781
2022-03-03
op
if (!spawned) {
782
2022-03-03
op
log_debug("spawning the daemon");
783
2022-03-03
op
spawn_daemon();
784
2022-03-03
op
spawned = 1;
785
2022-03-03
op
}
786
2022-03-03
op
787
2022-03-03
op
nanosleep(&ts, NULL);
788
2022-03-03
op
goto retry;
789
2022-03-03
op
}
790
2022-03-03
op
791
2022-03-03
op
if (locked && lockfd >= 0) {
792
2022-03-03
op
unlink(lockfile);
793
2022-03-03
op
free(lockfile);
794
2022-03-03
op
close(lockfd);
795
2022-03-03
op
}
796
2022-03-03
op
return fd;
797
2022-03-03
op
798
2022-03-03
op
failed:
799
2022-03-03
op
if (locked) {
800
2022-03-03
op
free(lockfile);
801
2022-03-03
op
close(lockfd);
802
2022-03-03
op
}
803
2022-03-03
op
close(fd);
804
2022-03-03
op
return -1;
805
2022-02-16
op
}
806
2022-02-16
op
807
2022-02-16
op
__dead void
808
2022-02-16
op
ctl(int argc, char **argv)
809
2022-02-16
op
{
810
2022-03-03
op
int ctl_sock;
811
2022-02-16
op
812
2022-02-16
op
log_init(1, LOG_DAEMON);
813
2022-02-16
op
log_setverbose(verbose);
814
2022-02-16
op
815
2022-06-09
op
if (getcwd(cwd, sizeof(cwd)) == NULL)
816
2022-06-09
op
fatal("getcwd");
817
2022-06-09
op
818
2022-03-03
op
if ((ctl_sock = ctl_connect()) == -1)
819
2022-03-03
op
fatal("can't connect");
820
2022-02-16
op
821
2022-02-16
op
if (ctl_sock == -1)
822
2022-02-16
op
fatalx("failed to connect to the daemon");
823
2022-02-16
op
824
2022-02-16
op
ibuf = xmalloc(sizeof(*ibuf));
825
2022-02-16
op
imsg_init(ibuf, ctl_sock);
826
2022-02-16
op
827
2022-02-16
op
optreset = 1;
828
2022-02-16
op
optind = 1;
829
2022-02-16
op
830
2022-02-16
op
exit(parse(argc, argv));
831
2022-02-16
op
}
Omar Polo