@@ -255,7 +255,6 @@ wk_service(wk *paramweb)

                                                 client->serviced=0; /* we have finished servicing this one */

                                                 if(!client->keepalive)

                                                         wk_close((wk *)web, fd); /* all sent */

-

                                         }

                                 }

                         }

@@ -285,13 +284,40 @@ wk_serve_error(wk *paramweb, int connid, wk_error wkerror)

 int

 wk_writestr(wk *paramweb, int connid, char *str)

 {

-

+        return(wk_write(paramweb,connid,str,strlen(str)));

 }

 int

 wk_write(wk *paramweb, int connid, void *data, int datalen)

 {

-

+        int k;

+        _wk *web=(_wk *)paramweb;

+        wk_client *client;

+        sbuf *out;

+        long added;

+        long total;

+        if(web==NULL)

+                return(-1);

+        if((client=wk_clientget(web,connid))==NULL)

+                return(-1);

+        total=0;

+        for(k=(client->usedoutbufids>0)?client->usedoutbufids-1:0;

+          datalen>0 && k<MAXOUTBUF;k++) {

+                if(client->outbufids[k]==-1) {

+                        if((client->outbufids[k]=wk_sbufacquire((wk *)web))==-1)

+                                return(-1); /* insufficient memory */

+                        client->usedoutbufids++;

+                }

+                if((out=wk_sbufget((wk *)web,client->outbufids[k]))==NULL)

+                        return(-1); /* internal error */

+                if(sbuf_unused(out)==0)

+                        continue;

+                added=sbuf_add(out,data,datalen);

+                data+=added;

+                datalen-=added;

+                total+=added;

+        }

+        return(total);

 }

 int