summaryrefslogtreecommitdiff
path: root/libgcrypt-1.4.6/src/ath.c
diff options
context:
space:
mode:
Diffstat (limited to 'libgcrypt-1.4.6/src/ath.c')
-rw-r--r--libgcrypt-1.4.6/src/ath.c140
1 files changed, 70 insertions, 70 deletions
diff --git a/libgcrypt-1.4.6/src/ath.c b/libgcrypt-1.4.6/src/ath.c
index 0c274cd..fe7f289 100644
--- a/libgcrypt-1.4.6/src/ath.c
+++ b/libgcrypt-1.4.6/src/ath.c
@@ -38,7 +38,7 @@
#include "ath.h"
-
+
/* The interface table. */
static struct ath_ops ops;
@@ -58,7 +58,7 @@ static int ops_set;
#define GET_VERSION(a) (((a) >> 8)& 0xff)
-
+
/* The lock we take while checking for lazy lock initialization. */
static ath_mutex_t check_init_lock = ATH_MUTEX_INITIALIZER;
@@ -68,13 +68,13 @@ ath_init (void)
int err = 0;
if (ops_set)
- {
- if (ops.init)
+ {
+ if (ops.init)
err = (*ops.init) ();
- if (err)
+ if (err)
return err;
- err = (*ops.mutex_init) (&check_init_lock);
- }
+ err = (*ops.mutex_init) (&check_init_lock);
+ }
return err;
}
@@ -86,38 +86,38 @@ gpg_err_code_t
ath_install (struct ath_ops *ath_ops, int check_only)
{
if (check_only)
- {
- unsigned int option = 0;
-
- /* Check if the requested thread option is compatible to the
+ {
+ unsigned int option = 0;
+
+ /* Check if the requested thread option is compatible to the
thread option we are already committed to. */
- if (ath_ops)
+ if (ath_ops)
option = ath_ops->option;
- if (!ops_set && GET_OPTION (option))
+ if (!ops_set && GET_OPTION (option))
return GPG_ERR_NOT_SUPPORTED;
- if (GET_OPTION (ops.option) == ATH_THREAD_OPTION_USER
+ if (GET_OPTION (ops.option) == ATH_THREAD_OPTION_USER
|| GET_OPTION (option) == ATH_THREAD_OPTION_USER
|| GET_OPTION (ops.option) != GET_OPTION (option)
- || GET_VERSION (ops.option) != GET_VERSION (option))
+ || GET_VERSION (ops.option) != GET_VERSION (option))
return GPG_ERR_NOT_SUPPORTED;
- return 0;
- }
-
+ return 0;
+ }
+
if (ath_ops)
- {
- /* It is convenient to not require DESTROY. */
- if (!ath_ops->mutex_init || !ath_ops->mutex_lock
+ {
+ /* It is convenient to not require DESTROY. */
+ if (!ath_ops->mutex_init || !ath_ops->mutex_lock
|| !ath_ops->mutex_unlock)
return GPG_ERR_INV_ARG;
- ops = *ath_ops;
- ops_set = 1;
- }
+ ops = *ath_ops;
+ ops_set = 1;
+ }
else
- ops_set = 0;
+ ops_set = 0;
return 0;
}
@@ -129,11 +129,11 @@ mutex_init (ath_mutex_t *lock, int just_check)
int err = 0;
if (just_check)
- (*ops.mutex_lock) (&check_init_lock);
+ (*ops.mutex_lock) (&check_init_lock);
if (*lock == ATH_MUTEX_INITIALIZER || !just_check)
- err = (*ops.mutex_init) (lock);
+ err = (*ops.mutex_init) (lock);
if (just_check)
- (*ops.mutex_unlock) (&check_init_lock);
+ (*ops.mutex_unlock) (&check_init_lock);
return err;
}
@@ -142,7 +142,7 @@ int
ath_mutex_init (ath_mutex_t *lock)
{
if (ops_set)
- return mutex_init (lock, 0);
+ return mutex_init (lock, 0);
#ifndef NDEBUG
*lock = MUTEX_UNLOCKED;
@@ -155,19 +155,19 @@ int
ath_mutex_destroy (ath_mutex_t *lock)
{
if (ops_set)
- {
- if (!ops.mutex_destroy)
+ {
+ if (!ops.mutex_destroy)
return 0;
- (*ops.mutex_lock) (&check_init_lock);
- if (*lock == ATH_MUTEX_INITIALIZER)
+ (*ops.mutex_lock) (&check_init_lock);
+ if (*lock == ATH_MUTEX_INITIALIZER)
{
(*ops.mutex_unlock) (&check_init_lock);
return 0;
}
- (*ops.mutex_unlock) (&check_init_lock);
- return (*ops.mutex_destroy) (lock);
- }
+ (*ops.mutex_unlock) (&check_init_lock);
+ return (*ops.mutex_destroy) (lock);
+ }
#ifndef NDEBUG
assert (*lock == MUTEX_UNLOCKED);
@@ -182,12 +182,12 @@ int
ath_mutex_lock (ath_mutex_t *lock)
{
if (ops_set)
- {
- int ret = mutex_init (lock, 1);
- if (ret)
+ {
+ int ret = mutex_init (lock, 1);
+ if (ret)
return ret;
- return (*ops.mutex_lock) (lock);
- }
+ return (*ops.mutex_lock) (lock);
+ }
#ifndef NDEBUG
assert (*lock == MUTEX_UNLOCKED);
@@ -202,12 +202,12 @@ int
ath_mutex_unlock (ath_mutex_t *lock)
{
if (ops_set)
- {
- int ret = mutex_init (lock, 1);
- if (ret)
+ {
+ int ret = mutex_init (lock, 1);
+ if (ret)
return ret;
- return (*ops.mutex_unlock) (lock);
- }
+ return (*ops.mutex_unlock) (lock);
+ }
#ifndef NDEBUG
assert (*lock == MUTEX_LOCKED);
@@ -222,9 +222,9 @@ ssize_t
ath_read (int fd, void *buf, size_t nbytes)
{
if (ops_set && ops.read)
- return (*ops.read) (fd, buf, nbytes);
+ return (*ops.read) (fd, buf, nbytes);
else
- return read (fd, buf, nbytes);
+ return _read (fd, buf, nbytes);
}
@@ -232,28 +232,28 @@ ssize_t
ath_write (int fd, const void *buf, size_t nbytes)
{
if (ops_set && ops.write)
- return (*ops.write) (fd, buf, nbytes);
+ return (*ops.write) (fd, buf, nbytes);
else
- return write (fd, buf, nbytes);
+ return _write (fd, buf, nbytes);
}
ssize_t
#ifdef _WIN32
ath_select (int nfd, void *rset, void *wset, void *eset,
- struct timeval *timeout)
+ struct timeval *timeout)
#else
ath_select (int nfd, fd_set *rset, fd_set *wset, fd_set *eset,
- struct timeval *timeout)
+ struct timeval *timeout)
#endif
{
if (ops_set && ops.select)
- return (*ops.select) (nfd, rset, wset, eset, timeout);
+ return (*ops.select) (nfd, rset, wset, eset, timeout);
else
#ifdef _WIN32
- return -1;
+ return -1;
#else
- return select (nfd, rset, wset, eset, timeout);
+ return select (nfd, rset, wset, eset, timeout);
#endif
}
@@ -262,12 +262,12 @@ ssize_t
ath_waitpid (pid_t pid, int *status, int options)
{
if (ops_set && ops.waitpid)
- return (*ops.waitpid) (pid, status, options);
+ return (*ops.waitpid) (pid, status, options);
else
#ifdef _WIN32
- return -1;
+ return -1;
#else
- return waitpid (pid, status, options);
+ return waitpid (pid, status, options);
#endif
}
@@ -280,12 +280,12 @@ ath_accept (int s, struct sockaddr *addr, socklen_t *length_ptr)
#endif
{
if (ops_set && ops.accept)
- return (*ops.accept) (s, addr, length_ptr);
+ return (*ops.accept) (s, addr, length_ptr);
else
#ifdef _WIN32
- return -1;
+ return -1;
#else
- return accept (s, addr, length_ptr);
+ return accept (s, addr, length_ptr);
#endif
}
@@ -298,12 +298,12 @@ ath_connect (int s, struct sockaddr *addr, socklen_t length)
#endif
{
if (ops_set && ops.connect)
- return (*ops.connect) (s, addr, length);
+ return (*ops.connect) (s, addr, length);
else
#ifdef _WIN32
- return -1;
+ return -1;
#else
- return connect (s, addr, length);
+ return connect (s, addr, length);
#endif
}
@@ -316,12 +316,12 @@ ath_sendmsg (int s, const struct msghdr *msg, int flags)
#endif
{
if (ops_set && ops.sendmsg)
- return (*ops.sendmsg) (s, msg, flags);
+ return (*ops.sendmsg) (s, msg, flags);
else
#ifdef _WIN32
- return -1;
+ return -1;
#else
- return sendmsg (s, msg, flags);
+ return sendmsg (s, msg, flags);
#endif
}
@@ -334,12 +334,12 @@ ath_recvmsg (int s, struct msghdr *msg, int flags)
#endif
{
if (ops_set && ops.recvmsg)
- return (*ops.recvmsg) (s, msg, flags);
+ return (*ops.recvmsg) (s, msg, flags);
else
#ifdef _WIN32
- return -1;
+ return -1;
#else
- return recvmsg (s, msg, flags);
+ return recvmsg (s, msg, flags);
#endif
}
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-14 17:41:01 +0000