Skip to content

Commit

Permalink
new push
Browse files Browse the repository at this point in the history
  • Loading branch information
Antonio committed Sep 13, 2022
1 parent 19007be commit 37f6ea3
Show file tree
Hide file tree
Showing 2 changed files with 210 additions and 0 deletions.
198 changes: 198 additions & 0 deletions mixedDynamic.py
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,198 @@
import multiprocessing
from src.Graphs.Objects.MultipleEdge import DynamicGraph
from src.StastModules.Snapshot import get_snapshot_dynamic
from src.FileOperations.WriteOnFile import create_file, create_folder, write_on_file_contents

import math as mt
import logging
import pandas as pd

logging.basicConfig(format='%(levelname)s:%(message)s', level=logging.DEBUG)


def worker(data, return_dict):
def check_convergence_dynamic():
flood_dictionary = {}
# print(G.get_converged())
if (G.get_converged()):
if (G.flooding.get_initiator() == -1):
# print("STARTING FLOODING")
logging.info("Flooding started for simulation %r ", data['sim'])
G.set_flooding()
G.flooding.set_stop_time(mt.floor(mt.log(G.get_target_n(), 2)))
G.flooding.set_initiator()
G.flooding.update_flooding(G)
else:

# Updating Flooding
# if (G.flooding.get_t_flood() == 1):
# print("Flooding protocol STARTED %r" % (G.flooding.get_started()))
if (G.flooding.get_started() == True):
G.flooding.update_flooding(G)

if (not G.flooding.check_flooding_status()):
G.set_converged(True)
if (G.flooding.get_number_of_restart() == 0):
# print("All the informed nodes left the network")
# print("Flooding Protocol status: Failed")
# print("----------------------------------------------------------------")
G.flooding.set_converged(False)
G.flooding.set_failed(True)
# if (G.flooding.get_converged()):
# print("AL NODES IN THE NETWORK ARE INFORMED")
# print("Number of informed nodes %d" % (G.flooding.get_informed_nodes()))
# print("Number of uninformed nodes %d " % (G.flooding.get_uninformed_nodes()))
# print("Percentage of informed nodes %r" % (G.flooding.get_percentage()))
# print("Informed Ratio: %r" % (G.flooding.get_last_ratio()))
# print("Flooding Protocol status: Correctly Terminated")
# print("Flooding time: %d" % (G.flooding.get_t_flood()))
# print("----------------------------------------------------------------")

threshold = G.get_target_n()
if (G.flooding.get_t_flood() > 100 * threshold):
# print("Iterations > threshold")
# print("The Flooding protocol is too slow, stopping the simulation")
# print("Number of informed nodes %d " % (G.flooding.get_informed_nodes()))
# print("Number of uninformed nodes %d " % (G.flooding.get_uninformed_nodes()))
# print("Percentage of informed nodes %r" % (G.flooding.get_percentage()))
# print("Informed Ratio: %r" % (G.flooding.get_last_ratio()))
# print("Flooding Protocol status: Failed")
# print("Number of executed steps: %d Step threshold: %d" % (
# G.flooding.get_t_flood(), threshold))
# print("----------------------------------------------------------------")
G.set_converged(True)
G.flooding.set_converged(False)
G.flooding.set_failed(True)

flood_dictionary['informed_nodes'] = G.flooding.get_informed_nodes()
flood_dictionary['uninformed_nodes'] = G.flooding.get_uninformed_nodes()
flood_dictionary['percentage_informed'] = G.flooding.get_percentage()
flood_dictionary['t_flood'] = G.flooding.get_t_flood()
flood_dictionary['process_status'] = G.get_converged()
flood_dictionary['flood_status'] = G.flooding.get_converged()
flood_dictionary['initiator'] = G.flooding.get_initiator()

else:
flood_dictionary['informed_nodes'] = 0
flood_dictionary['uninformed_nodes'] = len(G.get_list_of_nodes())
flood_dictionary['percentage_informed'] = 0
flood_dictionary['t_flood'] = 0
flood_dictionary['process_status'] = G.get_converged()
flood_dictionary['flood_status'] = G.flooding.get_converged()
flood_dictionary['initiator'] = G.flooding.get_initiator()

