RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-17 17:05:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

*** empty log message ***

Browse Source 
git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@668 29311d96-e01e-0410-9327-a35deaab8ce9
This commit is contained in:
sage 2006-02-23 05:37:06 +00:00
parent b5df4a472c
commit 68690dd8c5
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
ceph/client/Client.cc
View File

@ -838,12 +838,6 @@ void Client::handle_file_caps(MClientFileCaps *m)
!(new_caps & CAP_FILE_RDCACHE))
release_inode_buffers(in);
// ack?
if (old_caps & ~new_caps) {
dout(5) << " we lost caps " << cap_string(old_caps & ~new_caps) << ", acking" << endl;
messenger->send_message(m, m->get_source(), m->get_source_port());
}
// wake up waiters?
if (new_caps & CAP_FILE_RD) {
for (list<Cond*>::iterator it = in->waitfor_read.begin();
@ -864,7 +858,15 @@ void Client::handle_file_caps(MClientFileCaps *m)
in->waitfor_write.clear();
}
delete m;
// ack?
if (old_caps & ~new_caps) {
// send back to mds
dout(5) << " we lost caps " << cap_string(old_caps & ~new_caps) << ", acking" << endl;
messenger->send_message(m, m->get_source(), m->get_source_port());
} else {
// discard
delete m;
}
}
void Client::finish_flush(Inode *in)