Blame
Date:
Sat Jun 11 07:57:14 2022 UTC
Message:
skip every non-regular file not only directories... I guess we can't do much even with sockets, fifos or character devices. (symbolic links are still supported since we follow them)
001
2022-02-16
op
/*
002
2022-02-16
op
* Copyright (c) 2022 Omar Polo <op@openbsd.org>
003
2022-02-16
op
*
004
2022-02-16
op
* Permission to use, copy, modify, and distribute this software for any
005
2022-02-16
op
* purpose with or without fee is hereby granted, provided that the above
006
2022-02-16
op
* copyright notice and this permission notice appear in all copies.
007
2022-02-16
op
*
008
2022-02-16
op
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
009
2022-02-16
op
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
010
2022-02-16
op
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
011
2022-02-16
op
* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
012
2022-02-16
op
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
013
2022-02-16
op
* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
014
2022-02-16
op
* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
015
2022-02-16
op
*/
016
2022-02-16
op
017
2022-02-16
op
#include <sys/types.h>
018
2022-02-16
op
#include <sys/queue.h>
019
2022-02-16
op
#include <sys/socket.h>
020
2022-02-24
op
#include <sys/stat.h>
021
2022-02-16
op
#include <sys/uio.h>
022
2022-02-16
op
#include <sys/wait.h>
023
2022-02-16
op
024
2022-02-16
op
#include <event.h>
025
2022-02-16
op
#include <errno.h>
026
2022-02-16
op
#include <fcntl.h>
027
2022-02-16
op
#include <limits.h>
028
2022-02-16
op
#include <signal.h>
029
2022-02-16
op
#include <stdio.h>
030
2022-02-16
op
#include <stdlib.h>
031
2022-02-16
op
#include <stdint.h>
032
2022-02-16
op
#include <string.h>
033
2022-02-16
op
#include <syslog.h>
034
2022-02-16
op
#include <unistd.h>
035
2022-02-16
op
#include <imsg.h>
036
2022-02-16
op
037
2022-02-16
op
#include "amused.h"
038
2022-02-16
op
#include "control.h"
039
2022-02-16
op
#include "log.h"
040
2022-02-16
op
#include "playlist.h"
041
2022-02-16
op
#include "xmalloc.h"
042
2022-02-16
op
043
2022-02-16
op
char *csock = NULL;
044
2022-02-16
op
int debug;
045
2022-02-16
op
int verbose;
046
2022-02-16
op
struct imsgev *iev_player;
047
2022-02-16
op
048
2022-02-16
op
const char *argv0;
049
2022-02-16
op
pid_t player_pid;
050
2022-02-16
op
struct event ev_sigint;
051
2022-02-16
op
struct event ev_sigterm;
052
2022-02-16
op
053
2022-02-16
op
enum amused_process {
054
2022-02-16
op
PROC_MAIN,
055
2022-02-16
op
PROC_PLAYER,
056
2022-02-16
op
};
057
2022-02-16
op
058
2022-02-16
op
__dead void
059
2022-02-16
op
main_shutdown(void)
060
2022-02-16
op
{
061
2022-02-16
op
pid_t pid;
062
2022-02-16
op
int status;
063
2022-02-16
op
064
2022-02-16
op
/* close pipes. */
065
2022-02-16
op
msgbuf_clear(&iev_player->ibuf.w);
066
2022-02-16
op
close(iev_player->ibuf.fd);
067
2022-02-16
op
free(iev_player);
068
2022-02-16
op
069
2022-02-16
op
log_debug("waiting for children to terminate");
070
2022-02-16
op
do {
071
2022-02-16
op
pid = wait(&status);
072
2022-02-16
op
if (pid == -1) {
073
2022-02-16
op
if (errno != EINTR && errno != ECHILD)
074
2022-02-16
op
fatal("wait");
075
2022-02-16
op
} else if (WIFSIGNALED(status))
076
2022-02-16
op
log_warnx("player terminated; signal %d",
077
2022-02-16
op
WTERMSIG(status));
078
2022-02-16
op
} while (pid != -1 || (pid == -1 && errno == EINTR));
079
2022-02-16
op
080
2022-02-16
op
log_info("terminating");
081
2022-02-16
op
exit(0);
082
2022-02-16
op
}
083
2022-02-16
op
084
2022-02-16
op
static void
085
2022-02-16
op
main_sig_handler(int sig, short event, void *arg)
086
2022-02-16
op
{
087
2022-02-16
op
/*
088
2022-02-16
op
* Normal signal handler rules don't apply because libevent
089
2022-02-16
op
* decouples for us.
090
2022-02-16
op
*/
091
2022-02-16
op
092
2022-02-16
op
switch (sig) {
093
2022-02-16
op
case SIGTERM:
094
2022-02-16
op
case SIGINT:
095
2022-02-16
op
main_shutdown();
096
2022-02-16
op
break;
097
2022-02-16
op
default:
098
2022-02-16
op
fatalx("unexpected signal %d", sig);
099
2022-02-16
op
}
100
2022-02-16
op
}
101
2022-02-16
op
102
2022-02-16
op
static void
103
2022-02-16
op
main_dispatch_player(int sig, short event, void *d)
104
2022-02-16
op
{
105
2022-02-16
op
struct imsgev *iev = d;
106
2022-02-16
op
struct imsgbuf *ibuf = &iev->ibuf;
107
2022-02-16
op
struct imsg imsg;
108
2022-02-16
op
ssize_t n;
109
2022-02-16
op
int shut = 0;
110
2022-02-16
op
111
2022-02-16
op
if (event & EV_READ) {
112
2022-02-16
op
if ((n = imsg_read(ibuf)) == -1 && errno != EAGAIN)
113
2022-02-16
op
fatal("imsg_read error");
114
2022-02-16
op
if (n == 0) /* Connection closed */
115
2022-02-16
op
shut = 1;
116
2022-02-16
op
}
117
2022-02-16
op
if (event & EV_WRITE) {
118
2022-02-16
op
if ((n = msgbuf_write(&ibuf->w)) == -1 && errno != EAGAIN)
119
2022-02-16
op
fatal("msgbuf_write");
120
2022-02-16
op
if (n == 0) /* Connection closed */
121
2022-02-16
op
shut = 1;
122
2022-02-16
op
}
123
2022-02-16
op
124
2022-02-16
op
for (;;) {
125
2022-02-16
op
if ((n = imsg_get(ibuf, &imsg)) == -1)
126
2022-02-16
op
fatal("imsg_get");
127
2022-02-16
op
if (n == 0) /* No more messages. */
128
2022-02-16
op
break;
129
2022-02-16
op
130
2022-02-16
op
switch (imsg.hdr.type) {
131
2022-02-16
op
case IMSG_ERR:
132
2022-05-10
op
log_warnx("failed to play, skipping %s", current_song);
133
2022-02-16
op
playlist_dropcurrent();
134
2022-02-22
op
/* fallthrough */
135
2022-02-16
op
case IMSG_EOF:
136
2022-02-22
op
if (repeat_one && current_song != NULL) {
137
2022-02-19
op
if (main_play_song(current_song))
138
2022-02-19
op
break;
139
2022-02-22
op
playlist_dropcurrent();
140
2022-02-22
op
}
141
2022-02-16
op
main_playlist_advance();
142
2022-02-21
op
if (play_state == STATE_PLAYING)
143
2022-02-21
op
control_notify(NULL, IMSG_CTL_NEXT);
144
2022-02-21
op
else
145
2022-02-21
op
control_notify(NULL, IMSG_CTL_STOP);
146
2022-02-16
op
break;
147
2022-02-16
op
default:
148
2022-02-16
op
log_debug("%s: error handling imsg %d", __func__,
149
2022-02-16
op
imsg.hdr.type);
150
2022-02-16
op
break;
151
2022-02-16
op
}
152
2022-02-16
op
imsg_free(&imsg);
153
2022-02-16
op
}
154
2022-02-16
op
155
2022-02-16
op
if (!shut)
156
2022-02-16
op
imsg_event_add(iev);
157
2022-02-16
op
else {
158
2022-02-16
op
/* This pipe is dead. Remove its event handler. */
159
2022-02-16
op
event_del(&iev->ev);
160
2022-02-16
op
event_loopexit(NULL);
161
2022-02-16
op
}
162
2022-02-16
op
}
163
2022-02-16
op
164
2022-02-16
op
static pid_t
165
2022-02-16
op
start_child(enum amused_process proc, int fd)
166
2022-02-16
op
{
167
2022-03-03
op
const char *argv[7];
168
2022-02-16
op
int argc = 0;
169
2022-02-16
op
pid_t pid;
170
2022-02-16
op
171
2022-03-03
op
if (fd == -1 && debug)
172
2022-03-03
op
goto exec;
173
2022-03-03
op
174
2022-02-16
op
switch (pid = fork()) {
175
2022-02-16
op
case -1:
176
2022-02-16
op
fatal("cannot fork");
177
2022-02-16
op
case 0:
178
2022-02-16
op
break;
179
2022-02-16
op
default:
180
2022-02-16
op
close(fd);
181
2022-02-16
op
return pid;
182
2022-02-16
op
}
183
2022-02-16
op
184
2022-02-16
op
if (fd != 3) {
185
2022-02-16
op
if (fd != -1 && dup2(fd, 3) == -1)
186
2022-02-16
op
fatal("cannot setup imsg fd");
187
2022-02-16
op
} else if (fcntl(F_SETFD, 0) == -1)
188
2022-02-16
op
fatal("cannot setup imsg fd");
189
2022-02-16
op
190
2022-03-03
op
exec:
191
2022-02-16
op
argv[argc++] = argv0;
192
2022-02-17
op
193
2022-02-16
op
switch (proc) {
194
2022-02-16
op
case PROC_MAIN:
195
2022-02-17
op
argv[argc++] = "-s";
196
2022-02-17
op
argv[argc++] = csock;
197
2022-03-03
op
argv[argc++] = "-Tm";
198
2022-02-16
op
break;
199
2022-02-16
op
case PROC_PLAYER:
200
2022-02-16
op
argv[argc++] = "-Tp";
201
2022-02-16
op
break;
202
2022-02-16
op
}
203
2022-02-16
op
204
2022-02-16
op
if (debug)
205
2022-02-16
op
argv[argc++] = "-d";
206
2022-02-16
op
if (verbose)
207
2022-02-16
op
argv[argc++] = "-v";
208
2022-02-16
op
argv[argc++] = NULL;
209
2022-02-16
op
210
2022-02-16
op
/* obnoxious casts */
211
2022-02-16
op
execvp(argv0, (char *const *)argv);
212
2022-02-16
op
fatal("execvp %s", argv0);
213
2022-02-16
op
}
214
2022-02-16
op
215
2022-02-16
op
/* daemon main routine */
216
2022-03-10
op
static __dead void
217
2022-02-16
op
amused_main(void)
218
2022-02-16
op
{
219
2022-02-16
op
int pipe_main2player[2];
220
2022-02-16
op
int control_fd;
221
2022-02-16
op
222
2022-02-16
op
log_init(debug, LOG_DAEMON);
223
2022-02-16
op
log_setverbose(verbose);
224
2022-02-16
op
log_procinit("main");
225
2022-02-16
op
226
2022-02-16
op
if (!debug)
227
2022-02-16
op
daemon(1, 0);
228
2022-02-16
op
229
2022-02-16
op
if (socketpair(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC | SOCK_NONBLOCK,
230
2022-02-16
op
PF_UNSPEC, pipe_main2player) == -1)
231
2022-02-16
op
fatal("socketpair");
232
2022-02-16
op
233
2022-02-16
op
player_pid = start_child(PROC_PLAYER, pipe_main2player[1]);
234
2022-02-16
op
235
2022-02-16
op
event_init();
236
2022-02-16
op
237
2022-02-16
op
signal_set(&ev_sigint, SIGINT, main_sig_handler, NULL);
238
2022-02-16
op
signal_set(&ev_sigterm, SIGTERM, main_sig_handler, NULL);
239
2022-02-16
op
240
2022-02-16
op
signal_add(&ev_sigint, NULL);
241
2022-02-16
op
signal_add(&ev_sigterm, NULL);
242
2022-02-16
op
243
2022-02-16
op
signal(SIGHUP, SIG_IGN);
244
2022-02-16
op
signal(SIGCHLD, SIG_IGN);
245
2022-02-16
op
signal(SIGPIPE, SIG_IGN);
246
2022-02-16
op
247
2022-02-16
op
iev_player = xmalloc(sizeof(*iev_player));
248
2022-02-16
op
imsg_init(&iev_player->ibuf, pipe_main2player[0]);
249
2022-02-16
op
iev_player->handler = main_dispatch_player;
250
2022-02-16
op
iev_player->events = EV_READ;
251
2022-02-16
op
event_set(&iev_player->ev, iev_player->ibuf.fd, iev_player->events,
252
2022-02-16
op
iev_player->handler, iev_player);
253
2022-02-16
op
event_add(&iev_player->ev, NULL);
254
2022-02-16
op
255
2022-02-16
op
if ((control_fd = control_init(csock)) == -1)
256
2022-02-16
op
fatal("control socket setup failed %s", csock);
257
2022-02-16
op
control_listen(control_fd);
258
2022-02-16
op
259
2022-02-16
op
if (pledge("stdio rpath unix sendfd", NULL) == -1)
260
2022-02-16
op
fatal("pledge");
261
2022-02-16
op
262
2022-02-16
op
log_info("startup");
263
2022-02-16
op
event_dispatch();
264
2022-02-16
op
main_shutdown();
265
2022-02-16
op
}
266
2022-02-16
op
267
2022-02-16
op
int
268
2022-02-16
op
main(int argc, char **argv)
269
2022-02-16
op
{
270
2022-03-03
op
int ch, proc = -1;
271
2022-02-16
op
272
2022-02-16
op
log_init(1, LOG_DAEMON); /* Log to stderr until daemonized */
273
2022-02-16
op
log_setverbose(1);
274
2022-02-16
op
275
2022-02-16
op
argv0 = argv[0];
276
2022-02-16
op
if (argv0 == NULL)
277
2022-02-16
op
argv0 = "amused";
278
2022-02-16
op
279
2022-02-19
op
while ((ch = getopt(argc, argv, "ds:T:v")) != -1) {
280
2022-02-16
op
switch (ch) {
281
2022-02-16
op
case 'd':
282
2022-02-16
op
debug = 1;
283
2022-02-16
op
break;
284
2022-02-16
op
case 's':
285
2022-02-16
op
free(csock);
286
2022-02-16
op
csock = xstrdup(optarg);
287
2022-02-16
op
break;
288
2022-02-16
op
case 'T':
289
2022-02-16
op
switch (*optarg) {
290
2022-03-03
op
case 'm':
291
2022-03-03
op
proc = PROC_MAIN;
292
2022-03-03
op
break;
293
2022-02-16
op
case 'p':
294
2022-02-16
op
proc = PROC_PLAYER;
295
2022-02-16
op
break;
296
2022-02-16
op
default:
297
2022-02-16
op
usage();
298
2022-02-16
op
}
299
2022-02-16
op
break;
300
2022-02-16
op
case 'v':
301
2022-02-16
op
verbose++;
302
2022-02-16
op
break;
303
2022-02-16
op
default:
304
2022-02-16
op
usage();
305
2022-02-16
op
}
306
2022-02-16
op
}
307
2022-02-16
op
argv += optind;
308
2022-02-16
op
argc -= optind;
309
2022-02-16
op
310
2022-03-03
op
if (proc == PROC_MAIN)
311
2022-03-03
op
amused_main();
312
2022-02-16
op
if (proc == PROC_PLAYER)
313
2022-02-16
op
exit(player(debug, verbose));
314
2022-02-16
op
315
2022-02-16
op
if (csock == NULL)
316
2022-02-16
op
xasprintf(&csock, "/tmp/amused-%d", getuid());
317
2022-02-16
op
318
2022-03-03
op
if (argc > 0)
319
2022-03-03
op
debug = 0;
320
2022-03-03
op
321
2022-03-03
op
ctl(argc, argv);
322
2022-02-16
op
}
323
2022-02-16
op
324
2022-02-16
op
void
325
2022-02-16
op
spawn_daemon(void)
326
2022-02-16
op
{
327
2022-02-16
op
start_child(PROC_MAIN, -1);
328
2022-02-16
op
}
329
2022-02-16
op
330
2022-02-16
op
void
331
2022-02-16
op
imsg_event_add(struct imsgev *iev)
332
2022-02-16
op
{
333
2022-02-16
op
iev->events = EV_READ;
334
2022-02-16
op
if (iev->ibuf.w.queued)
335
2022-02-16
op
iev->events |= EV_WRITE;
336
2022-02-16
op
337
2022-02-16
op
event_del(&iev->ev);
338
2022-02-16
op
event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev);
339
2022-02-16
op
event_add(&iev->ev, NULL);
340
2022-02-16
op
}
341
2022-02-16
op
342
2022-02-16
op
int
343
2022-02-16
op
imsg_compose_event(struct imsgev *iev, uint16_t type, uint32_t peerid,
344
2022-02-16
op
pid_t pid, int fd, const void *data, uint16_t datalen)
345
2022-02-16
op
{
346
2022-02-16
op
int ret;
347
2022-02-16
op
348
2022-02-16
op
if ((ret = imsg_compose(&iev->ibuf, type, peerid, pid, fd, data,
349
2022-02-16
op
datalen)) != -1)
350
2022-02-16
op
imsg_event_add(iev);
351
2022-02-16
op
352
2022-02-16
op
return ret;
353
2022-02-16
op
}
354
2022-02-16
op
355
2022-02-16
op
int
356
2022-05-10
op
main_send_player(uint16_t type, int fd)
357
2022-02-16
op
{
358
2022-05-10
op
return imsg_compose_event(iev_player, type, 0, 0, fd, NULL, 0);
359
2022-02-16
op
}
360
2022-02-16
op
361
2022-02-16
op
int
362
2022-05-10
op
main_play_song(const char *path)
363
2022-02-16
op
{
364
2022-02-24
op
struct stat sb;
365
2022-02-16
op
int fd;
366
2022-02-16
op
367
2022-02-16
op
if ((fd = open(path, O_RDONLY)) == -1) {
368
2022-02-16
op
log_warn("open %s", path);
369
2022-02-24
op
return 0;
370
2022-02-24
op
}
371
2022-02-24
op
372
2022-02-24
op
if (fstat(fd, &sb) == -1) {
373
2022-02-24
op
log_warn("failed to stat %s", path);
374
2022-02-24
op
close(fd);
375
2022-02-16
op
return 0;
376
2022-02-16
op
}
377
2022-02-16
op
378
2022-06-11
op
if (!S_ISREG(sb.st_mode)) {
379
2022-06-11
op
log_info("skipping non-regular file: %s", path);
380
2022-02-24
op
close(fd);
381
2022-02-24
op
return 0;
382
2022-02-24
op
}
383
2022-02-24
op
384
2022-02-16
op
play_state = STATE_PLAYING;
385
2022-05-10
op
main_send_player(IMSG_PLAY, fd);
386
2022-02-16
op
return 1;
387
2022-02-17
op
}
388
2022-02-17
op
389
2022-02-17
op
void
390
2022-02-17
op
main_playlist_jump(struct imsgev *iev, struct imsg *imsg)
391
2022-02-17
op
{
392
2022-02-17
op
size_t datalen;
393
2022-02-17
op
char arg[PATH_MAX];
394
2022-02-17
op
const char *song;
395
2022-02-17
op
396
2022-02-17
op
datalen = IMSG_DATA_SIZE(*imsg);
397
2022-02-17
op
if (datalen != sizeof(arg)) {
398
2022-02-17
op
main_senderr(iev, "wrong size");
399
2022-02-17
op
return;
400
2022-02-17
op
}
401
2022-02-17
op
402
2022-02-17
op
memcpy(arg, imsg->data, sizeof(arg));
403
2022-02-17
op
if (arg[sizeof(arg)-1] != '\0') {
404
2022-02-17
op
main_senderr(iev, "data corrupted");
405
2022-02-17
op
return;
406
2022-02-17
op
}
407
2022-02-17
op
408
2022-02-17
op
song = playlist_jump(arg);
409
2022-02-17
op
if (song == NULL) {
410
2022-02-17
op
main_senderr(iev, "not found");
411
2022-02-17
op
return;
412
2022-02-17
op
}
413
2022-02-17
op
414
2022-05-10
op
main_send_player(IMSG_STOP, -1);
415
2022-02-17
op
if (!main_play_song(song)) {
416
2022-02-17
op
main_senderr(iev, "can't play");
417
2022-02-17
op
playlist_dropcurrent();
418
2022-02-17
op
main_playlist_advance();
419
2022-02-17
op
return;
420
2022-02-17
op
}
421
2022-02-17
op
422
2022-02-17
op
main_send_status(iev);
423
2022-02-17
op
}
424
2022-02-17
op
425
2022-02-17
op
void
426
2022-02-17
op
main_playlist_resume(void)
427
2022-02-17
op
{
428
2022-02-17
op
const char *song;
429
2022-02-17
op
430
2022-02-19
op
if ((song = current_song) == NULL)
431
2022-02-17
op
song = playlist_advance();
432
2022-02-17
op
433
2022-02-17
op
for (; song != NULL; song = playlist_advance()) {
434
2022-02-17
op
if (main_play_song(song))
435
2022-02-17
op
return;
436
2022-02-17
op
437
2022-02-17
op
playlist_dropcurrent();
438
2022-02-17
op
}
439
2022-02-16
op
}
440
2022-02-16
op
441
2022-02-16
op
void
442
2022-02-16
op
main_playlist_advance(void)
443
2022-02-16
op
{
444
2022-02-16
op
const char *song;
445
2022-02-16
op
446
2022-02-16
op
for (;;) {
447
2022-02-16
op
song = playlist_advance();
448
2022-02-16
op
if (song == NULL)
449
2022-02-16
op
return;
450
2022-02-16
op
451
2022-02-16
op
if (main_play_song(song))
452
2022-02-16
op
break;
453
2022-02-16
op
454
2022-02-16
op
playlist_dropcurrent();
455
2022-02-16
op
}
456
2022-02-16
op
}
457
2022-02-16
op
458
2022-02-16
op
void
459
2022-02-17
op
main_playlist_previous(void)
460
2022-02-17
op
{
461
2022-02-17
op
const char *song;
462
2022-02-17
op
463
2022-02-17
op
for (;;) {
464
2022-02-17
op
song = playlist_previous();
465
2022-02-17
op
if (song == NULL)
466
2022-02-17
op
return;
467
2022-02-17
op
468
2022-02-17
op
if (main_play_song(song))
469
2022-02-17
op
break;
470
2022-02-17
op
471
2022-02-17
op
playlist_dropcurrent();
472
2022-02-17
op
}
473
2022-02-17
op
}
474
2022-02-17
op
475
2022-02-17
op
void
476
2022-02-16
op
main_restart_track(void)
477
2022-02-16
op
{
478
2022-06-09
op
if (current_song == NULL)
479
2022-02-16
op
return;
480
2022-02-16
op
481
2022-06-09
op
if (main_play_song(current_song))
482
2022-02-16
op
return;
483
2022-02-16
op
484
2022-02-16
op
playlist_dropcurrent();
485
2022-02-16
op
main_playlist_advance();
486
2022-02-16
op
}
487
2022-02-16
op
488
2022-02-16
op
void
489
2022-02-17
op
main_senderr(struct imsgev *iev, const char *msg)
490
2022-02-16
op
{
491
2022-02-17
op
imsg_compose_event(iev, IMSG_CTL_ERR, 0, 0, -1,
492
2022-02-17
op
msg, strlen(msg)+1);
493
2022-02-17
op
}
494
2022-02-17
op
495
2022-02-17
op
void
496
2022-02-17
op
main_enqueue(int tx, struct playlist *px, struct imsgev *iev,
497
2022-02-17
op
struct imsg *imsg)
498
2022-02-17
op
{
499
2022-02-16
op
size_t datalen;
500
2022-06-09
op
char path[PATH_MAX];
501
2022-02-16
op
const char *err = NULL;
502
2022-02-16
op
503
2022-02-16
op
datalen = IMSG_DATA_SIZE(*imsg);
504
2022-02-16
op
if (datalen != sizeof(path)) {
505
2022-02-16
op
err = "data size mismatch";
506
2022-02-16
op
goto err;
507
2022-02-16
op
}
508
2022-02-16
op
509
2022-02-16
op
memcpy(path, imsg->data, sizeof(path));
510
2022-02-16
op
if (path[datalen-1] != '\0') {
511
2022-02-16
op
err = "malformed data";
512
2022-02-16
op
goto err;
513
2022-02-16
op
}
514
2022-02-16
op
515
2022-02-18
op
if (tx)
516
2022-02-17
op
playlist_push(px, path);
517
2022-02-17
op
else
518
2022-02-17
op
playlist_enqueue(path);
519
2022-02-16
op
imsg_compose_event(iev, IMSG_CTL_ADD, 0, 0, -1, path, sizeof(path));
520
2022-02-16
op
return;
521
2022-02-16
op
err:
522
2022-03-02
op
main_senderr(iev, err);
523
2022-02-16
op
}
524
2022-02-16
op
525
2022-02-16
op
void
526
2022-02-16
op
main_send_playlist(struct imsgev *iev)
527
2022-02-16
op
{
528
2022-02-17
op
struct player_status s;
529
2022-02-16
op
size_t i;
530
2022-02-16
op
531
2022-02-16
op
for (i = 0; i < playlist.len; ++i) {
532
2022-02-17
op
memset(&s, 0, sizeof(s));
533
2022-02-17
op
strlcpy(s.path, playlist.songs[i], sizeof(s.path));
534
2022-02-17
op
s.status = play_off == i ? STATE_PLAYING : STATE_STOPPED;
535
2022-02-17
op
imsg_compose_event(iev, IMSG_CTL_SHOW, 0, 0, -1, &s,
536
2022-02-17
op
sizeof(s));
537
2022-02-16
op
}
538
2022-02-16
op
539
2022-02-16
op
imsg_compose_event(iev, IMSG_CTL_SHOW, 0, 0, -1, NULL, 0);
540
2022-02-16
op
}
541
2022-02-16
op
542
2022-02-16
op
void
543
2022-02-16
op
main_send_status(struct imsgev *iev)
544
2022-02-16
op
{
545
2022-02-16
op
struct player_status s;
546
2022-02-16
op
547
2022-02-16
op
memset(&s, 0, sizeof(s));
548
2022-02-16
op
549
2022-02-19
op
if (current_song != NULL)
550
2022-02-19
op
strlcpy(s.path, current_song, sizeof(s.path));
551
2022-02-16
op
s.status = play_state;
552
2022-02-19
op
s.rp.repeat_all = repeat_all;
553
2022-02-19
op
s.rp.repeat_one = repeat_one;
554
2022-02-16
op
555
2022-02-16
op
imsg_compose_event(iev, IMSG_CTL_STATUS, 0, 0, -1, &s, sizeof(s));
556
2022-02-16
op
}
Omar Polo