return (flood_dictionary)

"""worker function"""
final_stats = []

d = data["d"]
c = data["c"]
inrate = data["inrate"]
outrate = data["outrate"]
edge_falling_rate = data["edge_falling_rate"]
# sim = data["sim"]
max_iter = data["max_iter"]
G = DynamicGraph(0, d, c, inrate, outrate, edge_falling_rate)
t = 0
achieved = False
repeat = True
sim = {
"simulation": data["sim"]
}
while (repeat):

G.disconnect_from_network()
G.connect_to_network()
# print("NODES IN new ",G.get_nodes_t())

G.add_phase_vd()
G.del_phase_vd()

G.random_fall()

if (not achieved):
if (G.get_target_density()):
# print("The Graph contains the desired number of nodes")
achieved = True
# print("CI SONO")
G.set_converged(True)
stats = get_snapshot_dynamic(G, G.get_d(), G.get_c(), t)
flood_info = check_convergence_dynamic()
conv_perc = {"conv_percentage": (G.get_semiregular_percentage())}
final_stats.append({**sim, **conv_perc, **stats, **flood_info})
else:
stats = get_snapshot_dynamic(G, G.get_d(), G.get_c(), t)
flood_info = check_convergence_dynamic()
conv_perc = {"conv_percentage": (G.get_semiregular_percentage())}
final_stats.append({**sim, **conv_perc, **stats, **flood_info})

else:
stats = get_snapshot_dynamic(G, G.get_d(), G.get_c(), t)
flood_info = check_convergence_dynamic()
conv_perc = {"conv_percentage": (G.get_semiregular_percentage())}
final_stats.append({**sim, **conv_perc, **stats, **flood_info})

if (G.flooding.get_t_flood() == max_iter):
logging.info("Flooding protocol simulation %r: CONVERGED" % data["sim"])
repeat = False
if (G.flooding.get_failed()):
repeat = False
logging.info("Flooding protocol simulation %r: FAILED" % data["sim"])
t += 1

# print(G.flooding.get_list_of_informed_ndoes())
# print(str(sim) + " represent!")
return_dict[sim['simulation']] = final_stats


if __name__ == "__main__":
d_list = [4]
c_list = [1.5]
n_list = [512, 1024, 2048, 4096, 8192, 16384, 32768, 65536]
outrate_list = [0.1]
inrate_list = []
for n in n_list:
for q in outrate_list:
inrate_list.append(n * q)

probs_list = [0.1, 0.2, 0.3, 0.4, 0.5, 0.6, 0.7, 0.8, 0.9, 1]
outPath = "./tmp/"
for d in d_list:
for c in c_list:
for inrate in inrate_list:
for outrate in outrate_list:
for probs in probs_list:
data = {
"d": d,
"c": c,
"inrate": inrate,
"outrate": outrate,
"edge_falling_rate": probs,
"max_iter": 100
}
name = "MixedDynamic_d_" + str(d) + "_c_" + str(c) + "_inrate_" + str(
inrate) + "_outrate_" + str(outrate) + "_p_" + str(probs)
outpath = create_folder(outPath, name)
logging.info("EXECUTING: %r " % name)
manager = multiprocessing.Manager()
return_dict = manager.dict()
jobs = []
for i in range(10):
data["sim"] = i
p = multiprocessing.Process(target=worker, args=(data, return_dict))
jobs.append(p)
p.start()

for proc in jobs:
proc.join()

reduced = []
for key in return_dict:
reduced.extend(return_dict[key])

df = pd.DataFrame(reduced)

df.to_csv(outpath + "results.csv")

# print(return_dict.values())
12 changes: 12 additions & 0 deletions requirements_CPU_branch.txt
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
certifi==2021.5.30
cycler==0.10.0
decorator==4.4.2
kiwisolver==1.3.1
matplotlib==3.4.2
networkx==2.5.1
numpy==1.20.3
Pillow==8.2.0
pyparsing==2.4.7
python-dateutil==2.8.1
scipy==1.6.3
six==1.16.0

0 comments on commit 37f6ea3

Please sign in to comment.