Condition.c File Reference

#include <assert.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include "Condition.h"

Go to the source code of this file.

Macros
#define	_Class   _Condition

Functions
Class *	_Condition (void)
static void	_signal (Condition *self)
static void	_wait (Condition *self)
static void	broadcast (Condition *self)
static void	dealloc (Object *self)
static Condition *	init (Condition *self)
static void	initialize (Class *clazz)
static _Bool	waitUntilDate (Condition *self, const Date *date)

Macro Definition Documentation

_Class

#define _Class   _Condition

Definition at line 34 of file Condition.c.

Function Documentation

_Condition()

Class * _Condition

(

void

)

Definition at line 141 of file Condition.c.

                        {
    static Class *clazz;
    static Once once;
 
    do_once(&once, {
        clazz = _initialize(&(const ClassDef) {
            .name = "Condition",
            .superclass = _Lock(),
            .instanceSize = sizeof(Condition),
            .interfaceOffset = offsetof(Condition, interface),
            .interfaceSize = sizeof(ConditionInterface),
            .initialize = initialize,
        });
    });
 
    return clazz;
}

_signal()

static void _signal ( Condition *  self )

static

Definition at line 86 of file Condition.c.

                                     {
 
    int err = pthread_cond_signal(self->condition);
    assert(err == 0);
}

_wait()

static void _wait ( Condition *  self )

static

Definition at line 96 of file Condition.c.

                                   {
 
    int err = pthread_cond_wait(self->condition, self->lock.lock);
    assert(err == 0);
}

broadcast()

static void broadcast ( Condition *  self )

static

Definition at line 57 of file Condition.c.

                                       {
 
    int err = pthread_cond_broadcast(self->condition);
    assert(err == 0);
}

dealloc()

static void dealloc ( Object *  self )

static

See also

Object::dealloc(Object *)

Definition at line 41 of file Condition.c.

                                  {
 
    Condition *this = (Condition *) self;
 
    pthread_cond_destroy(this->condition);
    free(this->condition);
 
    super(Object, self, dealloc);
}

init()

static Condition * init ( Condition *  self )

static

Definition at line 67 of file Condition.c.

                                        {
 
    self = (Condition *) super(Lock, self, init);
    if (self) {
 
        self->condition = calloc(1, sizeof(pthread_cond_t));
        assert(self->condition);
 
        const int err = pthread_cond_init(self->condition, NULL);
        assert(err == 0);
    }
 
    return self;
}

initialize()

static void initialize ( Class *  clazz )

static

See also

Class::initialize(Class *)

Definition at line 126 of file Condition.c.

                                     {
 
    ((ObjectInterface *) clazz->interface)->dealloc = dealloc;
 
    ((ConditionInterface *) clazz->interface)->broadcast = broadcast;
    ((ConditionInterface *) clazz->interface)->init = init;
    ((ConditionInterface *) clazz->interface)->signal = _signal;
    ((ConditionInterface *) clazz->interface)->wait = _wait;
    ((ConditionInterface *) clazz->interface)->waitUntilDate = waitUntilDate;
}

waitUntilDate()

static _Bool waitUntilDate ( Condition *  self, const Date *  date  )

static

Definition at line 106 of file Condition.c.

                                                              {
 
    Lock *lock = (Lock *) self;
 
    const struct timespec time = {
        .tv_sec = date->time.tv_sec,
        .tv_nsec = date->time.tv_usec * 1000
    };
 
    int err = pthread_cond_timedwait(self->condition, lock->lock, &time);
    assert(err == 0 || err == ETIMEDOUT);
 
    return err == 0;
}