From: Samuel Just Date: Fri, 19 Apr 2013 00:39:10 +0000 (-0700) Subject: common/: add tracked_int_ptr.hpp X-Git-Tag: v0.61~136^2~7 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=66c007fb3b71156a72e8bcfd8295a3e8f812d1bb;p=ceph.git common/: add tracked_int_ptr.hpp TrackedIntPtr acts like intrusive_ptr, but is able to track a ref id. Signed-off-by: Samuel Just --- diff --git a/src/Makefile.am b/src/Makefile.am index d528b78a1bef..cd360fcd147a 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -1601,6 +1601,7 @@ noinst_HEADERS = \ common/admin_socket.h \ common/admin_socket_client.h \ common/shared_cache.hpp \ + common/tracked_int_ptr.hpp \ common/simple_cache.hpp \ common/sharedptr_registry.hpp \ common/map_cacher.hpp \ diff --git a/src/common/tracked_int_ptr.hpp b/src/common/tracked_int_ptr.hpp new file mode 100644 index 000000000000..ba0900db6bd9 --- /dev/null +++ b/src/common/tracked_int_ptr.hpp @@ -0,0 +1,67 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab +/* + * Ceph - scalable distributed file system + * + * Copyright (C) 2013 Inktank Storage, Inc. + * + * This is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software + * Foundation. See file COPYING. + * + */ + +#ifndef CEPH_TRACKEDINTPTR_H +#define CEPH_TRACKEDINTPTR_H + +#include +#include +#include +#include +#include "common/Mutex.h" +#include "common/Cond.h" + +template +class TrackedIntPtr { + T *ptr; + uint64_t id; +public: + TrackedIntPtr() : ptr(NULL), id(0) {} + TrackedIntPtr(T *ptr) : ptr(ptr), id(ptr ? get_with_id(ptr) : 0) {} + ~TrackedIntPtr() { + if (ptr) + put_with_id(ptr, id); + else + assert(id == 0); + } + void swap(TrackedIntPtr &other) { + T *optr = other.ptr; + uint64_t oid = other.id; + other.ptr = ptr; + other.id = id; + ptr = optr; + id = oid; + } + TrackedIntPtr(const TrackedIntPtr &rhs) : + ptr(rhs.ptr), id(ptr ? get_with_id(ptr) : 0) {} + + void operator=(const TrackedIntPtr &rhs) { + TrackedIntPtr o(rhs.ptr); + swap(o); + } + T &operator*() { + return *ptr; + } + T *operator->() { + return ptr; + } + bool operator<(const TrackedIntPtr &lhs) const { + return ptr < lhs.ptr; + } + bool operator==(const TrackedIntPtr &lhs) const { + return ptr == lhs.ptr; + } +}; + +#endif