src/ipc/sem.hpp

Idź do dokumentacji tego pliku.

/* header file for core/ipc/sem.cpp */

#ifndef _CORE_IPC_SEM_HPP
#define _CORE_IPC_SEM_HPP

#include "src/common/blist.hpp"
// #include "src/thread/thread.hpp"

// extern class blist_t named_sems;

struct thread_t;

// namespace IPC {
// namespace Sem {

//sem flags
const uint32 SF_OPEN    = 1;    //when the sem is open

// info on a waiting thread
struct thwait_t
 {
        struct thread_t *thread;
        uint64 timestamp;       //when the thread was added to the waiting queue
 };

// a single semaphore
struct sem_t
 {
        class blist_t wait_queue;       // threads which happen to request the sem when it's non-vacant will be put here.
        class IPC::Lock::lock_t lock_sem;       //we still need a lock for the val
        int volatile val;       //tha boss. he tells you what ya'll do

        uint32 flags;   //custom flags

        const char *name;       // purrrely debugical. has to be const char*
 };

int sem_init(sem_t *sem, unsigned int value, const char *name);
int sem_destroy(sem_t *sem);
int sem_getvalue(sem_t *sem, int *sval);
int sem_wait(sem_t *sem);
int sem_trywait(sem_t *sem);
int sem_post(sem_t *sem);


//   }; /*namespace Sem*/
//  };  /*naemespace IPC*/


#endif

---