summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorRussell Belfer <rb@github.com>2013-04-15 16:31:04 -0700
committerVicent Marti <tanoku@gmail.com>2013-04-22 16:52:07 +0200
commitc628918625c7f779d2050a56998fb2b675f097fb (patch)
tree90ae07f0127035f5ad15633d914290e507ef0ed3 /src
parente976b56dda6ae3d7d81bd114b61750e97cc918d3 (diff)
downloadlibgit2-c628918625c7f779d2050a56998fb2b675f097fb.tar.gz
Fixes for Windows cas/threading stuff
Diffstat (limited to 'src')
-rw-r--r--src/thread-utils.h9
-rw-r--r--src/win32/pthread.c17
2 files changed, 15 insertions, 11 deletions
diff --git a/src/thread-utils.h b/src/thread-utils.h
index 7b663182d..e53a60c05 100644
--- a/src/thread-utils.h
+++ b/src/thread-utils.h
@@ -71,16 +71,15 @@ GIT_INLINE(int) git_atomic_dec(git_atomic *a)
GIT_INLINE(void *) git___compare_and_swap(
volatile void **ptr, void *oldval, void *newval)
{
- bool swapped;
+ void *foundval;
#if defined(GIT_WIN32)
- swapped = ((LONGLONG)oldval == InterlockedCompareExchange64(
- (LONGLONG volatile *)ptr, (LONGLONG)newval, (LONGLONG)oldval));
+ foundval = InterlockedCompareExchangePointer(ptr, newval, oldval);
#elif defined(__GNUC__)
- swapped = (__sync_val_compare_and_swap(ptr, oldval, newval) == oldval);
+ foundval = __sync_val_compare_and_swap(ptr, oldval, newval);
#else
# error "Unsupported architecture for atomic operations"
#endif
- return swapped ? oldval : newval;
+ return (foundval == oldval) ? oldval : newval;
}
#else
diff --git a/src/win32/pthread.c b/src/win32/pthread.c
index 105f4b89e..c78213f15 100644
--- a/src/win32/pthread.c
+++ b/src/win32/pthread.c
@@ -14,18 +14,23 @@ int pthread_create(
void *GIT_RESTRICT arg)
{
GIT_UNUSED(attr);
- *thread = (pthread_t) CreateThread(
+ *thread = CreateThread(
NULL, 0, (LPTHREAD_START_ROUTINE)start_routine, arg, 0, NULL);
return *thread ? 0 : -1;
}
int pthread_join(pthread_t thread, void **value_ptr)
{
- int ret;
- ret = WaitForSingleObject(thread, INFINITE);
- if (ret && value_ptr)
- GetExitCodeThread(thread, (void*) value_ptr);
- return -(!!ret);
+ DWORD ret = WaitForSingleObject(thread, INFINITE);
+
+ if (ret == WAIT_OBJECT_0) {
+ if (value_ptr != NULL)
+ GetExitCodeThread(thread, (void *)value_ptr);
+ CloseHandle(thread);
+ return 0;
+ }
+
+ return -1;
}
int pthread_mutex_init(pthread_mutex_t *GIT_RESTRICT mutex,