RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-18 01:16:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

PG: reset timeout in _scan_list for each object, read chunk

Browse Source 
Signed-off-by: Samuel Just <sam.just@inktank.com>
This commit is contained in:
Samuel Just 2013-05-23 15:24:39 -07:00
parent b8a25e08a6
commit d62716dd4c
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/osd/PG.cc
View File

@ -3258,6 +3258,7 @@ void PG::_scan_list(
for (vector<hobject_t>::iterator p = ls.begin(); for (vector<hobject_t>::iterator p = ls.begin();
p != ls.end(); p != ls.end();
++p, i++) { ++p, i++) {
handle.reset_tp_timeout();
hobject_t poid = *p; hobject_t poid = *p;
struct stat st; struct stat st;
@ -3277,6 +3278,7 @@ void PG::_scan_list(
while ( (r = osd->store->read(coll, poid, pos, while ( (r = osd->store->read(coll, poid, pos,
g_conf->osd_deep_scrub_stride, bl, g_conf->osd_deep_scrub_stride, bl,
true)) > 0) { true)) > 0) {
handle.reset_tp_timeout();
h << bl; h << bl;
pos += bl.length(); pos += bl.length();
bl.clear(); bl.clear();