Bug #4679 » 0001-ceph-add-osd-request-to-inode-unsafe-list-in-advance.patch
| fs/ceph/caps.c | ||
|---|---|---|
|
if (list_empty(head))
|
||
|
goto out;
|
||
|
/* set upper bound as _last_ entry in chain */
|
||
|
req = list_entry(head->prev, struct ceph_osd_request,
|
||
|
r_unsafe_item);
|
||
|
last_tid = req->r_tid;
|
||
|
/* set upper bound as last started request */
|
||
|
last_tid = (u64)-1;
|
||
|
list_for_each_entry_reverse(req, head, r_unsafe_item) {
|
||
|
if (req->r_tid != (u64)-1) {
|
||
|
last_tid = req->r_tid;
|
||
|
break;
|
||
|
}
|
||
|
}
|
||
|
if (last_tid == (u64)-1)
|
||
|
goto out;
|
||
|
do {
|
||
|
ceph_osdc_get_request(req);
|
||
| fs/ceph/file.c | ||
|---|---|---|
|
if ((file->f_flags & O_SYNC) == 0) {
|
||
|
/* get a second commit callback */
|
||
|
req->r_safe_callback = sync_write_commit;
|
||
|
req->r_inode = inode;
|
||
|
req->r_tid = (u64)-1;
|
||
|
own_pages = true;
|
||
|
spin_lock(&ci->i_unsafe_lock);
|
||
|
list_add_tail(&req->r_unsafe_item,
|
||
|
&ci->i_unsafe_writes);
|
||
|
spin_unlock(&ci->i_unsafe_lock);
|
||
|
ceph_get_cap_refs(ci, CEPH_CAP_FILE_WR);
|
||
|
}
|
||
|
}
|
||
|
osd_req_op_extent_osd_data_pages(req, 0, true, pages, len,
|
||
| ... | ... | |
|
ret = ceph_osdc_start_request(&fsc->client->osdc, req, false);
|
||
|
if (!ret) {
|
||
|
if (req->r_safe_callback) {
|
||
|
/*
|
||
|
* Add to inode unsafe list only after we
|
||
|
* start_request so that a tid has been assigned.
|
||
|
*/
|
||
|
spin_lock(&ci->i_unsafe_lock);
|
||
|
list_add_tail(&req->r_unsafe_item,
|
||
|
&ci->i_unsafe_writes);
|
||
|
spin_unlock(&ci->i_unsafe_lock);
|
||
|
ceph_get_cap_refs(ci, CEPH_CAP_FILE_WR);
|
||
|
}
|
||
|
|
||
|
ret = ceph_osdc_wait_request(&fsc->client->osdc, req);
|
||
|
if (ret < 0 && req->r_safe_callback) {
|
||
|
spin_lock(&ci->i_unsafe_lock);
|
||
|
list_del_init(&req->r_unsafe_item);
|
||
|
spin_unlock(&ci->i_unsafe_lock);
|
||
|
ceph_put_cap_refs(ci, CEPH_CAP_FILE_WR);
|
||
|
}
|
||
|
} else if (req->r_safe_callback) {
|
||
|
spin_lock(&ci->i_unsafe_lock);
|
||
|
list_del_init(&req->r_unsafe_item);
|
||
|
spin_unlock(&ci->i_unsafe_lock);
|
||
|
ceph_put_cap_refs(ci, CEPH_CAP_FILE_WR);
|
||
|
}
|
||
|
if (file->f_flags & O_DIRECT)
|
||