Addressing comments.

Signed-off-by: Lakshman <Lakshman@node-000.lakshman-266241.rperf-pg0.wisc.cloudlab.us>

Author: Lakshman

.gitattributes

@@ -32,3 +32,4 @@ benchmarks/compression/files/img4.jpg filter=lfs diff=lfs merge=lfs -text
 benchmarks/compression/files/img1.jpg filter=lfs diff=lfs merge=lfs -text
 benchmarks/compression/files/img2.jpg filter=lfs diff=lfs merge=lfs -text
 benchmarks/compression/files/img3.jpg filter=lfs diff=lfs merge=lfs -text
+*.json.gz filter=lfs diff=lfs merge=lfs -text

benchmarks/graph-bfs/Dockerfile

@@ -1,6 +1,6 @@
 # MIT License
 #
-# Copyright (c) 2022 David Schall and EASE lab
+# Copyright (c) 2025 EASE lab
 #
 # Permission is hereby granted, free of charge, to any person obtaining a copy
 # of this software and associated documentation files (the "Software"), to deal
@@ -30,8 +30,8 @@ COPY ./benchmarks/graph-bfs/python/requirements.txt ./
 RUN pip3 install --user -r requirements.txt
 COPY ./utils/tracing/python/tracing.py ./
 COPY ./benchmarks/graph-bfs/python/server.py ./
-ADD https://raw.githubusercontent.com/vhive-serverless/vSwarm-proto/refs/heads/graph-benchmark/proto/graph_bfs/graph_bfs_pb2_grpc.py ./
-ADD https://raw.githubusercontent.com/vhive-serverless/vSwarm-proto/refs/heads/graph-benchmark/proto/graph_bfs/graph_bfs_pb2.py ./proto/graph_bfs/
+ADD https://raw.githubusercontent.com/vhive-serverless/vSwarm-proto/refs/heads/main/proto/graph_bfs/graph_bfs_pb2_grpc.py ./
+ADD https://raw.githubusercontent.com/vhive-serverless/vSwarm-proto/refs/heads/main/proto/graph_bfs/graph_bfs_pb2.py ./proto/graph_bfs/
 
 # Second stage (Runner):
 FROM vhiveease/python-slim:latest as graphBfsPython

benchmarks/graph-bfs/Makefile

@@ -1,6 +1,6 @@
 # MIT License
 
-# Copyright (c) 2022 EASE lab
+# Copyright (c) 2025 EASE lab
 
 # Permission is hereby granted, free of charge, to any person obtaining a copy
 # of this software and associated documentation files (the "Software"), to deal
@@ -20,7 +20,7 @@
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
 
-FUNCTIONS = graph-bfs-python
+FUNCTIONS = graph-bfs-python-image
 ALL_IMAGES = $(FUNCTIONS)
 
 ROOT = ../../

benchmarks/graph-bfs/python/server.py

@@ -2,7 +2,7 @@
 
 # MIT License
 
-# Copyright (c) 2022 EASE lab
+# Copyright (c) 2025 EASE lab
 
 # Permission is hereby granted, free of charge, to any person obtaining a copy
 # of this software and associated documentation files (the "Software"), to deal
@@ -54,46 +54,46 @@
 parser.add_argument("-a", "--addr", dest="addr", default="0.0.0.0", help="IP address")
 parser.add_argument("-p", "--port", dest="port", default="50051", help="serve port")
 parser.add_argument("-zipkin", "--zipkin", dest="url", default="http://0.0.0.0:9411/api/v2/spans", help="Zipkin endpoint url")
+parser.add_argument("--vertices", dest="vertices", default="100000", help="Number of vertices")
+parser.add_argument("--edges", dest="edges", default="1000000", help="Number of edges")
+
 args = parser.parse_args()
 
+
+
 if tracing.IsTracingEnabled():
     tracing.initTracer("graph_bfs", url=args.url)
     tracing.grpcInstrumentClient()
     tracing.grpcInstrumentServer()
 
-def graph_bfs(dur):
+
+def graph_bfs(g, dur, num_vertices):
     """
-    Builds a large random graph and performs random BFS traversals for the specified duration (in milliseconds).
+    Performs random BFS traversals for the specified duration (in milliseconds).
     Returns the number of BFS traversals performed.
     """
