Referencia del Archivo src/libmysql_std/include/my_pthread.h

#include <errno.h>
#include <pthread.h>

Ir al código fuente de este archivo.

Clases
struct	st_safe_mutex_t
struct	_my_rw_lock_t
struct	st_my_thread_var
'defines'
#define	ETIME   ETIMEDOUT
#define	EXTERNC
#define	_REENTRANT
#define	pthread_key(T, V)   pthread_key_t V
#define	my_pthread_getspecific_ptr(T, V)   my_pthread_getspecific(T,(V))
#define	my_pthread_setspecific_ptr(T, V)   pthread_setspecific(T,(void*) (V))
#define	pthread_detach_this_thread()
#define	pthread_handler_t   EXTERNC void *
#define	my_sigwait(A, B)   sigwait((A),(B))
#define	my_sigset(A, B)   signal((A),(B))
#define	pthread_attr_setscope(A, B)
#define	my_pthread_getspecific(A, B)   ((A) pthread_getspecific(B))
#define	pthread_key_delete(A)   pthread_dummy(0)
#define	HAVE_PTHREAD_KILL
#define	set_timespec(ABSTIME, SEC)
#define	set_timespec_nsec(ABSTIME, NSEC)
#define	safe_mutex_assert_owner(mp)
#define	safe_mutex_assert_not_owner(mp)
#define	rw_lock_t   my_rw_lock_t
#define	rw_rdlock(A)   my_rw_rdlock((A))
#define	rw_wrlock(A)   my_rw_wrlock((A))
#define	rw_tryrdlock(A)   my_rw_tryrdlock((A))
#define	rw_trywrlock(A)   my_rw_trywrlock((A))
#define	rw_unlock(A)   my_rw_unlock((A))
#define	rwlock_destroy(A)   my_rwlock_destroy((A))
#define	GETHOSTBYADDR_BUFF_SIZE   2048
#define	thr_setconcurrency(A)   pthread_dummy(0)
#define	pthread_attr_setstacksize(A, B)   pthread_dummy(0)
#define	MY_MUTEX_INIT_SLOW   NULL
#define	MY_MUTEX_INIT_FAST   NULL
#define	MY_MUTEX_INIT_ERRCHK   NULL
#define	ESRCH   1
#define	THREAD_NAME_SIZE   10
#define	DEFAULT_THREAD_STACK   (192*1024)
#define	my_thread_var   (_my_thread_var())
#define	my_errno   my_thread_var->thr_errno
#define	THD_LIB_OTHER   1
#define	THD_LIB_NPTL   2
#define	THD_LIB_LT   4
#define	thread_safe_increment(V, L)   (pthread_mutex_lock((L)), (V)++, pthread_mutex_unlock((L)))
#define	thread_safe_decrement(V, L)   (pthread_mutex_lock((L)), (V)--, pthread_mutex_unlock((L)))
#define	thread_safe_add(V, C, L)   (pthread_mutex_lock((L)), (V)+=(C), pthread_mutex_unlock((L)))
#define	thread_safe_sub(V, C, L)   (pthread_mutex_lock((L)), (V)-=(C), pthread_mutex_unlock((L)))
#define	statistic_decrement(V, L)   (V)--
#define	statistic_increment(V, L)   (V)++
#define	statistic_add(V, C, L)   (V)+=(C)
'typedefs'
typedef void *(*	pthread_handler )(void *)
typedef struct st_safe_mutex_t	safe_mutex_t
typedef struct _my_rw_lock_t	my_rw_lock_t
Funciones
int	my_pthread_getprio (pthread_t thread_id)
int	sigwait (sigset_t *setp, int *sigp)
void	my_pthread_setprio (pthread_t thread_id, int prior)
void	my_pthread_attr_setprio (pthread_attr_t *attr, int priority)
struct tm *	localtime_r (const time_t *clock, struct tm *res)
struct tm *	gmtime_r (const time_t *clock, struct tm *res)
int	safe_mutex_init (safe_mutex_t *mp, const pthread_mutexattr_t *attr, const char *file, uint line)
int	safe_mutex_lock (safe_mutex_t *mp, const char *file, uint line)
int	safe_mutex_unlock (safe_mutex_t *mp, const char *file, uint line)
int	safe_mutex_destroy (safe_mutex_t *mp, const char *file, uint line)
int	safe_cond_wait (pthread_cond_t *cond, safe_mutex_t *mp, const char *file, uint line)
int	safe_cond_timedwait (pthread_cond_t *cond, safe_mutex_t *mp, struct timespec *abstime, const char *file, uint line)
void	safe_mutex_global_init (void)
void	safe_mutex_end (FILE *file)
int	my_rwlock_init (my_rw_lock_t *, void *)
int	my_rwlock_destroy (my_rw_lock_t *)
int	my_rw_rdlock (my_rw_lock_t *)
int	my_rw_wrlock (my_rw_lock_t *)
int	my_rw_unlock (my_rw_lock_t *)
int	my_rw_tryrdlock (my_rw_lock_t *)
int	my_rw_trywrlock (my_rw_lock_t *)
my_bool	my_thread_global_init (void)
void	my_thread_global_end (void)
my_bool	my_thread_init (void)
void	my_thread_end (void)
const char *	my_thread_name (void)
long	my_thread_id (void)
int	pthread_no_free (void *)
int	pthread_dummy (int)
struct st_my_thread_var *	_my_thread_var (void) __attribute__((const ))
Variables
uint	my_thread_end_wait_time
uint	thd_lib_detected

