Skip to content

Commit a3f672e

Browse files
committed
Fix some logging
1 parent 7b2cc52 commit a3f672e

3 files changed

Lines changed: 4 additions & 8 deletions

File tree

src/source_plugin/client/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -253,7 +253,7 @@ impl Client {
253253
cancel_rx: watch::Receiver<bool>,
254254
zone_exit_tx: mpsc::UnboundedSender<String>,
255255
) -> Result<JoinSet<()>> {
256-
info!("Listening for kernel events from zone {}", zone_id);
256+
debug!("listening for kernel events from zone {}", zone_id);
257257
let event = MonitorZoneKernelEventRequest {
258258
zone_id: zone_id.clone(),
259259
request: Some(zk_req::Request::Update(ZoneKernelEventStreamUpdate {

src/source_plugin/mod.rs

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -64,11 +64,7 @@ impl EderaSourcePluginInstance {
6464
// and populate our internal thread table with them, rather than
6565
// adding them to the batch and passing them back to `scap`.
6666
threadsnap_count += 1;
67-
debug!(
68-
"take_events: received thread snapshot for zone_id {:?} with {} threads, initializing zone",
69-
snap.zone_id,
70-
snap.thread_info.len(),
71-
);
67+
info!("discovered and initialized zone {}", snap.zone_id,);
7268
plugin.threadstate.init_zone_with_snap(snap);
7369
}
7470
Some(Reply::Syscall(evt)) => {
@@ -111,7 +107,7 @@ impl EderaSourcePluginInstance {
111107
// we want to handle these before dealing with any subsequent events
112108
if let Some(zone_dead_rx) = &mut self.zone_exit_rx {
113109
while let Ok(term_zone_id) = zone_dead_rx.try_recv() {
114-
debug!("zone {term_zone_id} is dead, dropping from threadsnap");
110+
info!("stopped streaming events from zone {term_zone_id}");
115111
plugin.threadstate.drop_zone_from_snap(&term_zone_id);
116112
}
117113
}

src/threadstate.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3374,7 +3374,7 @@ impl ThreadState {
33743374
.expect("should parse");
33753375

33763376
let Some(zinfo) = self.zone_info.get_mut(&event.zone_id) else {
3377-
warn!("ignoring event for unknown zone {:?}", &event.zone_id);
3377+
debug!("ignoring event for unmonitored zone {:?}", &event.zone_id);
33783378
return Ok(());
33793379
};
33803380

0 commit comments

Comments
 (0)