+ struct mdd_device *mdd = (struct mdd_device *)thread->mgt_data;
+ struct dt_object *dor = mdd->mdd_orphans;
+ struct lu_dirent *ent = &mdd_env_info(env)->mti_ent;
+ const struct dt_it_ops *iops;
+ struct dt_it *it;
+ struct lu_fid fid;
+ int key_sz = 0;
+ int rc;
+ ENTRY;
+
+ iops = &dor->do_index_ops->dio_it;
+ it = iops->init(env, dor, LUDA_64BITHASH);
+ if (IS_ERR(it)) {
+ rc = PTR_ERR(it);
+ CERROR("%s: cannot clean '%s': rc = %d\n",
+ mdd2obd_dev(mdd)->obd_name, mdd_orphan_index_name, rc);
+ GOTO(out, rc);
+ }
+
+ rc = iops->load(env, it, 0);
+ if (rc < 0)
+ GOTO(out_put, rc);
+ if (rc == 0) {
+ CERROR("%s: error loading iterator to clean '%s'\n",
+ mdd2obd_dev(mdd)->obd_name, mdd_orphan_index_name);
+ /* Index contains no zero key? */
+ GOTO(out_put, rc = -EIO);
+ }
+
+ mdd_env_info(env)->mti_flags |= MTI_KEEP_KEY;
+ do {
+ if (thread->mgt_abort)
+ break;
+
+ key_sz = iops->key_size(env, it);
+ /* filter out "." and ".." entries from PENDING dir. */
+ if (key_sz < 8)
+ goto next;
+
+ rc = iops->rec(env, it, (struct dt_rec *)ent, LUDA_64BITHASH);
+ if (rc != 0) {
+ CERROR("%s: fail to get FID for orphan it: rc = %d\n",
+ mdd2obd_dev(mdd)->obd_name, rc);
+ goto next;
+ }
+
+ fid_le_to_cpu(&fid, &ent->lde_fid);
+ if (!fid_is_sane(&fid)) {
+ CERROR("%s: bad FID "DFID" cleaning '%s'\n",
+ mdd2obd_dev(mdd)->obd_name, PFID(&fid),
+ mdd_orphan_index_name);
+ goto next;
+ }
+
+ /* kill orphan object */
+ iops->put(env, it);
+ rc = mdd_orphan_key_test_and_delete(env, mdd, &fid,
+ (struct dt_key *)ent->lde_name);
+ /* after index delete reset iterator */
+ if (rc == 0)
+ rc = iops->get(env, it, (const void *)"");
+next:
+ rc = iops->next(env, it);
+ } while (rc == 0);
+
+ GOTO(out_put, rc = 0);
+out_put:
+ iops->put(env, it);
+ iops->fini(env, it);
+
+out:
+ return rc;