---

Documentación de los 'defines'

#define _REENTRANT

#define DEFAULT_THREAD_STACK   (192*1024)

#define ESRCH   1

#define ETIME   ETIMEDOUT

#define EXTERNC

#define GETHOSTBYADDR_BUFF_SIZE   2048

#define HAVE_PTHREAD_KILL

#define my_errno   my_thread_var->thr_errno

#define MY_MUTEX_INIT_ERRCHK   NULL

#define MY_MUTEX_INIT_FAST   NULL

#define MY_MUTEX_INIT_SLOW   NULL

#define my_pthread_getspecific	(		A,
			B
	)		((A) pthread_getspecific(B))

#define my_pthread_getspecific_ptr	(		T,
			V
	)		my_pthread_getspecific(T,(V))

#define my_pthread_setspecific_ptr	(		T,
			V
	)		pthread_setspecific(T,(void*) (V))

#define my_sigset	(		A,
			B
	)		signal((A),(B))

#define my_sigwait	(		A,
			B
	)		sigwait((A),(B))

#define my_thread_var   (_my_thread_var())

#define pthread_attr_setscope	(		A,
			B
	)

#define pthread_attr_setstacksize	(		A,
			B
	)		pthread_dummy(0)

#define pthread_detach_this_thread

(

)

#define pthread_handler_t   EXTERNC void *

#define pthread_key	(		T,
			V
	)		pthread_key_t V

#define pthread_key_delete

(

A

)

pthread_dummy(0)

#define rw_lock_t   my_rw_lock_t

#define rw_rdlock

(

A

)

my_rw_rdlock((A))

#define rw_tryrdlock

(

A

)

my_rw_tryrdlock((A))

#define rw_trywrlock

(

A

)

my_rw_trywrlock((A))

#define rw_unlock

(

A

)

my_rw_unlock((A))

#define rw_wrlock

(

A

)

my_rw_wrlock((A))

#define rwlock_destroy

(

A

)

my_rwlock_destroy((A))

#define safe_mutex_assert_not_owner

(

mp

)

#define safe_mutex_assert_owner

(

mp

)

#define set_timespec	(		ABSTIME,
			SEC
	)

Valor:

{\
  struct timeval tv;\
  gettimeofday(&tv,0);\
  (ABSTIME).tv_sec=tv.tv_sec+(time_t) (SEC);\
  (ABSTIME).tv_nsec=tv.tv_usec*1000;\
}

#define set_timespec_nsec	(		ABSTIME,
			NSEC
	)

