RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-03 17:42:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

mds: implement look_for_lock, for fcntl F_GETLK-style things

Browse Source
This commit is contained in:
Greg Farnum 2010-04-29 16:00:10 -07:00
parent 5d375ea7cf
commit 0dbcdd8486
2 changed files with 26 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/mds/Server.cc
View File

@ -2660,7 +2660,7 @@ void Server::handle_client_file_readlock(MDRequest *mdr)
<< ", dropping request!" << dendl;
return;
}
lock_state->add_lock(checking_lock, false, false);
lock_state->look_for_lock(checking_lock);
bufferlist lock_bl;
::encode(lock_state, lock_bl);

28
src/mds/mdstypes.h
View File

@ -385,6 +385,28 @@ struct ceph_lock_state_t {
return false;
}
void look_for_lock(ceph_filelock& testing_lock) {
list<ceph_filelock*> overlapping_locks, self_overlapping_locks;
if (get_overlapping_locks(testing_lock, overlapping_locks)) {
split_by_owner(testing_lock, overlapping_locks, self_overlapping_locks);
}
if (!overlapping_locks.empty()) { //somebody else owns overlapping lock
if (CEPH_LOCK_EXCL == testing_lock.type) { //any lock blocks it
testing_lock = *(*overlapping_locks.begin());
} else {
ceph_filelock *blocking_lock;
if ((blocking_lock = contains_exclusive_lock(overlapping_locks))) {
testing_lock = *blocking_lock;
} else { //nothing blocking!
testing_lock.type = CEPH_LOCK_UNLOCK;
}
}
return;
}
//if we get here, only our own locks block
testing_lock.type = CEPH_LOCK_UNLOCK;
}
/*
* Remove lock(s) described in old_lock. This may involve splitting a
* previous lock or making a previous lock smaller.
@ -659,13 +681,13 @@ private:
}
}
bool contains_exclusive_lock(list<ceph_filelock*>& locks) {
ceph_filelock *contains_exclusive_lock(list<ceph_filelock*>& locks) {
for (list<ceph_filelock*>::iterator iter = locks.begin();
iter != locks.end();
++iter) {
if (CEPH_LOCK_EXCL == (*iter)->type) return true;
if (CEPH_LOCK_EXCL == (*iter)->type) return *iter;
}
return false;
return NULL;
}
public: