commit b76f85def2a3f4e85c6cce4437ace40b630dee19
Author: glenda <glenda@9front.local>
Date: Wed, 13 May 2020 09:02:24 +0000
initial commit
Diffstat:
| A | amp.c | | | 367 | +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ |
| A | mkfile | | | 9 | +++++++++ |
2 files changed, 376 insertions(+), 0 deletions(-)
diff --git a/amp.c b/amp.c
@@ -0,0 +1,367 @@
+#include <u.h>
+#include <libc.h>
+#include <draw.h>
+#include <thread.h>
+#include <mouse.h>
+#include <cursor.h>
+#include <keyboard.h>
+
+#define DHEIGHT 32
+#define ZOOMOUT 512
+
+typedef struct Fetchctl Fetchctl;
+struct Fetchctl {
+ long state;
+ Channel *c;
+ Channel *plchan;
+ Channel *pos;
+};
+
+s8int *pcm, *pp;
+long pcmlen, scroll, curpos;
+Rectangle *thumb;
+Image *Ibg, *Itrbg, *Itrfg, *Icur;
+int dwidth;
+int yieldcounter;
+long playing;
+
+void usage(void);
+void clear(void);
+void setdwidth(void);
+void drawpcm(Point, ulong);
+void drawpcmbar(Point, ulong);
+void drawcur(Point);
+void drawcurabs(void);
+void clearcurabs(void);
+void redraw(ulong);
+void loadpcm(char*);
+void mkthumb(void);
+Point getcurxy(void);
+void threadplay(void*);
+void threadfetch(void*);
+Fetchctl* initfetch(void);
+
+void
+threadmain(int argc, char **argv)
+{
+ Mousectl *mctl;
+ Keyboardctl *kctl;
+ Fetchctl *fctl;
+ Mouse mv;
+ Rune kv;
+ int rv[2];
+ long pv;
+
+ ARGBEGIN{
+ default:
+ usage();
+ break;
+ }ARGEND;
+
+ if (argc <= 0) usage();
+ if(initdraw(0, 0, "amp") < 0)
+ sysfatal("inidraw failed: %r");
+ if((mctl = initmouse(0, screen)) == nil)
+ sysfatal("initmouse failed: %r");
+ if((kctl = initkeyboard(0)) == nil)
+ sysfatal("initkeyboard failed: %r");
+ if((fctl = initfetch()) == nil)
+ sysfatal("initfetch failed: %r");
+
+ Ibg = allocimage(display, Rect(0,0,1,1), RGB24, 1, 0xBBBBBBFF);
+ Itrbg = allocimage(display, Rect(0,0,1,1), RGB24, 1, DWhite);
+ Itrfg = allocimage(display, Rect(0,0,1,1), RGB24, 1, DBlack);
+ Icur = allocimage(display, Rect(0,0,1,1), RGB24, 1, DRed);
+
+ curpos = 0;
+ playing = 0;
+
+ loadpcm(argv[0]);
+ mkthumb();
+ setdwidth();
+ clear();
+ redraw(0);
+ flushimage(display, 1);
+ Alt alts[5] = {
+ {kctl->c, &kv, CHANRCV},
+ {mctl->c, &mv, CHANRCV},
+ {mctl->resizec, rv, CHANRCV},
+ {fctl->pos, &pv, CHANRCV},
+ {0, 0, CHANEND},
+ };
+ for (;;) {
+ switch (alt(alts)) {
+ case 0: /* keyboard */
+ if (kv == 0x7f) threadexitsall(nil);
+ break;
+ case 1: /* mouse */
+ if (mv.buttons == 0) {
+ nbsend(fctl->c, &playing);
+ }
+ if (mv.buttons == 1) {
+ nbsendul(fctl->c, 0);
+ clearcurabs();
+ long mrow = (mv.xy.y - screen->r.min.y) / (DHEIGHT + 4);
+ long mx = mv.xy.x - screen->r.min.x - 4;
+ if (mx < 0) mx = 0;
+ if (mx >= dwidth) mx = dwidth - 1;
+ long newpos = (scroll + mrow) * dwidth + mx;
+ curpos = newpos;
+ if (curpos >= pcmlen / (ZOOMOUT * 4))
+ curpos = pcmlen / (ZOOMOUT * 4) - 1;
+ pp = pcm + curpos * (ZOOMOUT * 4);
+ drawcurabs();
+ flushimage(display, 1);
+ }
+ if (mv.buttons == 4) {
+ playing = (playing)? 0 : 1;
+ nbsend(fctl->c, &playing);
+ }
+ if (mv.buttons == 8) { /* scroll up */
+ if (scroll == 0) break;
+ scroll--;
+ if (scroll < 0) scroll = 0;
+ clear();
+ redraw(scroll * dwidth);
+ flushimage(display, 1);
+ }
+ if (mv.buttons == 16) { /* scroll down */
+ scroll++;
+ if (scroll > pcmlen/(4 * ZOOMOUT*dwidth))
+ scroll = pcmlen/(4 * ZOOMOUT*dwidth);
+ clear();
+ redraw(scroll * dwidth);
+ flushimage(display, 1);
+ }
+ break;
+ case 2: /* resize */
+ if(getwindow(display, Refnone) < 0)
+ sysfatal("resize failed: %r");
+ setdwidth();
+ if (scroll > pcmlen/(4 * ZOOMOUT*dwidth))
+ scroll = pcmlen/(4 * ZOOMOUT*dwidth);
+ clear();
+ redraw(scroll * dwidth);
+ flushimage(display, 1);
+ break;
+ case 3: /* position change */
+ clearcurabs();
+ curpos = pv / (4 * ZOOMOUT);
+ drawcurabs();
+ flushimage(display, 1);
+ break;
+ }
+ }
+}
+
+
+void
+threadplay(void *v)
+{
+ Channel *c;
+ s8int buf[1024];
+ int devaudio;
+ c = v;
+ devaudio = open("/dev/audio", OWRITE);
+ if (devaudio <= 0){
+ fprint(2, "can't open /dev/audio\n");
+ return;
+ }
+ for (;;) {
+ recv(c, buf);
+ write(devaudio, buf, 1024);
+ }
+}
+
+void
+threadfetch(void* v)
+{
+ long pos, len, newstate;
+ s8int buf[1024];
+ Fetchctl *fctl;
+ fctl = v;
+ for (;;) {
+ recv(fctl->c, &newstate);
+ fctl->state = newstate;
+ while (fctl->state != 0) {
+ if (nbrecv(fctl->c, &newstate) > 0) fctl->state = newstate;
+ memset(buf, 0, 1024);
+ len = (pp + 1024 < pcm + pcmlen) ? 1024 : pcm + pcmlen - pp;
+ memcpy(buf, pp, len);
+ pp += len;
+ if (pp >= pcm+pcmlen) {
+ pp = pcm;
+ fctl->state = 0;
+ playing = 0;
+ }
+ pos = pp-pcm;
+ nbsend(fctl->pos, &pos);
+ send(fctl->plchan, buf);
+ }
+ }
+}
+
+Fetchctl*
+initfetch(void)
+{
+ Fetchctl *fctl;
+ fctl = malloc(sizeof(Fetchctl));
+ fctl->state = 0;
+ fctl->plchan = chancreate(1024, 0);
+ fctl->pos = chancreate(sizeof(long), 0);
+ fctl->c = chancreate(sizeof(long), 16);
+ threadcreate(threadplay, fctl->plchan, 64 * 1024);
+ threadcreate(threadfetch, fctl, 64 * 1024);
+ return fctl;
+}
+
+void
+usage(void)
+{
+ fprint(2, "usage: %s file.pcm\n", argv0);
+ exits("usage");
+}
+
+
+void
+clear(void)
+{
+ draw(screen, screen->r, Ibg, 0, ZP);
+}
+
+
+void
+setdwidth(void)
+{
+ dwidth = screen->r.max.x - screen->r.min.x - 8;
+}
+
+
+void
+drawpcm(Point p, ulong start)
+{
+ ulong i;
+ Rectangle r;
+ i = start;
+ r.min = p;
+ r.max.x = r.min.x + dwidth;
+ r.max.y = r.min.y + DHEIGHT;
+ while (p.x < r.max.x){
+ if (i >= pcmlen/(4 * ZOOMOUT)) break;
+ if (i == curpos) drawcur(p);
+ else drawpcmbar(p, i);
+ p.x++;
+ i++;
+ }
+}
+
+
+void
+drawpcmbar(Point p, ulong i)
+{
+ Rectangle r, rr;
+ r = Rpt(p, addpt(p, Pt(1, DHEIGHT)));
+ rr = rectaddpt(thumb[i], p);
+ draw(screen, r, Itrbg, 0, ZP);
+ draw(screen, rr, Itrfg, 0, ZP);
+ yieldcounter++;
+ if (yieldcounter >= 1024) {
+ flushimage(display, 0);
+ yieldcounter = 0;
+ yield();
+ }
+}
+
+
+Point getcurxy()
+{
+ Point p;
+ p = addpt(screen->r.min, Pt(4,4));
+ p.x += curpos%dwidth;
+ p.y += (curpos/dwidth - scroll)*(DHEIGHT + 4);
+ return p;
+}
+
+
+void
+drawcur(Point p)
+{
+ draw(screen, Rpt(p, addpt(p, Pt(1, DHEIGHT))), Icur, 0, ZP);
+}
+
+
+void
+drawcurabs(void)
+{
+ if (curpos < scroll *dwidth) return;
+ drawcur(getcurxy());
+}
+
+
+void
+clearcurabs(void)
+{
+ if (curpos < scroll *dwidth) return;
+ drawpcmbar(getcurxy(), curpos);
+}
+
+
+void
+redraw(ulong d)
+{
+ Point p;
+ p = addpt(screen->r.min, Pt(4,4));
+ while (p.y < screen->r.max.y - DHEIGHT) {
+ if (d > pcmlen/(4 * ZOOMOUT)) break;
+ drawpcm(p, d);
+ d += dwidth;
+ p.y += DHEIGHT + 4;
+ }
+}
+
+
+void
+loadpcm(char *path)
+{
+ long n;
+ int fd;
+ s8int buf[1024];
+ fd = open(path, OREAD);
+ pcmlen = 0;
+ while((n = read(fd, buf, 1024)) > 0){
+ pcm = realloc(pcm, pcmlen + n);
+ memcpy(pcm + pcmlen, buf, n);
+ pcmlen += n;
+ }
+ close(fd);
+ pp = pcm;
+}
+
+
+void
+mkthumb(void)
+{
+ s8int *pp;
+ Rectangle *thmp;
+ s8int min, max;
+ ulong i;
+ pp = pcm+1;
+ thmp = thumb = realloc(thumb, sizeof(Rectangle)*pcmlen/(4*ZOOMOUT));
+ i = 0;
+ min = 0x7f;
+ max = -0x7f;
+ while (pp < pcm+pcmlen){
+ if (min > *pp) min = *pp;
+ if (max < *pp) max = *pp;
+ pp += 2;
+ if (i==(ZOOMOUT * 2)){
+ i = 0;
+ *thmp = Rect(0, min * DHEIGHT / 256 + DHEIGHT/2,
+ 1, max * DHEIGHT / 256 + DHEIGHT/2 + 1);
+ thmp++;
+ min = 0x7fff;
+ max = -0x7fff;
+ }
+ i++;
+ }
+}
diff --git a/mkfile b/mkfile
@@ -0,0 +1,9 @@
+</$objtype/mkfile
+
+TARG=amp
+
+OFILES=\
+ amp.$O\
+
+BIN=/$objtype/bin
+</sys/src/cmd/mkone
