[mirror_frr.git] / lib / thread.h

/* Thread management routine header.
 * Copyright (C) 1998 Kunihiro Ishiguro
 *
 * This file is part of GNU Zebra.
 *
 * GNU Zebra is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License as published by the
 * Free Software Foundation; either version 2, or (at your option) any
 * later version.
 *
 * GNU Zebra is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; see the file COPYING; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
 */

#ifndef _ZEBRA_THREAD_H
#define _ZEBRA_THREAD_H

#include <zebra.h>
#include <pthread.h>
#include <poll.h>
#include "monotime.h"
#include "frratomic.h"
#include "typesafe.h"

#ifdef __cplusplus
extern "C" {
#endif

struct rusage_t {
	struct rusage cpu;
	struct timeval real;
};
#define RUSAGE_T        struct rusage_t

#define GETRUSAGE(X) thread_getrusage(X)

PREDECL_LIST(thread_list)
PREDECL_HEAP(thread_timer_list)

struct fd_handler {
	/* number of pfd that fit in the allocated space of pfds. This is a
	 * constant
	 * and is the same for both pfds and copy. */
	nfds_t pfdsize;

	/* file descriptors to monitor for i/o */
	struct pollfd *pfds;
	/* number of pollfds stored in pfds */
	nfds_t pfdcount;

	/* chunk used for temp copy of pollfds */
	struct pollfd *copy;
	/* number of pollfds stored in copy */
	nfds_t copycount;
};

struct cancel_req {
	struct thread *thread;
	void *eventobj;
	struct thread **threadref;
};

/* Master of the theads. */
struct thread_master {
	char *name;

	struct thread **read;
	struct thread **write;
	struct thread_timer_list_head timer;
	struct thread_list_head event, ready, unuse;
	struct list *cancel_req;
	bool canceled;
	pthread_cond_t cancel_cond;
	struct hash *cpu_record;
	int io_pipe[2];
	int fd_limit;
	struct fd_handler handler;
	unsigned long alloc;
	long selectpoll_timeout;
	bool spin;
	bool handle_signals;
	pthread_mutex_t mtx;
	pthread_t owner;
};

/* Thread itself. */
struct thread {
	uint8_t type;		  /* thread type */
	uint8_t add_type;	  /* thread type */
	struct thread_list_item threaditem;
	struct thread_timer_list_item timeritem;
	struct thread **ref;	  /* external reference (if given) */
	struct thread_master *master; /* pointer to the struct thread_master */
	int (*func)(struct thread *); /* event function */
	void *arg;		      /* event argument */
	union {
		int val;	      /* second argument of the event. */
		int fd;		      /* file descriptor in case of r/w */
		struct timeval sands; /* rest of time sands value. */
	} u;
	struct timeval real;
	struct cpu_thread_history *hist; /* cache pointer to cpu_history */
	unsigned long yield;		 /* yield time in microseconds */
	const char *funcname;		 /* name of thread function */
	const char *schedfrom; /* source file thread was scheduled from */
	int schedfrom_line;    /* line number of source file */
	pthread_mutex_t mtx;   /* mutex for thread.c functions */
};

struct cpu_thread_history {
	int (*func)(struct thread *);
	atomic_uint_fast32_t total_calls;
	atomic_uint_fast32_t total_active;
	struct time_stats {
		atomic_size_t total, max;
	} real;
	struct time_stats cpu;
	atomic_uint_fast32_t types;
	const char *funcname;
};

/* Struct timeval's tv_usec one second value.  */
#define TIMER_SECOND_MICRO 1000000L

/* Thread types. */
#define THREAD_READ           0
#define THREAD_WRITE          1
#define THREAD_TIMER          2
#define THREAD_EVENT          3
#define THREAD_READY          4
#define THREAD_UNUSED         5
#define THREAD_EXECUTE        6

/* Thread yield time.  */
#define THREAD_YIELD_TIME_SLOT     10 * 1000L /* 10ms */

#define THREAD_TIMER_STRLEN 12

/* Macros. */
#define THREAD_ARG(X) ((X)->arg)
#define THREAD_FD(X)  ((X)->u.fd)
#define THREAD_VAL(X) ((X)->u.val)

#define THREAD_OFF(thread)                                                     \
	do {                                                                   \
		if (thread) {                                                  \
			thread_cancel(thread);                                 \
			thread = NULL;                                         \
		}                                                              \
	} while (0)

#define THREAD_READ_OFF(thread)  THREAD_OFF(thread)
#define THREAD_WRITE_OFF(thread)  THREAD_OFF(thread)
#define THREAD_TIMER_OFF(thread)  THREAD_OFF(thread)

#define debugargdef  const char *funcname, const char *schedfrom, int fromln

#define thread_add_read(m,f,a,v,t) funcname_thread_add_read_write(THREAD_READ,m,f,a,v,t,#f,__FILE__,__LINE__)
#define thread_add_write(m,f,a,v,t) funcname_thread_add_read_write(THREAD_WRITE,m,f,a,v,t,#f,__FILE__,__LINE__)
#define thread_add_timer(m,f,a,v,t) funcname_thread_add_timer(m,f,a,v,t,#f,__FILE__,__LINE__)
#define thread_add_timer_msec(m,f,a,v,t) funcname_thread_add_timer_msec(m,f,a,v,t,#f,__FILE__,__LINE__)
#define thread_add_timer_tv(m,f,a,v,t) funcname_thread_add_timer_tv(m,f,a,v,t,#f,__FILE__,__LINE__)
#define thread_add_event(m,f,a,v,t) funcname_thread_add_event(m,f,a,v,t,#f,__FILE__,__LINE__)
#define thread_execute(m,f,a,v) funcname_thread_execute(m,f,a,v,#f,__FILE__,__LINE__)
#define thread_execute_name(m, f, a, v, n)				\
	funcname_thread_execute(m, f, a, v, n, __FILE__, __LINE__)

/* Prototypes. */
extern struct thread_master *thread_master_create(const char *);
void thread_master_set_name(struct thread_master *master, const char *name);
extern void thread_master_free(struct thread_master *);
extern void thread_master_free_unused(struct thread_master *);

extern struct thread *
funcname_thread_add_read_write(int dir, struct thread_master *,
			       int (*)(struct thread *), void *, int,
			       struct thread **, debugargdef);

extern struct thread *funcname_thread_add_timer(struct thread_master *,
						int (*)(struct thread *),
						void *, long, struct thread **,
						debugargdef);

extern struct thread *
funcname_thread_add_timer_msec(struct thread_master *, int (*)(struct thread *),
			       void *, long, struct thread **, debugargdef);

extern struct thread *funcname_thread_add_timer_tv(struct thread_master *,
						   int (*)(struct thread *),
						   void *, struct timeval *,
						   struct thread **,
						   debugargdef);

extern struct thread *funcname_thread_add_event(struct thread_master *,
						int (*)(struct thread *),
						void *, int, struct thread **,
						debugargdef);

extern void funcname_thread_execute(struct thread_master *,
				    int (*)(struct thread *), void *, int,
				    debugargdef);
#undef debugargdef

extern void thread_cancel(struct thread *);
extern void thread_cancel_async(struct thread_master *, struct thread **,
				void *);
extern void thread_cancel_event(struct thread_master *, void *);
extern struct thread *thread_fetch(struct thread_master *, struct thread *);
extern void thread_call(struct thread *);
extern unsigned long thread_timer_remain_second(struct thread *);
extern struct timeval thread_timer_remain(struct thread *);
extern unsigned long thread_timer_remain_msec(struct thread *);
extern int thread_should_yield(struct thread *);
/* set yield time for thread */
extern void thread_set_yield_time(struct thread *, unsigned long);

/* Internal libfrr exports */
extern void thread_getrusage(RUSAGE_T *);
extern void thread_cmd_init(void);

/* Returns elapsed real (wall clock) time. */
extern unsigned long thread_consumed_time(RUSAGE_T *after, RUSAGE_T *before,
					  unsigned long *cpu_time_elapsed);

/* only for use in logging functions! */
extern pthread_key_t thread_current;
extern char *thread_timer_to_hhmmss(char *buf, int buf_size,
		struct thread *t_timer);

#ifdef __cplusplus
}
#endif

