static const uint64_t WAIT_FROZEN = (1<<1);
static const uint64_t WAIT_TRUNC = (1<<2);
static const uint64_t WAIT_FLOCK = (1<<3);
- static const uint64_t WAIT_UNLINK = (1<<4);
-
+
static const uint64_t WAIT_ANY_MASK = (uint64_t)(-1);
// misc
if (target_pin != dir->inode &&
target_realm->get_subvolume_ino() !=
dir->inode->find_snaprealm()->get_subvolume_ino()) {
- if (target_pin->is_stray()) {
- mds->locker->drop_locks(mdr.get());
- targeti->add_waiter(CInode::WAIT_UNLINK,
- new C_MDS_RetryRequest(mdcache, mdr));
- mdlog->flush();
- return;
- }
dout(7) << "target is in different subvolume, failing..." << dendl;
respond_to_request(mdr, -CEPHFS_EXDEV);
return;
C_MDS_rename_finish *fin = new C_MDS_rename_finish(this, mdr, srcdn, destdn, straydn);
journal_and_reply(mdr, srci, destdn, le, fin);
-
- // trigger to flush mdlog in case reintegrating or migrating the stray dn,
- // because the link requests maybe waiting.
- if (srcdn->get_dir()->inode->is_stray()) {
- mdlog->flush();
- }
mds->balancer->maybe_fragment(destdn->get_dir(), false);
}
srcdn->get_dir()->unlink_inode(srcdn);
- // After the stray dn being unlinked from the corresponding inode in case of
- // reintegrate_stray/migrate_stray, just wake up the waitiers.
- MDSContext::vec finished;
- in->take_waiting(CInode::WAIT_UNLINK, finished);
- if (!finished.empty()) {
- mds->queue_waiters(finished);
- }
-
// dest
if (srcdn_was_remote) {
if (!linkmerge) {
dir->remove_dentry(dn);
}
- // Once we are here normally the waiter list are mostly empty
- // but in corner case that the clients pass a invalidate ino,
- // which maybe under unlinking, the link caller will add the
- // request to the waiter list. We need try to wake them up
- // anyway.
- MDSContext::vec finished;
- in->take_waiting(CInode::WAIT_UNLINK, finished);
- if (!finished.empty()) {
- mds->queue_waiters(finished);
- }
-
// drop inode
inodeno_t ino = in->ino();
if (in->is_dirty())