Blame jemalloc/include/jemalloc/internal/prof_inlines_a.h

Packit Service 724aca
#ifndef JEMALLOC_INTERNAL_PROF_INLINES_A_H
Packit Service 724aca
#define JEMALLOC_INTERNAL_PROF_INLINES_A_H
Packit Service 724aca
Packit Service 724aca
#include "jemalloc/internal/mutex.h"
Packit Service 724aca
Packit Service 724aca
static inline bool
Packit Service 724aca
prof_accum_add(tsdn_t *tsdn, prof_accum_t *prof_accum,
Packit Service 724aca
    uint64_t accumbytes) {
Packit Service 724aca
	cassert(config_prof);
Packit Service 724aca
Packit Service 724aca
	bool overflow;
Packit Service 724aca
	uint64_t a0, a1;
Packit Service 724aca
Packit Service 724aca
	/*
Packit Service 724aca
	 * If the application allocates fast enough (and/or if idump is slow
Packit Service 724aca
	 * enough), extreme overflow here (a1 >= prof_interval * 2) can cause
Packit Service 724aca
	 * idump trigger coalescing.  This is an intentional mechanism that
Packit Service 724aca
	 * avoids rate-limiting allocation.
Packit Service 724aca
	 */
Packit Service 724aca
#ifdef JEMALLOC_ATOMIC_U64
Packit Service 724aca
	a0 = atomic_load_u64(&prof_accum->accumbytes, ATOMIC_RELAXED);
Packit Service 724aca
	do {
Packit Service 724aca
		a1 = a0 + accumbytes;
Packit Service 724aca
		assert(a1 >= a0);
Packit Service 724aca
		overflow = (a1 >= prof_interval);
Packit Service 724aca
		if (overflow) {
Packit Service 724aca
			a1 %= prof_interval;
Packit Service 724aca
		}
Packit Service 724aca
	} while (!atomic_compare_exchange_weak_u64(&prof_accum->accumbytes, &a0,
Packit Service 724aca
	    a1, ATOMIC_RELAXED, ATOMIC_RELAXED));
Packit Service 724aca
#else
Packit Service 724aca
	malloc_mutex_lock(tsdn, &prof_accum->mtx);
Packit Service 724aca
	a0 = prof_accum->accumbytes;
Packit Service 724aca
	a1 = a0 + accumbytes;
Packit Service 724aca
	overflow = (a1 >= prof_interval);
Packit Service 724aca
	if (overflow) {
Packit Service 724aca
		a1 %= prof_interval;
Packit Service 724aca
	}
Packit Service 724aca
	prof_accum->accumbytes = a1;
Packit Service 724aca
	malloc_mutex_unlock(tsdn, &prof_accum->mtx);
Packit Service 724aca
#endif
Packit Service 724aca
	return overflow;
Packit Service 724aca
}
Packit Service 724aca
Packit Service 724aca
static inline void
Packit Service 724aca
prof_accum_cancel(tsdn_t *tsdn, prof_accum_t *prof_accum,
Packit Service 724aca
    size_t usize) {
Packit Service 724aca
	cassert(config_prof);
Packit Service 724aca
Packit Service 724aca
	/*
Packit Service 724aca
	 * Cancel out as much of the excessive prof_accumbytes increase as
Packit Service 724aca
	 * possible without underflowing.  Interval-triggered dumps occur
Packit Service 724aca
	 * slightly more often than intended as a result of incomplete
Packit Service 724aca
	 * canceling.
Packit Service 724aca
	 */
Packit Service 724aca
	uint64_t a0, a1;
Packit Service 724aca
#ifdef JEMALLOC_ATOMIC_U64
Packit Service 724aca
	a0 = atomic_load_u64(&prof_accum->accumbytes, ATOMIC_RELAXED);
Packit Service 724aca
	do {
Packit Service 724aca
		a1 = (a0 >= SC_LARGE_MINCLASS - usize)
Packit Service 724aca
		    ? a0 - (SC_LARGE_MINCLASS - usize) : 0;
Packit Service 724aca
	} while (!atomic_compare_exchange_weak_u64(&prof_accum->accumbytes, &a0,
Packit Service 724aca
	    a1, ATOMIC_RELAXED, ATOMIC_RELAXED));
Packit Service 724aca
#else
Packit Service 724aca
	malloc_mutex_lock(tsdn, &prof_accum->mtx);
Packit Service 724aca
	a0 = prof_accum->accumbytes;
Packit Service 724aca
	a1 = (a0 >= SC_LARGE_MINCLASS - usize)
Packit Service 724aca
	    ?  a0 - (SC_LARGE_MINCLASS - usize) : 0;
Packit Service 724aca
	prof_accum->accumbytes = a1;
Packit Service 724aca
	malloc_mutex_unlock(tsdn, &prof_accum->mtx);
Packit Service 724aca
#endif
Packit Service 724aca
}
Packit Service 724aca
Packit Service 724aca
JEMALLOC_ALWAYS_INLINE bool
Packit Service 724aca
prof_active_get_unlocked(void) {
Packit Service 724aca
	/*
Packit Service 724aca
	 * Even if opt_prof is true, sampling can be temporarily disabled by
Packit Service 724aca
	 * setting prof_active to false.  No locking is used when reading
Packit Service 724aca
	 * prof_active in the fast path, so there are no guarantees regarding
Packit Service 724aca
	 * how long it will take for all threads to notice state changes.
Packit Service 724aca
	 */
Packit Service 724aca
	return prof_active;
Packit Service 724aca
}
Packit Service 724aca
Packit Service 724aca
#endif /* JEMALLOC_INTERNAL_PROF_INLINES_A_H */