#endif /* _ZEBRA_THREAD_H */
Commit	Line	Data
718e3744	1	/* Thread management routine header.
	2	* Copyright (C) 1998 Kunihiro Ishiguro
	3	*
	4	* This file is part of GNU Zebra.
	5	*
	6	* GNU Zebra is free software; you can redistribute it and/or modify it
	7	* under the terms of the GNU General Public License as published by the
	8	* Free Software Foundation; either version 2, or (at your option) any
	9	* later version.
	10	*
	11	* GNU Zebra is distributed in the hope that it will be useful, but
	12	* WITHOUT ANY WARRANTY; without even the implied warranty of
	13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	14	* General Public License for more details.
	15	*
896014f4 DL	16	* You should have received a copy of the GNU General Public License along
	17	* with this program; see the file COPYING; if not, write to the Free Software
	18	* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
718e3744	19	*/
	20
	21	#ifndef _ZEBRA_THREAD_H
	22	#define _ZEBRA_THREAD_H
	23
5734509c	24	#include <zebra.h>
1189d95f	25	#include <pthread.h>
75bcb355 QY	26	#include <poll.h>
75bcb355 QY	27	#include "monotime.h"
fbcac826	28	#include "frratomic.h"
c284542b	29	#include "typesafe.h"
5734509c	30
5e244469 RW	31	#ifdef __cplusplus
	32	extern "C" {
	33	#endif
	34
d62a17ae	35	struct rusage_t {
	36	struct rusage cpu;
	37	struct timeval real;
8b70d0b0	38	};
	39	#define RUSAGE_T struct rusage_t
	40
db9c0df9	41	#define GETRUSAGE(X) thread_getrusage(X)
718e3744	42
c284542b	43	PREDECL_LIST(thread_list)
27d29ced	44	PREDECL_HEAP(thread_timer_list)
4becea72	45
d62a17ae	46	struct fd_handler {
	47	/* number of pfd that fit in the allocated space of pfds. This is a
	48	* constant
	49	* and is the same for both pfds and copy. */
	50	nfds_t pfdsize;
	51
	52	/* file descriptors to monitor for i/o */
	53	struct pollfd *pfds;
	54	/* number of pollfds stored in pfds */
	55	nfds_t pfdcount;
	56
	57	/* chunk used for temp copy of pollfds */
	58	struct pollfd *copy;
	59	/* number of pollfds stored in copy */
	60	nfds_t copycount;
0a95a0d0	61	};
0a95a0d0	62
63ccb9cb	63	struct cancel_req {
d62a17ae	64	struct thread *thread;
	65	void *eventobj;
	66	struct thread **threadref;
63ccb9cb QY	67	};
63ccb9cb QY	68
718e3744	69	/* Master of the theads. */
d62a17ae	70	struct thread_master {
	71	char *name;
	72
	73	struct thread **read;
	74	struct thread **write;
27d29ced	75	struct thread_timer_list_head timer;
c284542b	76	struct thread_list_head event, ready, unuse;
d62a17ae	77	struct list *cancel_req;
	78	bool canceled;
	79	pthread_cond_t cancel_cond;
	80	struct hash *cpu_record;
	81	int io_pipe[2];
	82	int fd_limit;
	83	struct fd_handler handler;
	84	unsigned long alloc;
	85	long selectpoll_timeout;
	86	bool spin;
	87	bool handle_signals;
	88	pthread_mutex_t mtx;
	89	pthread_t owner;
718e3744	90	};
	91
	92	/* Thread itself. */
d62a17ae	93	struct thread {
fbcac826 QY	94	uint8_t type; /* thread type */
fbcac826 QY	95	uint8_t add_type; /* thread type */
c284542b	96	struct thread_list_item threaditem;
27d29ced	97	struct thread_timer_list_item timeritem;
d62a17ae	98	struct thread *ref; / external reference (if given) */
	99	struct thread_master master; / pointer to the struct thread_master */
	100	int (func)(struct thread ); /* event function */
	101	void arg; / event argument */
	102	union {
	103	int val; /* second argument of the event. */
	104	int fd; /* file descriptor in case of r/w */
	105	struct timeval sands; /* rest of time sands value. */
	106	} u;
d62a17ae	107	struct timeval real;
	108	struct cpu_thread_history hist; / cache pointer to cpu_history */
	109	unsigned long yield; /* yield time in microseconds */
	110	const char funcname; / name of thread function */
	111	const char schedfrom; / source file thread was scheduled from */
	112	int schedfrom_line; /* line number of source file */
	113	pthread_mutex_t mtx; /* mutex for thread.c functions */
e04ab74d	114	};
e04ab74d	115
d62a17ae	116	struct cpu_thread_history {
d62a17ae	117	int (func)(struct thread );
c8a65463 DL	118	atomic_uint_fast32_t total_calls;
c8a65463 DL	119	atomic_uint_fast32_t total_active;
d62a17ae	120	struct time_stats {
c8a65463	121	atomic_size_t total, max;
d62a17ae	122	} real;
d62a17ae	123	struct time_stats cpu;
c8a65463	124	atomic_uint_fast32_t types;
d62a17ae	125	const char *funcname;
718e3744	126	};
718e3744	127
ca1f4309 DS	128	/* Struct timeval's tv_usec one second value. */
	129	#define TIMER_SECOND_MICRO 1000000L
	130
718e3744	131	/* Thread types. */
	132	#define THREAD_READ 0
	133	#define THREAD_WRITE 1
	134	#define THREAD_TIMER 2
	135	#define THREAD_EVENT 3
	136	#define THREAD_READY 4
a587d00b QY	137	#define THREAD_UNUSED 5
a587d00b QY	138	#define THREAD_EXECUTE 6
718e3744	139
718e3744	140	/* Thread yield time. */
17fc128d	141	#define THREAD_YIELD_TIME_SLOT 10 * 1000L /* 10ms */
718e3744	142
0447957e AK	143	#define THREAD_TIMER_STRLEN 12
0447957e AK	144
718e3744	145	/* Macros. */
	146	#define THREAD_ARG(X) ((X)->arg)
	147	#define THREAD_FD(X) ((X)->u.fd)
	148	#define THREAD_VAL(X) ((X)->u.val)
	149
d62a17ae	150	#define THREAD_OFF(thread) \
	151	do { \
	152	if (thread) { \
	153	thread_cancel(thread); \
	154	thread = NULL; \
	155	} \
	156	} while (0)
718e3744	157
	158	#define THREAD_READ_OFF(thread) THREAD_OFF(thread)
	159	#define THREAD_WRITE_OFF(thread) THREAD_OFF(thread)
	160	#define THREAD_TIMER_OFF(thread) THREAD_OFF(thread)
	161
9c7753e4 DL	162	#define debugargdef const char funcname, const char schedfrom, int fromln
9c7753e4 DL	163
ffa2c898 QY	164	#define thread_add_read(m,f,a,v,t) funcname_thread_add_read_write(THREAD_READ,m,f,a,v,t,#f,__FILE__,__LINE__)
	165	#define thread_add_write(m,f,a,v,t) funcname_thread_add_read_write(THREAD_WRITE,m,f,a,v,t,#f,__FILE__,__LINE__)
	166	#define thread_add_timer(m,f,a,v,t) funcname_thread_add_timer(m,f,a,v,t,#f,__FILE__,__LINE__)
	167	#define thread_add_timer_msec(m,f,a,v,t) funcname_thread_add_timer_msec(m,f,a,v,t,#f,__FILE__,__LINE__)
	168	#define thread_add_timer_tv(m,f,a,v,t) funcname_thread_add_timer_tv(m,f,a,v,t,#f,__FILE__,__LINE__)
	169	#define thread_add_event(m,f,a,v,t) funcname_thread_add_event(m,f,a,v,t,#f,__FILE__,__LINE__)
9c7753e4	170	#define thread_execute(m,f,a,v) funcname_thread_execute(m,f,a,v,#f,__FILE__,__LINE__)
b7fb24ce DS	171	#define thread_execute_name(m, f, a, v, n) \
b7fb24ce DS	172	funcname_thread_execute(m, f, a, v, n, __FILE__, __LINE__)
fb9e46bb	173
718e3744	174	/* Prototypes. */
d62a17ae	175	extern struct thread_master thread_master_create(const char );
d8a8a8de	176	void thread_master_set_name(struct thread_master master, const char name);
d62a17ae	177	extern void thread_master_free(struct thread_master *);
495f0b13	178	extern void thread_master_free_unused(struct thread_master *);
8cc4198f	179
d62a17ae	180	extern struct thread *
	181	funcname_thread_add_read_write(int dir, struct thread_master *,
	182	int ()(struct thread ), void *, int,
	183	struct thread **, debugargdef);
	184
	185	extern struct thread funcname_thread_add_timer(struct thread_master ,
	186	int ()(struct thread ),
	187	void , long, struct thread *,
	188	debugargdef);
	189
	190	extern struct thread *
	191	funcname_thread_add_timer_msec(struct thread_master , int ()(struct thread *),
	192	void , long, struct thread *, debugargdef);
	193
	194	extern struct thread funcname_thread_add_timer_tv(struct thread_master ,
	195	int ()(struct thread ),
	196	void , struct timeval ,
	197	struct thread **,
	198	debugargdef);
	199
	200	extern struct thread funcname_thread_add_event(struct thread_master ,
	201	int ()(struct thread ),
	202	void , int, struct thread *,
	203	debugargdef);
	204
	205	extern void funcname_thread_execute(struct thread_master *,
	206	int ()(struct thread ), void *, int,
	207	debugargdef);
9c7753e4 DL	208	#undef debugargdef
9c7753e4 DL	209
d62a17ae	210	extern void thread_cancel(struct thread *);
	211	extern void thread_cancel_async(struct thread_master , struct thread *,
	212	void *);
	213	extern void thread_cancel_event(struct thread_master , void );
	214	extern struct thread thread_fetch(struct thread_master , struct thread *);
	215	extern void thread_call(struct thread *);
	216	extern unsigned long thread_timer_remain_second(struct thread *);
	217	extern struct timeval thread_timer_remain(struct thread *);
78ca0342	218	extern unsigned long thread_timer_remain_msec(struct thread *);
d62a17ae	219	extern int thread_should_yield(struct thread *);
50596be0	220	/* set yield time for thread */
d62a17ae	221	extern void thread_set_yield_time(struct thread *, unsigned long);
718e3744	222
55c72803	223	/* Internal libfrr exports */
d62a17ae	224	extern void thread_getrusage(RUSAGE_T *);
d62a17ae	225	extern void thread_cmd_init(void);
e04ab74d	226
8b70d0b0	227	/* Returns elapsed real (wall clock) time. */
	228	extern unsigned long thread_consumed_time(RUSAGE_T after, RUSAGE_T before,
	229	unsigned long *cpu_time_elapsed);
	230
d1265948	231	/* only for use in logging functions! */
e0bebc7c	232	extern pthread_key_t thread_current;
0447957e AK	233	extern char thread_timer_to_hhmmss(char buf, int buf_size,
0447957e AK	234	struct thread *t_timer);
d1265948	235
5e244469 RW	236	#ifdef __cplusplus
	237	}
	238	#endif
	239
718e3744	240	#endif /* _ZEBRA_THREAD_H */