Loading src/simap_connector/service/telemetry/worker/data/SyntheticSamplers.py +8 −12 Original line number Diff line number Diff line Loading @@ -74,8 +74,8 @@ class SyntheticSampler: # First sample: start at average for this connection count bw_utilization = avg else: # Add ±2% noise to previous value for temporal continuity noise_factor = random.uniform(-0.02, 0.02) # Add ±1% noise to previous value for temporal continuity noise_factor = random.uniform(-0.01, 0.01) bw_utilization = self.prev_bw * (1.0 + noise_factor) # Clamp to current range (handles "jump" when connection count changes) Loading @@ -88,8 +88,8 @@ class SyntheticSampler: if self.prev_latency is None: latency = target_latency else: # Add ±2% noise to previous latency noise_factor = random.uniform(-0.02, 0.02) # Add ±1% noise to previous latency noise_factor = random.uniform(-0.01, 0.01) latency = self.prev_latency * (1.0 + noise_factor) # Clamp latency to reasonable range Loading @@ -109,10 +109,6 @@ class SyntheticSamplers: def add_sampler( self, sampler_name : str, base_bw_range : Tuple[float, float] = (5.0, 20.0), base_latency_range : Tuple[float, float] = (0.3, 2.0), sensitivity_range : Tuple[float, float] = (0.3, 1.0), curve_type : Optional[str] = None, connection_count : int = 0, link_capacity : float = 100.0 ) -> None: Loading Loading
src/simap_connector/service/telemetry/worker/data/SyntheticSamplers.py +8 −12 Original line number Diff line number Diff line Loading @@ -74,8 +74,8 @@ class SyntheticSampler: # First sample: start at average for this connection count bw_utilization = avg else: # Add ±2% noise to previous value for temporal continuity noise_factor = random.uniform(-0.02, 0.02) # Add ±1% noise to previous value for temporal continuity noise_factor = random.uniform(-0.01, 0.01) bw_utilization = self.prev_bw * (1.0 + noise_factor) # Clamp to current range (handles "jump" when connection count changes) Loading @@ -88,8 +88,8 @@ class SyntheticSampler: if self.prev_latency is None: latency = target_latency else: # Add ±2% noise to previous latency noise_factor = random.uniform(-0.02, 0.02) # Add ±1% noise to previous latency noise_factor = random.uniform(-0.01, 0.01) latency = self.prev_latency * (1.0 + noise_factor) # Clamp latency to reasonable range Loading @@ -109,10 +109,6 @@ class SyntheticSamplers: def add_sampler( self, sampler_name : str, base_bw_range : Tuple[float, float] = (5.0, 20.0), base_latency_range : Tuple[float, float] = (0.3, 2.0), sensitivity_range : Tuple[float, float] = (0.3, 1.0), curve_type : Optional[str] = None, connection_count : int = 0, link_capacity : float = 100.0 ) -> None: Loading