Get estimated node/cloud->DS bandwidth from configuration

Author: matteonardelli

internal/config/keys.go

@@ -90,3 +90,9 @@ const OFFLOADING_POLICY_ILP_OPTIMIZER_PORT = "offloading.policy.ilp.port"
 
 // IP address / hostname used by ILP Offloading Policy for solving the ILP formulation
 const OFFLOADING_POLICY_ILP_OPTIMIZER_HOST = "offloading.policy.ilp.host"
+
+// Estimated bandwidth between the current node and the data store
+const OFFLOADING_POLICY_NODE_TO_DATA_STORE_BANDWIDTH = "offloading.policy.node2datastore.bandwidth"
+
+// Estimated bandwidth between cloud nodes and the data store
+const OFFLOADING_POLICY_CLOUD_TO_DATA_STORE_BANDWIDTH = "offloading.policy.cloud2datastore.bandwidth"

internal/workflow/ilp_offloading_policy.go

@@ -227,11 +227,11 @@ func (policy *IlpOffloadingPolicy) Evaluate(r *Request, p *Progress) (Offloading
 	params.DSLatency[CLOUD] = 0.001
 
 	// Bandwidth (we assume identical)
-	dsBandwidth := 100.0 // TODO: read from configuration?
+	dsBandwidth := config.GetFloat(config.OFFLOADING_POLICY_NODE_TO_DATA_STORE_BANDWIDTH, 100.0)
 	for _, n := range params.EdgeNodes {
 		params.DSBandwidth[n] = dsBandwidth
 	}
-	params.DSBandwidth[CLOUD] = dsBandwidth * 10
+	params.DSBandwidth[CLOUD] = config.GetFloat(config.OFFLOADING_POLICY_CLOUD_TO_DATA_STORE_BANDWIDTH, dsBandwidth*10)
 
 	// Workflow
 	params.InputSize = float64(r.ParamsSize)