package org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow;
-import java.util.concurrent.ScheduledExecutorService;
-
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
-import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.EndpointManager;
import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.OfContext;
-import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.PolicyManager;
-import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.PolicyManager.Dirty;
-import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.SwitchManager;
-import org.opendaylight.groupbasedpolicy.resolver.PolicyInfo;
-import org.opendaylight.groupbasedpolicy.resolver.PolicyResolver;
+import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.OfWriter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.Endpoint;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
* @author readams
*/
public abstract class OfTable {
- protected static final Logger LOG =
- LoggerFactory.getLogger(OfTable.class);
+
+ protected static final Logger LOG = LoggerFactory.getLogger(OfTable.class);
protected final OfContext ctx;
public OfTable(OfContext ctx) {
- super();
this.ctx = ctx;
}
-
- // *******
- // OfTable
- // *******
-
/**
* Update the relevant flow table for the node
- * @param nodeId the node to update
- * @param dirty the dirty set
- * @throws Exception
+ *
+ * @param endpoint flows will be created for
+ * @param ofWriter the {@link OfWriter}
+ * @throws Exception throws all exception
*/
- public abstract void update(NodeId nodeId,
- PolicyInfo policyInfo,
- Dirty dirty) throws Exception;
+ public abstract void sync(Endpoint endpoint, OfWriter ofWriter)
+ throws Exception;
}