Source code
Revision control
Copy as Markdown
Other Tools
/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* vim: set ts=8 sts=2 et sw=2 tw=80: */
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
#include "CrossProcessSemaphore.h"
#include "nsDebug.h"
#include "nsISupportsImpl.h"
#include <mach/mach_time.h>
static const uint64_t kNsPerUs = 1000;
static const uint64_t kNsPerSec = 1000000000;
namespace mozilla {
/* static */
CrossProcessSemaphore* CrossProcessSemaphore::Create(const char*,
uint32_t aInitialValue) {
semaphore_t sem = SEMAPHORE_NULL;
if (semaphore_create(mach_task_self(), &sem, SYNC_POLICY_FIFO,
aInitialValue) == KERN_SUCCESS &&
sem != SEMAPHORE_NULL) {
return new CrossProcessSemaphore(CrossProcessSemaphoreHandle(sem));
}
return nullptr;
}
/* static */
CrossProcessSemaphore* CrossProcessSemaphore::Create(
CrossProcessSemaphoreHandle aHandle) {
if (!aHandle) {
return nullptr;
}
return new CrossProcessSemaphore(std::move(aHandle));
}
CrossProcessSemaphore::CrossProcessSemaphore(
CrossProcessSemaphoreHandle aSemaphore)
: mSemaphore(std::move(aSemaphore)) {
MOZ_COUNT_CTOR(CrossProcessSemaphore);
}
CrossProcessSemaphore::~CrossProcessSemaphore() {
MOZ_ASSERT(mSemaphore, "Improper construction of semaphore or double free.");
MOZ_COUNT_DTOR(CrossProcessSemaphore);
}
bool CrossProcessSemaphore::Wait(const Maybe<TimeDuration>& aWaitTime) {
MOZ_ASSERT(mSemaphore, "Improper construction of semaphore.");
int kr = KERN_OPERATION_TIMED_OUT;
// semaphore_(timed)wait may be interrupted by KERN_ABORTED. Carefully restart
// the wait until it either succeeds or times out.
if (aWaitTime.isNothing()) {
do {
kr = semaphore_wait(mSemaphore.get());
} while (kr == KERN_ABORTED);
} else {
mach_timebase_info_data_t tb;
if (mach_timebase_info(&tb) != KERN_SUCCESS) {
return false;
}
uint64_t now = (mach_absolute_time() * tb.numer) / tb.denom;
uint64_t deadline = now + uint64_t(kNsPerUs * aWaitTime->ToMicroseconds());
while (now <= deadline) {
uint64_t ns = deadline - now;
mach_timespec_t ts;
ts.tv_sec = ns / kNsPerSec;
ts.tv_nsec = ns % kNsPerSec;
kr = semaphore_timedwait(mSemaphore.get(), ts);
if (kr != KERN_ABORTED) {
break;
}
now = (mach_absolute_time() * tb.numer) / tb.denom;
}
}
return kr == KERN_SUCCESS;
}
void CrossProcessSemaphore::Signal() {
MOZ_ASSERT(mSemaphore, "Improper construction of semaphore.");
semaphore_signal(mSemaphore.get());
}
CrossProcessSemaphoreHandle CrossProcessSemaphore::CloneHandle() {
// Transfer the mach port backing the semaphore.
return mozilla::RetainMachSendRight(mSemaphore.get());
}
void CrossProcessSemaphore::CloseHandle() {}
} // namespace mozilla