update

examples/echo_service/prod_test/Makefile

@@ -2,7 +2,8 @@ CMDPATH=../../../cmd
 BINPATH=../../../bin
 
 PROD=1
-NUM_NODES=$(shell ls ./other_nodes | wc -l)
+NUM_NODES=10
+LIST_NODES=$(shell ls ./other_nodes | wc -l)
 
 .PHONY: default init build run clean
 default: init clean build run
@@ -11,7 +12,7 @@ init:
 	pkill -15 --version
 
 generate-configs: 
-	go run ./gen_cfgs prod_$(PROD)
+	go run ./gen_cfgs prod_$(PROD) $(NUM_NODES)
 
 build: generate-configs
 	# MAKEFILE BUILD
@@ -20,7 +21,7 @@ build: generate-configs
 	# COPY HLS
 	cp -r $(BINPATH)/hls ./recv_hls/prog_hls1
 	cp -r $(BINPATH)/hls ./send_hls/prog_hls2
-	for i in $$(seq 1 $(NUM_NODES)); do \
+	for i in $$(seq 1 $(LIST_NODES)); do \
 		cp -r $(BINPATH)/hls ./other_nodes/other_hls$${i}/prog_other_hls$${i}; \
 	done;
 
@@ -33,12 +34,12 @@ clean:
 	# MAKEFILE CLEAN 
 	make clean -C ./recv_hls
 	make clean -C ./send_hls
-	for i in $$(seq 1 $(NUM_NODES)); do \
+	for i in $$(seq 1 $(LIST_NODES)); do \
 		make clean -C ./other_nodes/other_hls$${i}; \
 	done;
 	rm -rf other_nodes/
 
 run-other-nodes:
-	for i in $$(seq 1 $(NUM_NODES)); do \
+	for i in $$(seq 1 $(LIST_NODES)); do \
 		make run -C ./other_nodes/other_hls$${i}; \
 	done;

examples/echo_service/prod_test/gen_cfgs/main.go

@@ -3,12 +3,12 @@ package main
 import (
 	"fmt"
 	"os"
+	"strconv"
 	"strings"
 )
 
 const (
 	cMessageSizeBytes = (8 << 10)
-	cLenOtherNodes    = 10
 )
 
 type sNodeHLS struct {
@@ -18,13 +18,14 @@ type sNodeHLS struct {
 }
 
 var (
+	gNumOtherNodes  int
 	gNetworkKey     string
 	gListOfConnects []string
 )
 
 func initRun() error {
-	if len(os.Args) != 2 {
-		return fmt.Errorf("len args != 2")
+	if len(os.Args) != 3 {
+		return fmt.Errorf("len args != 3")
 	}
 
 	switch os.Args[1] {
@@ -38,6 +39,12 @@ func initRun() error {
 		return fmt.Errorf("unknown param")
 	}
 
+	numNodes, err := strconv.Atoi(os.Args[2])
+	if err != nil {
+		panic(err)
+	}
+
+	gNumOtherNodes = numNodes
 	return nil
 }
 
@@ -55,11 +62,11 @@ func main() {
 	firstConnect := connects[0]
 	secondConnect := connects[len(connects)-1]
 
-	nodes := make([]*sNodeHLS, 0, 2+cLenOtherNodes) // 2 = recv+send
+	nodes := make([]*sNodeHLS, 0, 2+gNumOtherNodes) // 2 = recv+send
 	nodes = append(nodes, initRecvNode(firstConnect), initSendNode(secondConnect))
 
 	os.Mkdir("other_nodes", 0744)
-	for i := 1; i <= cLenOtherNodes; i++ {
+	for i := 1; i <= gNumOtherNodes; i++ {
 		node := initOtherNode(i, strConnects)
 		nodes = append(nodes, node)
 		os.Mkdir(node.fPath, 0744)