diff options
author | Colin Cross <ccross@android.com> | 2016-01-14 15:35:40 -0800 |
---|---|---|
committer | Colin Cross <ccross@android.com> | 2016-02-08 17:08:49 -0800 |
commit | bcb4ed3eaa92d23949d4ab33dbf1b2604bba8a18 (patch) | |
tree | 3fdec871a3f3ca3762df545224971fa403bb23d4 /libmemunreachable/Semaphore.h | |
parent | aae1eb2c4f10f3d2c49455eb37c4ae4b38ffa47d (diff) | |
download | core-bcb4ed3eaa92d23949d4ab33dbf1b2604bba8a18.tar.gz core-bcb4ed3eaa92d23949d4ab33dbf1b2604bba8a18.tar.bz2 core-bcb4ed3eaa92d23949d4ab33dbf1b2604bba8a18.zip |
imprecise mark and sweep native memory leak detector
libmemunreachable uses an imprecise mark and sweep pass over all memory
allocated by jemalloc in order to find unreachable allocations.
Change-Id: Ia70bbf31f5b40ff71dab28cfd6cd06c5ef01a2d4
Diffstat (limited to 'libmemunreachable/Semaphore.h')
-rw-r--r-- | libmemunreachable/Semaphore.h | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/libmemunreachable/Semaphore.h b/libmemunreachable/Semaphore.h new file mode 100644 index 000000000..45e8c819d --- /dev/null +++ b/libmemunreachable/Semaphore.h @@ -0,0 +1,56 @@ +/* + * Copyright (C) 2016 The Android Open Source Project + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef LIBMEMUNREACHABLE_SEMAPHORE_H_ +#define LIBMEMUNREACHABLE_SEMAPHORE_H_ + +#include <chrono> +#include <mutex> + +#include "android-base/macros.h" + +class Semaphore { + public: + Semaphore(int count = 0) : count_(count) {} + ~Semaphore() = default; + + void Wait(std::chrono::milliseconds ms) { + std::unique_lock<std::mutex> lk(m_); + cv_.wait_for(lk, ms, [&]{ + if (count_ > 0) { + count_--; + return true; + } + return false; + }); + } + void Post() { + { + std::lock_guard<std::mutex> lk(m_); + count_++; + } + cv_.notify_one(); + } + private: + DISALLOW_COPY_AND_ASSIGN(Semaphore); + + int count_; + std::mutex m_; + std::condition_variable cv_; +}; + + +#endif // LIBMEMUNREACHABLE_SEMAPHORE_H_ |