Fix [model] logging, c_p equation bug, and

fair share type signalling

* Add a timestamp_us to LogMetric of [model]
* Remove double p_all_rnti from c_p equation
* Publish fair share type on download-start from [downloader] to [model]

src/logic/downloader.rs

@@ -1,5 +1,4 @@
 use std::net::SocketAddr;
-use std::os::unix::io::AsRawFd;
 use std::sync::mpsc::TryRecvError;
 use std::{
     collections::HashMap,
@@ -22,7 +21,7 @@ use crate::ngscope::types::NgScopeCellDci;
 use crate::{
     logger::{log_download, log_info},
     parse::{Arguments, FlattenedDownloadArgs, Scenario},
-    util::{determine_process_id, init_heap_buffer, print_debug, print_info, sockopt_get_tcp_info},
+    util::{determine_process_id, init_heap_buffer, print_debug, print_info},
 };
 
 pub const INITIAL_SLEEP_TIME_MS: u64 = 20_000;
@@ -104,7 +103,7 @@ struct RunArgs {
 
 #[derive(Debug, Clone, PartialEq)]
 pub struct DownloadConfig {
-    pub rtt_us: u64,
+    pub rtt_us: Option<u64>,
     pub rnti_share_type: u8,
 }
 
@@ -210,7 +209,7 @@ fn run(run_args: &mut RunArgs) -> Result<()> {
                     rnti_share_type: determine_rnti_fair_share_type_by_path(&download_path),
                     ..Default::default()
                 };
-                handle_start_download(&mut current_download, stream_handle)
+                handle_start_download(&mut current_download, stream_handle, tx_download_config)
             }
             DownloaderState::Downloading => {
                 let params = DownloadingParameters {
@@ -313,7 +312,15 @@ fn handle_finish_download(finish_parameters: DownloadFinishParameters) -> Downlo
 fn handle_start_download(
     download_stream_state: &mut DownloadStreamState,
     stream_option: &mut Option<TcpStream>,
+    tx_download_config: &mut Bus<MessageDownloadConfig>,
 ) -> DownloaderState {
+    tx_download_config.broadcast(MessageDownloadConfig {
+        config: DownloadConfig {
+            rtt_us: None,
+            rnti_share_type: download_stream_state.rnti_share_type,
+        },
+    });
+
     match create_download_stream(
         &download_stream_state.base_addr,
         &download_stream_state.path,
@@ -368,7 +375,7 @@ fn handle_downloading(params: DownloadingParameters) -> DownloaderState {
                     });
                     tx_download_config.broadcast(MessageDownloadConfig {
                         config: DownloadConfig {
-                            rtt_us,
+                            rtt_us: Some(rtt_us),
                             rnti_share_type: *rnti_share_type,
                         },
                     });
@@ -481,14 +488,6 @@ fn create_download_stream(base_addr: &str, path: &str) -> Result<TcpStream> {
     Ok(stream)
 }
 
-fn determine_socket_rtt(stream: &mut TcpStream) -> Result<u64> {
-    let socket_file_descriptor: i32 = stream.as_raw_fd();
-    let tcp_info = sockopt_get_tcp_info(socket_file_descriptor)?;
-    let rtt_us = tcp_info.tcpi_rtt as u64;
-    print_debug(&format!("DEBUG [determine_socket_rtt] rtt: {:?}", rtt_us));
-    Ok(rtt_us)
-}
-
 fn try_to_decode_rtt(buffer: &[u8], last_rtt_us: &mut Option<u64>) -> Option<u64> {
     // Only search in a small portion of the whole buffer
     let partial_buffer = if buffer.len() > 40 {

src/logic/mod.rs

@@ -310,6 +310,8 @@ pub struct MessageDownloadConfig {
 pub struct MetricA {
     /// Timestamp when the metric was calculated
     timestamp_us: u64,
+    /// Fair (0), less fair (1) , Greedy (2)
+    fair_share_type: u8,
     /// Fair share send rate [bits/subframe] = [bits/ms]
     fair_share_send_rate: u64,
     /// Timestamp of the latest DCI used to calculate the metric
@@ -320,10 +322,10 @@ pub struct MetricA {
     nof_dci: u16,
     /// Ratio of no TBS PRBs to PRBs with TBS (~reTx ratio)
     no_tbs_prb_ratio: f64,
-    /// Flag, signalling whether phy_rate was averagerd over all RNTIs or just our UE RNTI
-    flag_phy_rate_all_rnti: u8,
-    /// Average bit per PRB (either over all RNTIs or just the UE RNTI)
+    /// Average bit per PRB
     phy_rate: u64,
+    /// Flag, signalling whether phy_rate was static (0) averagerd over all RNTIs (1) or just our UE RNTI (2)
+    phy_rate_mode: u8,
 }
 
 /*  --------------  */

src/logic/model_handler.rs

@@ -90,16 +90,22 @@ pub struct MetricResult {
     pub transport_fair_share_capacity_bit_per_ms: u64,
     pub physical_fair_share_capacity_bit_per_ms: u64,
     pub physical_rate_bit_per_prb: u64,
-    /// If 1, all RNTIs are used to determine the bit/PRB rate (more general)
-    /// If 0, only the target-RNTI PRBs are used to determine the bit/PRB rate (more specific)
-    pub physical_rate_coarse_flag: u8,
+    /// If 2, all RNTIs are used to determine the bit/PRB rate (more general)
+    /// If 1, only the target-RNTI PRBs are used to determine the bit/PRB rate (more specific)
+    /// If 0, the static rate is used
+    pub physical_rate_mode: u8,
+    /// If 2, greedy
+    /// If 1, not soo fair
+    /// If 0, super fair
+    pub fair_share_type: u8,
     pub no_tbs_prb_ratio: f64,
 }
 
 #[derive(Clone, Debug, PartialEq, Default, Serialize, Deserialize)]
 pub struct MetricBasis {
     pub nof_dci: u64,
     pub p_cell: u64,
+    pub p_idle: u64,
     pub nof_rnti_shared: u64,
     pub nof_rnti_in_dci: u64,
     pub rnti_share_type: u8,
@@ -115,6 +121,7 @@ pub struct MetricBasis {
 
 #[derive(Clone, Debug, PartialEq, Default, Serialize, Deserialize)]
 pub struct LogMetric {
+    timestamp_us: u64,
     result: MetricResult,
     basis: MetricBasis,
 }
@@ -236,7 +243,9 @@ fn run(run_args: &mut RunArgs) -> Result<()> {
         };
         match rx_download_config.try_recv() {
             Ok(download_config) => {
-                last_rtt_us = Some(download_config.config.rtt_us);
+                if let Some(new_rtt_us) = download_config.config.rtt_us {
+                    last_rtt_us = Some(new_rtt_us);
+                }
                 last_rnti_share_type = download_config.config.rnti_share_type;
             }
             Err(TryRecvError::Empty) => {}
@@ -346,24 +355,19 @@ fn handle_calculate_metric(
             is_log_metric,
             rnti_share_type,
         ) {
-            let transport_capacity = metric_wrapper
-                .result
-                .transport_fair_share_capacity_bit_per_ms;
-            let physical_rate_flag = metric_wrapper.result.physical_rate_coarse_flag;
-            let physical_rate = metric_wrapper.result.physical_rate_bit_per_prb;
-            let no_tbs_prb_ratio = metric_wrapper.result.no_tbs_prb_ratio;
             let now_us = chrono::Local::now().timestamp_micros() as u64;
 
             tx_metric.broadcast(MessageMetric {
                 metric: MetricTypes::A(MetricA {
                     timestamp_us: now_us,
-                    fair_share_send_rate: transport_capacity,
+                    fair_share_type: metric_wrapper.result.fair_share_type,
+                    fair_share_send_rate: metric_wrapper.result.transport_fair_share_capacity_bit_per_ms,
                     latest_dci_timestamp_us: buffer_slice.first().unwrap().time_stamp,
                     oldest_dci_timestamp_us: buffer_slice.last().unwrap().time_stamp,
                     nof_dci: buffer_slice.len() as u16,
-                    no_tbs_prb_ratio,
-                    flag_phy_rate_all_rnti: physical_rate_flag,
-                    phy_rate: physical_rate,
+                    no_tbs_prb_ratio: metric_wrapper.result.no_tbs_prb_ratio,
+                    phy_rate_mode: metric_wrapper.result.physical_rate_mode,
+                    phy_rate: metric_wrapper.result.physical_rate_bit_per_prb,
                 }),
             });
         }
@@ -411,7 +415,7 @@ fn calculate_capacity(
             * 1000.0
             / (1024.0 * 1024.0),
         metric_wrapper.result.physical_rate_bit_per_prb,
-        metric_wrapper.result.physical_rate_coarse_flag,
+        metric_wrapper.result.physical_rate_mode,
         metric_wrapper.result.no_tbs_prb_ratio,
     ));
     Ok(metric_wrapper)
@@ -500,20 +504,22 @@ fn calculate_pbe_cc_capacity(
 
     // Flag to signialize that the bit per PRB rate does NOT belong to our RNTI and is a coarse
     // estimation
-    let mut r_w_coarse_flag: u8 = 0;
+    let r_w_mode: u8;
 
     // [bit/PRB]
     let r_w: u64 = if p_alloc_rnti == 0 {
-        r_w_coarse_flag = 1;
         if p_alloc > 0 {
             /* Use mean ratio of other RNTIs */
+            r_w_mode = 1;
             tbs_alloc_bit / p_alloc
         } else {
             /* Use bit per PRB rate from experience */
+            r_w_mode = 0;
             STANDARD_BIT_PER_PRB
         }
     } else {
         /* Use the bit per PRB of our RNTI */
+        r_w_mode = 2;
         tbs_alloc_rnti_bit / p_alloc_rnti
     };
 
@@ -570,10 +576,8 @@ fn calculate_pbe_cc_capacity(
     /*
      * Determine the fair share badnwidth c_p (physical layer) and c_t (transport layer)
      * */
-    let p_alloc_rnti_suggested: u64 =
-        p_alloc_rnti + ((p_idle + nof_rnti_shared - 1) / nof_rnti_shared);
-    let c_p: u64 =
-        ((r_w as f64 * (p_alloc_rnti + (p_alloc_rnti_suggested)) as f64) / nof_dci as f64) as u64;
+    let p_alloc_rnti_suggested: u64 = p_alloc_rnti + ((p_idle + nof_rnti_shared - 1) / nof_rnti_shared);
+    let c_p: u64 = (((r_w * p_alloc_rnti_suggested) as f64) / (nof_dci as f64)) as u64;
     let c_t = translate_physcial_to_transport_simple(c_p);
 
     let mut no_tbs_prb_ratio = 0.0;
@@ -611,17 +615,21 @@ fn calculate_pbe_cc_capacity(
         (tbs_alloc_rnti_bit as f64 / (nof_dci as f64)) * 1000.0 / (1024.0 * 1024.0),
     ));
 
+    let log_timestamp_us = chrono::Local::now().timestamp_micros() as u64;
     Ok(LogMetric {
+        timestamp_us: log_timestamp_us,
         result: MetricResult {
             physical_fair_share_capacity_bit_per_ms: c_p,
             transport_fair_share_capacity_bit_per_ms: c_t,
+            fair_share_type: used_rnti_share_type,
             physical_rate_bit_per_prb: r_w,
-            physical_rate_coarse_flag: r_w_coarse_flag,
+            physical_rate_mode: r_w_mode,
             no_tbs_prb_ratio,
         },
         basis: MetricBasis {
             nof_dci,
             p_cell,
+            p_idle,
             nof_rnti_shared,
             nof_rnti_in_dci: nof_rnti,
             rnti_share_type: used_rnti_share_type,
@@ -719,7 +727,7 @@ mod tests {
             33621
         );
         assert_eq!(metric_params.result.physical_rate_bit_per_prb, 512);
-        assert_eq!(metric_params.result.physical_rate_coarse_flag, 0);
+        assert_eq!(metric_params.result.physical_rate_mode, 0);
         assert_eq!(metric_params.result.no_tbs_prb_ratio, 0.0);
         Ok(())
     }

src/util.rs

@@ -7,7 +7,7 @@ use std::sync::Arc;
 
 use anyhow::{anyhow, Result};
 use lazy_static::lazy_static;
-use libc::{c_void, getsockopt, socklen_t, TCP_INFO};
+use libc::{c_void, getsockopt, socklen_t, TCP_INFO, gettid};
 use std::mem;
 
 use crate::logger::log_info;
@@ -158,7 +158,8 @@ pub fn helper_json_pointer(
 
 pub fn determine_process_id() -> u64 {
     /* Taken from: https://github.com/alecmocatta/palaver/blob/cc955a9d56f187fe57a2d042e4ff4120d50dc3a7/src/thread.rs#L23 */
-    match Into::<libc::pid_t>::into(nix::unistd::gettid()).try_into() {
+    let gettid_res = unsafe { gettid() };
+    match Into::<libc::pid_t>::into(gettid_res).try_into() {
         Ok(res) => res,
         Err(_) => std::process::id() as u64,
     }