Skip to content

Commit

Permalink
nptl: Rename lll_timedlock to lll_clocklock and add clockid parameter
Browse files Browse the repository at this point in the history
Rename lll_timedlock to lll_clocklock and add clockid
parameter to indicate the clock that the abstime parameter should
be measured against in preparation for adding
pthread_mutex_clocklock.

The name change mirrors the naming for the exposed pthread functions:

 timed => absolute timeout measured against CLOCK_REALTIME (or clock
          specified by attribute in the case of pthread_cond_timedwait.)

 clock => absolute timeout measured against clock specified in preceding
          parameter.

	* sysdeps/nptl/lowlevellock.h (lll_clocklock): Rename from
	lll_timedlock and add clockid parameter. (__lll_clocklock): Rename
	from __lll_timedlock and add clockid parameter.
	* sysdeps/unix/sysv/linux/sparc/lowlevellock.h (lll_clocklock):
	Likewise.
	* nptl/lll_timedlock_wait.c (__lll_clocklock_wait): Rename from
	__lll_timedlock_wait and add clockid parameter. Use __clock_gettime
	rather than __gettimeofday so that clockid can be used. This means
	that conversion from struct timeval is no longer required.
	* sysdeps/sparc/sparc32/lowlevellock.c (lll_clocklock_wait):
	Likewise.
	* sysdeps/sparc/sparc32/lll_timedlock_wait.c: Update comment to
	refer to __lll_clocklock_wait rather than __lll_timedlock_wait.
	* nptl/pthread_mutex_timedlock.c (lll_clocklock_elision): Rename
	from lll_timedlock_elision, add clockid parameter and use
	meaningful names for other parameters. (__pthread_mutex_timedlock):
	Pass CLOCK_REALTIME where necessary to lll_clocklock and
	lll_clocklock_elision.
	* sysdeps/unix/sysv/linux/powerpc/lowlevellock.h
	(lll_clocklock_elision): Rename from lll_timedlock_elision and add
	clockid parameter. (__lll_clocklock_elision): Rename from
	__lll_timedlock_elision and add clockid parameter.
	* sysdeps/unix/sysv/linux/s390/lowlevellock.h: Likewise.
	* sysdeps/unix/sysv/linux/x86/lowlevellock.h: Likewise.
	* sysdeps/unix/sysv/linux/powerpc/elision-timed.c
	(__lll_lock_elision): Call __lll_clocklock_elision rather than
	__lll_timedlock_elision. (EXTRAARG): Add clockid parameter.
	(LLL_LOCK): Likewise.
	* sysdeps/unix/sysv/linux/s390/elision-timed.c: Likewise.
	* sysdeps/unix/sysv/linux/x86/elision-timed.c: Likewise.

Reviewed-by: Adhemerval Zanella <[email protected]>
  • Loading branch information
mikecrowe authored and zatrazz committed Jul 12, 2019
1 parent e996fa7 commit 5921309
Show file tree
Hide file tree
Showing 13 changed files with 103 additions and 54 deletions.
35 changes: 35 additions & 0 deletions ChangeLog
Original file line number Diff line number Diff line change
@@ -1,5 +1,40 @@
2019-07-12 Mike Crowe <[email protected]>

nptl: Rename lll_timedlock to lll_clocklock and add clockid
parameter to indicate the clock that the abstime parameter should
be measured against in preparation for adding
pthread_mutex_clocklock.
* sysdeps/nptl/lowlevellock.h (lll_clocklock): Rename from
lll_timedlock and add clockid parameter. (__lll_clocklock): Rename
from __lll_timedlock and add clockid parameter.
* sysdeps/unix/sysv/linux/sparc/lowlevellock.h (lll_clocklock):
Likewise.
* nptl/lll_timedlock_wait.c (__lll_clocklock_wait): Rename from
__lll_timedlock_wait and add clockid parameter. Use __clock_gettime
rather than __gettimeofday so that clockid can be used. This means
that conversion from struct timeval is no longer required.
* sysdeps/sparc/sparc32/lowlevellock.c (lll_clocklock_wait):
Likewise.
* sysdeps/sparc/sparc32/lll_timedlock_wait.c: Update comment to
refer to __lll_clocklock_wait rather than __lll_timedlock_wait.
* nptl/pthread_mutex_timedlock.c (lll_clocklock_elision): Rename
from lll_timedlock_elision, add clockid parameter and use
meaningful names for other parameters. (__pthread_mutex_timedlock):
Pass CLOCK_REALTIME where necessary to lll_clocklock and
lll_clocklock_elision.
* sysdeps/unix/sysv/linux/powerpc/lowlevellock.h
(lll_clocklock_elision): Rename from lll_timedlock_elision and add
clockid parameter. (__lll_clocklock_elision): Rename from
__lll_timedlock_elision and add clockid parameter.
* sysdeps/unix/sysv/linux/s390/lowlevellock.h: Likewise.
* sysdeps/unix/sysv/linux/x86/lowlevellock.h: Likewise.
* sysdeps/unix/sysv/linux/powerpc/elision-timed.c
(__lll_lock_elision): Call __lll_clocklock_elision rather than
__lll_timedlock_elision. (EXTRAARG): Add clockid parameter.
(LLL_LOCK): Likewise.
* sysdeps/unix/sysv/linux/s390/elision-timed.c: Likewise.
* sysdeps/unix/sysv/linux/x86/elision-timed.c: Likewise.

