Chromium Code Reviews| Index: base/win/scoped_handle.cc |
| diff --git a/base/win/scoped_handle.cc b/base/win/scoped_handle.cc |
| index 7b38369d5aa2706a8f7469f994ed1c1d48801846..be887af1bc5007075ef2fdcb1ae0d213174794e7 100644 |
| --- a/base/win/scoped_handle.cc |
| +++ b/base/win/scoped_handle.cc |
| @@ -4,11 +4,12 @@ |
| #include "base/win/scoped_handle.h" |
| -#include <map> |
| - |
| +#include "base/containers/hash_tables.h" |
| #include "base/debug/alias.h" |
| +#include "base/hash.h" |
| #include "base/lazy_instance.h" |
| -#include "base/synchronization/lock.h" |
| +#include "base/logging.h" |
| +#include "base/synchronization/lock_impl.h" |
| #include "base/win/windows_version.h" |
| namespace { |
| @@ -19,23 +20,82 @@ struct Info { |
| const void* pc2; |
| DWORD thread_id; |
| }; |
| -typedef std::map<HANDLE, Info> HandleMap; |
| +typedef base::hash_map<HANDLE, Info> HandleMap; |
| +typedef base::internal::LockImpl NativeLock; |
| base::LazyInstance<HandleMap>::Leaky g_handle_map = LAZY_INSTANCE_INITIALIZER; |
| -base::LazyInstance<base::Lock>::Leaky g_lock = LAZY_INSTANCE_INITIALIZER; |
| +base::LazyInstance<NativeLock>::Leaky g_lock = LAZY_INSTANCE_INITIALIZER; |
| +bool g_closing = false; |
| +bool g_verifier_enabled = false; |
| + |
| +bool CloseHandleWrapper(HANDLE handle) { |
| + if (!::CloseHandle(handle)) |
| + CHECK(false); |
| + return true; |
| +} |
| + |
| +// Simple automatic locking using a native critical section so it supports |
| +// recursive locking. |
| +class AutoNativeLock { |
| + public: |
| + explicit AutoNativeLock(NativeLock& lock) : lock_(lock) { |
| + lock_.Lock(); |
| + } |
| + |
| + ~AutoNativeLock() { |
| + lock_.Unlock(); |
| + } |
| + |
| + private: |
| + NativeLock& lock_; |
| + DISALLOW_COPY_AND_ASSIGN(AutoNativeLock); |
| +}; |
| } // namespace |
| +namespace BASE_HASH_NAMESPACE { |
| +#if defined(COMPILER_MSVC) |
| +inline size_t hash_value(const HANDLE& handle) { |
| + ULONG_PTR int_handle = reinterpret_cast<ULONG_PTR>(handle); |
| + return base::Hash(reinterpret_cast<char*>(&int_handle), sizeof(int_handle)); |
| +} |
| +#elif defined (COMPILER_GCC) |
| +template <> |
|
cpu_(ooo_6.6-7.5)
2014/08/22 01:52:04
this branch is for nacl?
rvargas (doing something else)
2014/08/22 02:10:32
Not really. It is for completeness if people are t
cpu_(ooo_6.6-7.5)
2014/08/22 22:10:20
Acknowledged.
|
| +struct hash<HANDLE> { |
| + size_t operator()(const HANDLE& key) const { |
| + ULONG_PTR int_handle = reinterpret_cast<ULONG_PTR>(handle); |
| + return base::Hash(reinterpret_cast<char*>(&int_handle), sizeof(int_handle)); |
|
cpu_(ooo_6.6-7.5)
2014/08/22 01:52:05
shouldn't we be doing bit_cast<char[N]> or somesuc
rvargas (doing something else)
2014/08/22 02:10:31
Maybe? what is N? sizeof? I wanted to be explicit/
cpu_(ooo_6.6-7.5)
2014/08/22 22:10:20
yes sizeof.
rvargas (doing something else)
2014/08/23 02:22:07
Done.
|
| + } |
| +}; |
| +#endif |
| +} // BASE_HASH_NAMESPACE |
| + |
| namespace base { |
| namespace win { |
| // Static. |
| +bool HandleTraits::CloseHandle(HANDLE handle) { |
| + if (!g_verifier_enabled) |
| + return CloseHandleWrapper(handle); |
| + |
| + AutoNativeLock lock(g_lock.Get()); |
| + g_closing = true; |
| + CloseHandleWrapper(handle); |
| + g_closing = false; |
| + |
| + return true; |
| +} |
| + |
| +// Static. |
| void VerifierTraits::StartTracking(HANDLE handle, const void* owner, |
| const void* pc1, const void* pc2) { |
| + if (!g_verifier_enabled) |
| + return; |
| + |
| // Grab the thread id before the lock. |
| DWORD thread_id = GetCurrentThreadId(); |
| - AutoLock lock(g_lock.Get()); |
| + AutoNativeLock lock(g_lock.Get()); |
| Info handle_info = { owner, pc1, pc2, thread_id }; |
| std::pair<HANDLE, Info> item(handle, handle_info); |
| @@ -50,7 +110,10 @@ void VerifierTraits::StartTracking(HANDLE handle, const void* owner, |
| // Static. |
| void VerifierTraits::StopTracking(HANDLE handle, const void* owner, |
| const void* pc1, const void* pc2) { |
| - AutoLock lock(g_lock.Get()); |
| + if (!g_verifier_enabled) |
| + return; |
| + |
| + AutoNativeLock lock(g_lock.Get()); |
| HandleMap::iterator i = g_handle_map.Get().find(handle); |
| if (i == g_handle_map.Get().end()) |
| CHECK(false); |
| @@ -64,5 +127,23 @@ void VerifierTraits::StopTracking(HANDLE handle, const void* owner, |
| g_handle_map.Get().erase(i); |
| } |
| +void EnableHandleVerifier() { |
| + g_verifier_enabled = true; |
| +} |
| + |
| +void OnHandleBeingClosed(HANDLE handle) { |
| + AutoNativeLock lock(g_lock.Get()); |
| + if (g_closing) |
| + return; |
| + |
| + HandleMap::iterator i = g_handle_map.Get().find(handle); |
| + if (i == g_handle_map.Get().end()) |
| + return; |
| + |
| + Info other = i->second; |
| + debug::Alias(&other); |
| + CHECK(false); |
| +} |
| + |
| } // namespace win |
| } // namespace base |