| 12633 | } |
| 12634 | |
| 12635 | int Client::WriteEncMgr_Buffered::do_write() |
| 12636 | { |
| 12637 | ldout(cct, 10) << __func__ << dendl; |
| 12638 | int r = 0; |
| 12639 | |
| 12640 | // do buffered write |
| 12641 | if (!in->oset.dirty_or_tx) |
| 12642 | clnt->get_cap_ref(in, CEPH_CAP_FILE_CACHE | CEPH_CAP_FILE_BUFFER); |
| 12643 | |
| 12644 | clnt->get_cap_ref(in, CEPH_CAP_FILE_BUFFER); |
| 12645 | |
| 12646 | // async, caching, non-blocking. |
| 12647 | r = clnt->objectcacher->file_write(&in->oset, &in->layout, |
| 12648 | in->snaprealm->get_snap_context(), |
| 12649 | offset, size, *pbl, ceph::real_clock::now(), |
| 12650 | 0, iofinish, |
| 12651 | !async |
| 12652 | ? clnt->objectcacher->CFG_block_writes_upfront() |
| 12653 | : false); |
| 12654 | |
| 12655 | return r; |
| 12656 | } |
| 12657 | |
| 12658 | int Client::WriteEncMgr_NotBuffered::do_write() |
| 12659 | { |
nothing calls this directly
no test coverage detected