moq-native 0.14.0

Media over QUIC - Helper library for native applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use tikv_jemalloc_ctl::raw;

pub use tikv_jemallocator;

/// Activate jemalloc heap profiling and listen for SIGUSR1 to dump profiles.
///
/// The dump path is controlled by `MALLOC_CONF=prof_prefix:<path>`.
/// Returns `Ok(())` if profiling is not available (i.e. MALLOC_CONF=prof:true was not set).
pub async fn run() -> anyhow::Result<()> {
	let prof_active = b"prof.active\0";

	match unsafe { raw::read::<bool>(prof_active) } {
		Ok(true) => tracing::info!("jemalloc heap profiling is active"),
		Ok(false) => {
			tracing::info!("jemalloc profiling compiled in; activating");
			unsafe { raw::write(prof_active, true) }
				.map_err(|err| anyhow::anyhow!("failed to activate jemalloc profiling: {err}"))?;
		}
		Err(err) => {
			tracing::debug!(%err, "jemalloc profiling not available — set MALLOC_CONF=prof:true to enable");
			return Ok(());
		}
	}

	let mut sig = tokio::signal::unix::signal(tokio::signal::unix::SignalKind::user_defined1())?;

	loop {
		sig.recv().await;

		// Null pointer tells jemalloc to use prof_prefix from MALLOC_CONF.
		match unsafe { raw::write(b"prof.dump\0", std::ptr::null::<u8>()) } {
			Ok(()) => tracing::info!("heap profile dumped"),
			Err(err) => tracing::error!(%err, "failed to dump heap profile"),
		}
	}
}