-    # Parameters for a massive graph (adjust as needed for your system's memory)
-    num_vertices = 100000  # 100k nodes
-    num_edges = 1000000    # 1M edges
-
-    # Build a random graph
-    g = igraph.Graph.Erdos_Renyi(n=num_vertices, m=num_edges, directed=False)
-
     start_time = time.time()
     bfs_count = 0
     dur_sec = dur / 1000.0
-
     while (time.time() - start_time) < dur_sec:
         root = random.randint(0, num_vertices - 1)
-        # Perform BFS from a random root
         _ = g.bfs(root)
         bfs_count += 1
-
     return bfs_count
 
 
+
 class GraphBFSBenchmark(graph_bfs_pb2_grpc.GraphBFSBenchmarkServicer):
+    def __init__(self):
+        self.num_vertices = int(args.vertices)
+        num_edges = int(args.edges)
+        self.g = igraph.Graph.Erdos_Renyi(n=self.num_vertices, m=num_edges, directed=False)
 
     def GetBfs(self, request, context):
         with tracing.Span("Run graph_bfs"):
-            dur = int(request.name)         # Duration the function must run for in milliseconds
-            bfs_count = graph_bfs(dur)
+            dur = int(request.name)  # Duration the function must run for in milliseconds
+            bfs_count = graph_bfs(self.g, dur, self.num_vertices)
 
-        gid = syscall(104)
         msg = f"fn: graph_bfs | duration_ms: {dur} | bfs_count: {bfs_count} | runtime: python"
         return graph_bfs_pb2.GraphBFSBenchmarkReply(message=msg)
 

benchmarks/graph-bfs/yamls/docker-compose/dc-graph-bfs-python.yaml

@@ -1,6 +1,6 @@
 # MIT License
 
-# Copyright (c) 2022 EASE lab
+# Copyright (c) 2025 EASE lab
 
 # Permission is hereby granted, free of charge, to any person obtaining a copy
 # of this software and associated documentation files (the "Software"), to deal
@@ -30,6 +30,8 @@ services:
       - /app/server.py
       - --addr=0.0.0.0
       - --port=50051
+      - --vertices=100000
+      - --edges=1000000
     ports:
       - target: 50051
 

benchmarks/graph-bfs/yamls/knative/kn-graph-bfs-python.yaml

@@ -1,6 +1,6 @@
 # MIT License
 
-# Copyright (c) 2022 EASE lab
+# Copyright (c) 2025 EASE lab
 
 # Permission is hereby granted, free of charge, to any person obtaining a copy
 # of this software and associated documentation files (the "Software"), to deal
@@ -42,4 +42,6 @@ spec:
         - image: docker.io/vhiveease/graph-bfs-python:latest
           args:
             - --addr=0.0.0.0
-            - --port=50051
+            - --port=50051
+            - --vertices=100000
+            - --edges=1000000

tools/invoker/client.go

@@ -142,13 +142,6 @@ func runExperiment(endpoints []*endpoint.Endpoint, runDuration int, targetRPS fl
 		}
 	}
 	latSlice.Lock()
-	var maxLatency int64
-	maxLatency = 0
-	for _, value := range latSlice.slice {
-		if value > maxLatency {
-			maxLatency = value
-		}
-	}
 	latSlice.slice = []int64{}
 	latSlice.Unlock()
 	profSlice.Lock()

tools/profiler/README.md

@@ -53,7 +53,7 @@ optional arguments:
 python3 main.py profile
 ```
 
-The functions to be profiled are stored in an input JSON file named `config.json` by default(the user can utilize `-config` or `--config_file` to change this argument). The standard structure of this file is a list of json objects: a list of `predeployment-commands`, `postdeployment-commands` and `yaml-location`.  A compressed config file consisting of all the functions that can currently be profiled in the vSwarm suite has been provided.
+The functions to be profiled are stored in an input JSON file named `config.json` by default (the user can utilize `-config` or `--config_file` to change this argument). The standard structure of this file is a list of JSON objects: a list of `predeployment-commands`, `postdeployment-commands`, and `yaml-location`.  A compressed config file consisting of all the functions that can currently be profiled in the vSwarm suite has been provided.
 
 An example input file can look like this:
 ```json