pthreadex.c

Go to the documentation of this file.

/*
    clsync - file tree sync utility based on inotify/kqueue
 
    Copyright (C) 2013-2014 Dmitry Yu Okunev <dyokunev@ut.mephi.ru> 0x8E30679C
 
    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.
 
    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.
 
    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
#include <string.h>
#include <pthread.h>
#include "pthreadex.h"
#include "malloc.h"
 
int pthread_mutex_init_shared ( pthread_mutex_t **mutex_p )
{
    static pthread_mutex_t mutex_initial = PTHREAD_MUTEX_INITIALIZER;
    *mutex_p = shm_malloc_try ( sizeof ( **mutex_p ) );
    memcpy ( *mutex_p, &mutex_initial, sizeof ( mutex_initial ) );
    pthread_mutexattr_t attr;
    pthread_mutexattr_init ( &attr );
    pthread_mutexattr_setpshared ( &attr, PTHREAD_PROCESS_SHARED );
    return pthread_mutex_init ( *mutex_p, &attr );
}
 
int pthread_mutex_destroy_shared ( pthread_mutex_t *mutex_p )
{
    int rc;
    rc = pthread_mutex_destroy ( mutex_p );
    shm_free ( mutex_p );
    return rc;
}
 
int pthread_cond_init_shared ( pthread_cond_t **cond_p )
{
    static pthread_cond_t cond_initial = PTHREAD_COND_INITIALIZER;
    *cond_p = shm_malloc ( sizeof ( **cond_p ) );
    memcpy ( *cond_p, &cond_initial, sizeof ( cond_initial ) );
    pthread_condattr_t attr;
    pthread_condattr_init ( &attr );
    pthread_condattr_setpshared ( &attr, PTHREAD_PROCESS_SHARED );
    return pthread_cond_init ( *cond_p, &attr );
}
 
int pthread_cond_destroy_shared ( pthread_cond_t *cond_p )
{
    int rc;
    rc = pthread_cond_destroy ( cond_p );
    shm_free ( cond_p );
    return rc;
}
 
int pthread_mutex_reltimedlock ( pthread_mutex_t *mutex_p, long tv_sec, long tv_nsec )
{
    struct timespec abs_time;
 
    if ( clock_gettime ( CLOCK_REALTIME, &abs_time ) )
        return -1;
 
    abs_time.tv_sec  += tv_sec;
    abs_time.tv_nsec += tv_nsec;
 
    if ( abs_time.tv_nsec > 1000 * 1000 * 1000 ) {
        abs_time.tv_sec++;
        abs_time.tv_nsec -= 1000 * 1000 * 1000;
    }
 
    return pthread_mutex_timedlock ( mutex_p, &abs_time );
}