Assert.assertNotNull(dbSchema);
GenericTableSchema bridge = dbSchema.table("Bridge", GenericTableSchema.class);
- List<MonitorRequest<GenericTableSchema>> monitorRequests = Lists.newArrayList();
+ List<MonitorRequest> monitorRequests = Lists.newArrayList();
ColumnSchema<GenericTableSchema, Set<Integer>> flood_vlans = bridge.multiValuedColumn("flood_vlans", Integer.class);
ColumnSchema<GenericTableSchema, Map<String, String>> externalIds = bridge.multiValuedColumn("external_ids", String.class, String.class);
ColumnSchema<GenericTableSchema, String> name = bridge.column("name", String.class);
Assert.assertNotNull(dbSchema);
GenericTableSchema ovsTable = dbSchema.table("Open_vSwitch", GenericTableSchema.class);
- List<MonitorRequest<GenericTableSchema>> monitorRequests = Lists.newArrayList();
+ List<MonitorRequest> monitorRequests = Lists.newArrayList();
ColumnSchema<GenericTableSchema, UUID> _uuid = ovsTable.column("_uuid", UUID.class);
List<OperationResult> results = ovs.transactBuilder(dbSchema)
*
* @return MonitorRequest that includes all the Bridge Columns including _uuid
*/
- public <T extends TypedBaseTable<GenericTableSchema>> MonitorRequest<GenericTableSchema> getAllColumnsMonitorRequest (Class <T> klazz) {
+ public <T extends TypedBaseTable<GenericTableSchema>> MonitorRequest getAllColumnsMonitorRequest (Class <T> klazz) {
TypedBaseTable<GenericTableSchema> table = getClient().createTypedRowWrapper(klazz);
GenericTableSchema tableSchema = table.getSchema();
Set<String> columns = tableSchema.getColumns();
return bridgeBuilder.with(new MonitorSelect(true, true, true, true)).build();
}
- public <T extends TableSchema<T>> MonitorRequest<T> getAllColumnsMonitorRequest (T tableSchema) {
+ public <T extends TableSchema<T>> MonitorRequest getAllColumnsMonitorRequest (T tableSchema) {
Set<String> columns = tableSchema.getColumns();
MonitorRequestBuilder<T> monitorBuilder = MonitorRequestBuilder.builder(tableSchema);
for (String column : columns) {
assertNotNull(getDbSchema());
- List<MonitorRequest<GenericTableSchema>> monitorRequests = Lists.newArrayList();
+ List<MonitorRequest> monitorRequests = Lists.newArrayList();
Set<String> tables = getDbSchema().getTables();
assertNotNull("ovsdb tables should not be null", tables);
*
* @return MonitorRequest that includes all the Bridge Columns including _uuid
*/
- public <T extends TypedBaseTable<GenericTableSchema>> MonitorRequest<GenericTableSchema> getAllColumnsMonitorRequest (Class <T> klazz) {
+ public <T extends TypedBaseTable<GenericTableSchema>> MonitorRequest getAllColumnsMonitorRequest (Class <T> klazz) {
TypedBaseTable<GenericTableSchema> table = getClient().createTypedRowWrapper(klazz);
GenericTableSchema tableSchema = table.getSchema();
Set<String> columns = tableSchema.getColumns();
return bridgeBuilder.with(new MonitorSelect(true, true, true, true)).build();
}
- public <T extends TableSchema<T>> MonitorRequest<T> getAllColumnsMonitorRequest (T tableSchema) {
+ public <T extends TableSchema<T>> MonitorRequest getAllColumnsMonitorRequest (T tableSchema) {
Set<String> columns = tableSchema.getColumns();
MonitorRequestBuilder<T> monitorBuilder = MonitorRequestBuilder.builder(tableSchema);
for (String column : columns) {
assertNotNull(getDbSchema());
- List<MonitorRequest<GenericTableSchema>> monitorRequests = Lists.newArrayList();
+ List<MonitorRequest> monitorRequests = Lists.newArrayList();
Set<String> tables = getDbSchema().getTables();
assertNotNull("ovsdb tables should not be null", tables);
try{
for (Enumeration<NetworkInterface> ifaces = NetworkInterface.getNetworkInterfaces();
ifaces.hasMoreElements();) {
- NetworkInterface iface = (NetworkInterface) ifaces.nextElement();
+ NetworkInterface iface = ifaces.nextElement();
for (Enumeration<InetAddress> inetAddrs = iface.getInetAddresses(); inetAddrs.hasMoreElements();) {
- InetAddress inetAddr = (InetAddress) inetAddrs.nextElement();
+ InetAddress inetAddr = inetAddrs.nextElement();
if (!inetAddr.isLoopbackAddress()) {
if (inetAddr.isSiteLocalAddress()) {
ipaddress = inetAddr.getHostAddress();
ImmutableBiMap<String, Class<? extends OvsdbBridgeProtocolBase>> mapper =
SouthboundConstants.OVSDB_PROTOCOL_MAP.inverse();
protocolList.add(new ProtocolEntryBuilder().
- setProtocol((Class<? extends OvsdbBridgeProtocolBase>) mapper.get("OpenFlow13")).build());
+ setProtocol(mapper.get("OpenFlow13")).build());
return protocolList;
}
*/
int index = 0;
for(Map.Entry<String, LoadBalancerPoolMember> entry : this.getMembers().entrySet()) {
- ((LoadBalancerPoolMember) entry.getValue()).setIndex(index++);
+ entry.getValue().setIndex(index++);
}
return this.members;
}
ImmutableBiMap<String, Class<? extends OvsdbBridgeProtocolBase>> mapper =
MdsalHelper.OVSDB_PROTOCOL_MAP.inverse();
protocolList.add(new ProtocolEntryBuilder().
- setProtocol((Class<? extends OvsdbBridgeProtocolBase>) mapper.get("OpenFlow13")).build());
+ setProtocol(mapper.get("OpenFlow13")).build());
return protocolList;
}
when(ev.getNeutronFloatingIP()).thenReturn(mock(NeutronFloatingIP.class));
when(ev.getAction()).thenReturn(Action.UPDATE);
- floatingHandler.processEvent((AbstractEvent) ev);
+ floatingHandler.processEvent(ev);
verify(neutronL3Adapter, times(1)).handleNeutronFloatingIPEvent(ev.getNeutronFloatingIP(), ev.getAction());
when(ev.getAction()).thenReturn(Action.ADD);
- floatingHandler.processEvent((AbstractEvent) ev);
+ floatingHandler.processEvent(ev);
verify(neutronL3Adapter, times(1)).handleNeutronFloatingIPEvent(ev.getNeutronFloatingIP(), ev.getAction());
when(ev.getAction()).thenReturn(Action.DELETE);
- floatingHandler.processEvent((AbstractEvent) ev);
+ floatingHandler.processEvent(ev);
verify(neutronL3Adapter, times(1)).handleNeutronFloatingIPEvent(ev.getNeutronFloatingIP(), ev.getAction());
}
logger.warn("Database {} without any tables. Strange !", dbSchema.getName());
return null;
}
- List<MonitorRequest<GenericTableSchema>> monitorRequests = Lists.newArrayList();
+ List<MonitorRequest> monitorRequests = Lists.newArrayList();
for (String tableName : tables) {
GenericTableSchema tableSchema = dbSchema.table(tableName, GenericTableSchema.class);
monitorRequests.add(this.getAllColumnsMonitorRequest(tableSchema));
*
* @return MonitorRequest that includes all the Bridge Columns including _uuid
*/
- public <T extends TableSchema<T>> MonitorRequest<T> getAllColumnsMonitorRequest (T tableSchema) {
+ public <T extends TableSchema<T>> MonitorRequest getAllColumnsMonitorRequest (T tableSchema) {
Set<String> columns = tableSchema.getColumns();
MonitorRequestBuilder<T> monitorBuilder = MonitorRequestBuilder.builder(tableSchema);
for (String column : columns) {