X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;f=ucw%2Ffb-direct.c;h=f87baa36316ba4ebfd78ce4d3371e3e9ce2a3491;hb=f17e4350dcf0c033891e52b30b0c32a4a4fed5e0;hp=264905792acdf4b7e59aee727be86dc7890199a4;hpb=681b277c0aabea785a21e109dc07338847c0cb32;p=libucw.git diff --git a/ucw/fb-direct.c b/ucw/fb-direct.c index 26490579..f87baa36 100644 --- a/ucw/fb-direct.c +++ b/ucw/fb-direct.c @@ -25,12 +25,12 @@ #undef LOCAL_DEBUG -#include "ucw/lib.h" -#include "ucw/fastbuf.h" -#include "ucw/lfs.h" -#include "ucw/asio.h" -#include "ucw/conf.h" -#include "ucw/threads.h" +#include +#include +#include +#include +#include +#include #include #include @@ -57,7 +57,7 @@ struct fb_direct { enum fbdir_mode mode; byte name[0]; }; -#define FB_DIRECT(f) ((struct fb_direct *)(f)->is_fastbuf) +#define FB_DIRECT(f) ((struct fb_direct *)(f)) #ifndef TEST uns fbdir_cheat; @@ -159,7 +159,7 @@ fbdir_refill(struct fastbuf *f) if (!r->status) return 0; if (r->status < 0) - bthrow(f, "fb.read", "Error reading %s: %s", f->name, strerror(r->returned_errno)); + bthrow(f, "read", "Error reading %s: %s", f->name, strerror(r->returned_errno)); f->bptr = f->buffer = r->buffer; f->bstop = f->bufend = f->buffer + r->status; f->pos += r->status; @@ -193,7 +193,7 @@ fbdir_spout(struct fastbuf *f) asio_sync(F->io_queue); DBG("FB-DIRECT: Truncating at %llu", (long long)f->pos); if (ucw_ftruncate(F->fd, f->pos) < 0) - bthrow(f, "fb.write", "Error truncating %s: %m", f->name); + bthrow(f, "write", "Error truncating %s: %m", f->name); } else asio_submit(r); @@ -308,13 +308,12 @@ fbdir_open_fd_internal(int fd, const char *name, struct asio_queue *q, uns buffe f->close = fbdir_close; f->config = fbdir_config; f->can_overwrite_buffer = 2; - fb_tie(f); return f; } #ifdef TEST -#include "ucw/getopt.h" +#include int main(int argc, char **argv) {