ref: 86f2bdceaa324b0d6207593e439d8acd7456945f
parent: 0dd4900441c6f226dbfa00b18018b0178e9ef05a
author: kvik <kvik@a-b.xyz>
date: Tue Sep 15 05:05:35 EDT 2020
mq: implement 'most-recent' stream replay mode
--- a/man/4/mq
+++ b/man/4/mq
@@ -165,7 +165,7 @@
.B data message | coalesce
Sets the data mode.
.TP
-.B replay no | last | all
+.B replay off | last | all
Sets the queue replay mode.
.TP
.B depth <size> | <count>
--- a/src/mq.c
+++ b/src/mq.c
@@ -18,7 +18,7 @@
Stream *order;
/* configuration */
- int replay;
+ enum {Replayoff, Replaylast, Replayall} replay;};
struct Stream {@@ -85,7 +85,7 @@
mq = emalloc(sizeof(Mq));
mq->group = (Stream*)listalloc();
mq->order = (Stream*)streamalloc(mq);
- mq->replay = 0;
+ mq->replay = Replayoff;
ctl = order = nil;
if((d = createfile(parent, name, uid, perm, mq)) == nil)
@@ -266,7 +266,7 @@
Cmddebug, Cmddebug9p,
};
Cmdtab mqcmd[] = {- /* replay on|off*/
+ /* replay off|last|all */
{Cmdreplay, "replay", 2},/* debug on|off */
@@ -293,13 +293,16 @@
}
switch(t->index){ case Cmdreplay: {- if(strncmp(cmd->f[1], "on", 2) == 0)
- mq->replay = 1;
- else
if(strncmp(cmd->f[1], "off", 3) == 0)
- mq->replay = 0;
+ mq->replay = Replayoff;
else
- e = "usage: replay on|off";
+ if(strncmp(cmd->f[1], "last", 4) == 0)
+ mq->replay = Replaylast;
+ else
+ if(strncmp(cmd->f[1], "all", 3) == 0)
+ mq->replay = Replayall;
+ else
+ e = "usage: replay off|last|all";
break;
}
case Cmddebug: {@@ -367,10 +370,14 @@
Client *c;
c = r->fid->aux = emalloc(sizeof(Client));
- if(s->mq->replay)
- c->cursor = (Write*)s->queue;
- else
- c->cursor = (Write*)s->queue->tail;
+ switch(s->mq->replay){+ case Replayoff:
+ c->cursor = (Write*)s->queue->tail; break;
+ case Replaylast:
+ c->cursor = (Write*)s->queue->tail->tail; break;
+ case Replayall:
+ c->cursor = (Write*)s->queue; break;
+ }
break;
}}
respond(r, nil);