int verbose = 0;
struct obd_group_info {
- int dir_exists;
+ int dir_exists;
};
struct obd_group_info grp_info[MAX_GROUPS];
-static void usage(char *progname)
+void usage(char *progname)
{
- fprintf(stderr, "Usage: %s [-hv] -d lost+found_directory\n", progname);
- fprintf(stderr, "You need to mount the corrupted OST filesystem and "
- "provide the path for the lost+found directory as the -d "
- "option, for example:\n"
- "ll_recover_lost_found_objs -d /mnt/ost/lost+found\n");
- exit(1);
+ fprintf(stderr, "Usage: %s [-hv] -d lost+found_directory\n", progname);
+ fprintf(stderr, "You need to mount the corrupted OST filesystem and"
+ "provide the path for the lost+found directory as the -d "
+ "option, for example:\n"
+ "ll_recover_lost_found_objs -d /mnt/ost/lost+found\n");
+ exit(1);
}
-static int _ll_sprintf(char *buf, size_t size, const char *func, int line,
- const char *format, ...)
+int mkdir_p(char *dest_path, char *mount, __u64 ff_group)
{
- int rc;
- va_list ap;
-
- va_start(ap, format);
- rc = vsnprintf(buf, size, format, ap);
- if (!(rc > -1 && rc < size)) {
- fprintf(stderr,
- "error: %s:%d: path \"", func, line);
- vfprintf(stderr, format, ap);
- va_end(ap);
- fprintf(stderr, "\" is too long\n");
- return 1;
- }
- va_end(ap);
- return 0;
-}
-
-#define ll_sprintf(buf, size, format, ...) \
- _ll_sprintf(buf, size, __FUNCTION__, __LINE__, format, ## __VA_ARGS__)
-
-static int mkdir_p(const char *dest_path, const char *mount, __u64 ff_group)
-{
- struct stat stat_buf;
- int retval;
- mode_t mode = 0700;
- char tmp_path[PATH_MAX];
-
- if (stat(dest_path, &stat_buf) == 0)
- return 0;
-
- if (grp_info[ff_group].dir_exists == 0) {
- if (ll_sprintf(tmp_path, PATH_MAX, "%s/O/"LPU64,
- mount, ff_group))
- return 1;
-
- if (stat(tmp_path, &stat_buf) != 0) {
- retval = mkdir(tmp_path, mode);
- if (retval < 0) {
- fprintf(stderr, "error: creating directory %s: "
- "%s\n", tmp_path, strerror(errno));
- return 1;
- }
- grp_info[ff_group].dir_exists = 1;
- }
- }
-
- retval = mkdir(dest_path, mode);
- if (retval < 0) {
- fprintf(stderr, "error: creating directory %s: "
- "%s\n", dest_path, strerror(errno));
- return 1;
- }
-
- return 0;
+ struct stat stat_buf;
+ char tmp_path[PATH_MAX];
+ int retval;
+ mode_t mode = 0700;
+
+ if (stat(dest_path, &stat_buf) == 0)
+ return 0;
+
+ if (grp_info[ff_group].dir_exists == 0) {
+ sprintf(tmp_path, "%s/O/"LPU64, mount, ff_group);
+ if (stat(tmp_path, &stat_buf) != 0) {
+ retval = mkdir(tmp_path, 0700);
+ if (retval < 0) {
+ fprintf(stderr, "error: creating directory %s: "
+ "%s\n", tmp_path, strerror(errno));
+ return 1;
+ }
+ grp_info[ff_group].dir_exists = 1;
+ }
+ }
+
+ retval = mkdir(dest_path, mode);
+ if (retval < 0)
+ return 1;
+
+ return 0;
}
/* This is returning 0 for an error */
-static __u64 read_last_id(char *file_path)
+__u64 read_last_id(char *file_path)
{
- __u64 last_id;
- int fd;
- int count;
-
- fd = open(file_path, O_RDONLY);
- if (fd < 0) {
- if (errno != ENOENT)
- fprintf(stderr, "error: opening %s: %s\n",
- file_path, strerror(errno));
- return 0;
- }
-
- count = read(fd, &last_id, sizeof(last_id));
- if (count < 0) {
- fprintf(stderr, "error: reading file %s: %s\n", file_path,
- strerror(errno));
- close(fd);
- return 0;
- }
- if (count != sizeof(last_id)) {
- fprintf(stderr, "error: Could not read full last_id from %s\n",
- file_path);
- close(fd);
- return 0;
- }
-
- close(fd);
- return le64_to_cpu(last_id);
+ __u64 last_id;
+ int fd;
+ int count;
+
+ fd = open(file_path, O_RDONLY);
+ if (fd < 0)
+ return 0;
+
+ count = read(fd, &last_id, sizeof(last_id));
+ if (count < 0) {
+ fprintf(stderr, "error: reading file %s: %s\n", file_path,
+ strerror(errno));
+ close(fd);
+ return 0;
+ }
+ if (count != sizeof(last_id)) {
+ fprintf(stderr, "error: Could not read full last_id from %s\n",
+ file_path);
+ close(fd);
+ return 0;
+ }
+
+ close(fd);
+ return le64_to_cpu(last_id);
}
static unsigned filetype_dir_table[] = {
- [0]= DT_UNKNOWN,
- [S_IFIFO]= DT_FIFO,
- [S_IFCHR] = DT_CHR,
- [S_IFDIR] = DT_DIR,
- [S_IFBLK] = DT_BLK,
- [S_IFREG] = DT_REG,
- [S_IFLNK] = DT_LNK,
- [S_IFSOCK]= DT_SOCK,
+ [0]= DT_UNKNOWN,
+ [S_IFIFO]= DT_FIFO,
+ [S_IFCHR] = DT_CHR,
+ [S_IFDIR] = DT_DIR,
+ [S_IFBLK] = DT_BLK,
+ [S_IFREG] = DT_REG,
+ [S_IFLNK] = DT_LNK,
+ [S_IFSOCK]= DT_SOCK,
#if defined(DT_DOOR) && defined(S_IFDOOR)
- [S_IFDOOR]= DT_DOOR,
+ [S_IFDOOR]= DT_DOOR,
#endif
};
-static int traverse_lost_found(char *src_dir, const char *mount_path)
+static int traverse_lost_found(char *src_dir, char *mount_path)
{
- DIR *dir_ptr;
- struct filter_fid trusted_fid;
- struct dirent64 *dirent;
- __u64 ff_group, ff_objid;
- char *file_path;
- char dest_path[PATH_MAX];
- char last_id_file[PATH_MAX];
- __u64 last_id[MAX_GROUPS] = {0};
- __u64 tmp_last_id;
- struct stat st;
- int obj_exists, xattr_len;
- int len, ret = 0, error = 0;
-
- len = strlen(src_dir);
-
- dir_ptr = opendir(src_dir);
- if (!dir_ptr) {
- fprintf(stderr, "error: opening directory: %s\n",
- strerror(errno));
- return 1;
- }
-
- while ((dirent = readdir64(dir_ptr)) != NULL) {
- if (!strcmp(dirent->d_name, ".") ||
- !strcmp(dirent->d_name, ".."))
- continue;
-
- src_dir[len] = 0;
- if ((len + strlen(dirent->d_name) + 2) > PATH_MAX) {
- fprintf(stderr, "error: %s/%s: path too long\n",
- src_dir, dirent->d_name);
- break;
- }
- strcat(src_dir, "/");
- strcat(src_dir, dirent->d_name);
-
- if (dirent->d_type == DT_UNKNOWN) {
- ret = stat(src_dir, &st);
- if (ret == -1) {
- fprintf(stderr,
- "error: stating %s: %s\n",
- src_dir, strerror(errno));
- continue;
- }
- dirent->d_type = filetype_dir_table[st.st_mode &
- S_IFMT];
- if (dirent->d_type == DT_UNKNOWN) {
- fprintf(stderr,
- "error: %s of unknown type 0%o\n",
- src_dir, st.st_mode);
- continue;
- }
- }
-
- switch(dirent->d_type) {
- case DT_DIR:
- ret = traverse_lost_found(src_dir, mount_path);
- if (ret) {
- closedir(dir_ptr);
- return ret;
- }
- break;
-
- case DT_REG:
- file_path = src_dir;
- xattr_len = getxattr(file_path, "trusted.fid",
- (void *)&trusted_fid,
- sizeof(trusted_fid));
-
- if (xattr_len == -1 || xattr_len < sizeof(trusted_fid))
- /*
- * Its very much possible that we dont find fid
- * on precreated files, LAST_ID
- */
- continue;
-
- ff_group = le64_to_cpu(trusted_fid.ff_group);
- ff_objid = le64_to_cpu(trusted_fid.ff_objid);
-
- if (ff_group >= MAX_GROUPS) {
- fprintf(stderr, "error: invalid group "LPU64" likely"
- "indicates a corrupt xattr for file %s.\n",
- ff_group, file_path);
- continue;
- }
-
- /* might need to create the parent directories for
- this object */
- if (ll_sprintf(dest_path, PATH_MAX, "%s/O/"LPU64"/d"LPU64,
- mount_path, ff_group, ff_objid % 32)) {
- closedir(dir_ptr);
- return 1;
- }
-
- ret = mkdir_p(dest_path, mount_path, ff_group);
- if (ret) {
- closedir(dir_ptr);
- return ret;
- }
-
- /*
- * Object ID needs to be verified against last_id.
- * LAST_ID file may not be present in the group directory
- * due to corruption. In case of any error tyr to recover
- * as many objects as possible by setting last_id to ~0ULL.
- */
- if (last_id[ff_group] == 0) {
- if (ll_sprintf(last_id_file, PATH_MAX,
- "%s/O/"LPU64"/LAST_ID",
- mount_path, ff_group)) {
- closedir(dir_ptr);
- return 1;
- }
-
- tmp_last_id = read_last_id(last_id_file);
- if (tmp_last_id == 0)
- tmp_last_id = ~0ULL;
- last_id[ff_group] = tmp_last_id;
- }
-
- if (ff_objid > last_id[ff_group]) {
- fprintf(stderr, "error: file skipped because object ID "
- "greater than LAST_ID\nFilename: %s\n"
- "Group: "LPU64"\nObjectid: "LPU64"\n"
- "LAST_ID: "LPU64, file_path, ff_group, ff_objid,
- last_id[ff_group]);
- continue;
- }
-
- /* move file from lost+found to proper object
- directory */
- if (ll_sprintf(dest_path, PATH_MAX,
- "%s/O/"LPU64"/d"LPU64"/"LPU64, mount_path,
- ff_group, ff_objid % 32, ff_objid)) {
- closedir(dir_ptr);
- return 1;
- }
-
- obj_exists = 1;
- ret = stat(dest_path, &st);
- if (ret == 0) {
- if (st.st_size == 0)
- obj_exists = 0;
- } else {
- if (errno != ENOENT)
- fprintf(stderr,
- "warning: stat for %s: %s\n",
- dest_path, strerror(errno));
- obj_exists = 0;
- }
-
- if (obj_exists) {
- fprintf(stderr, "error: target object %s already "
- "exists and will not be replaced.\n",dest_path);
- continue;
- }
-
- if (rename(file_path, dest_path) < 0) {
- fprintf(stderr, "error: rename failed for file %s: %s\n",
- file_path, strerror(errno));
- error++;
- continue;
- }
-
- printf("Object %s restored.\n", dest_path);
- break;
- }
- }
-
- closedir(dir_ptr);
-
- return error;
+ DIR *dir_ptr;
+ struct filter_fid trusted_fid;
+ struct dirent64 *dirent;
+ __u64 ff_group, ff_objid;
+ char file_path[PATH_MAX];
+ char dest_path[PATH_MAX];
+ char last_id_file[PATH_MAX];
+ __u64 last_id[MAX_GROUPS] = {0};
+ __u64 tmp_last_id;
+ struct stat st;
+ int obj_exists, xattr_len;
+ int len, ret = 0, error = 0;
+
+ len = strlen(src_dir);
+
+ dir_ptr = opendir(src_dir);
+ if (!dir_ptr) {
+ fprintf(stderr, "error: opening directory: %s\n",
+ strerror(errno));
+ return errno;
+ }
+
+ while ((dirent = readdir64(dir_ptr)) != NULL) {
+ if (!strcmp(dirent->d_name, ".") ||
+ !strcmp(dirent->d_name, ".."))
+ continue;
+
+ src_dir[len] = 0;
+ if ((len + dirent->d_reclen + 2) > PATH_MAX) {
+ fprintf(stderr, "error: %s: string buffer is too small",
+ __FUNCTION__);
+ break;
+ }
+ strcat(src_dir, "/");
+ strcat(src_dir, dirent->d_name);
+
+ if (dirent->d_type == DT_UNKNOWN) {
+ struct stat st;
+
+ ret = stat(src_dir, &st);
+ if (ret == 0)
+ dirent->d_type = filetype_dir_table[st.st_mode &
+ S_IFMT];
+ }
+
+ switch(dirent->d_type) {
+ case DT_DIR:
+ ret = traverse_lost_found(src_dir, mount_path);
+ if (ret)
+ goto out;
+ break;
+
+ case DT_REG:
+ sprintf(file_path, "%s", src_dir);
+ xattr_len = getxattr(file_path, "trusted.fid", (void *)&trusted_fid,
+ sizeof(trusted_fid));
+
+ if (xattr_len < 0 || xattr_len < sizeof(trusted_fid)) {
+ /*
+ * Its very much possible that we dont find fid
+ * on precreated files, LAST_ID
+ */
+ continue;
+ }
+
+ ff_group = le64_to_cpu(trusted_fid.ff_group);
+ ff_objid = le64_to_cpu(trusted_fid.ff_objid);
+
+ if (ff_group >= MAX_GROUPS) {
+ fprintf(stderr, "error: invalid group "LPU64" likely"
+ "indicates a corrupt xattr for file %s.\n",
+ ff_group, file_path);
+ continue;
+ }
+
+ /* might need to create the parent directories for this object */
+ sprintf(dest_path, "%s/O/"LPU64"/d"LPU64, mount_path, ff_group,
+ ff_objid % 32);
+
+ ret = mkdir_p(dest_path, mount_path, ff_group);
+ if (ret) {
+ fprintf(stderr, "error: creating directory %s : %s\n",
+ dest_path, strerror(errno));
+ goto out;
+ }
+
+ /*
+ * Object ID needs to be verified against last_id.
+ * LAST_ID file may not be present in the group directory
+ * due to corruption. In case of any error try to recover
+ * as many objects as possible by setting last_id to ~0ULL.
+ */
+ if (last_id[ff_group] == 0) {
+ sprintf(last_id_file, "%s/O/"LPU64"/LAST_ID",
+ mount_path, ff_group);
+ tmp_last_id = read_last_id(last_id_file);
+
+ if (tmp_last_id == 0)
+ tmp_last_id = ~0ULL;
+ last_id[ff_group] = tmp_last_id;
+ }
+
+ if (ff_objid > last_id[ff_group]) {
+ fprintf(stderr, "error: file skipped because object ID "
+ "greater than LAST_ID\nFilename: %s\n"
+ "Group: "LPU64"\nObjectid: "LPU64"\n"
+ "LAST_ID: "LPU64, file_path, ff_group, ff_objid,
+ last_id[ff_group]);
+ continue;
+ }
+
+ /* move file from lost+found to proper object directory */
+ sprintf(dest_path, "%s/O/"LPU64"/d"LPU64"/"LPU64, mount_path,
+ ff_group, ff_objid % 32, ff_objid);
+
+ obj_exists = 1;
+ ret = stat(dest_path, &st);
+ if (ret == 0) {
+ if (st.st_size == 0)
+ obj_exists = 0;
+ } else if (ret < 0 && errno == ENOENT) {
+ obj_exists = 0;
+ }
+
+ if (obj_exists) {
+ fprintf(stderr, "error: target object %s already "
+ "exists and will not be replaced.\n",dest_path);
+ continue;
+ }
+
+ if (rename(file_path, dest_path) < 0) {
+ fprintf(stderr, "error: rename failed for file %s: %s\n",
+ file_path, strerror(errno));
+ error++;
+ continue;
+ }
+
+ printf("Object %s restored.\n", dest_path);
+ break;
+
+ case DT_UNKNOWN:
+ continue;
+ }
+ }
+out:
+ if (dir_ptr)
+ closedir(dir_ptr);
+
+ return error;
}
/*
* object ID found in that group. By the time we come here all possible objects
* have been restored.
*/
-static int check_last_id(const char *mount_path)
+int check_last_id(char *mount_path)
{
- char lastid_path[PATH_MAX];
- char dirname[PATH_MAX], subdirname[PATH_MAX];
- DIR *groupdir, *subdir;
- struct stat st;
- struct dirent *dirent;
- __u64 group;
- __u64 max_objid;
- int fd;
- int ret;
-
- for (group = 0; group < MAX_GROUPS; group++) {
- max_objid = 0;
-
- if (ll_sprintf(dirname, PATH_MAX, "%s/O/"LPU64,
- mount_path, group))
- return 1;
- if (ll_sprintf(lastid_path, PATH_MAX, "%s/LAST_ID", dirname))
- return 1;
-
- if (stat(lastid_path, &st) == 0)
- continue;
-
- groupdir = opendir(dirname);
- if (groupdir == NULL) {
- if (errno != ENOENT)
- fprintf(stderr, "error: opening %s: %s\n",
- dirname, strerror(errno));
- continue;
- }
-
- while ((dirent = readdir(groupdir)) != NULL) {
- if (!strcmp(dirent->d_name, ".") ||
- !strcmp(dirent->d_name, ".."))
- continue;
-
- if (ll_sprintf(subdirname, PATH_MAX, "%s/%s",
- dirname, dirent->d_name)) {
- closedir(groupdir);
- return 1;
- }
- subdir = opendir(subdirname);
- if (subdir == NULL) {
- fprintf(stderr, "error: opening %s: %s\n",
- subdirname, strerror(errno));
- continue;
- }
-
- while ((dirent = readdir(subdir)) != NULL) {
- __u64 objid;
- char *end;
-
- if (!strcmp(dirent->d_name, ".") ||
- !strcmp(dirent->d_name, ".."))
- continue;
-
- objid = strtoull(dirent->d_name, &end, 0);
- if (end == dirent->d_name || *end != 0) {
- fprintf(stderr, "error: unknown object"
- "ID %s/%s\n", subdirname,
- dirent->d_name);
- continue;
- }
- if (objid > max_objid)
- max_objid = objid;
- }
- closedir(subdir);
- }
- closedir(groupdir);
-
- fd = open(lastid_path, O_RDWR | O_CREAT, 0700);
- if (fd < 0) {
- fprintf(stderr, "error: open \"%s\" failed: %s\n",
- lastid_path, strerror(errno));
- return 1;
- }
-
- max_objid = cpu_to_le64(max_objid);
- ret = write(fd, &max_objid, sizeof(__u64));
- if (ret < sizeof(__u64)) {
- fprintf(stderr, "error: write \"%s\" failed: %s\n",
- lastid_path, strerror(errno));
- close(fd);
- return 1;
- }
-
- close(fd);
- }
-
- return 0;
+ char lastid_path[PATH_MAX];
+ char dirname[PATH_MAX], subdirname[PATH_MAX];
+ DIR *groupdir, *subdir;
+ struct stat st;
+ struct dirent *dirent;
+ unsigned long long group;
+ __u64 max_objid;
+ int fd;
+ int ret;
+
+ for (group = 0; group < MAX_GROUPS; group++) {
+ max_objid = 0;
+ sprintf(dirname, "%s/O/%llu", mount_path, group);
+
+ strcpy(lastid_path, dirname);
+ strcat(lastid_path, "/LAST_ID");
+ if (stat(lastid_path, &st) == 0)
+ continue;
+
+ groupdir = opendir(dirname);
+ if (groupdir == NULL) {
+ if (errno != ENOENT)
+ fprintf(stderr, "error: opening %s: %s\n",
+ dirname, strerror(errno));
+ continue;
+ }
+
+ while ((dirent = readdir(groupdir)) != NULL) {
+ if (!strcmp(dirent->d_name, ".") ||
+ !strcmp(dirent->d_name, ".."))
+ continue;
+
+ sprintf(subdirname, "%s/%s", dirname, dirent->d_name);
+
+ subdir = opendir(subdirname);
+ if (subdir == NULL) {
+ fprintf(stderr, "error: opening %s: %s\n",
+ subdirname, strerror(errno));
+ continue;
+ }
+
+ while ((dirent = readdir(subdir)) != NULL) {
+ __u64 objid;
+ char *end;
+
+ if (!strcmp(dirent->d_name, ".") ||
+ !strcmp(dirent->d_name, ".."))
+ continue;
+
+ objid = strtoull(dirent->d_name, &end, 0);
+ if (end == dirent->d_name || *end != 0) {
+ fprintf(stderr, "error: unknown object"
+ "ID %s/%s\n", subdirname,
+ dirent->d_name);
+ continue;
+ }
+ if (objid > max_objid)
+ max_objid = objid;
+ }
+ closedir(subdir);
+ }
+ closedir(groupdir);
+
+ fd = open(lastid_path, O_RDWR | O_CREAT, 0700);
+ if (fd < 0) {
+ fprintf(stderr, "error: open \"%s\" failed: %s\n",
+ lastid_path, strerror(errno));
+ close(fd);
+ return -errno;
+ }
+
+ ret = write(fd, &max_objid, sizeof(__u64));
+ if (ret < sizeof(__u64)) {
+ close(fd);
+ return errno;
+ }
+
+ close(fd);
+ }
+
+ return 0;
}
int main(int argc, char **argv)
{
- char *progname;
- struct stat stat_buf;
- char src_dir[PATH_MAX] = "";
- char mount_path[PATH_MAX];
- char tmp_path[PATH_MAX];
- int c;
- int retval;
-
- progname = argv[0];
-
- while ((c = getopt(argc, argv, "d:hv")) != EOF) {
- switch (c) {
- case 'd':
- if (chdir(optarg)) {
- fprintf(stderr, "error: chdir to %s: %s\n",
- optarg, strerror(errno));
- return 1;
- }
- if (getcwd(src_dir, PATH_MAX) == NULL) {
- fprintf(stderr,
- "error: getcwd of lost+found: %s\n",
- strerror(errno));
- return 1;
- }
- if (chdir("..")) {
- fprintf(stderr, "error: chdir to \"..\": %s\n",
- strerror(errno));
- return 1;
- }
- if (getcwd(mount_path, PATH_MAX) == NULL) {
- fprintf(stderr,
- "error: getcwd of mount point: %s\n",
- strerror(errno));
- return 1;
- }
- if (!strcmp(src_dir, mount_path)) {
- fprintf(stderr,
- "error: root directory is detected\n");
- return 1;
- }
- fprintf(stdout, "\"lost+found\" directory path: %s\n",
- src_dir);
- break;
- case 'v':
- verbose = 1;
- break;
- case 'h':
- usage(progname);
- default:
- fprintf(stderr, "%s: bad option '%c'\n",
- progname, c);
- usage(progname);
- }
- }
-
- if (src_dir[0] == 0)
- usage(progname);
-
- /* Check if 'O' directory exists and create it if needed */
- if (ll_sprintf(tmp_path, PATH_MAX, "%s/O", mount_path))
- return 1;
-
- if (stat(tmp_path, &stat_buf) != 0) {
- retval = mkdir(tmp_path, 0700);
- if (retval == -1) {
- fprintf(stderr, "error: creating objects directory %s:"
- " %s\n", tmp_path, strerror(errno));
- return 1;
- }
- }
-
- retval = traverse_lost_found(src_dir, mount_path);
- if (retval) {
- fprintf(stderr, "error: traversing lost+found looking for "
- "orphan objects.\n");
- return retval;
- }
-
- retval = check_last_id(mount_path);
- if (retval)
- fprintf(stderr, "error: while checking/restoring LAST_ID.\n");
-
- return retval;
+ char *progname;
+ char *src_dir = NULL, *last_dir = NULL;
+ struct stat stat_buf;
+ char tmp_path[PATH_MAX];
+ char mount_path[PATH_MAX] = {0};
+ int c;
+ int retval;
+
+ progname = argv[0];
+
+ while ((c = getopt(argc, argv, "d:hv")) != EOF) {
+ switch (c) {
+ case 'd':
+ src_dir = optarg;
+ /* Trim last '/' */
+ last_dir = strrchr(src_dir, '/');
+ if (last_dir != strchr(src_dir, '/')) {
+ if (last_dir != NULL && (*(last_dir + 1) == '\0'))
+ *(last_dir) = '\0';
+ }
+ fprintf(stdout, "\"lost+found\" directory path: %s\n",
+ src_dir);
+ break;
+ case 'v':
+ verbose = 1;
+ break;
+ case 'h':
+ usage(progname);
+ default:
+ fprintf(stderr, "%s: bad option '%c'\n",
+ progname, c);
+ usage(progname);
+ }
+ }
+
+ if (src_dir == NULL)
+ usage(progname);
+
+ last_dir = strrchr(src_dir, '/');
+ if (last_dir == NULL) {
+ /* Current directory */
+ strcpy(mount_path, src_dir);
+ strcat(mount_path, "/..");
+ } else {
+ strncpy(mount_path, src_dir, (int)(last_dir - src_dir));
+ }
+
+ /* Check if 'O' directory exists and create it if needed */
+ sprintf(tmp_path, "%s/O", mount_path);
+ if (stat(tmp_path, &stat_buf) != 0) {
+ retval = mkdir(tmp_path, 0700);
+ if (retval < 0)
+ fprintf(stderr, "error: creating objects directory %s:"
+ " %s\n", tmp_path, strerror(errno));
+ return errno;
+ }
+
+ memset(grp_info, 0, MAX_GROUPS * sizeof(struct obd_group_info));
+
+ retval = traverse_lost_found(src_dir, mount_path);
+ if (retval) {
+ fprintf(stderr, "error: traversing lost+found looking for "
+ "orphan objects.\n");
+ return retval;
+ }
+
+ retval = check_last_id(mount_path);
+ if (retval)
+ fprintf(stderr, "error: while checking/restoring LAST_ID.\n");
+
+ return retval;
}
git://git.whamcloud.com / fs / lustre-release.git / blobdiff