Valor:

{\
  ulonglong now= my_getsystime() + (NSEC/100); \
  (ABSTIME).tv_sec=  (time_t) (now / ULL(10000000));                  \
  (ABSTIME).tv_nsec= (long) (now % ULL(10000000) * 100 + ((NSEC) % 100)); \
}

#define statistic_add	(		V,
			C,
			L
	)		(V)+=(C)

#define statistic_decrement	(		V,
			L
	)		(V)--

#define statistic_increment	(		V,
			L
	)		(V)++

#define THD_LIB_LT   4

#define THD_LIB_NPTL   2

#define THD_LIB_OTHER   1

#define thr_setconcurrency

(

A

)

pthread_dummy(0)

#define THREAD_NAME_SIZE   10

#define thread_safe_add	(		V,
			C,
			L
	)		(pthread_mutex_lock((L)), (V)+=(C), pthread_mutex_unlock((L)))

#define thread_safe_decrement	(		V,
			L
	)		(pthread_mutex_lock((L)), (V)--, pthread_mutex_unlock((L)))

#define thread_safe_increment	(		V,
			L
	)		(pthread_mutex_lock((L)), (V)++, pthread_mutex_unlock((L)))

#define thread_safe_sub	(		V,
			C,
			L
	)		(pthread_mutex_lock((L)), (V)-=(C), pthread_mutex_unlock((L)))

---

Documentación de los 'typedefs'

typedef struct _my_rw_lock_t my_rw_lock_t

typedef void*(* pthread_handler)(void *)

typedef struct st_safe_mutex_t safe_mutex_t

---

Documentación de las funciones

struct st_my_thread_var* _my_thread_var

(

void

)

const [read]

struct tm* gmtime_r	(	const time_t *	clock,
		struct tm *	res
	)		[read]

struct tm* localtime_r	(	const time_t *	clock,
		struct tm *	res
	)		[read]

void my_pthread_attr_setprio	(	pthread_attr_t *	attr,
		int	priority
	)

int my_pthread_getprio

(

pthread_t

thread_id

)

void my_pthread_setprio	(	pthread_t	thread_id,
		int	prior
	)

int my_rw_rdlock

(

my_rw_lock_t *

)

int my_rw_tryrdlock

(

my_rw_lock_t *

)

int my_rw_trywrlock

(

my_rw_lock_t *

)

int my_rw_unlock

(

my_rw_lock_t *

)

int my_rw_wrlock

(

my_rw_lock_t *

)

int my_rwlock_destroy

(

my_rw_lock_t *

)

int my_rwlock_init	(	my_rw_lock_t *	,
		void *
	)

void my_thread_end

(

void

)

void my_thread_global_end

(

void

)

my_bool my_thread_global_init

(

void

)

long my_thread_id

(

void

)

my_bool my_thread_init

(

void

)

const char* my_thread_name

(

void

)

int pthread_dummy

(

int

)

int pthread_no_free

(

void *

)

int safe_cond_timedwait	(	pthread_cond_t *	cond,
		safe_mutex_t *	mp,
		struct timespec *	abstime,
		const char *	file,
		uint	line
	)

int safe_cond_wait	(	pthread_cond_t *	cond,
		safe_mutex_t *	mp,
		const char *	file,
		uint	line
	)

int safe_mutex_destroy	(	safe_mutex_t *	mp,
		const char *	file,
		uint	line
	)

void safe_mutex_end

(

FILE *

file

)

void safe_mutex_global_init

(

void

)

int safe_mutex_init	(	safe_mutex_t *	mp,
		const pthread_mutexattr_t *	attr,
		const char *	file,
		uint	line
	)

int safe_mutex_lock	(	safe_mutex_t *	mp,
		const char *	file,
		uint	line
	)

int safe_mutex_unlock	(	safe_mutex_t *	mp,
		const char *	file,
		uint	line
	)

int sigwait	(	sigset_t *	setp,
		int *	sigp
	)

---

Documentación de las variables

uint my_thread_end_wait_time

uint thd_lib_detected