Remove unused mutex wrappers
This commit is contained in:
116
src/thread.c
116
src/thread.c
@@ -1,116 +0,0 @@
|
||||
/* thread.c
|
||||
** strophe XMPP client library -- thread abstraction
|
||||
**
|
||||
** Copyright (C) 2005-2009 Collecta, Inc.
|
||||
**
|
||||
** This software is provided AS-IS with no warranty, either express
|
||||
** or implied.
|
||||
**
|
||||
** This program is dual licensed under the MIT and GPLv3 licenses.
|
||||
*/
|
||||
|
||||
/** @file
|
||||
* Thread absraction.
|
||||
*/
|
||||
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
|
||||
#ifdef _WIN32
|
||||
#define WIN32_LEAN_AND_MEAN
|
||||
#include <windows.h>
|
||||
#else
|
||||
#include <pthread.h>
|
||||
#endif
|
||||
|
||||
#include "strophe.h"
|
||||
#include "common.h"
|
||||
#include "thread.h"
|
||||
|
||||
struct _mutex_t {
|
||||
const xmpp_ctx_t *ctx;
|
||||
|
||||
#ifdef _WIN32
|
||||
HANDLE mutex;
|
||||
#else
|
||||
pthread_mutex_t *mutex;
|
||||
#endif
|
||||
};
|
||||
|
||||
/* mutex functions */
|
||||
|
||||
mutex_t *mutex_create(const xmpp_ctx_t * ctx)
|
||||
{
|
||||
mutex_t *mutex;
|
||||
|
||||
mutex = xmpp_alloc(ctx, sizeof(mutex_t));
|
||||
if (mutex) {
|
||||
mutex->ctx = ctx;
|
||||
#ifdef _WIN32
|
||||
mutex->mutex = CreateMutex(NULL, FALSE, NULL);
|
||||
#else
|
||||
mutex->mutex = xmpp_alloc(ctx, sizeof(pthread_mutex_t));
|
||||
if (mutex->mutex)
|
||||
if (pthread_mutex_init(mutex->mutex, NULL) != 0) {
|
||||
xmpp_free(ctx, mutex->mutex);
|
||||
mutex->mutex = NULL;
|
||||
}
|
||||
#endif
|
||||
if (!mutex->mutex) {
|
||||
xmpp_free(ctx, mutex);
|
||||
mutex = NULL;
|
||||
}
|
||||
}
|
||||
|
||||
return mutex;
|
||||
}
|
||||
|
||||
int mutex_destroy(mutex_t *mutex)
|
||||
{
|
||||
int ret = 1;
|
||||
const xmpp_ctx_t *ctx;
|
||||
|
||||
#ifdef _WIN32
|
||||
if (mutex->mutex)
|
||||
ret = CloseHandle(mutex->mutex);
|
||||
#else
|
||||
if (mutex->mutex)
|
||||
ret = pthread_mutex_destroy(mutex->mutex) == 0;
|
||||
#endif
|
||||
ctx = mutex->ctx;
|
||||
xmpp_free(ctx, mutex);
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
int mutex_lock(mutex_t *mutex)
|
||||
{
|
||||
int ret;
|
||||
|
||||
#ifdef _WIN32
|
||||
ret = WaitForSingleObject(mutex->mutex, INFINITE) == 0;
|
||||
#else
|
||||
ret = pthread_mutex_lock(mutex->mutex) == 0;
|
||||
#endif
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
int mutex_trylock(mutex_t *mutex)
|
||||
{
|
||||
/* TODO */
|
||||
return 0;
|
||||
}
|
||||
|
||||
int mutex_unlock(mutex_t *mutex)
|
||||
{
|
||||
int ret;
|
||||
|
||||
#ifdef _WIN32
|
||||
ret = ReleaseMutex(mutex->mutex);
|
||||
#else
|
||||
ret = pthread_mutex_unlock(mutex->mutex) == 0;
|
||||
#endif
|
||||
|
||||
return ret;
|
||||
}
|
||||
40
src/thread.h
40
src/thread.h
@@ -1,40 +0,0 @@
|
||||
/* thread.h
|
||||
** strophe XMPP client library -- thread abstraction header
|
||||
**
|
||||
** Copyright (C) 2005-2009 Collecta, Inc.
|
||||
**
|
||||
** This software is provided AS-IS with no warranty, either express
|
||||
** or implied.
|
||||
**
|
||||
** This program is dual licensed under the MIT and GPLv3 licenses.
|
||||
*/
|
||||
|
||||
/** @file
|
||||
* Threading abstraction API.
|
||||
*/
|
||||
|
||||
#ifndef __LIBSTROPHE_THREAD_H__
|
||||
#define __LIBSTROPHE_THREAD_H__
|
||||
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
|
||||
#ifdef _WIN32
|
||||
#include <windows.h>
|
||||
#else
|
||||
#include <pthread.h>
|
||||
#endif
|
||||
|
||||
#include "strophe.h"
|
||||
|
||||
typedef struct _mutex_t mutex_t;
|
||||
|
||||
/* mutex functions */
|
||||
|
||||
mutex_t *mutex_create(const xmpp_ctx_t *ctx);
|
||||
int mutex_destroy(mutex_t *mutex);
|
||||
int mutex_lock(mutex_t *mutex);
|
||||
int mutex_trylock(mutex_t *mutex);
|
||||
int mutex_unlock(mutex_t *mutex);
|
||||
|
||||
#endif /* __LIBSTROPHE_THREAD_H__ */
|
||||
Reference in New Issue
Block a user