#include "rc.h"
#include "exec.h"
#include "io.h"
#include "fns.h"
enum { Stralloc = 100, };
int pfmtnest = 0;
void
pfmt(io *f, char *fmt, ...)
{
va_list ap;
char err[ERRMAX];
va_start(ap, fmt);
pfmtnest++;
for(;*fmt;fmt++)
if(*fmt!='%')
pchr(f, *fmt);
else switch(*++fmt){
case '\0':
va_end(ap);
return;
case 'c':
pchr(f, va_arg(ap, int));
break;
case 'd':
pdec(f, va_arg(ap, int));
break;
case 'o':
poct(f, va_arg(ap, unsigned));
break;
case 'p':
pptr(f, va_arg(ap, void*));
break;
case 'Q':
pquo(f, va_arg(ap, char *));
break;
case 'q':
pwrd(f, va_arg(ap, char *));
break;
case 'r':
errstr(err, sizeof err); pstr(f, err);
break;
case 's':
pstr(f, va_arg(ap, char *));
break;
case 't':
pcmd(f, va_arg(ap, struct tree *));
break;
case 'v':
pval(f, va_arg(ap, struct word *));
break;
default:
pchr(f, *fmt);
break;
}
va_end(ap);
if(--pfmtnest==0)
flush(f);
}
void
pchr(io *b, int c)
{
if(b->bufp==b->ebuf)
fullbuf(b, c);
else *b->bufp++=c;
}
int
rchr(io *b)
{
if(b->bufp==b->ebuf)
return emptybuf(b);
return *b->bufp++;
}
void
pquo(io *f, char *s)
{
pchr(f, '\'');
for(;*s;s++)
if(*s=='\'')
pfmt(f, "''");
else pchr(f, *s);
pchr(f, '\'');
}
void
pwrd(io *f, char *s)
{
char *t;
for(t = s;*t;t++) if(*t >= 0 && needsrcquote(*t)) break;
if(t==s || *t)
pquo(f, s);
else pstr(f, s);
}
void
pptr(io *f, void *v)
{
int n;
uintptr p;
p = (uintptr)v;
if(sizeof(uintptr) == sizeof(uvlong) && p>>32)
for(n = 60;n>=32;n-=4) pchr(f, "0123456789ABCDEF"[(p>>n)&0xF]);
for(n = 28;n>=0;n-=4) pchr(f, "0123456789ABCDEF"[(p>>n)&0xF]);
}
void
pstr(io *f, char *s)
{
if(s==0)
s="(null)";
while(*s) pchr(f, *s++);
}
void
pdec(io *f, int n)
{
if(n<0){
n=-n;
if(n>=0){
pchr(f, '-');
pdec(f, n);
return;
}
/* n is two's complement minimum integer */
n = 1-n;
pchr(f, '-');
pdec(f, n/10);
pchr(f, n%10+'1');
return;
}
if(n>9)
pdec(f, n/10);
pchr(f, n%10+'0');
}
void
poct(io *f, unsigned n)
{
if(n>7)
poct(f, n>>3);
pchr(f, (n&7)+'0');
}
void
pval(io *f, word *a)
{
if(a){
while(a->next && a->next->word){
pwrd(f, (char *)a->word);
pchr(f, ' ');
a = a->next;
}
pwrd(f, (char *)a->word);
}
}
int
fullbuf(io *f, int c)
{
flush(f);
return *f->bufp++=c;
}
void
flush(io *f)
{
int n;
if(f->strp){
n = f->ebuf - f->strp;
f->strp = realloc(f->strp, n+Stralloc+1);
if(f->strp==0)
panic("Can't realloc %d bytes in flush!", n+Stralloc+1);
f->bufp = f->strp + n;
f->ebuf = f->bufp + Stralloc;
memset(f->bufp, '\0', Stralloc+1);
}
else{
n = f->bufp-f->buf;
if(n && Write(f->fd, f->buf, n) != n){
Write(2, "Write error\n", 12);
if(ntrap)
dotrap();
}
f->bufp = f->buf;
f->ebuf = f->buf+NBUF;
}
}
io*
openfd(int fd)
{
io *f = new(struct io);
f->fd = fd;
f->bufp = f->ebuf = f->buf;
f->strp = 0;
return f;
}
io*
openstr(void)
{
io *f = new(struct io);
f->fd = -1;
f->bufp = f->strp = emalloc(Stralloc+1);
f->ebuf = f->bufp + Stralloc;
memset(f->bufp, '\0', Stralloc+1);
return f;
}
/*
* Open a corebuffer to read. EOF occurs after reading len
* characters from buf.
*/
io*
opencore(char *s, int len)
{
io *f = new(struct io);
uchar *buf = emalloc(len);
f->fd = -1 /*open("/dev/null", 0)*/;
f->bufp = f->strp = buf;
f->ebuf = buf+len;
Memcpy(buf, s, len);
return f;
}
void
rewind(io *io)
{
if(io->fd==-1)
io->bufp = io->strp;
else{
io->bufp = io->ebuf = io->buf;
Seek(io->fd, 0L, 0);
}
}
void
closeio(io *io)
{
if(io->fd>=0)
close(io->fd);
if(io->strp)
efree(io->strp);
efree(io);
}
int
emptybuf(io *f)
{
int n;
if(f->fd==-1 || (n = Read(f->fd, f->buf, NBUF))<=0) return EOF;
f->bufp = f->buf;
f->ebuf = f->buf + n;
return *f->bufp++;
}
|