762655010d
* js/async-thread:
fast-import: die_nicely() back to vsnprintf (reverts part of ebaa79f)
Enable threaded async procedures whenever pthreads is available
Dying in an async procedure should only exit the thread, not the process.
Reimplement async procedures using pthreads
Windows: more pthreads functions
Fix signature of fcntl() compatibility dummy
Make report() from usage.c public as vreportf() and use it.
Modernize t5530-upload-pack-error.
Conflicts:
http-backend.c
100 lines
2.6 KiB
C
100 lines
2.6 KiB
C
/*
|
|
* Header used to adapt pthread-based POSIX code to Windows API threads.
|
|
*
|
|
* Copyright (C) 2009 Andrzej K. Haczewski <ahaczewski@gmail.com>
|
|
*/
|
|
|
|
#ifndef PTHREAD_H
|
|
#define PTHREAD_H
|
|
|
|
#ifndef WIN32_LEAN_AND_MEAN
|
|
#define WIN32_LEAN_AND_MEAN
|
|
#endif
|
|
|
|
#include <windows.h>
|
|
|
|
/*
|
|
* Defines that adapt Windows API threads to pthreads API
|
|
*/
|
|
#define pthread_mutex_t CRITICAL_SECTION
|
|
|
|
#define pthread_mutex_init(a,b) (InitializeCriticalSection((a)), 0)
|
|
#define pthread_mutex_destroy(a) DeleteCriticalSection((a))
|
|
#define pthread_mutex_lock EnterCriticalSection
|
|
#define pthread_mutex_unlock LeaveCriticalSection
|
|
|
|
typedef int pthread_mutexattr_t;
|
|
#define pthread_mutexattr_init(a) (*(a) = 0)
|
|
#define pthread_mutexattr_destroy(a) do {} while (0)
|
|
#define pthread_mutexattr_settype(a, t) 0
|
|
#define PTHREAD_MUTEX_RECURSIVE 0
|
|
|
|
/*
|
|
* Implement simple condition variable for Windows threads, based on ACE
|
|
* implementation.
|
|
*
|
|
* See original implementation: http://bit.ly/1vkDjo
|
|
* ACE homepage: http://www.cse.wustl.edu/~schmidt/ACE.html
|
|
* See also: http://www.cse.wustl.edu/~schmidt/win32-cv-1.html
|
|
*/
|
|
typedef struct {
|
|
LONG waiters;
|
|
int was_broadcast;
|
|
CRITICAL_SECTION waiters_lock;
|
|
HANDLE sema;
|
|
HANDLE continue_broadcast;
|
|
} pthread_cond_t;
|
|
|
|
extern int pthread_cond_init(pthread_cond_t *cond, const void *unused);
|
|
extern int pthread_cond_destroy(pthread_cond_t *cond);
|
|
extern int pthread_cond_wait(pthread_cond_t *cond, CRITICAL_SECTION *mutex);
|
|
extern int pthread_cond_signal(pthread_cond_t *cond);
|
|
extern int pthread_cond_broadcast(pthread_cond_t *cond);
|
|
|
|
/*
|
|
* Simple thread creation implementation using pthread API
|
|
*/
|
|
typedef struct {
|
|
HANDLE handle;
|
|
void *(*start_routine)(void*);
|
|
void *arg;
|
|
DWORD tid;
|
|
} pthread_t;
|
|
|
|
extern int pthread_create(pthread_t *thread, const void *unused,
|
|
void *(*start_routine)(void*), void *arg);
|
|
|
|
/*
|
|
* To avoid the need of copying a struct, we use small macro wrapper to pass
|
|
* pointer to win32_pthread_join instead.
|
|
*/
|
|
#define pthread_join(a, b) win32_pthread_join(&(a), (b))
|
|
|
|
extern int win32_pthread_join(pthread_t *thread, void **value_ptr);
|
|
|
|
#define pthread_equal(t1, t2) ((t1).tid == (t2).tid)
|
|
extern pthread_t pthread_self(void);
|
|
|
|
static inline int pthread_exit(void *ret)
|
|
{
|
|
ExitThread((DWORD)ret);
|
|
}
|
|
|
|
typedef DWORD pthread_key_t;
|
|
static inline int pthread_key_create(pthread_key_t *keyp, void (*destructor)(void *value))
|
|
{
|
|
return (*keyp = TlsAlloc()) == TLS_OUT_OF_INDEXES ? EAGAIN : 0;
|
|
}
|
|
|
|
static inline int pthread_setspecific(pthread_key_t key, const void *value)
|
|
{
|
|
return TlsSetValue(key, (void *)value) ? 0 : EINVAL;
|
|
}
|
|
|
|
static inline void *pthread_getspecific(pthread_key_t key)
|
|
{
|
|
return TlsGetValue(key);
|
|
}
|
|
|
|
#endif /* PTHREAD_H */
|