diff options
| author | Samuel Just <sam.just@inktank.com> | 2013-05-23 15:24:39 -0700 |
|---|---|---|
| committer | Samuel Just <sam.just@inktank.com> | 2013-05-23 19:42:32 -0700 |
| commit | d62716dd4ceb29032759bf84e864d214fe38a17c (patch) | |
| tree | 9e41c86b85965518e4e45b5525f5cdb7545a620a | |
| parent | b8a25e08a638c31b9cfc2c1bf6d9bad40e921a9f (diff) | |
| download | ceph-d62716dd4ceb29032759bf84e864d214fe38a17c.tar.gz | |
PG: reset timeout in _scan_list for each object, read chunk
Signed-off-by: Samuel Just <sam.just@inktank.com>
| -rw-r--r-- | src/osd/PG.cc | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/osd/PG.cc b/src/osd/PG.cc index a419c68de17..6e8079dae5a 100644 --- a/src/osd/PG.cc +++ b/src/osd/PG.cc @@ -3258,6 +3258,7 @@ void PG::_scan_list( for (vector<hobject_t>::iterator p = ls.begin(); p != ls.end(); ++p, i++) { + handle.reset_tp_timeout(); hobject_t poid = *p; struct stat st; @@ -3277,6 +3278,7 @@ void PG::_scan_list( while ( (r = osd->store->read(coll, poid, pos, g_conf->osd_deep_scrub_stride, bl, true)) > 0) { + handle.reset_tp_timeout(); h << bl; pos += bl.length(); bl.clear(); |