if (!size)
return 0;
if (!ctx->last_pass_time)
- return -1;
+ return 0;
return (uns)((double)size / (1<<20) * 1000 / ctx->last_pass_time);
}
static sh_off_t
sbuck_ins_or_join(struct sort_bucket *b, cnode *list_pos, struct sort_bucket *join, sh_off_t join_size)
{
- if (join)
+ if (join && join->runs >= 2)
{
if (b)
sbuck_drop(b);