thodg/libgit2/src/thread-utils.h

• Show log

  Commit

• Hash : 7a6f51de
  Author :
  Date : 2012-01-26T18:03:14
  

  win32: Use the Windows Atomic API on MinGW too

Download

• src/thread-utils.h

• /*
   * Copyright (C) 2009-2011 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 -- disabled by now */
  #define git_cond unsigned int //pthread_cond_t
  #define git_cond_init(c, a)	(void)0		//pthread_cond_init(c, a)
  #define git_cond_free(c) (void)0		//pthread_cond_destroy(c)
  #define git_cond_wait(c, l)	(void)0		//pthread_cond_wait(c, l)
  #define git_cond_signal(c)	(void)0		//pthread_cond_signal(c)
  #define git_cond_broadcast(c) (void)0	//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__ */
  

Download