EXPECT_EQ(sem_destroy(&sem), 0);
}
-static void contendedUse(uint n, int posters, int waiters) {
+static void contendedUse(uint32_t n, int posters, int waiters) {
LifoSemImpl<std::atomic> sem;
std::vector<std::thread> threads;
BENCHMARK_SUSPEND {
for (int t = 0; t < waiters; ++t) {
threads.emplace_back([=,&sem] {
- for (uint i = t; i < n; i += waiters) {
+ for (uint32_t i = t; i < n; i += waiters) {
sem.wait();
}
});
while (!go.load()) {
std::this_thread::yield();
}
- for (uint i = t; i < n; i += posters) {
+ for (uint32_t i = t; i < n; i += posters) {
sem.post();
}
});
}
}
-static void folly_rwspin_reads(uint numOps,
+static void folly_rwspin_reads(uint32_t numOps,
size_t numThreads,
bool useSeparateLocks) {
runContendedReaders<atomic, RWSpinLock, Locker>(
numOps, numThreads, useSeparateLocks);
}
-static void shmtx_wr_pri_reads(uint numOps,
+static void shmtx_wr_pri_reads(uint32_t numOps,
size_t numThreads,
bool useSeparateLocks) {
runContendedReaders<atomic, SharedMutexWritePriority, TokenLocker>(
numOps, numThreads, useSeparateLocks);
}
-static void shmtx_w_bare_reads(uint numOps,
+static void shmtx_w_bare_reads(uint32_t numOps,
size_t numThreads,
bool useSeparateLocks) {
runContendedReaders<atomic, SharedMutexWritePriority, Locker>(
numOps, numThreads, useSeparateLocks);
}
-static void shmtx_rd_pri_reads(uint numOps,
+static void shmtx_rd_pri_reads(uint32_t numOps,
size_t numThreads,
bool useSeparateLocks) {
runContendedReaders<atomic, SharedMutexReadPriority, TokenLocker>(
numOps, numThreads, useSeparateLocks);
}
-static void shmtx_r_bare_reads(uint numOps,
+static void shmtx_r_bare_reads(uint32_t numOps,
size_t numThreads,
bool useSeparateLocks) {
runContendedReaders<atomic, SharedMutexReadPriority, Locker>(
numOps, numThreads, useSeparateLocks);
}
-static void folly_ticket_reads(uint numOps,
+static void folly_ticket_reads(uint32_t numOps,
size_t numThreads,
bool useSeparateLocks) {
runContendedReaders<atomic, RWTicketSpinLock64, Locker>(
numOps, numThreads, useSeparateLocks);
}
-static void boost_shared_reads(uint numOps,
+static void boost_shared_reads(uint32_t numOps,
size_t numThreads,
bool useSeparateLocks) {
runContendedReaders<atomic, boost::shared_mutex, Locker>(
numOps, numThreads, useSeparateLocks);
}
-static void pthrd_rwlock_reads(uint numOps,
+static void pthrd_rwlock_reads(uint32_t numOps,
size_t numThreads,
bool useSeparateLocks) {
runContendedReaders<atomic, PosixRWLock, Locker>(
numOps, numThreads, writeFraction, useSeparateLocks);
}
-static void shmtx_wr_pri(uint numOps,
+static void shmtx_wr_pri(uint32_t numOps,
size_t numThreads,
double writeFraction,
bool useSeparateLocks) {
numOps, numThreads, writeFraction, useSeparateLocks);
}
-static void shmtx_w_bare(uint numOps,
+static void shmtx_w_bare(uint32_t numOps,
size_t numThreads,
double writeFraction,
bool useSeparateLocks) {
numOps, numThreads, writeFraction, useSeparateLocks);
}
-static void shmtx_rd_pri(uint numOps,
+static void shmtx_rd_pri(uint32_t numOps,
size_t numThreads,
double writeFraction,
bool useSeparateLocks) {
numOps, numThreads, writeFraction, useSeparateLocks);
}
-static void shmtx_r_bare(uint numOps,
+static void shmtx_r_bare(uint32_t numOps,
size_t numThreads,
double writeFraction,
bool useSeparateLocks) {