aj/fix fd max metric

bottlecap/src/metrics/enhanced/lambda.rs

@@ -566,7 +566,7 @@ impl Lambda {
 
             // Set fd_max and initial value for fd_use
             let fd_max = proc::get_fd_max_data(&pids);
-            let mut fd_use = proc::get_fd_use_data(&pids).unwrap_or_else(|_| -1_f64);
+            let mut fd_use = proc::get_fd_use_data(&pids);
 
             // Set threads_max and initial value for threads_use
             let threads_max = proc::get_threads_max_data(&pids);
@@ -586,9 +586,8 @@ impl Lambda {
                     // Otherwise keep monitoring file descriptor and thread usage periodically
                     _ = interval.tick() => {
                         pids = proc::get_pid_list();
-                        if let Ok(fd_use_curr) = proc::get_fd_use_data(&pids) {
-                            fd_use = fd_use.max(fd_use_curr);
-                        }
+                        let fd_use_curr = proc::get_fd_use_data(&pids);
+                        fd_use = fd_use.max(fd_use_curr);
                         if let Ok(threads_use_curr) = proc::get_threads_use_data(&pids) {
                             threads_use = threads_use.max(threads_use_curr);
                         }

bottlecap/src/proc/mod.rs

@@ -11,7 +11,7 @@ use constants::{
     LAMDBA_NETWORK_INTERFACE, PROC_NET_DEV_PATH, PROC_PATH, PROC_STAT_PATH, PROC_UPTIME_PATH,
 };
 use regex::Regex;
-use tracing::debug;
+use tracing::{debug, trace};
 
 #[must_use]
 pub fn get_pid_list() -> Vec<i64> {
@@ -244,26 +244,28 @@ fn get_fd_max_data_from_path(path: &str, pids: &[i64]) -> f64 {
     fd_max
 }
 
-pub fn get_fd_use_data(pids: &[i64]) -> Result<f64, io::Error> {
+pub fn get_fd_use_data(pids: &[i64]) -> f64 {
     get_fd_use_data_from_path(PROC_PATH, pids)
 }
 
-fn get_fd_use_data_from_path(path: &str, pids: &[i64]) -> Result<f64, io::Error> {
+fn get_fd_use_data_from_path(path: &str, pids: &[i64]) -> f64 {
     let mut fd_use = 0;
 
     for &pid in pids {
         let fd_path = format!("{path}/{pid}/fd");
-        let Ok(files) = fs::read_dir(fd_path) else {
-            return Err(io::Error::new(
-                io::ErrorKind::InvalidData,
-                "File descriptor use data not found",
-            ));
+        let Ok(files) = fs::read_dir(&fd_path) else {
+            trace!(
+                "File descriptor use data not found in path {} with pid {}",
+                fd_path,
+                pid
+            );
+            continue;
         };
         let count = files.count();
         fd_use += count;
     }
 
-    Ok(fd_use as f64)
+    return fd_use as f64;
 }
 
 #[must_use]
@@ -473,14 +475,8 @@ mod tests {
     fn test_get_fd_use_data() {
         let path = "./tests/proc/process/valid";
         let pids = get_pid_list_from_path(path_from_root(path).as_str());
-        let fd_use_result = get_fd_use_data_from_path(path, &pids);
-        assert!(fd_use_result.is_ok());
-        let fd_use = fd_use_result.unwrap();
+        let fd_use = get_fd_use_data_from_path(path, &pids);
         assert!((fd_use - 5.0).abs() < f64::EPSILON);
-
-        let path = "./tests/proc/process/invalid_missing";
-        let fd_use_result = get_fd_use_data_from_path(path, &pids);
-        assert!(fd_use_result.is_err());
     }
 
     #[test]

bottlecap/src/tags/lambda/tags.rs

@@ -49,7 +49,7 @@ const FUNCTION_TAGS_KEY: &str = "_dd.tags.function";
 // TODO(astuyve) decide what to do with the version
 const EXTENSION_VERSION_KEY: &str = "dd_extension_version";
 // TODO(duncanista) figure out a better way to not hardcode this
-const EXTENSION_VERSION: &str = "68-next";
+const EXTENSION_VERSION: &str = "69-next";
 
 const REGION_KEY: &str = "region";
 const ACCOUNT_ID_KEY: &str = "account_id";