CN/app_streamlit.py at main · nandhakumar-murugan/CN · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
import os
import streamlit as st
import numpy as np
import pandas as pd
import simpy

from simulation.network_models import CircuitSwitchedNetwork, PacketSwitchedNetwork, compute_metrics
from simulation.traffic import generate_voip_flow, generate_video_flow
from visualization.plotting import (
    plot_delay_box,
    plot_jitter_bar,
    plot_loss_rate,
    plot_bandwidth_utilization,
)


st.set_page_config(page_title="Circuit vs Packet Switching", layout="wide")
st.title("Performance Analysis: Circuit vs Packet Switching (VoIP & Video)")

with st.sidebar:
    st.header("Simulation Parameters")
    duration_s = st.slider("Duration (s)", 10, 120, 30)
    voip_calls = st.slider("VoIP calls", 1, 50, 10)
    video_streams = st.slider("Video streams", 1, 10, 2)
    link_bandwidth_mbps = st.slider("Packet link bandwidth (Mbps)", 1, 100, 10)
    buffer_capacity_packets = st.slider("Packet buffer capacity (packets)", 10, 1000, 100)
    base_delay_ms = st.slider("Base propagation delay (ms)", 1, 100, 15)
    jitter_ms_mean = st.slider("Jitter mean (ms)", 0, 50, 5)
    jitter_ms_std = st.slider("Jitter std (ms)", 0, 50, 2)

col_run, col_save = st.columns(2)
run_clicked = col_run.button("Run Simulation")

if run_clicked:
    np.random.seed(42)
    # Circuit
    env_c = simpy.Environment()
    net_c = CircuitSwitchedNetwork(env_c, base_delay_ms=10.0)
    for i in range(voip_calls):
        env_c.process(generate_voip_flow(env_c, net_c, i, duration_s))
    for j in range(video_streams):
        env_c.process(generate_video_flow(env_c, net_c, j, duration_s))
    env_c.run(until=duration_s)
    df_c = net_c.get_results_df()
    util_c = net_c.utilization(duration_s)

    # Packet
    env_p = simpy.Environment()
    net_p = PacketSwitchedNetwork(
        env_p,
        link_bandwidth_bps=link_bandwidth_mbps * 1e6,
        buffer_capacity_packets=buffer_capacity_packets,
        base_delay_ms=base_delay_ms,
        jitter_ms_mean=jitter_ms_mean,
        jitter_ms_std=jitter_ms_std,
    )
    for i in range(voip_calls):
        env_p.process(generate_voip_flow(env_p, net_p, i, duration_s))
    for j in range(video_streams):
        env_p.process(generate_video_flow(env_p, net_p, j, duration_s))
    env_p.run(until=duration_s)
    df_p = net_p.get_results_df()
    util_p = net_p.utilization(duration_s)

    df_all = pd.concat([df_c, df_p], ignore_index=True)
    metrics_df = compute_metrics(df_all, duration_s, circuit_utilization=util_c, packet_utilization=util_p)

    st.subheader("Summary Metrics")
    st.dataframe(metrics_df)

    st.subheader("Delay Comparison (ms)")
    fig1 = plot_delay_box(df_all)
    st.pyplot(fig1)

    st.subheader("Jitter Comparison (ms)")
    fig2 = plot_jitter_bar(metrics_df)
    st.pyplot(fig2)

    st.subheader("Packet Loss Rate")
    fig3 = plot_loss_rate(metrics_df)
    st.pyplot(fig3)

    st.subheader("Bandwidth Utilization")
    fig4 = plot_bandwidth_utilization(metrics_df)
    st.pyplot(fig4)

    # Optional save
    if col_save.button("Save CSVs & Images"):
        data_dir = os.path.join(os.path.dirname(__file__), 'data')
        img_dir = os.path.join(os.path.dirname(__file__), 'visualization', 'images')
        os.makedirs(data_dir, exist_ok=True)
        os.makedirs(img_dir, exist_ok=True)
        df_c[df_c['stream_type'] == 'voip'].to_csv(os.path.join(data_dir, 'voip_circuit.csv'), index=False)
        df_c[df_c['stream_type'] == 'video'].to_csv(os.path.join(data_dir, 'video_circuit.csv'), index=False)
        df_p[df_p['stream_type'] == 'voip'].to_csv(os.path.join(data_dir, 'voip_packet.csv'), index=False)
        df_p[df_p['stream_type'] == 'video'].to_csv(os.path.join(data_dir, 'video_packet.csv'), index=False)
        metrics_df.to_csv(os.path.join(data_dir, 'summary.csv'), index=False)
        st.success("Saved CSVs and summary.")