}
delete[] buf;
- return wrote;
+ return wrote*4; // KB
}
void Ager::age_empty(float pc) {
for (int c=1; c<=count; c++) {
if (g_clock.now() > until) break;
- if (c == 7) start_debug = true;
+ //if (c == 7) start_debug = true;
dout(1) << "age " << c << "/" << count << " filling to " << high_water << endl;
__uint64_t w = age_fill(high_water, until);
//pfrag(st);
-
if (c == count) {
dout(1) << "age final empty to " << final_water << endl;
age_empty(final_water);
}
store->sync();
store->_get_frag_stat(st);
+
+ dout(1) << wrote / (1024ULL*1024ULL) << " GB written\t";// << endl;
+
+
pfrag(st);
// dump freelist?
}
}
- dout(1) << wrote / (1024ULL*1024ULL) << " GB written" << endl;
-
// dump the freelist
save_freelist(0);
exit(0); // hack
if (scalar(@files) == 1 && $files[0] =~ /\*/) {
my ($dir, $pat) = $files[0] =~ /^(.*)\/([^\/]+)$/;
@files = ();
-
+ $pat =~ s/\*//;
+# print "dir $dir pat $pat\n";
opendir(D,"$dir");
for my $f (readdir(D)) {
+ # print "$f\n";
next unless $f =~ /^$pat/;
- push(@files, $f);
+ push(@files, "$dir/$f");
}
closedir(D);