153a5a1b3Sopenharmony_ci/***
253a5a1b3Sopenharmony_ci  This file is part of PulseAudio.
353a5a1b3Sopenharmony_ci
453a5a1b3Sopenharmony_ci  Copyright 2006 Pierre Ossman <ossman@cendio.se> for Cendio AB
553a5a1b3Sopenharmony_ci
653a5a1b3Sopenharmony_ci  PulseAudio is free software; you can redistribute it and/or modify
753a5a1b3Sopenharmony_ci  it under the terms of the GNU Lesser General Public License as published
853a5a1b3Sopenharmony_ci  by the Free Software Foundation; either version 2.1 of the License,
953a5a1b3Sopenharmony_ci  or (at your option) any later version.
1053a5a1b3Sopenharmony_ci
1153a5a1b3Sopenharmony_ci  PulseAudio is distributed in the hope that it will be useful, but
1253a5a1b3Sopenharmony_ci  WITHOUT ANY WARRANTY; without even the implied warranty of
1353a5a1b3Sopenharmony_ci  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
1453a5a1b3Sopenharmony_ci  General Public License for more details.
1553a5a1b3Sopenharmony_ci
1653a5a1b3Sopenharmony_ci  You should have received a copy of the GNU Lesser General Public License
1753a5a1b3Sopenharmony_ci  along with PulseAudio; if not, see <http://www.gnu.org/licenses/>.
1853a5a1b3Sopenharmony_ci***/
1953a5a1b3Sopenharmony_ci
2053a5a1b3Sopenharmony_ci#ifdef HAVE_CONFIG_H
2153a5a1b3Sopenharmony_ci#include <config.h>
2253a5a1b3Sopenharmony_ci#endif
2353a5a1b3Sopenharmony_ci
2453a5a1b3Sopenharmony_ci#include <windows.h>
2553a5a1b3Sopenharmony_ci
2653a5a1b3Sopenharmony_ci#include <pulse/xmalloc.h>
2753a5a1b3Sopenharmony_ci#include <pulsecore/macro.h>
2853a5a1b3Sopenharmony_ci
2953a5a1b3Sopenharmony_ci#include "semaphore.h"
3053a5a1b3Sopenharmony_ci
3153a5a1b3Sopenharmony_cistruct pa_semaphore {
3253a5a1b3Sopenharmony_ci    HANDLE sema;
3353a5a1b3Sopenharmony_ci};
3453a5a1b3Sopenharmony_ci
3553a5a1b3Sopenharmony_cipa_semaphore* pa_semaphore_new(unsigned value) {
3653a5a1b3Sopenharmony_ci    pa_semaphore *s;
3753a5a1b3Sopenharmony_ci
3853a5a1b3Sopenharmony_ci    s = pa_xnew(pa_semaphore, 1);
3953a5a1b3Sopenharmony_ci
4053a5a1b3Sopenharmony_ci    s->sema = CreateSemaphore(NULL, value, 32767, NULL);
4153a5a1b3Sopenharmony_ci    pa_assert(s->sema != NULL);
4253a5a1b3Sopenharmony_ci
4353a5a1b3Sopenharmony_ci    return s;
4453a5a1b3Sopenharmony_ci}
4553a5a1b3Sopenharmony_ci
4653a5a1b3Sopenharmony_civoid pa_semaphore_free(pa_semaphore *s) {
4753a5a1b3Sopenharmony_ci    pa_assert(s);
4853a5a1b3Sopenharmony_ci    CloseHandle(s->sema);
4953a5a1b3Sopenharmony_ci    pa_xfree(s);
5053a5a1b3Sopenharmony_ci}
5153a5a1b3Sopenharmony_ci
5253a5a1b3Sopenharmony_civoid pa_semaphore_post(pa_semaphore *s) {
5353a5a1b3Sopenharmony_ci    pa_assert(s);
5453a5a1b3Sopenharmony_ci    ReleaseSemaphore(s->sema, 1, NULL);
5553a5a1b3Sopenharmony_ci}
5653a5a1b3Sopenharmony_ci
5753a5a1b3Sopenharmony_civoid pa_semaphore_wait(pa_semaphore *s) {
5853a5a1b3Sopenharmony_ci    pa_assert(s);
5953a5a1b3Sopenharmony_ci    WaitForSingleObject(s->sema, INFINITE);
6053a5a1b3Sopenharmony_ci}
61