Commit d93d7222 authored by Nicolas Seydoux's avatar Nicolas Seydoux
Browse files

Fixed issue with cdp propagation

The rule was not forwarded back to applications
parent 79aadc03
......@@ -317,6 +317,12 @@ public class RuleManager {
|| mode.equals(E_Centralization.CENTRAL_INDIRECT_PROCESSED)){
LOGGER.debug("Marking current node as originator");
query = this.queries.getTemplateQueries().get("reconstruct_rule_originator").substitute(substitution);
// The application pust also be marked as consumer of the rule's results
String retrieveOriginatorQuery = this.queries.getTemplateQueries().get("get_originator").substitute(substitution);
Map<String, String> originator = Node.getInstance().getKBManager().queryModel(retrieveOriginatorQuery).get(0);
substitution.put("consumer", originator.get("originator"));
String addRuleConsumerQuery = this.queries.getTemplateQueries().get("add_rule_consumer").substitute(substitution);
Node.getInstance().getKBManager().updateModel(addRuleConsumerQuery);
// } else if (mode.equals(E_Centralization.CENTRAL_DIRECT_PROCESSED) && Node.getInstance().getConfiguration().getRemotes().size() > 0){
// LOGGER.debug("Marking root node as originator");
// query = this.queries.getTemplateQueries().get("reconstruct_rule_originator").substitute(substitution);
......
echo "scalability 0"
# python3 factory_generator.py -b scala_syndream/clone_f_0_blueprint.json -d scala_syndream/clone_f_0.ttl -o scala_syndream/clone_f_0.json
python3 factory_generator.py -b scala_syndream/clone_f_0_blueprint.json -d scala_syndream/clone_f_0.ttl -o scala_syndream/clone_f_0.json
echo "scalability 1"
python3 factory_generator.py -b scala_syndream/clone_f_1_blueprint.json -d scala_syndream/clone_f_1.ttl -o scala_syndream/clone_f_1.json
echo "scalability 2"
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment