X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;ds=sidebyside;f=lib%2Fsorter.h;h=4c42d7788d90b04771e8ed31840705acdd25ef7a;hb=75eea53f8050dc1482de088b3cbd081b2511c5a4;hp=d1f059fccec58f0240748dc7dc0777cb78eaa27d;hpb=4714386ed8888c1edc4e13ed976dd2c3d67c63ee;p=libucw.git diff --git a/lib/sorter.h b/lib/sorter.h index d1f059fc..4c42d778 100644 --- a/lib/sorter.h +++ b/lib/sorter.h @@ -1,7 +1,10 @@ /* * Sherlock Library -- Universal Sorter * - * (c) 2001 Martin Mares + * (c) 2001--2003 Martin Mares + * + * This software may be freely distributed and used according to the terms + * of the GNU Lesser General Public License. */ /* @@ -17,6 +20,10 @@ * defined by the sorter) * SORT_PRESORT include an in-core presorting pass * SORT_UNIFY merge items with identical keys + * SORT_REGULAR all items are equally long and they don't contain + * anything else than the key. In this case, the sorter + * automatically supplies fetch_key, copy_data, fetch_item + * and store_item functions. * SORT_DELETE_INPUT a C expression, if true, the input files are * deleted as soon as possible * SORT_INPUT_FILE input is a file with this name @@ -64,6 +71,9 @@ * from the list of items, but not deallocated, so * the remaining item can freely reference data of the * other one. + * + * After including this file, all parameter macros are automatically + * undef'd. */ /* Declarations of externals from sorter.c */ @@ -75,8 +85,7 @@ extern uns sorter_trace; extern uns sorter_presort_bufsize; extern uns sorter_stream_bufsize; -extern uns sorter_pass_counter, sorter_file_counter; -struct fastbuf *sorter_open_tmp(void); +extern uns sorter_pass_counter; #endif /* !SORT_DECLS_READ */ @@ -102,6 +111,34 @@ struct fastbuf *sorter_open_tmp(void); #define LESS <= #endif +#ifdef SORT_REGULAR + +static inline int +P(fetch_key)(struct fastbuf *in, SORT_KEY *x) +{ + return breadb(in, x, sizeof(*x)); +} + +static inline void +P(copy_data)(struct fastbuf *in UNUSED, struct fastbuf *out, SORT_KEY *x) +{ + bwrite(out, x, sizeof(*x)); +} + +static inline byte * +P(fetch_item)(struct fastbuf *in UNUSED, SORT_KEY *x UNUSED, byte *limit UNUSED) +{ + return (byte *)(x+1); +} + +static inline void +P(store_item)(struct fastbuf *out, SORT_KEY *x) +{ + bwrite(out, x, sizeof(*x)); +} + +#endif + static struct fastbuf * P(flush_out)(struct fastbuf *out) { @@ -147,7 +184,7 @@ P(pass)(struct fastbuf **fb1, struct fastbuf **fb2) struct fastbuf *t; SWAP(out1, out2, t); if (!out1) - out1 = sorter_open_tmp(); + out1 = bopen_tmp(sorter_stream_bufsize); run_count++; } if (comp LESS 0) @@ -273,7 +310,7 @@ P(presort)(struct fastbuf **fb1, struct fastbuf **fb2) { SWAP(out1, out2, tbuf); if (!out1) - out1 = sorter_open_tmp(); + out1 = bopen_tmp(sorter_stream_bufsize); current = buffer; last = &first; if (leftover) @@ -346,6 +383,7 @@ P(presort)(struct fastbuf **fb1, struct fastbuf **fb2) (out2 ? (int)((btell(out2) + 1023) / 1024) : 0)); *fb1 = P(flush_out)(out1); *fb2 = P(flush_out)(out2); + xfree(buffer); } #endif /* SORT_PRESORT */ @@ -382,7 +420,7 @@ struct fastbuf *fb1, struct fastbuf *fb2 #endif #ifdef SORT_DELETE_INPUT - fb1->is_temp_file = SORT_DELETE_INPUT; + bconfig(fb1, BCONFIG_IS_TEMP_FILE, SORT_DELETE_INPUT); #endif sorter_pass_counter = 1; #ifdef SORT_PRESORT @@ -391,12 +429,12 @@ struct fastbuf *fb1, struct fastbuf *fb2 #endif do P(pass)(&fb1, &fb2); while (fb1 && fb2); if (!fb1) - fb1 = sorter_open_tmp(); + fb1 = bopen_tmp(sorter_stream_bufsize); #ifdef SORT_OUTPUT_FB return fb1; #else - fb1->is_temp_file = 0; + bconfig(fb1, BCONFIG_IS_TEMP_FILE, 0); if (rename(fb1->name, outname) < 0) die("rename(%s,%s): %m", fb1->name, outname); bclose(fb1); @@ -407,5 +445,15 @@ struct fastbuf *fb1, struct fastbuf *fb2 #undef LESS #undef SWAP #undef SORT_NODE +#undef SORT_KEY +#undef SORT_PREFIX +#undef SORT_UNIFY +#undef SORT_REGULAR +#undef SORT_DELETE_INPUT +#undef SORT_INPUT_FILE +#undef SORT_INPUT_FB +#undef SORT_INPUT_FBPAIR +#undef SORT_OUTPUT_FILE +#undef SORT_OUTPUT_FB #endif /* !SORT_DECLARE_ONLY */