X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;f=lib%2Fsorter%2Fsbuck.c;h=bff52d6616ca9b0bfec6cd1908da4374984b4f71;hb=f08c91407f0ccdcc07cee4a49ccb4bddd4c35988;hp=4d9bb91b64cf55493ed0273dad15987683a73e3e;hpb=b340e1fbbfa9fcfc4c3f9ef41c84f2e86c523bdc;p=libucw.git diff --git a/lib/sorter/sbuck.c b/lib/sorter/sbuck.c index 4d9bb91b..bff52d66 100644 --- a/lib/sorter/sbuck.c +++ b/lib/sorter/sbuck.c @@ -69,15 +69,12 @@ sbuck_swap_in(struct sort_bucket *b) { if (b->flags & SBF_SWAPPED_OUT) { - if (sorter_stream_bufsize) /* FIXME: Needs better configuration, probably semi-automatic one */ - b->fb = bopen(b->filename, O_RDWR, sorter_stream_bufsize); - else - b->fb = fbdir_open(b->filename, O_RDWR, NULL); + b->fb = bopen_file(b->filename, O_RDWR, &sorter_fb_params); /* FIXME: Something different for small buckets? */ if (b->flags & SBF_OPEN_WRITE) bseek(b->fb, 0, SEEK_END); bconfig(b->fb, BCONFIG_IS_TEMP_FILE, 1); b->flags &= ~SBF_SWAPPED_OUT; - SORT_XTRACE(2, "Swapped in %s", b->filename); + SORT_XTRACE(3, "Swapped in %s", b->filename); } } @@ -107,10 +104,7 @@ sbuck_write(struct sort_bucket *b) else { ASSERT(!(b->flags & (SBF_OPEN_READ | SBF_DESTROYED))); - if (sorter_stream_bufsize) - b->fb = bopen_tmp(sorter_stream_bufsize); - else - b->fb = fbdir_open_tmp(NULL); + b->fb = bopen_tmp_file(&sorter_fb_params); if (sorter_debug & SORT_DEBUG_KEEP_BUCKETS) bconfig(b->fb, BCONFIG_IS_TEMP_FILE, 0); b->flags |= SBF_OPEN_WRITE; @@ -130,7 +124,7 @@ sbuck_swap_out(struct sort_bucket *b) bclose(b->fb); b->fb = NULL; b->flags |= SBF_SWAPPED_OUT; - SORT_XTRACE(2, "Swapped out %s", b->filename); + SORT_XTRACE(3, "Swapped out %s", b->filename); } }