RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-21 19:02:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'wip-8100'

Browse Source 
Reviewed-by: Mark Nelson <mark.nelson@inktank.com>
This commit is contained in:
David Zafman 2014-04-16 15:09:09 -07:00
commit a3d759ebdd
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/common/obj_bencher.cc
View File

@ -584,7 +584,7 @@ int ObjBencher::seq_read_bench(int seconds_to_run, int num_objects, int concurre
completion_wait(slot);
lock.Lock();
r = completion_ret(slot);
if (r != 0) {
if (r < 0) {
cerr << "read got " << r << std::endl;
lock.Unlock();
goto ERR;
@ -627,7 +627,7 @@ int ObjBencher::seq_read_bench(int seconds_to_run, int num_objects, int concurre
completion_wait(slot);
lock.Lock();
r = completion_ret(slot);
if (r != 0) {
if (r < 0) {
cerr << "read got " << r << std::endl;
lock.Unlock();
goto ERR;
@ -771,7 +771,7 @@ int ObjBencher::rand_read_bench(int seconds_to_run, int num_objects, int concurr
completion_wait(slot);
lock.Lock();
r = completion_ret(slot);
if (r != 0) {
if (r < 0) {
cerr << "read got " << r << std::endl;
lock.Unlock();
goto ERR;
@ -814,7 +814,7 @@ int ObjBencher::rand_read_bench(int seconds_to_run, int num_objects, int concurr
completion_wait(slot);
lock.Lock();
r = completion_ret(slot);
if (r != 0) {
if (r < 0) {
cerr << "read got " << r << std::endl;
lock.Unlock();
goto ERR;