thread-utils.h 2.76 KB
Newer Older
Vicent Marti committed
1
/*
Edward Thomson committed
2
 * Copyright (C) the libgit2 contributors. All rights reserved.
Vicent Marti committed
3 4 5 6
 *
 * This file is part of libgit2, distributed under the GNU GPL v2 with
 * a Linking Exception. For full terms see the included COPYING file.
 */
7 8 9
#ifndef INCLUDE_thread_utils_h__
#define INCLUDE_thread_utils_h__

10
#include "common.h"
Vicent Marti committed
11 12 13

/* Common operations even if threading has been disabled */
typedef struct {
14
#if defined(GIT_WIN32)
15 16
	volatile long val;
#else
Vicent Marti committed
17
	volatile int val;
18
#endif
Vicent Marti committed
19 20
} git_atomic;

Vicent Marti committed
21
GIT_INLINE(void) git_atomic_set(git_atomic *a, int val)
Vicent Marti committed
22 23 24 25 26 27
{
	a->val = val;
}

#ifdef GIT_THREADS

28 29 30 31 32 33 34 35
#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
Vicent Marti committed
36 37
#define git_mutex_init(a)	pthread_mutex_init(a, NULL)
#define git_mutex_lock(a)	pthread_mutex_lock(a)
38
#define git_mutex_unlock(a) pthread_mutex_unlock(a)
Vicent Marti committed
39
#define git_mutex_free(a)	pthread_mutex_destroy(a)
40

41 42 43 44 45 46 47
/* 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)
Vicent Marti committed
48

Vicent Marti committed
49
GIT_INLINE(int) git_atomic_inc(git_atomic *a)
Vicent Marti committed
50
{
51
#if defined(GIT_WIN32)
Vicent Marti committed
52
	return InterlockedIncrement(&a->val);
53 54
#elif defined(__GNUC__)
	return __sync_add_and_fetch(&a->val, 1);
Vicent Marti committed
55 56 57 58 59
#else
#	error "Unsupported architecture for atomic operations"
#endif
}

Vicent Marti committed
60
GIT_INLINE(int) git_atomic_dec(git_atomic *a)
Vicent Marti committed
61
{
62
#if defined(GIT_WIN32)
Vicent Marti committed
63
	return InterlockedDecrement(&a->val);
64 65
#elif defined(__GNUC__)
	return __sync_sub_and_fetch(&a->val, 1);
Vicent Marti committed
66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81
#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
82
#define git_mutex_lock(a) 0
Vicent Marti committed
83 84 85
#define git_mutex_unlock(a) (void)0
#define git_mutex_free(a) (void)0

86
/* Pthreads condition vars */
Vicent Marti committed
87 88 89 90 91 92 93
#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

Vicent Marti committed
94
GIT_INLINE(int) git_atomic_inc(git_atomic *a)
Vicent Marti committed
95 96 97 98
{
	return ++a->val;
}

Vicent Marti committed
99
GIT_INLINE(int) git_atomic_dec(git_atomic *a)
Vicent Marti committed
100 101 102 103 104
{
	return --a->val;
}

#endif
105

106
extern int git_online_cpus(void);
107 108

#endif /* INCLUDE_thread_utils_h__ */