ref: 81916a6bba65225bf4ed83133ebb2081eb996dc5
dir: /zuke.c/
#include <u.h>
#include <libc.h>
#include <draw.h>
#include <event.h>
#include <keyboard.h>
#include <bio.h>
#include <thread.h>
typedef struct Player Player;
enum
{
Cstart = 1,
Cstop,
Ctoggle,
};
static struct
{
char *file;
char *name;
}*plist;
static int plen;
struct Player
{
Channel *ctl, *ev;
int pcur;
};
int mainstacksize = 32768;
static int audio;
static int pcur, pcurplaying;
static int scroll, scrollsz;
static Image *cola, *colb;
static Font *f;
static Channel *ev;
static void
redraw(Image *screen, int new)
{
Point p, sp;
int i;
sp.x = sp.y = 0;
if(new)
draw(screen, screen->r, cola, nil, ZP);
p.x = screen->r.min.x + 2;
p.y = screen->r.min.y + 2;
scrollsz = Dy(screen->r) / f->height - 1;
for(i = scroll; i < plen; i++){
if(p.y > screen->r.max.y)
break;
if(pcurplaying == i){
Point right, left;
left.y = right.y = p.y - 1;
left.x = p.x;
right.x = screen->r.max.x;
line(screen, left, right, 0, 0, 0, colb, sp);
left.y = right.y = p.y + f->height;
line(screen, left, right, 0, 0, 0, colb, sp);
}
if(pcur == i){
Rectangle sel;
sel = screen->r;
sel.min.y = p.y;
sel.max.y = p.y + f->height;
draw(screen, sel, colb, nil, ZP);
string(screen, p, cola, sp, f, plist[i].name);
}
else
string(screen, p, colb, sp, f, plist[i].name);
p.y += f->height;
}
flushimage(display, 1);
}
static void
playerthread(void *player_)
{
char *buf;
Ioproc *io;
Player *player;
ulong c;
int p[2], pid, n, noinit;
player = player_;
noinit = 0;
io = nil;
buf = nil;
next:
pipe(p);
if((pid = rfork(RFPROC|RFFDG|RFREND|RFNOTEG)) == 0){
dup(p[0], 1);
close(p[0]);
close(p[1]);
close(0);
close(2);
execl("/bin/play", "/bin/play", "-o", "/fd/1", plist[player->pcur].file, nil);
sysfatal("execl: %r");
}
if(pid < 0)
sysfatal("rfork: %r");
close(p[0]);
if(!noinit){
threadsetname("player");
sendp(player->ev, nil); /* "ready to start" */
c = recvul(player->ctl);
if(c != Cstart)
return;
io = ioproc();
buf = malloc(8192);
}
pcurplaying = player->pcur;
redraw(screen, 1);
while((n = ioread(io, p[1], buf, 8192)) > 0){
c = nbrecvul(player->ctl);
if(c == Cstop)
goto stop;
if(c == Ctoggle){
c = recvul(player->ctl);
if(c == Cstop)
goto stop;
}
if(iowrite(io, audio, buf, n) != n)
break;
}
if(n == 0){ /* end of the song, need to skip to the next one */
close(p[1]);
player->pcur++;
noinit = 1;
goto next;
}
stop:
close(p[1]);
postnote(PNGROUP, pid, "interrupt");
free(buf);
closeioproc(io);
sendp(player->ev, nil); /* "finished" */
}
static Player *
newplayer(int pcur)
{
Player *player;
player = malloc(sizeof(*player));
player->ctl = chancreate(sizeof(ulong), 0);
player->ev = chancreate(sizeof(void*), 0);
player->pcur = pcur;
proccreate(playerthread, player, mainstacksize);
recvp(player->ev); /* wait for it to become ready */
return player;
}
static void
stop(Player *player)
{
if(player == nil)
return;
sendul(player->ctl, Cstop);
recvp(player->ev); /* wait until it dies */
chanclose(player->ev);
chanclose(player->ctl);
free(player);
}
static void
start(Player *player)
{
if(player != nil)
sendul(player->ctl, Cstart);
}
static void
toggle(Player *player)
{
if(player != nil)
sendul(player->ctl, Ctoggle);
}
static void
readplist(void)
{
Biobuf b;
Binit(&b, 0, OREAD);
for(plen = 0;; plen++){
char *s[2];
int n;
s[0] = Brdstr(&b, '\n', 1);
if(s[0] == nil)
break;
plist = realloc(plist, sizeof(*plist)*(plen+1));
n = getfields(s[0], s, 2, 1, "\t");
if(n < 1)
break;
plist[plen].file = plist[plen].name = s[0];
if(n > 1)
plist[plen].name = s[1];
else if((plist[plen].name = strrchr(s[0], '/')) != nil)
plist[plen].name++;
}
}
static void
usage(void)
{
fprint(2, "usage: zuke [-b]\n");
exits("usage");
}
void
eresized(int new)
{
if(getwindow(display, Refnone) < 0)
sysfatal("can't reattach to window: %r");
redraw(screen, new);
}
void
threadmain(int argc, char **argv)
{
int inv;
Player *player;
inv = 0;
ARGBEGIN{
case 'b':
inv = 1;
break;
default:
usage();
}ARGEND
audio = open("/dev/audio", OWRITE);
if(audio < 0)
sysfatal("audio: %r");
readplist();
if(plen < 1){
fprint(2, "empty playlist\n");
sysfatal("empty");
}
if(initdraw(0, 0, "zuke") < 0)
sysfatal("initdraw failed");
f = display->defaultfont;
cola = inv ? display->black : display->white;
colb = inv ? display->white : display->black;
einit(Emouse | Ekeyboard);
srand(time(0));
pcurplaying = -1;
player = nil;
threadsetname("zuke");
redraw(screen, 1);
for(;;){
int oldpcur, key;
Event e;
oldpcur = pcur;
key = event(&e);
if(key == Emouse){
if(e.mouse.buttons > 0){
pcur = scroll + (e.mouse.xy.y - screen->r.min.y)/f->height;
if(e.mouse.buttons == 4){
stop(player);
player = newplayer(pcur);
start(player);
}
}
}
else if(key == Ekeyboard){
if(e.kbdc == Kup){
pcur--;
}else if(e.kbdc == Kpgup){
pcur -= scrollsz;
}else if(e.kbdc == Kdown){
pcur++;
}else if(e.kbdc == Kpgdown){
pcur += scrollsz;
}else if(e.kbdc == Kend){
pcur = plen-1;
}else if(e.kbdc == Khome){
pcur = 0;
}else if(e.kbdc == 0x0a){
stop(player);
player = newplayer(pcur);
start(player);
}else if(e.kbdc == 'q' || e.kbdc == Kesc){
stop(player);
break;
}else if(e.kbdc == 'o'){
pcur = pcurplaying;
}else if(e.kbdc == '>' && pcurplaying >= 0){
pcur = pcurplaying;
if(++pcur >= plen)
pcur = 0;
stop(player);
player = newplayer(pcur);
start(player);
}else if(e.kbdc == '<' && pcurplaying >= 0){
pcur = pcurplaying;
if(--pcur < 0)
pcur = plen-1;
stop(player);
player = newplayer(pcur);
start(player);
}else if(e.kbdc == 's' && player != nil){
pcur = -1;
stop(player);
player = nil;
}else if(e.kbdc == 'p'){
toggle(player);
}
}
if(pcur != oldpcur){
if(pcur < 0)
pcur = 0;
else if(pcur >= plen)
pcur = plen - 1;
if(pcur < scroll)
scroll = pcur;
else if(pcur > scroll + scrollsz)
scroll = pcur - scrollsz;
if(scroll > plen - scrollsz)
scroll = plen - scrollsz;
else if(scroll < 0)
scroll = 0;
if(pcur != oldpcur)
redraw(screen, 1);
}
}
threadexitsall(nil);
}