bug 8029 handle expired in transit entries

[ovsdb.git] / hwvtepsouthbound / hwvtepsouthbound-impl / src / main / java / org / opendaylight / ovsdb / hwvtepsouthbound / HwvtepConnectionInstance.java

diff --git a/hwvtepsouthbound/hwvtepsouthbound-impl/src/main/java/org/opendaylight/ovsdb/hwvtepsouthbound/HwvtepConnectionInstance.java b/hwvtepsouthbound/hwvtepsouthbound-impl/src/main/java/org/opendaylight/ovsdb/hwvtepsouthbound/HwvtepConnectionInstance.java
index c8eab8b1e24d4a88245e2a1517468b6ed7f07aa1..30e17d2cb3ca398b1c45e03cc3bac154fb0ad62a 100644 (file)
--- a/hwvtepsouthbound/hwvtepsouthbound-impl/src/main/java/org/opendaylight/ovsdb/hwvtepsouthbound/HwvtepConnectionInstance.java
+++ b/hwvtepsouthbound/hwvtepsouthbound-impl/src/main/java/org/opendaylight/ovsdb/hwvtepsouthbound/HwvtepConnectionInstance.java
@@ -58,6 +58,7 @@ public class HwvtepConnectionInstance {
     private static final Logger LOG = LoggerFactory.getLogger(HwvtepConnectionInstance.class);
     private ConnectionInfo connectionInfo;
     private OvsdbClient client;
+    private final HwvtepTableReader hwvtepTableReader;
     private InstanceIdentifier<Node> instanceIdentifier;
     private TransactionInvoker txInvoker;
     private Map<DatabaseSchema,TransactInvoker> transactInvokers;
@@ -79,6 +80,7 @@ public class HwvtepConnectionInstance {
         this.txInvoker = txInvoker;
         this.deviceInfo = new HwvtepDeviceInfo(this);
         this.dataBroker = dataBroker;
+        this.hwvtepTableReader = new HwvtepTableReader(this);
     }
 
     public synchronized void transact(TransactCommand command) {
@@ -133,6 +135,8 @@ public class HwvtepConnectionInstance {
                     GenericTableSchema tableSchema = dbSchema.table(tableName, GenericTableSchema.class);
                     Set<String> columns = new HashSet<>(tableSchema.getColumns());
                     List<String> skipColumns = HwvtepSouthboundConstants.SKIP_COLUMN_FROM_HWVTEP_TABLE.get(tableName);
+                    skipColumns = skipColumns == null ? new ArrayList<>() : new ArrayList<>(skipColumns);
+                    skipColumns.add(HwvtepSouthboundConstants.VERSION_COLUMN);
                     if (skipColumns != null) {
                         LOG.info("HwvtepSouthbound NOT monitoring columns {} in table {}", skipColumns, tableName);
                         columns.removeAll(skipColumns);
@@ -306,4 +310,8 @@ public class HwvtepConnectionInstance {
     public OvsdbClient getOvsdbClient() {
         return client;
     }
+
+    public HwvtepTableReader getHwvtepTableReader() {
+        return hwvtepTableReader;
+    }
 }