X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;f=lib%2Fsorter%2Fsorter.h;h=a0b6b39b76a1407fa7425f300bd0551b75cbac76;hb=fe6dc0daa9980627429b4ece23a51f971dd9698a;hp=83d3e7dcacf32203528e634190914dd69780354b;hpb=f6d9e92d2dfc4d86e9599449cc56a3eba2bf9626;p=libucw.git diff --git a/lib/sorter/sorter.h b/lib/sorter/sorter.h index 83d3e7dc..a0b6b39b 100644 --- a/lib/sorter/sorter.h +++ b/lib/sorter/sorter.h @@ -201,6 +201,10 @@ static inline void P(copy_merged)(P(key) **keys, struct fastbuf **data UNUSED, u #include "lib/sorter/s-twoway.h" +#ifndef SORT_UNIFY +#include "lib/sorter/s-multiway.h" +#endif + #if defined(SORT_HASH_BITS) || defined(SORT_INT) #include "lib/sorter/s-radix.h" #endif @@ -225,7 +229,7 @@ static struct fastbuf *P(sort)( bzero(&ctx, sizeof(ctx)); #ifdef SORT_INPUT_FILE - ctx.in_fb = bopen(in, O_RDONLY, sorter_stream_bufsize); + ctx.in_fb = bopen_file(in, O_RDONLY, &sorter_fb_params); ctx.in_size = bfilesize(ctx.in_fb); #elif defined(SORT_INPUT_FB) ctx.in_fb = in; @@ -269,13 +273,14 @@ static struct fastbuf *P(sort)( ctx.internal_estimate = P(internal_estimate); ctx.twoway_merge = P(twoway_merge); +#ifndef SORT_UNIFY + ctx.multiway_merge = P(multiway_merge); +#endif + sorter_run(&ctx); #ifdef SORT_OUTPUT_FILE - if (rename(ctx.out_fb->name, out) < 0) - die("Cannot rename %s to %s: %m", ctx.out_fb->name, out); - bconfig(ctx.out_fb, BCONFIG_IS_TEMP_FILE, 0); - bclose(ctx.out_fb); + bfix_tmp_file(ctx.out_fb, out); ctx.out_fb = NULL; #endif return ctx.out_fb;