93c5246832
This improves usability a little as we no longer require using touch. Also reword the manpage wrt. parameters and fix usage() [1] With no media in a cd(4) drive, the reads will loop producing EINVAL, abort in that case [2]. Document the shortcoming of sectorsize and MAXPHYS (a quick solution to this might be having MAXPHYS as the "bigsize", in short testing it didn't make a difference on throughput). Submitted by: arundel [1] PR: bin/154528 [2]
318 lines
6.6 KiB
C
318 lines
6.6 KiB
C
/*-
|
|
* ----------------------------------------------------------------------------
|
|
* "THE BEER-WARE LICENSE" (Revision 42):
|
|
* <phk@FreeBSD.ORG> wrote this file. As long as you retain this notice you
|
|
* can do whatever you want with this stuff. If we meet some day, and you think
|
|
* this stuff is worth it, you can buy me a beer in return. Poul-Henning Kamp
|
|
* ----------------------------------------------------------------------------
|
|
*
|
|
* $FreeBSD$
|
|
*/
|
|
#include <sys/param.h>
|
|
#include <sys/queue.h>
|
|
#include <sys/disk.h>
|
|
#include <sys/stat.h>
|
|
|
|
#include <err.h>
|
|
#include <errno.h>
|
|
#include <fcntl.h>
|
|
#include <signal.h>
|
|
#include <stdint.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <time.h>
|
|
#include <unistd.h>
|
|
|
|
volatile sig_atomic_t aborting = 0;
|
|
static size_t bigsize = 1024 * 1024;
|
|
static size_t medsize;
|
|
static size_t minsize = 512;
|
|
|
|
struct lump {
|
|
off_t start;
|
|
off_t len;
|
|
int state;
|
|
TAILQ_ENTRY(lump) list;
|
|
};
|
|
|
|
static TAILQ_HEAD(, lump) lumps = TAILQ_HEAD_INITIALIZER(lumps);
|
|
|
|
static void
|
|
new_lump(off_t start, off_t len, int state)
|
|
{
|
|
struct lump *lp;
|
|
|
|
lp = malloc(sizeof *lp);
|
|
if (lp == NULL)
|
|
err(1, "Malloc failed");
|
|
lp->start = start;
|
|
lp->len = len;
|
|
lp->state = state;
|
|
TAILQ_INSERT_TAIL(&lumps, lp, list);
|
|
}
|
|
|
|
static struct lump *lp;
|
|
static char *wworklist = NULL;
|
|
static char *rworklist = NULL;
|
|
|
|
|
|
#define PRINT_HEADER \
|
|
printf("%13s %7s %13s %5s %13s %13s %9s\n", \
|
|
"start", "size", "block-len", "state", "done", "remaining", "% done")
|
|
|
|
#define PRINT_STATUS(start, i, len, state, d, t) \
|
|
printf("\r%13jd %7zu %13jd %5d %13jd %13jd %9.5f", \
|
|
(intmax_t)start, \
|
|
i, \
|
|
(intmax_t)len, \
|
|
state, \
|
|
(intmax_t)d, \
|
|
(intmax_t)(t - d), \
|
|
100*(double)d/(double)t)
|
|
|
|
/* Save the worklist if -w was given */
|
|
static void
|
|
save_worklist(void)
|
|
{
|
|
FILE *file;
|
|
struct lump *llp;
|
|
|
|
if (wworklist != NULL) {
|
|
(void)fprintf(stderr, "\nSaving worklist ...");
|
|
fflush(stderr);
|
|
|
|
file = fopen(wworklist, "w");
|
|
if (file == NULL)
|
|
err(1, "Error opening file %s", wworklist);
|
|
|
|
TAILQ_FOREACH(llp, &lumps, list)
|
|
fprintf(file, "%jd %jd %d\n",
|
|
(intmax_t)llp->start, (intmax_t)llp->len,
|
|
llp->state);
|
|
fclose(file);
|
|
(void)fprintf(stderr, " done.\n");
|
|
}
|
|
}
|
|
|
|
/* Read the worklist if -r was given */
|
|
static off_t
|
|
read_worklist(off_t t)
|
|
{
|
|
off_t s, l, d;
|
|
int state, lines;
|
|
FILE *file;
|
|
|
|
(void)fprintf(stderr, "Reading worklist ...");
|
|
fflush(stderr);
|
|
file = fopen(rworklist, "r");
|
|
if (file == NULL)
|
|
err(1, "Error opening file %s", rworklist);
|
|
|
|
lines = 0;
|
|
d = t;
|
|
for (;;) {
|
|
++lines;
|
|
if (3 != fscanf(file, "%jd %jd %d\n", &s, &l, &state)) {
|
|
if (!feof(file))
|
|
err(1, "Error parsing file %s at line %d",
|
|
rworklist, lines);
|
|
else
|
|
break;
|
|
}
|
|
new_lump(s, l, state);
|
|
d -= l;
|
|
}
|
|
(void)fprintf(stderr, " done.\n");
|
|
/*
|
|
* Return the number of bytes already read
|
|
* (at least not in worklist).
|
|
*/
|
|
return (d);
|
|
}
|
|
|
|
static void
|
|
usage(void)
|
|
{
|
|
(void)fprintf(stderr, "usage: recoverdisk [-b bigsize] [-r readlist] "
|
|
"[-s interval] [-w writelist] source [destination]\n");
|
|
exit(1);
|
|
}
|
|
|
|
static void
|
|
sighandler(__unused int sig)
|
|
{
|
|
|
|
aborting = 1;
|
|
}
|
|
|
|
int
|
|
main(int argc, char * const argv[])
|
|
{
|
|
int ch;
|
|
int fdr, fdw;
|
|
off_t t, d, start, len;
|
|
size_t i, j;
|
|
int error, state;
|
|
u_char *buf;
|
|
u_int sectorsize;
|
|
time_t t1, t2;
|
|
struct stat sb;
|
|
u_int n, snapshot = 60;
|
|
|
|
while ((ch = getopt(argc, argv, "b:r:w:s:")) != -1) {
|
|
switch (ch) {
|
|
case 'b':
|
|
bigsize = strtoul(optarg, NULL, 0);
|
|
break;
|
|
case 'r':
|
|
rworklist = strdup(optarg);
|
|
if (rworklist == NULL)
|
|
err(1, "Cannot allocate enough memory");
|
|
break;
|
|
case 's':
|
|
snapshot = strtoul(optarg, NULL, 0);
|
|
break;
|
|
case 'w':
|
|
wworklist = strdup(optarg);
|
|
if (wworklist == NULL)
|
|
err(1, "Cannot allocate enough memory");
|
|
break;
|
|
default:
|
|
usage();
|
|
/* NOTREACHED */
|
|
}
|
|
}
|
|
argc -= optind;
|
|
argv += optind;
|
|
|
|
if (argc < 1 || argc > 2)
|
|
usage();
|
|
|
|
fdr = open(argv[0], O_RDONLY);
|
|
if (fdr < 0)
|
|
err(1, "Cannot open read descriptor %s", argv[0]);
|
|
|
|
error = fstat(fdr, &sb);
|
|
if (error < 0)
|
|
err(1, "fstat failed");
|
|
if (S_ISBLK(sb.st_mode) || S_ISCHR(sb.st_mode)) {
|
|
error = ioctl(fdr, DIOCGSECTORSIZE, §orsize);
|
|
if (error < 0)
|
|
err(1, "DIOCGSECTORSIZE failed");
|
|
|
|
minsize = sectorsize;
|
|
bigsize = (bigsize / sectorsize) * sectorsize;
|
|
|
|
error = ioctl(fdr, DIOCGMEDIASIZE, &t);
|
|
if (error < 0)
|
|
err(1, "DIOCGMEDIASIZE failed");
|
|
} else {
|
|
t = sb.st_size;
|
|
}
|
|
|
|
if (bigsize < minsize)
|
|
bigsize = minsize;
|
|
|
|
for (ch = 0; (bigsize >> ch) > minsize; ch++)
|
|
continue;
|
|
medsize = bigsize >> (ch / 2);
|
|
medsize = (medsize / minsize) * minsize;
|
|
|
|
fprintf(stderr, "Bigsize = %zu, medsize = %zu, minsize = %zu\n",
|
|
bigsize, medsize, minsize);
|
|
|
|
buf = malloc(bigsize);
|
|
if (buf == NULL)
|
|
err(1, "Cannot allocate %zu bytes buffer", bigsize);
|
|
|
|
if (argc > 1) {
|
|
fdw = open(argv[1], O_WRONLY | O_CREAT, DEFFILEMODE);
|
|
if (fdw < 0)
|
|
err(1, "Cannot open write descriptor %s", argv[1]);
|
|
if (ftruncate(fdw, t) < 0)
|
|
err(1, "Cannot truncate output %s to %jd bytes",
|
|
argv[1], (intmax_t)t);
|
|
} else
|
|
fdw = -1;
|
|
|
|
if (rworklist != NULL) {
|
|
d = read_worklist(t);
|
|
} else {
|
|
new_lump(0, t, 0);
|
|
d = 0;
|
|
}
|
|
if (wworklist != NULL)
|
|
signal(SIGINT, sighandler);
|
|
|
|
t1 = 0;
|
|
start = len = i = state = 0;
|
|
PRINT_HEADER;
|
|
n = 0;
|
|
for (;;) {
|
|
lp = TAILQ_FIRST(&lumps);
|
|
if (lp == NULL)
|
|
break;
|
|
while (lp->len > 0 && !aborting) {
|
|
/* These are only copied for printing stats */
|
|
start = lp->start;
|
|
len = lp->len;
|
|
state = lp->state;
|
|
|
|
i = MIN(lp->len, (off_t)bigsize);
|
|
if (lp->state == 1)
|
|
i = MIN(lp->len, (off_t)medsize);
|
|
if (lp->state > 1)
|
|
i = MIN(lp->len, (off_t)minsize);
|
|
time(&t2);
|
|
if (t1 != t2 || lp->len < (off_t)bigsize) {
|
|
PRINT_STATUS(start, i, len, state, d, t);
|
|
t1 = t2;
|
|
if (++n == snapshot) {
|
|
save_worklist();
|
|
n = 0;
|
|
}
|
|
}
|
|
if (i == 0) {
|
|
errx(1, "BOGUS i %10jd", (intmax_t)i);
|
|
}
|
|
fflush(stdout);
|
|
j = pread(fdr, buf, i, lp->start);
|
|
if (j == i) {
|
|
d += i;
|
|
if (fdw >= 0)
|
|
j = pwrite(fdw, buf, i, lp->start);
|
|
else
|
|
j = i;
|
|
if (j != i)
|
|
printf("\nWrite error at %jd/%zu\n",
|
|
lp->start, i);
|
|
lp->start += i;
|
|
lp->len -= i;
|
|
continue;
|
|
}
|
|
printf("\n%jd %zu failed (%s)\n",
|
|
lp->start, i, strerror(errno));
|
|
if (errno == EINVAL) {
|
|
printf("read() size too big? Try with -b 131072");
|
|
aborting = 1;
|
|
}
|
|
if (errno == ENXIO)
|
|
aborting = 1;
|
|
new_lump(lp->start, i, lp->state + 1);
|
|
lp->start += i;
|
|
lp->len -= i;
|
|
}
|
|
if (aborting) {
|
|
save_worklist();
|
|
return (0);
|
|
}
|
|
TAILQ_REMOVE(&lumps, lp, list);
|
|
free(lp);
|
|
}
|
|
PRINT_STATUS(start, i, len, state, d, t);
|
|
save_worklist();
|
|
printf("\nCompleted\n");
|
|
return (0);
|
|
}
|