1 2277c5d7 2004-03-21 devnull #include "std.h"
2 2277c5d7 2004-03-21 devnull #include "dat.h"
5 2277c5d7 2004-03-21 devnull lbkick(Logbuf *lb)
11 2277c5d7 2004-03-21 devnull while(lb->wait && lb->rp != lb->wp){
12 2277c5d7 2004-03-21 devnull r = lb->wait;
13 2277c5d7 2004-03-21 devnull lb->wait = r->aux;
14 2277c5d7 2004-03-21 devnull if(lb->wait == nil)
15 2277c5d7 2004-03-21 devnull lb->waitlast = &lb->wait;
16 2277c5d7 2004-03-21 devnull r->aux = nil;
17 2277c5d7 2004-03-21 devnull if(r->ifcall.count < 5){
18 2277c5d7 2004-03-21 devnull respond(r, "factotum: read request count too short");
19 2277c5d7 2004-03-21 devnull continue;
21 2277c5d7 2004-03-21 devnull s = lb->msg[lb->rp];
22 2277c5d7 2004-03-21 devnull lb->msg[lb->rp] = nil;
23 2277c5d7 2004-03-21 devnull if(++lb->rp == nelem(lb->msg))
24 2277c5d7 2004-03-21 devnull lb->rp = 0;
25 2277c5d7 2004-03-21 devnull n = r->ifcall.count;
26 2277c5d7 2004-03-21 devnull if(n < strlen(s)+1+1){
27 2277c5d7 2004-03-21 devnull memmove(r->ofcall.data, s, n-5);
29 2277c5d7 2004-03-21 devnull r->ofcall.data[n] = '\0';
30 2277c5d7 2004-03-21 devnull /* look for first byte of UTF-8 sequence by skipping continuation bytes */
31 2277c5d7 2004-03-21 devnull while(n>0 && (r->ofcall.data[--n]&0xC0)==0x80)
33 2277c5d7 2004-03-21 devnull strcpy(r->ofcall.data+n, "...\n");
35 2277c5d7 2004-03-21 devnull strcpy(r->ofcall.data, s);
36 2277c5d7 2004-03-21 devnull strcat(r->ofcall.data, "\n");
38 2277c5d7 2004-03-21 devnull r->ofcall.count = strlen(r->ofcall.data);
40 2277c5d7 2004-03-21 devnull respond(r, nil);
45 2277c5d7 2004-03-21 devnull lbread(Logbuf *lb, Req *r)
47 2277c5d7 2004-03-21 devnull if(lb->waitlast == nil)
48 2277c5d7 2004-03-21 devnull lb->waitlast = &lb->wait;
49 2277c5d7 2004-03-21 devnull *(lb->waitlast) = r;
50 2277c5d7 2004-03-21 devnull lb->waitlast = (Req**)&r->aux;
51 2277c5d7 2004-03-21 devnull r->aux = nil;
52 2277c5d7 2004-03-21 devnull lbkick(lb);
56 2277c5d7 2004-03-21 devnull lbflush(Logbuf *lb, Req *r)
60 2277c5d7 2004-03-21 devnull for(l=&lb->wait; *l; l=(Req**)&(*l)->aux){
61 2277c5d7 2004-03-21 devnull if(*l == r){
62 2277c5d7 2004-03-21 devnull *l = r->aux;
63 2277c5d7 2004-03-21 devnull r->aux = nil;
64 2277c5d7 2004-03-21 devnull if(*l == nil)
65 2277c5d7 2004-03-21 devnull lb->waitlast = l;
66 2277c5d7 2004-03-21 devnull closereq(r);
73 2277c5d7 2004-03-21 devnull lbappend(Logbuf *lb, char *fmt, ...)
75 2277c5d7 2004-03-21 devnull va_list arg;
77 2277c5d7 2004-03-21 devnull va_start(arg, fmt);
78 2277c5d7 2004-03-21 devnull lbvappend(lb, fmt, arg);
79 2277c5d7 2004-03-21 devnull va_end(arg);
83 2277c5d7 2004-03-21 devnull lbvappend(Logbuf *lb, char *fmt, va_list arg)
87 2277c5d7 2004-03-21 devnull s = smprint(fmt, arg);
88 2277c5d7 2004-03-21 devnull if(s == nil)
89 2277c5d7 2004-03-21 devnull sysfatal("out of memory");
90 2277c5d7 2004-03-21 devnull if(lb->msg[lb->wp])
91 2277c5d7 2004-03-21 devnull free(lb->msg[lb->wp]);
92 2277c5d7 2004-03-21 devnull lb->msg[lb->wp] = s;
93 2277c5d7 2004-03-21 devnull if(++lb->wp == nelem(lb->msg))
94 2277c5d7 2004-03-21 devnull lb->wp = 0;
95 2277c5d7 2004-03-21 devnull lbkick(lb);
98 2277c5d7 2004-03-21 devnull Logbuf logbuf;
101 2277c5d7 2004-03-21 devnull logread(Req *r)
103 2277c5d7 2004-03-21 devnull lbread(&logbuf, r);
107 2277c5d7 2004-03-21 devnull logflush(Req *r)
109 2277c5d7 2004-03-21 devnull lbflush(&logbuf, r);
113 2277c5d7 2004-03-21 devnull flog(char *fmt, ...)
115 2277c5d7 2004-03-21 devnull va_list arg;
117 2277c5d7 2004-03-21 devnull va_start(arg, fmt);
118 2277c5d7 2004-03-21 devnull lbvappend(&logbuf, fmt, arg);
119 2277c5d7 2004-03-21 devnull va_end(arg);