#include "regimpl.h"
typedef struct RethreadQ RethreadQ;
-struct RethreadQ
-{
+struct RethreadQ {
Rethread *head;
Rethread **tail;
};
int
-rregexec(Reprog *prog, Rune *str, Resub *sem, int msize)
+rregexec(Reprog *p, Rune *str, Resub *sem, int msize)
{
RethreadQ lists[2], *clist, *nlist, *tmp;
- Rethread *t, *next, *pooltop, *avail;
- Reinst *curinst;
- Rune *rsp, *rep, endr, last;
- int match, first, gen, pri, matchpri;
+ Rethread *t, *next, *pool, *avail;
+ Reinst *ci;
+ Rune *rsp, *rep, endr, r;
+ int matchgen, gen;
+ memset(p->threads, 0, sizeof(Rethread)*p->nthr);
if(msize > NSUBEXPM)
msize = NSUBEXPM;
-
- if(prog->startinst->gen != 0) {
- for(curinst = prog->startinst; curinst < prog->startinst + prog->len; curinst++)
- curinst->gen = 0;
+ if(p->startinst->gen != 0) {
+ for(ci = p->startinst; ci < p->startinst + p->len; ci++)
+ ci->gen = 0;
}
clist = lists;
nlist->head = nil;
nlist->tail = &nlist->head;
- pooltop = prog->threads + prog->nthr;
+ pool = p->threads;
avail = nil;
+ gen = matchgen = 0;
- pri = matchpri = gen = match = 0;
rsp = str;
rep = nil;
endr = L'\0';
*sem->rep = '\0';
}
}
- last = 1;
- for(; last != L'\0'; rsp++) {
+
+ for(r = L'☺'; r != L'\0'; rsp++) {
+ r = *rsp;
gen++;
- last = *rsp;
- first = 1;
+ if(matchgen == 0) {
+ if(avail == nil) {
+ assert(pool < p->threads + p->nthr);
+ t = pool++;
+ } else {
+ t = avail;
+ avail = avail->next;
+ }
+ t->i = p->startinst;
+ if(msize > 0)
+ memset(t->sem, 0, sizeof(Resub)*msize);
+ t->next = nil;
+ t->gen = gen;
+ *clist->tail = t;
+ clist->tail = &t->next;
+ }
t = clist->head;
if(t == nil)
- goto Start;
- curinst = t->pc;
+ break;
+ ci = t->i;
Again:
- if(curinst->gen == gen)
+ if(ci->gen == gen)
goto Done;
- curinst->gen = gen;
- switch(curinst->op) {
+ ci->gen = gen;
+ switch(ci->op) {
case ORUNE:
- if(*rsp != curinst->r)
+ if(r != ci->r)
goto Done;
case OANY: /* fallthrough */
- Any:
next = t->next;
- t->pc = curinst + 1;
+ t->i = ci + 1;
t->next = nil;
*nlist->tail = t;
nlist->tail = &t->next;
- if(next == nil)
- break;
- t = next;
- curinst = t->pc;
- goto Again;
+ goto Next;
case OCLASS:
Class:
- if(*rsp < curinst->r)
+ if(r < ci->r)
goto Done;
- if(*rsp > curinst->r1) {
- curinst++;
+ if(r > ci->r1) {
+ ci++;
goto Class;
}
next = t->next;
- t->pc = curinst->a;
+ t->i = ci->a;
t->next = nil;
*nlist->tail = t;
nlist->tail = &t->next;
- if(next == nil)
- break;
- t = next;
- curinst = t->pc;
- goto Again;
+ goto Next;
case ONOTNL:
- if(*rsp != L'\n') {
- curinst++;
+ if(r != L'\n') {
+ ci++;
goto Again;
}
goto Done;
case OBOL:
if(rsp == str || rsp[-1] == L'\n') {
- curinst++;
+ ci++;
goto Again;
}
goto Done;
case OEOL:
- if(*rsp == L'\0' && rep == nil) {
- curinst++;
+ if(r == L'\n' || r == L'\0' && rep == nil) {
+ ci++;
goto Again;
}
- if(*rsp == '\n')
- goto Any;
goto Done;
case OJMP:
- curinst = curinst->a;
+ ci = ci->a;
goto Again;
case OSPLIT:
- if(avail == nil)
- next = --pooltop;
- else {
+ if(avail == nil) {
+ assert(pool < p->threads + p->nthr);
+ next = pool++;
+ } else {
next = avail;
avail = avail->next;
}
- next->pc = curinst->b;
+ next->i = ci->b;
if(msize > 0)
memcpy(next->sem, t->sem, sizeof(Resub)*msize);
- next->pri = t->pri;
next->next = t->next;
+ next->gen = t->gen;
t->next = next;
- curinst = curinst->a;
+ ci = ci->a;
goto Again;
case OSAVE:
- if(curinst->sub < msize)
- t->sem[curinst->sub].rsp = rsp;
- curinst++;
+ if(ci->sub < msize)
+ t->sem[ci->sub].rsp = rsp;
+ ci++;
goto Again;
case OUNSAVE:
- if(curinst->sub == 0) {
- /* "Highest" priority is the left-most longest. */
- if (t->pri > matchpri)
- goto Done;
- match = 1;
- matchpri = t->pri;
+ if(ci->sub == 0) {
+ matchgen = t->gen;
if(sem != nil && msize > 0) {
memcpy(sem, t->sem, sizeof(Resub)*msize);
sem->rep = rsp;
}
goto Done;
}
- if(curinst->sub < msize)
- t->sem[curinst->sub].rep = rsp;
- curinst++;
+ if(ci->sub < msize)
+ t->sem[ci->sub].rep = rsp;
+ ci++;
goto Again;
Done:
next = t->next;
t->next = avail;
avail = t;
+ Next:
if(next == nil)
break;
- t = next;
- curinst = t->pc;
- goto Again;
- }
-Start:
- /* Start again once if we haven't found anything. */
- if(first == 1 && match == 0) {
- first = 0;
- if(avail == nil)
- t = --pooltop;
- else {
- t = avail;
- avail = avail->next;
+ if(matchgen && next->gen > matchgen) {
+ *clist->tail = avail;
+ avail = next;
+ break;
}
- if(msize > 0)
- memset(t->sem, 0, sizeof(Resub)*msize);
- /* "Lower" priority thread */
- t->pri = matchpri = pri++;
- t->next = nil;
- curinst = prog->startinst;
+ t = next;
+ ci = t->i;
goto Again;
}
- /* If we have a match and no extant threads, we are done. */
- if(match == 1 && nlist->head == nil)
- break;
tmp = clist;
clist = nlist;
nlist = tmp;
}
if(rep != nil)
*rep = endr;
- return match;
+ return matchgen > 0 ? 1 : 0;
}
projects / plan9front.git / blobdiff