123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081 |
- /*
- 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 );
- }
|