Blame jemalloc/include/jemalloc/internal/background_thread_structs.h

Packit Service 724aca
#ifndef JEMALLOC_INTERNAL_BACKGROUND_THREAD_STRUCTS_H
Packit Service 724aca
#define JEMALLOC_INTERNAL_BACKGROUND_THREAD_STRUCTS_H
Packit Service 724aca
Packit Service 724aca
/* This file really combines "structs" and "types", but only transitionally. */
Packit Service 724aca
Packit Service 724aca
#if defined(JEMALLOC_BACKGROUND_THREAD) || defined(JEMALLOC_LAZY_LOCK)
Packit Service 724aca
#  define JEMALLOC_PTHREAD_CREATE_WRAPPER
Packit Service 724aca
#endif
Packit Service 724aca
Packit Service 724aca
#define BACKGROUND_THREAD_INDEFINITE_SLEEP UINT64_MAX
Packit Service 724aca
#define MAX_BACKGROUND_THREAD_LIMIT MALLOCX_ARENA_LIMIT
Packit Service 724aca
#define DEFAULT_NUM_BACKGROUND_THREAD 4
Packit Service 724aca
Packit Service 724aca
typedef enum {
Packit Service 724aca
	background_thread_stopped,
Packit Service 724aca
	background_thread_started,
Packit Service 724aca
	/* Thread waits on the global lock when paused (for arena_reset). */
Packit Service 724aca
	background_thread_paused,
Packit Service 724aca
} background_thread_state_t;
Packit Service 724aca
Packit Service 724aca
struct background_thread_info_s {
Packit Service 724aca
#ifdef JEMALLOC_BACKGROUND_THREAD
Packit Service 724aca
	/* Background thread is pthread specific. */
Packit Service 724aca
	pthread_t		thread;
Packit Service 724aca
	pthread_cond_t		cond;
Packit Service 724aca
#endif
Packit Service 724aca
	malloc_mutex_t		mtx;
Packit Service 724aca
	background_thread_state_t	state;
Packit Service 724aca
	/* When true, it means no wakeup scheduled. */
Packit Service 724aca
	atomic_b_t		indefinite_sleep;
Packit Service 724aca
	/* Next scheduled wakeup time (absolute time in ns). */
Packit Service 724aca
	nstime_t		next_wakeup;
Packit Service 724aca
	/*
Packit Service 724aca
	 *  Since the last background thread run, newly added number of pages
Packit Service 724aca
	 *  that need to be purged by the next wakeup.  This is adjusted on
Packit Service 724aca
	 *  epoch advance, and is used to determine whether we should signal the
Packit Service 724aca
	 *  background thread to wake up earlier.
Packit Service 724aca
	 */
Packit Service 724aca
	size_t			npages_to_purge_new;
Packit Service 724aca
	/* Stats: total number of runs since started. */
Packit Service 724aca
	uint64_t		tot_n_runs;
Packit Service 724aca
	/* Stats: total sleep time since started. */
Packit Service 724aca
	nstime_t		tot_sleep_time;
Packit Service 724aca
};
Packit Service 724aca
typedef struct background_thread_info_s background_thread_info_t;
Packit Service 724aca
Packit Service 724aca
struct background_thread_stats_s {
Packit Service 724aca
	size_t num_threads;
Packit Service 724aca
	uint64_t num_runs;
Packit Service 724aca
	nstime_t run_interval;
Packit Service 724aca
};
Packit Service 724aca
typedef struct background_thread_stats_s background_thread_stats_t;
Packit Service 724aca
Packit Service 724aca
#endif /* JEMALLOC_INTERNAL_BACKGROUND_THREAD_STRUCTS_H */