hurd: Code style fixes

No code change.
This commit is contained in:
Samuel Thibault 2018-03-20 03:00:15 +01:00
parent 8d3f9e85cf
commit 79962d89a9
3 changed files with 52 additions and 49 deletions

View File

@ -40,57 +40,58 @@ compute_reltime (const struct timespec *abstime, clockid_t clk)
ts.tv_nsec += 1000000000; ts.tv_nsec += 1000000000;
} }
return (ts.tv_sec < 0 ? -1 : return ts.tv_sec < 0 ? -1 : (int)(ts.tv_sec * 1000 + ts.tv_nsec / 1000000);
(int)(ts.tv_sec * 1000 + ts.tv_nsec / 1000000));
} }
int __lll_abstimed_wait (void *ptr, int val, int
__lll_abstimed_wait (void *ptr, int val,
const struct timespec *tsp, int flags, int clk) const struct timespec *tsp, int flags, int clk)
{ {
int mlsec = compute_reltime (tsp, clk); int mlsec = compute_reltime (tsp, clk);
return (mlsec < 0 ? KERN_TIMEDOUT : return mlsec < 0 ? KERN_TIMEDOUT : lll_timed_wait (ptr, val, mlsec, flags);
lll_timed_wait (ptr, val, mlsec, flags));
} }
int __lll_abstimed_xwait (void *ptr, int lo, int hi, int
__lll_abstimed_xwait (void *ptr, int lo, int hi,
const struct timespec *tsp, int flags, int clk) const struct timespec *tsp, int flags, int clk)
{ {
int mlsec = compute_reltime (tsp, clk); int mlsec = compute_reltime (tsp, clk);
return (mlsec < 0 ? KERN_TIMEDOUT : return mlsec < 0 ? KERN_TIMEDOUT : lll_timed_xwait (ptr, lo, hi, mlsec,
lll_timed_xwait (ptr, lo, hi, mlsec, flags)); flags);
} }
int __lll_abstimed_lock (void *ptr, int
__lll_abstimed_lock (void *ptr,
const struct timespec *tsp, int flags, int clk) const struct timespec *tsp, int flags, int clk)
{ {
if (lll_trylock (ptr) == 0) if (lll_trylock (ptr) == 0)
return (0); return 0;
while (1) while (1)
{ {
if (atomic_exchange_acq ((int *)ptr, 2) == 0) if (atomic_exchange_acq ((int *)ptr, 2) == 0)
return (0); return 0;
else if (tsp->tv_nsec < 0 || tsp->tv_nsec >= 1000000000) else if (tsp->tv_nsec < 0 || tsp->tv_nsec >= 1000000000)
return (EINVAL); return EINVAL;
int mlsec = compute_reltime (tsp, clk); int mlsec = compute_reltime (tsp, clk);
if (mlsec < 0 || lll_timed_wait (ptr, if (mlsec < 0 || lll_timed_wait (ptr, 2, mlsec, flags) == KERN_TIMEDOUT)
2, mlsec, flags) == KERN_TIMEDOUT) return ETIMEDOUT;
return (ETIMEDOUT);
} }
} }
/* Robust locks. */ /* Robust locks. */
/* Test if a given process id is still valid. */ /* Test if a given process id is still valid. */
static inline int valid_pid (int pid) static inline int
valid_pid (int pid)
{ {
task_t task = __pid2task (pid); task_t task = __pid2task (pid);
if (task == MACH_PORT_NULL) if (task == MACH_PORT_NULL)
return (0); return 0;
__mach_port_deallocate (__mach_task_self (), task); __mach_port_deallocate (__mach_task_self (), task);
return (1); return 1;
} }
/* Robust locks have currently no support from the kernel; they /* Robust locks have currently no support from the kernel; they
@ -98,7 +99,8 @@ static inline int valid_pid (int pid)
maximum blocking time is determined by this constant. */ maximum blocking time is determined by this constant. */
#define MAX_WAIT_TIME 1500 #define MAX_WAIT_TIME 1500
int __lll_robust_lock (void *ptr, int flags) int
__lll_robust_lock (void *ptr, int flags)
{ {
int *iptr = (int *)ptr; int *iptr = (int *)ptr;
int id = __getpid (); int id = __getpid ();
@ -111,9 +113,9 @@ int __lll_robust_lock (void *ptr, int flags)
{ {
val = *iptr; val = *iptr;
if (!val && atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0) if (!val && atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0)
return (0); return 0;
else if (atomic_compare_and_exchange_bool_acq (iptr, else if (atomic_compare_and_exchange_bool_acq (iptr,
val | LLL_WAITERS, val) == 0) val | LLL_WAITERS, val) == 0)
break; break;
} }
@ -121,11 +123,11 @@ int __lll_robust_lock (void *ptr, int flags)
{ {
val = *iptr; val = *iptr;
if (!val && atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0) if (!val && atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0)
return (0); return 0;
else if (val && !valid_pid (val & LLL_OWNER_MASK)) else if (val && !valid_pid (val & LLL_OWNER_MASK))
{ {
if (atomic_compare_and_exchange_bool_acq (iptr, id, val) == 0) if (atomic_compare_and_exchange_bool_acq (iptr, id, val) == 0)
return (EOWNERDEAD); return EOWNERDEAD;
} }
else else
{ {
@ -136,7 +138,8 @@ int __lll_robust_lock (void *ptr, int flags)
} }
} }
int __lll_robust_abstimed_lock (void *ptr, int
__lll_robust_abstimed_lock (void *ptr,
const struct timespec *tsp, int flags, int clk) const struct timespec *tsp, int flags, int clk)
{ {
int *iptr = (int *)ptr; int *iptr = (int *)ptr;
@ -148,7 +151,7 @@ int __lll_robust_abstimed_lock (void *ptr,
{ {
val = *iptr; val = *iptr;
if (!val && atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0) if (!val && atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0)
return (0); return 0;
else if (atomic_compare_and_exchange_bool_acq (iptr, else if (atomic_compare_and_exchange_bool_acq (iptr,
val | LLL_WAITERS, val) == 0) val | LLL_WAITERS, val) == 0)
break; break;
@ -158,30 +161,31 @@ int __lll_robust_abstimed_lock (void *ptr,
{ {
val = *iptr; val = *iptr;
if (!val && atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0) if (!val && atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0)
return (0); return 0;
else if (val && !valid_pid (val & LLL_OWNER_MASK)) else if (val && !valid_pid (val & LLL_OWNER_MASK))
{ {
if (atomic_compare_and_exchange_bool_acq (iptr, id, val) == 0) if (atomic_compare_and_exchange_bool_acq (iptr, id, val) == 0)
return (EOWNERDEAD); return EOWNERDEAD;
} }
else else
{ {
int mlsec = compute_reltime (tsp, clk); int mlsec = compute_reltime (tsp, clk);
if (mlsec < 0) if (mlsec < 0)
return (ETIMEDOUT); return ETIMEDOUT;
else if (mlsec > wait_time) else if (mlsec > wait_time)
mlsec = wait_time; mlsec = wait_time;
int res = lll_timed_wait (iptr, val, mlsec, flags); int res = lll_timed_wait (iptr, val, mlsec, flags);
if (res == KERN_TIMEDOUT) if (res == KERN_TIMEDOUT)
return (ETIMEDOUT); return ETIMEDOUT;
else if (wait_time < MAX_WAIT_TIME) else if (wait_time < MAX_WAIT_TIME)
wait_time <<= 1; wait_time <<= 1;
} }
} }
} }
int __lll_robust_trylock (void *ptr) int
__lll_robust_trylock (void *ptr)
{ {
int *iptr = (int *)ptr; int *iptr = (int *)ptr;
int id = __getpid (); int id = __getpid ();
@ -190,18 +194,19 @@ int __lll_robust_trylock (void *ptr)
if (!val) if (!val)
{ {
if (atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0) if (atomic_compare_and_exchange_bool_acq (iptr, id, 0) == 0)
return (0); return 0;
} }
else if (!valid_pid (val & LLL_OWNER_MASK) && else if (!valid_pid (val & LLL_OWNER_MASK)
atomic_compare_and_exchange_bool_acq (iptr, id, val) == 0) && atomic_compare_and_exchange_bool_acq (iptr, id, val) == 0)
return (EOWNERDEAD); return EOWNERDEAD;
return (EBUSY); return EBUSY;
} }
void __lll_robust_unlock (void *ptr, int flags) void
__lll_robust_unlock (void *ptr, int flags)
{ {
unsigned int val = atomic_load_relaxed((unsigned int *)ptr); unsigned int val = atomic_load_relaxed ((unsigned int *)ptr);
while (1) while (1)
{ {
if (val & LLL_WAITERS) if (val & LLL_WAITERS)

View File

@ -24,11 +24,11 @@
/* Gsync flags. */ /* Gsync flags. */
#ifndef GSYNC_SHARED #ifndef GSYNC_SHARED
#define GSYNC_SHARED 0x01 # define GSYNC_SHARED 0x01
#define GSYNC_QUAD 0x02 # define GSYNC_QUAD 0x02
#define GSYNC_TIMED 0x04 # define GSYNC_TIMED 0x04
#define GSYNC_BROADCAST 0x08 # define GSYNC_BROADCAST 0x08
#define GSYNC_MUTATE 0x10 # define GSYNC_MUTATE 0x10
#endif #endif
/* Static initializer for low-level locks. */ /* Static initializer for low-level locks. */

View File

@ -17,13 +17,11 @@
<http://www.gnu.org/licenses/>. */ <http://www.gnu.org/licenses/>. */
#if IS_IN (rtld) #if IS_IN (rtld)
/* /* rtld can not access TLS too early, thus rtld_errno.
* rtld can not access TLS too early, thus rtld_errno.
* Instead of making __open/__close pass errno from TLS to rtld_errno, simply
* Instead of making __open/__close pass errno from TLS to rtld_errno, simply use a weak __errno_location using rtld_errno, which will be overriden by the
* use a weak __errno_location using rtld_errno, which will be overriden by the libc definition. */
* libc definition.
*/
static int rtld_errno; static int rtld_errno;
int * weak_function int * weak_function
__errno_location (void) __errno_location (void)