// SPDX-FileCopyrightText: 2018 - 2023 UnionTech Software Technology Co., Ltd.
//
// SPDX-License-Identifier: GPL-3.0-or-later

#include "semaphore.h"

#include <sys/sem.h>

#include "logger.h"

namespace linglong {

union semun {
    int val;
    struct semid_ds *buf;
    ushort *array;
};

struct Semaphore::SemaphorePrivate {
    explicit SemaphorePrivate(Semaphore *parent = nullptr)
        : q_ptr(parent)
    {
        (void)q_ptr;
    }

    struct sembuf sem_lock = {0, -1, SEM_UNDO};

    struct sembuf sem_unlock = {0, 1, SEM_UNDO};

    int sem_id = -1;

    Semaphore *q_ptr;
};

Semaphore::Semaphore(int key)
    : dd_ptr(new SemaphorePrivate(this))
{
    dd_ptr->sem_id = semget(key, 1, IPC_CREAT | 0666);
    if (dd_ptr->sem_id < 0) {
        logErr() << "semget failed" << util::RetErrString(dd_ptr->sem_id);
    }
}

Semaphore::~Semaphore() = default;

int Semaphore::init()
{
    union semun sem_union = {0};
    sem_union.val = 0;
    logDbg() << "semctl " << dd_ptr->sem_id;
    if (semctl(dd_ptr->sem_id, 0, SETVAL, sem_union) == -1) {
        logErr() << "semctl failed" << util::RetErrString(-1);
    }
    return 0;
}

int Semaphore::passeren()
{
    return semop(dd_ptr->sem_id, &dd_ptr->sem_lock, 1);
}

int Semaphore::vrijgeven()
{
    return semop(dd_ptr->sem_id, &dd_ptr->sem_unlock, 1);
}

} // namespace linglong