nptl: Add POSIX-proposed pthread_rwlock_clockrdlock &
pthread_rwlock_clockwrlock which behave like
pthread_rwlock_timedrdlock and pthread_rwlock_timedwrlock
Expand Down
15 changes: 9 additions & 6 deletions nptl/lll_timedlock_wait.c
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,8 @@


int
__lll_timedlock_wait (int *futex, const struct timespec *abstime, int private)
__lll_clocklock_wait (int *futex, clockid_t clockid,
const struct timespec *abstime, int private)
{
/* Reject invalid timeouts. */
if (abstime->tv_nsec < 0 || abstime->tv_nsec >= 1000000000)
Expand All @@ -33,15 +34,17 @@ __lll_timedlock_wait (int *futex, const struct timespec *abstime, int private)
/* Try locking. */
while (atomic_exchange_acq (futex, 2) != 0)
{
struct timeval tv;
struct timespec ts;

/* Get the current time. */
(void) __gettimeofday (&tv, NULL);
/* Get the current time. This can only fail if clockid is not
valid. */
if (__glibc_unlikely (__clock_gettime (clockid, &ts) != 0))
return EINVAL;

/* Compute relative timeout. */
struct timespec rt;
rt.tv_sec = abstime->tv_sec - tv.tv_sec;
rt.tv_nsec = abstime->tv_nsec - tv.tv_usec * 1000;
rt.tv_sec = abstime->tv_sec - ts.tv_sec;
rt.tv_nsec = abstime->tv_nsec - ts.tv_nsec;
if (rt.tv_nsec < 0)
{
rt.tv_nsec += 1000000000;
Expand Down
16 changes: 9 additions & 7 deletions nptl/pthread_mutex_timedlock.c
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,9 @@

#include <stap-probe.h>

#ifndef lll_timedlock_elision
#define lll_timedlock_elision(a,dummy,b,c) lll_timedlock(a, b, c)
#ifndef lll_clocklock_elision
#define lll_clocklock_elision(futex, adapt_count, clockid, abstime, private) \
lll_clocklock (futex, clockid, abstime, private)
#endif

#ifndef lll_trylock_elision
Expand Down Expand Up @@ -75,7 +76,7 @@ __pthread_mutex_timedlock (pthread_mutex_t *mutex,
}

/* We have to get the mutex. */
result = lll_timedlock (mutex->__data.__lock, abstime,
result = lll_clocklock (mutex->__data.__lock, CLOCK_REALTIME, abstime,
PTHREAD_MUTEX_PSHARED (mutex));

if (result != 0)
Expand All @@ -98,16 +99,16 @@ __pthread_mutex_timedlock (pthread_mutex_t *mutex,
FORCE_ELISION (mutex, goto elision);
simple:
/* Normal mutex. */
result = lll_timedlock (mutex->__data.__lock, abstime,
result = lll_clocklock (mutex->__data.__lock, CLOCK_REALTIME, abstime,
PTHREAD_MUTEX_PSHARED (mutex));
break;

case PTHREAD_MUTEX_TIMED_ELISION_NP:
elision: __attribute__((unused))
/* Don't record ownership */
return lll_timedlock_elision (mutex->__data.__lock,
return lll_clocklock_elision (mutex->__data.__lock,
mutex->__data.__spins,
abstime,
CLOCK_REALTIME, abstime,
PTHREAD_MUTEX_PSHARED (mutex));


Expand All @@ -124,7 +125,8 @@ __pthread_mutex_timedlock (pthread_mutex_t *mutex,
{
if (cnt++ >= max_cnt)
{
result = lll_timedlock (mutex->__data.__lock, abstime,
result = lll_clocklock (mutex->__data.__lock,
CLOCK_REALTIME, abstime,
PTHREAD_MUTEX_PSHARED (mutex));
break;
}
Expand Down
16 changes: 9 additions & 7 deletions sysdeps/nptl/lowlevellock.h
Original file line number Diff line number Diff line change
Expand Up @@ -121,24 +121,26 @@ extern void __lll_lock_wait (int *futex, int private) attribute_hidden;
#define lll_cond_lock(futex, private) __lll_cond_lock (&(futex), private)


extern int __lll_timedlock_wait (int *futex, const struct timespec *,
extern int __lll_clocklock_wait (int *futex, clockid_t,
const struct timespec *,
int private) attribute_hidden;


/* As __lll_lock, but with a timeout. If the timeout occurs then return
ETIMEDOUT. If ABSTIME is invalid, return EINVAL. */
#define __lll_timedlock(futex, abstime, private) \
/* As __lll_lock, but with an absolute timeout measured against the clock
specified in CLOCKID. If the timeout occurs then return ETIMEDOUT. If
ABSTIME is invalid, return EINVAL. */
#define __lll_clocklock(futex, clockid, abstime, private) \
({ \
int *__futex = (futex); \
int __val = 0; \
\
if (__glibc_unlikely \
(atomic_compare_and_exchange_bool_acq (__futex, 1, 0))) \
__val = __lll_timedlock_wait (__futex, abstime, private); \
__val = __lll_clocklock_wait (__futex, clockid, abstime, private); \
__val; \
})
#define lll_timedlock(futex, abstime, private) \
__lll_timedlock (&(futex), abstime, private)
#define lll_clocklock(futex, clockid, abstime, private) \
__lll_clocklock (&(futex), clockid, abstime, private)


/* This is an expression rather than a statement even though its value is
Expand Down
2 changes: 1 addition & 1 deletion sysdeps/sparc/sparc32/lll_timedlock_wait.c
Original file line number Diff line number Diff line change
@@ -1 +1 @@
/* __lll_timedlock_wait is in lowlevellock.c. */
/* __lll_clocklock_wait is in lowlevellock.c. */
15 changes: 9 additions & 6 deletions sysdeps/sparc/sparc32/lowlevellock.c
Original file line number Diff line number Diff line change
Expand Up @@ -52,23 +52,26 @@ __lll_lock_wait (int *futex, int private)


int
__lll_timedlock_wait (int *futex, const struct timespec *abstime, int private)
__lll_clocklock_wait (int *futex, clockid_t clockid,
const struct timespec *abstime, int private)
{
/* Reject invalid timeouts. */
if (abstime->tv_nsec < 0 || abstime->tv_nsec >= 1000000000)
return EINVAL;

do
{
struct timeval tv;
struct timespec ts;
struct timespec rt;

/* Get the current time. */
(void) __gettimeofday (&tv, NULL);
/* Get the current time. This can only fail if clockid is not
valid. */
if (__glibc_unlikely (__clock_gettime (clockid, &ts) != 0))
return EINVAL;

/* Compute relative timeout. */
rt.tv_sec = abstime->tv_sec - tv.tv_sec;
rt.tv_nsec = abstime->tv_nsec - tv.tv_usec * 1000;
rt.tv_sec = abstime->tv_sec - ts.tv_sec;
rt.tv_nsec = abstime->tv_nsec - ts.tv_nsec;
if (rt.tv_nsec < 0)
{
rt.tv_nsec += 1000000000;
Expand Down
6 changes: 3 additions & 3 deletions sysdeps/unix/sysv/linux/powerpc/elision-timed.c
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@
#include <elision-conf.h>
#include "lowlevellock.h"

#define __lll_lock_elision __lll_timedlock_elision
#define EXTRAARG const struct timespec *t,
#define __lll_lock_elision __lll_clocklock_elision
#define EXTRAARG clockid_t clockid, const struct timespec *t,
#undef LLL_LOCK
#define LLL_LOCK(a, b) lll_timedlock(a, t, b)
#define LLL_LOCK(a, b) lll_clocklock(a, clockid, t, b)

#include "elision-lock.c"
9 changes: 5 additions & 4 deletions sysdeps/unix/sysv/linux/powerpc/lowlevellock.h
Original file line number Diff line number Diff line change
Expand Up @@ -22,12 +22,13 @@
#include <sysdeps/nptl/lowlevellock.h>

/* Transactional lock elision definitions. */
extern int __lll_timedlock_elision
(int *futex, short *adapt_count, const struct timespec *timeout, int private)
extern int __lll_clocklock_elision
(int *futex, short *adapt_count,
clockid_t clockid, const struct timespec *timeout, int private)
attribute_hidden;

#define lll_timedlock_elision(futex, adapt_count, timeout, private) \
__lll_timedlock_elision(&(futex), &(adapt_count), timeout, private)
#define lll_clocklock_elision(futex, adapt_count, clockid, timeout, private) \
__lll_clocklock_elision (&(futex), &(adapt_count), clockid, timeout, private)

extern int __lll_lock_elision (int *futex, short *adapt_count, int private)
attribute_hidden;
Expand Down
6 changes: 3 additions & 3 deletions sysdeps/unix/sysv/linux/s390/elision-timed.c
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@
#include <time.h>
#include <elision-conf.h>
#include <lowlevellock.h>
#define __lll_lock_elision __lll_timedlock_elision
#define EXTRAARG const struct timespec *t,
#define __lll_lock_elision __lll_clocklock_elision
#define EXTRAARG clockid_t clockid, const struct timespec *t,
#undef LLL_LOCK
#define LLL_LOCK(a, b) lll_timedlock(a, t, b)
#define LLL_LOCK(a, b) lll_clocklock(a, clockid, t, b)
#include "elision-lock.c"
9 changes: 5 additions & 4 deletions sysdeps/unix/sysv/linux/s390/lowlevellock.h
Original file line number Diff line number Diff line change
Expand Up @@ -22,12 +22,13 @@
#include <sysdeps/nptl/lowlevellock.h>

/* Transactional lock elision definitions. */
extern int __lll_timedlock_elision
(int *futex, short *adapt_count, const struct timespec *timeout, int private)
extern int __lll_clocklock_elision
(int *futex, short *adapt_count,
clockid_t clockid, const struct timespec *timeout, int private)
attribute_hidden;

# define lll_timedlock_elision(futex, adapt_count, timeout, private) \
__lll_timedlock_elision(&(futex), &(adapt_count), timeout, private)
# define lll_clocklock_elision(futex, adapt_count, clockid, timeout, private) \
__lll_clocklock_elision (&(futex), &(adapt_count), clockid, timeout, private)

extern int __lll_lock_elision (int *futex, short *adapt_count, int private)
attribute_hidden;
Expand Down
11 changes: 6 additions & 5 deletions sysdeps/unix/sysv/linux/sparc/lowlevellock.h
Original file line number Diff line number Diff line change
Expand Up @@ -75,22 +75,23 @@ __lll_cond_lock (int *futex, int private)
#define lll_cond_lock(futex, private) __lll_cond_lock (&(futex), private)


extern int __lll_timedlock_wait (int *futex, const struct timespec *,
extern int __lll_clocklock_wait (int *futex, clockid_t, const struct timespec *,
int private) attribute_hidden;

static inline int
__attribute__ ((always_inline))
__lll_timedlock (int *futex, const struct timespec *abstime, int private)
__lll_clocklock (int *futex, clockid_t clockid,
const struct timespec *abstime, int private)
{
int val = atomic_compare_and_exchange_val_24_acq (futex, 1, 0);
int result = 0;

if (__glibc_unlikely (val != 0))
result = __lll_timedlock_wait (futex, abstime, private);
result = __lll_clocklock_wait (futex, clockid, abstime, private);
return result;
}
#define lll_timedlock(futex, abstime, private) \
__lll_timedlock (&(futex), abstime, private)
#define lll_clocklock(futex, clockid, abstime, private) \
__lll_clocklock (&(futex), clockid, abstime, private)

#define lll_unlock(lock, private) \
((void) ({ \
Expand Down
6 changes: 3 additions & 3 deletions sysdeps/unix/sysv/linux/x86/elision-timed.c
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@
#include <time.h>
#include <elision-conf.h>
#include "lowlevellock.h"
#define __lll_lock_elision __lll_timedlock_elision
#define EXTRAARG const struct timespec *t,
#define __lll_lock_elision __lll_clocklock_elision
#define EXTRAARG clockid_t clockid, const struct timespec *t,
#undef LLL_LOCK
#define LLL_LOCK(a, b) lll_timedlock(a, t, b)
#define LLL_LOCK(a, b) lll_clocklock (a, clockid, t, b)
#include "elision-lock.c"
11 changes: 6 additions & 5 deletions sysdeps/unix/sysv/linux/x86/lowlevellock.h
Original file line number Diff line number Diff line change
Expand Up @@ -82,12 +82,13 @@ __lll_cas_lock (int *futex)
__lll_unlock (&(lock), private); \
}))

extern int __lll_timedlock_elision (int *futex, short *adapt_count,
const struct timespec *timeout,
int private) attribute_hidden;
extern int __lll_clocklock_elision (int *futex, short *adapt_count,
clockid_t clockid,
const struct timespec *timeout,
int private) attribute_hidden;

#define lll_timedlock_elision(futex, adapt_count, timeout, private) \
__lll_timedlock_elision(&(futex), &(adapt_count), timeout, private)
#define lll_clocklock_elision(futex, adapt_count, clockid, timeout, private) \
__lll_clocklock_elision (&(futex), &(adapt_count), clockid, timeout, private)

extern int __lll_lock_elision (int *futex, short *adapt_count, int private)
attribute_hidden;
Expand Down

0 comments on commit 5921309

Please sign in to comment.