bep: adjust default lock time and make the per message timeout be the… (#33)

… lock time

Author: DolceTriade

blade/bep/lib.rs

@@ -129,7 +129,7 @@ impl publish_build_event_server::PublishBuildEvent for BuildEventService {
             }
             let mut session = session::BESSession::new(handlers, global.clone());
             loop {
-                let Ok(msg) = tokio::time::timeout(std::time::Duration::from_secs(60), in_stream.message()).await else {
+                let Ok(msg) = tokio::time::timeout(global.session_lock_time, in_stream.message()).await else {
                     tracing::warn!("Timeout waiting for message for {}, skipping.", session.invocation_id());
                     let _ = tx.send(Err(tonic::Status::deadline_exceeded("failed to wait for timeout"))).await;
                     return;

blade/main.rs

@@ -117,7 +117,7 @@ cfg_if! {
             bytestream_overrides: Vec<String>,
             #[arg(short='r', long="retention", value_name = "RETENTION", value_parser = humantime::parse_duration)]
             retention: Option<std::time::Duration>,
-            #[arg(short='s', long="session_lock_time", value_name = "LOCK_TIME", value_parser = humantime::parse_duration, default_value="5m")]
+            #[arg(short='s', long="session_lock_time", value_name = "LOCK_TIME", value_parser = humantime::parse_duration, default_value="1h")]
             session_lock_time: std::time::Duration,
             #[arg(long="flame", value_name = "FLAME")]
             flame_path: Option<String>,