Skip to content

Commit

Permalink
feat: log domain on conn start
Browse files Browse the repository at this point in the history
  • Loading branch information
ramiroaisen committed Nov 14, 2023
1 parent 1066ab0 commit 7c52768
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions rs/packages/stream/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -421,18 +421,19 @@ impl StreamHandler {

let transfer_bytes = Arc::new(AtomicU64::new(0));

let station_name = station.name;
let ip = conn_doc.ip;

let conn_id = conn_doc.id;
let end_reason = Arc::new(Mutex::new(EndReason::None));

let station_name = station.name;
let ip = conn_doc.ip;
let domain = conn_doc_lite.domain.clone();

let connection_dropper = StreamConnectionDropper(Some(StreamConnectionDropperInner {
id: conn_id.clone(),
ip,
station_id: station_id.clone(),
station_name: station_name.clone(),
domain: conn_doc_lite.domain,
domain: domain.clone(),
account_id: station.account_id.clone(),
transfer_bytes: transfer_bytes.clone(),
token: drop_tracer.token(),
Expand All @@ -454,7 +455,7 @@ impl StreamHandler {

let mut is_first_chunk = true;

info!("START conn {conn_id} {ip} - station: {station_id} ({station_name})");
info!("START conn {conn_id} {ip} - {station_id} ({station_name}) in {domain}", domain = domain.as_deref().unwrap_or("???"),);

'root: loop {
let loop_start = Instant::now();
Expand Down

0 comments on commit 7c52768

Please sign in to comment.