Revision control
Copy as Markdown
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
//! Profile how frequent event recording affects performance.
//!
//! Build:
//!
//! ```no_rust
//! cargo build -p glean --example frequent-events --profile profiling
//! ```
//!
//!
//! ```no_rust
//! samply record target/profiling/examples/frequent-events tmp
//! ```
use std::env;
use std::path::PathBuf;
use std::{thread, time};
use once_cell::sync::Lazy;
use glean::net;
use glean::{private::PingType, ClientInfoMetrics, ConfigurationBuilder};
pub mod glean_metrics {
use glean::{private::EventMetric, traits::NoExtraKeys, CommonMetricData, Lifetime};
#[allow(non_upper_case_globals)]
pub static sample_event: ::glean::private::__export::Lazy<EventMetric<NoExtraKeys>> =
::glean::private::__export::Lazy::new(|| {
let meta = CommonMetricData {
category: "test.metrics".into(),
name: "sample_event".into(),
send_in_pings: vec!["prototype".into()],
lifetime: Lifetime::Ping,
disabled: false,
..Default::default()
};
EventMetric::new(meta)
});
}
// Define a fake uploader that sleeps.
#[derive(Debug)]
struct FakeUploader;
impl net::PingUploader for FakeUploader {
fn upload(&self, _upload_request: net::CapablePingUploadRequest) -> net::UploadResult {
thread::sleep(time::Duration::from_millis(100));
net::UploadResult::http_status(200)
}
}
#[allow(non_upper_case_globals)]
pub static PrototypePing: Lazy<PingType> = Lazy::new(|| {
PingType::new(
"prototype",
true,
true,
true,
true,
true,
vec![],
vec![],
true,
vec![],
)
});
fn main() {
env_logger::init();
let mut args = env::args().skip(1);
let data_path = PathBuf::from(args.next().expect("need data path"));
let max = args
.next()
.unwrap_or_else(|| String::from("500000"))
.parse()
.unwrap_or(500000);
log::debug!("Recording {max} events into {}", data_path.display());
_ = &*PrototypePing;
let cfg = ConfigurationBuilder::new(true, data_path, "glean.frequentevents")
.with_server_endpoint("invalid-test-host")
.with_use_core_mps(false)
.with_uploader(FakeUploader)
.build();
let client_info = ClientInfoMetrics {
app_build: env!("CARGO_PKG_VERSION").to_string(),
app_display_version: env!("CARGO_PKG_VERSION").to_string(),
channel: None,
locale: None,
};
glean::initialize(cfg, client_info);
// Wait for init to finish,
// otherwise we might be to quick with calling `shutdown`.
let _ = glean_metrics::sample_event.test_get_value(None);
for _ in 0..max {
glean_metrics::sample_event.record(None);
}
glean::shutdown();
}