Skip to content

Commit

Permalink
Merge pull request ceph#7274 from dillaman/wip-helgrind-race-jewel
Browse files Browse the repository at this point in the history
helgrind: additional race conditionslibrbd: journal replay should honor inter-event dependencies

Reviewed-by: Josh Durgin <[email protected]>
  • Loading branch information
jdurgin committed Jan 19, 2016
2 parents 2208e82 + 1aa674c commit 44f78d8
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 2 deletions.
3 changes: 3 additions & 0 deletions src/librados/IoCtxImpl.cc
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@
#include "librados/PoolAsyncCompletionImpl.h"
#include "librados/RadosClient.h"
#include "include/assert.h"
#include "common/valgrind.h"

#define dout_subsys ceph_subsys_rados
#undef dout_prefix
Expand Down Expand Up @@ -1159,6 +1160,8 @@ int librados::IoCtxImpl::getxattrs(const object_t& oid,

void librados::IoCtxImpl::set_sync_op_version(version_t ver)
{
ANNOTATE_BENIGN_RACE_SIZED(&last_objver, sizeof(last_objver),
"IoCtxImpl last_objver");
last_objver = ver;
}

Expand Down
4 changes: 2 additions & 2 deletions src/librbd/ExclusiveLock.cc
Original file line number Diff line number Diff line change
Expand Up @@ -339,8 +339,8 @@ void ExclusiveLock<I>::send_acquire_lock() {

template <typename I>
void ExclusiveLock<I>::handle_acquiring_lock(int r) {
CephContext *cct = m_image_ctx.cct;
ldout(cct, 10) << this << " " << __func__ << dendl;
Mutex::Locker locker(m_lock);
ldout(m_image_ctx.cct, 10) << this << " " << __func__ << dendl;

assert(r == 0);
assert(m_state == STATE_ACQUIRING);
Expand Down
1 change: 1 addition & 0 deletions src/msg/simple/Pipe.cc
Original file line number Diff line number Diff line change
Expand Up @@ -84,6 +84,7 @@ Pipe::Pipe(SimpleMessenger *r, int st, PipeConnection *con)
send_keepalive_ack(false),
connect_seq(0), peer_global_seq(0),
out_seq(0), in_seq(0), in_seq_acked(0) {
ANNOTATE_BENIGN_RACE_SIZED(&sd, sizeof(sd), "Pipe socket");
ANNOTATE_BENIGN_RACE_SIZED(&state, sizeof(state), "Pipe state");
ANNOTATE_BENIGN_RACE_SIZED(&recv_len, sizeof(recv_len), "Pipe recv_len");
ANNOTATE_BENIGN_RACE_SIZED(&recv_ofs, sizeof(recv_ofs), "Pipe recv_ofs");
Expand Down

0 comments on commit 44f78d8

Please sign in to comment.