mirror of
https://git.proxmox.com/git/libgit2
synced 2025-05-03 14:12:22 +00:00
109 lines
2.8 KiB
C
109 lines
2.8 KiB
C
/*
|
|
* Copyright (C) 2009-2012 the libgit2 contributors
|
|
*
|
|
* This file is part of libgit2, distributed under the GNU GPL v2 with
|
|
* a Linking Exception. For full terms see the included COPYING file.
|
|
*/
|
|
#ifndef INCLUDE_thread_utils_h__
|
|
#define INCLUDE_thread_utils_h__
|
|
|
|
#include "common.h"
|
|
|
|
/* Common operations even if threading has been disabled */
|
|
typedef struct {
|
|
#if defined(GIT_WIN32)
|
|
volatile long val;
|
|
#else
|
|
volatile int val;
|
|
#endif
|
|
} git_atomic;
|
|
|
|
GIT_INLINE(void) git_atomic_set(git_atomic *a, int val)
|
|
{
|
|
a->val = val;
|
|
}
|
|
|
|
#ifdef GIT_THREADS
|
|
|
|
#define git_thread pthread_t
|
|
#define git_thread_create(thread, attr, start_routine, arg) pthread_create(thread, attr, start_routine, arg)
|
|
#define git_thread_kill(thread) pthread_cancel(thread)
|
|
#define git_thread_exit(status) pthread_exit(status)
|
|
#define git_thread_join(id, status) pthread_join(id, status)
|
|
|
|
/* Pthreads Mutex */
|
|
#define git_mutex pthread_mutex_t
|
|
#define git_mutex_init(a) pthread_mutex_init(a, NULL)
|
|
#define git_mutex_lock(a) pthread_mutex_lock(a)
|
|
#define git_mutex_unlock(a) pthread_mutex_unlock(a)
|
|
#define git_mutex_free(a) pthread_mutex_destroy(a)
|
|
|
|
/* Pthreads condition vars */
|
|
#define git_cond pthread_cond_t
|
|
#define git_cond_init(c) pthread_cond_init(c, NULL)
|
|
#define git_cond_free(c) pthread_cond_destroy(c)
|
|
#define git_cond_wait(c, l) pthread_cond_wait(c, l)
|
|
#define git_cond_signal(c) pthread_cond_signal(c)
|
|
#define git_cond_broadcast(c) pthread_cond_broadcast(c)
|
|
|
|
GIT_INLINE(int) git_atomic_inc(git_atomic *a)
|
|
{
|
|
#if defined(GIT_WIN32)
|
|
return InterlockedIncrement(&a->val);
|
|
#elif defined(__GNUC__)
|
|
return __sync_add_and_fetch(&a->val, 1);
|
|
#else
|
|
# error "Unsupported architecture for atomic operations"
|
|
#endif
|
|
}
|
|
|
|
GIT_INLINE(int) git_atomic_dec(git_atomic *a)
|
|
{
|
|
#if defined(GIT_WIN32)
|
|
return InterlockedDecrement(&a->val);
|
|
#elif defined(__GNUC__)
|
|
return __sync_sub_and_fetch(&a->val, 1);
|
|
#else
|
|
# error "Unsupported architecture for atomic operations"
|
|
#endif
|
|
}
|
|
|
|
#else
|
|
|
|
#define git_thread unsigned int
|
|
#define git_thread_create(thread, attr, start_routine, arg) (void)0
|
|
#define git_thread_kill(thread) (void)0
|
|
#define git_thread_exit(status) (void)0
|
|
#define git_thread_join(id, status) (void)0
|
|
|
|
/* Pthreads Mutex */
|
|
#define git_mutex unsigned int
|
|
#define git_mutex_init(a) (void)0
|
|
#define git_mutex_lock(a) (void)0
|
|
#define git_mutex_unlock(a) (void)0
|
|
#define git_mutex_free(a) (void)0
|
|
|
|
/* Pthreads condition vars */
|
|
#define git_cond unsigned int
|
|
#define git_cond_init(c, a) (void)0
|
|
#define git_cond_free(c) (void)0
|
|
#define git_cond_wait(c, l) (void)0
|
|
#define git_cond_signal(c) (void)0
|
|
#define git_cond_broadcast(c) (void)0
|
|
|
|
GIT_INLINE(int) git_atomic_inc(git_atomic *a)
|
|
{
|
|
return ++a->val;
|
|
}
|
|
|
|
GIT_INLINE(int) git_atomic_dec(git_atomic *a)
|
|
{
|
|
return --a->val;
|
|
}
|
|
|
|
#endif
|
|
|
|
extern int git_online_cpus(void);
|
|
|
|
#endif /* INCLUDE_thread_utils_h__ */
|