summaryrefslogtreecommitdiffstats
path: root/base/task.h
diff options
context:
space:
mode:
authordarin@chromium.org <darin@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2009-09-28 18:12:55 +0000
committerdarin@chromium.org <darin@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2009-09-28 18:12:55 +0000
commit13f383ff5fc8ff095501794d4ce758f0067ff9b5 (patch)
treeceb1d08f38759bf8805ede009924a990bae496e5 /base/task.h
parentf61f331824ac9c98684a886be0d918aefe69d3ce (diff)
downloadchromium_src-13f383ff5fc8ff095501794d4ce758f0067ff9b5.zip
chromium_src-13f383ff5fc8ff095501794d4ce758f0067ff9b5.tar.gz
chromium_src-13f383ff5fc8ff095501794d4ce758f0067ff9b5.tar.bz2
Assert that thread-safe reference counting is used with
cross-thread NewRunnableMethod. This assertion caught such an error in VisitedLinkMaster! My approach, modify RunnableMethodTraits<T> to assert that when ReleaseCallee happens on a different thread from RetainCallee that the type supports thread-safe reference counting. I do this by adding a static method to both RefCounted<T> and RefCountedThreadSafe<T>. This results in a little ugliness in cases where people implement AddRef and Release by hand (to make the no-ops). There may be a nicer way to deal with those few cases. R=brettw BUG=none TEST=none Review URL: http://codereview.chromium.org/251012 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@27379 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'base/task.h')
-rw-r--r--base/task.h34
1 files changed, 28 insertions, 6 deletions
diff --git a/base/task.h b/base/task.h
index c827681..e9da8b3 100644
--- a/base/task.h
+++ b/base/task.h
@@ -205,12 +205,33 @@ class ReleaseTask : public CancelableTask {
template <class T>
struct RunnableMethodTraits {
- static void RetainCallee(T* obj) {
+ RunnableMethodTraits() {
+#ifndef NDEBUG
+ origin_thread_id_ = PlatformThread::CurrentId();
+#endif
+ }
+
+ ~RunnableMethodTraits() {
+#ifndef NDEBUG
+ // If destroyed on a separate thread, then we had better have been using
+ // thread-safe reference counting!
+ if (origin_thread_id_ != PlatformThread::CurrentId())
+ DCHECK(T::ImplementsThreadSafeReferenceCounting());
+#endif
+ }
+
+ void RetainCallee(T* obj) {
obj->AddRef();
}
- static void ReleaseCallee(T* obj) {
+
+ void ReleaseCallee(T* obj) {
obj->Release();
}
+
+ private:
+#ifndef NDEBUG
+ PlatformThreadId origin_thread_id_;
+#endif
};
// RunnableMethod and RunnableFunction -----------------------------------------
@@ -240,13 +261,13 @@ struct RunnableMethodTraits {
// RunnableMethod and NewRunnableMethod implementation -------------------------
template <class T, class Method, class Params>
-class RunnableMethod : public CancelableTask,
- public RunnableMethodTraits<T> {
+class RunnableMethod : public CancelableTask {
public:
RunnableMethod(T* obj, Method meth, const Params& params)
: obj_(obj), meth_(meth), params_(params) {
- RetainCallee(obj_);
+ traits_.RetainCallee(obj_);
}
+
~RunnableMethod() {
ReleaseCallee();
}
@@ -263,7 +284,7 @@ class RunnableMethod : public CancelableTask,
private:
void ReleaseCallee() {
if (obj_) {
- RunnableMethodTraits<T>::ReleaseCallee(obj_);
+ traits_.ReleaseCallee(obj_);
obj_ = NULL;
}
}
@@ -271,6 +292,7 @@ class RunnableMethod : public CancelableTask,
T* obj_;
Method meth_;
Params params_;
+ RunnableMethodTraits<T> traits_;
};
template <class T, class Method>