package org.opendaylight.protocol.bgp.parser.spi;
public interface BGPExtensionConsumerActivator {
- void start(BGPExtensionConsumerContext context) throws Exception;
- void stop() throws Exception;
+ void start(BGPExtensionConsumerContext context);
+ void stop();
}
\ No newline at end of file
}
- public static BGPExtensionConsumerContext createConsumerContext() throws Exception {
+ public static BGPExtensionConsumerContext createConsumerContext() {
final BGPExtensionProviderContext ctx = new SimpleBGPExtensionProviderContext();
final ServiceLoader<BGPExtensionProviderActivator> loader = ServiceLoader.load(BGPExtensionProviderActivator.class);
* @throws IllegalStateException if there is already a listener registered
* @return ListenerRegistration
*/
- public ListenerRegistration<BGPSessionListener> registerUpdateListener(BGPSessionListener listener,
+ ListenerRegistration<BGPSessionListener> registerUpdateListener(BGPSessionListener listener,
ReconnectStrategyFactory tcpStrategyFactory, ReconnectStrategy sessionStrategy);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.TablesKey;
public interface AdjRIBsInFactory {
- public AdjRIBsIn createAdjRIBsIn(final DataModificationTransaction trans, final Comparator<PathAttributes> comparator, final TablesKey key);
+ AdjRIBsIn createAdjRIBsIn(DataModificationTransaction trans, Comparator<PathAttributes> comparator, TablesKey key);
}
package org.opendaylight.protocol.bgp.rib.spi;
public interface RIBExtensionConsumerActivator {
- public void startRIBExtensionConsumer(RIBExtensionConsumerContext context) throws Exception;
- public void stopRIBExtensionConsumer(RIBExtensionConsumerContext context) throws Exception;
+ void startRIBExtensionConsumer(RIBExtensionConsumerContext context);
+ void stopRIBExtensionConsumer(RIBExtensionConsumerContext context);
}
\ No newline at end of file
* AdjRIBsIn instances, which handle the specifics.
*/
public interface RIBExtensionConsumerContext {
- public AdjRIBsInFactory getAdjRIBsInFactory(Class<? extends AddressFamily> afi,
- Class<? extends SubsequentAddressFamily> safi);
-
+ AdjRIBsInFactory getAdjRIBsInFactory(Class<? extends AddressFamily> afi, Class<? extends SubsequentAddressFamily> safi);
}
\ No newline at end of file
package org.opendaylight.protocol.bgp.rib.spi;
public interface RIBExtensionProviderActivator {
- public void startRIBExtensionProvider(RIBExtensionProviderContext context);
- public void stopRIBExtensionProvider();
+ void startRIBExtensionProvider(RIBExtensionProviderContext context);
+ void stopRIBExtensionProvider();
}
* @param factory AdjRIBsInFactory
* @return Registration handle. Call its close() method to remove it.
*/
- public AutoCloseable registerAdjRIBsInFactory(Class<? extends AddressFamily> afi,
- Class<? extends SubsequentAddressFamily> safi, AdjRIBsInFactory factory);
+ AutoCloseable registerAdjRIBsInFactory(Class<? extends AddressFamily> afi, Class<? extends SubsequentAddressFamily> safi, AdjRIBsInFactory factory);
}
\ No newline at end of file
}
}
- public static ServiceLoaderRIBExtensionConsumerContext createConsumerContext() throws Exception {
+ public static ServiceLoaderRIBExtensionConsumerContext createConsumerContext() {
final ServiceLoader<RIBExtensionProviderActivator> loader = ServiceLoader.load(RIBExtensionProviderActivator.class);
final ServiceLoaderRIBExtensionConsumerContext ctx = new ServiceLoaderRIBExtensionConsumerContext(loader);
}
@Override
- public void close() throws Exception {
+ public void close() {
for (RIBExtensionProviderActivator a : loader) {
try {
a.stopRIBExtensionProvider();
- } catch (Exception e) {
+ } catch (RuntimeException e) {
LOG.warn("Stopping activator {} failed", a, e);
}
}
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
+import java.util.concurrent.ExecutionException;
import org.opendaylight.bgpcep.topology.TopologyReference;
import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
}
@Override
- public final void close() throws Exception {
+ public final void close() throws InterruptedException, ExecutionException {
final DataModificationTransaction trans = dataProvider.beginTransaction();
trans.removeOperationalData(getInstanceIdentifier());
trans.commit().get();
try {
onLocRIBChange(trans, change);
- } catch (Exception e) {
+ } catch (RuntimeException e) {
LOG.info("Data change {} was not completely propagated to listener {}", change, this, e);
}
* @param depth Subscription path depth.
* @throws Exception throw it if you must. If you can handle it, please do so.
*/
- public void onLocRIBChange(DataModification<InstanceIdentifier<?>, DataObject> trans,
+ void onLocRIBChange(DataModification<InstanceIdentifier<?>, DataObject> trans,
DataChangeEvent<InstanceIdentifier<?>, DataObject> event) throws Exception;
}
* @throws DeserializerException if some parsing error occurs
* @throws DocumentedException if some documented error occurs
*/
- public T parse(final byte[] bytes) throws DeserializerException, DocumentedException;
+ T parse(byte[] bytes) throws DeserializerException, DocumentedException;
/**
* Serializes protocol specific message to byte array.
* @param msg message to be serialized.
* @return byte array resulting message
*/
- public byte[] put(final T msg);
+ byte[] put(T msg);
}
* Returns one session listener
* @return specific session listener
*/
- public T getSessionListener();
+ T getSessionListener();
}
* @param promise Promise to be notified
* @return new negotiator instance
*/
- public SessionNegotiator<S> getSessionNegotiator(SessionListenerFactory<L> factory, Channel channel, Promise<S> promise);
+ SessionNegotiator<S> getSessionNegotiator(SessionListenerFactory<L> factory, Channel channel, Promise<S> promise);
}
* @param listenerFactory to create listeners for clients
* @return instance of PCEPServer
*/
-
public ChannelFuture createServer(final InetSocketAddress address, final SessionListenerFactory<PCEPSessionListener> listenerFactory);
+
ChannelFuture createServer(InetSocketAddress address, SessionListenerFactory<PCEPSessionListener> listenerFactory);
}
*/
Future<Void> sendMessage(Message message);
- public void close(TerminationReason reason);
+ void close(TerminationReason reason);
- public Tlvs getRemoteTlvs();
+ Tlvs getRemoteTlvs();
- public InetAddress getRemoteAddress();
+ InetAddress getRemoteAddress();
}
* @param sessionId is used for creation of PCEPOpenObject
* @return specific session proposal
*/
- public Open getSessionProposal(InetSocketAddress address, int sessionId);
+ Open getSessionProposal(InetSocketAddress address, int sessionId);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.SubobjectType;
public interface EROSubobjectHandlerRegistry {
- public EROSubobjectParser getSubobjectParser(int subobjectType);
-
- public EROSubobjectSerializer getSubobjectSerializer(SubobjectType subobject);
+ EROSubobjectParser getSubobjectParser(int subobjectType);
+ EROSubobjectSerializer getSubobjectSerializer(SubobjectType subobject);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobjects;
public interface EROSubobjectParser {
- public Subobjects parseSubobject(final byte[] buffer, final boolean loose) throws PCEPDeserializerException;
+ Subobjects parseSubobject(byte[] buffer, boolean loose) throws PCEPDeserializerException;
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobjects;
public interface EROSubobjectSerializer {
-
@Deprecated
- public int getType();
+ int getType();
- public byte[] serializeSubobject(Subobjects subobject);
+ byte[] serializeSubobject(Subobjects subobject);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.label.subobject.LabelType;
public interface LabelHandlerRegistry {
- public LabelParser getLabelParser(int cType);
-
- public LabelSerializer getLabelSerializer(LabelType label);
+ LabelParser getLabelParser(int cType);
+ LabelSerializer getLabelSerializer(LabelType label);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.label.subobject.LabelType;
public interface LabelParser {
- public LabelType parseLabel(final byte[] buffer) throws PCEPDeserializerException;
+ LabelType parseLabel(byte[] buffer) throws PCEPDeserializerException;
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.label.subobject.LabelType;
public interface LabelSerializer {
-
@Deprecated
- public int getType();
-
- public byte[] serializeLabel(LabelType subobject);
+ int getType();
+ byte[] serializeLabel(LabelType subobject);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
public interface MessageHandlerRegistry {
- public MessageParser getMessageParser(int messageType);
- public MessageSerializer getMessageSerializer(Message message);
+ MessageParser getMessageParser(int messageType);
+ MessageSerializer getMessageSerializer(Message message);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
public interface MessageSerializer {
- public void serializeMessage(Message message, ByteBuf buffer);
-
@Deprecated
- public int getMessageType();
+ int getMessageType();
+ void serializeMessage(Message message, ByteBuf buffer);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Object;
public interface ObjectHandlerRegistry {
- public ObjectParser getObjectParser(int objectClass, int objectType);
- public ObjectSerializer getObjectSerializer(Object object);
+ ObjectParser getObjectParser(int objectClass, int objectType);
+ ObjectSerializer getObjectSerializer(Object object);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ObjectHeader;
public interface ObjectParser {
-
- public Object parseObject(final ObjectHeader header, final byte[] buffer) throws PCEPDeserializerException;
+ Object parseObject(ObjectHeader header, byte[] buffer) throws PCEPDeserializerException;
}
public interface ObjectSerializer {
@Deprecated
- public int getObjectType();
+ int getObjectType();
@Deprecated
- public int getObjectClass();
+ int getObjectClass();
- public byte[] serializeObject(Object object);
+ byte[] serializeObject(Object object);
}
package org.opendaylight.protocol.pcep.spi;
public interface PCEPExtensionConsumerActivator {
- public void start(PCEPExtensionConsumerContext context);
- public void stop();
+ void start(PCEPExtensionConsumerContext context);
+ void stop();
}
\ No newline at end of file
public interface PCEPExtensionConsumerContext {
- public LabelHandlerRegistry getLabelHandlerRegistry();
-
- public MessageHandlerRegistry getMessageHandlerRegistry();
+ LabelHandlerRegistry getLabelHandlerRegistry();
- public ObjectHandlerRegistry getObjectHandlerRegistry();
+ MessageHandlerRegistry getMessageHandlerRegistry();
- public EROSubobjectHandlerRegistry getEROSubobjectHandlerRegistry();
+ ObjectHandlerRegistry getObjectHandlerRegistry();
- public RROSubobjectHandlerRegistry getRROSubobjectHandlerRegistry();
+ EROSubobjectHandlerRegistry getEROSubobjectHandlerRegistry();
- public XROSubobjectHandlerRegistry getXROSubobjectHandlerRegistry();
+ RROSubobjectHandlerRegistry getRROSubobjectHandlerRegistry();
- public TlvHandlerRegistry getTlvHandlerRegistry();
+ XROSubobjectHandlerRegistry getXROSubobjectHandlerRegistry();
+
+ TlvHandlerRegistry getTlvHandlerRegistry();
}
package org.opendaylight.protocol.pcep.spi;
public interface PCEPExtensionProviderActivator {
- public void start(PCEPExtensionProviderContext context) throws Exception;
- public void stop() throws Exception;
+ void start(PCEPExtensionProviderContext context);
+ void stop();
}
\ No newline at end of file
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.label.subobject.LabelType;
public interface PCEPExtensionProviderContext extends PCEPExtensionConsumerContext {
- public AutoCloseable registerLabelSerializer(Class<? extends LabelType> labelClass, LabelSerializer serializer);
+ AutoCloseable registerLabelSerializer(Class<? extends LabelType> labelClass, LabelSerializer serializer);
- public AutoCloseable registerLabelParser(int cType, LabelParser parser);
+ AutoCloseable registerLabelParser(int cType, LabelParser parser);
- public AutoCloseable registerEROSubobjectParser(int subobjectType, EROSubobjectParser parser);
+ AutoCloseable registerEROSubobjectParser(int subobjectType, EROSubobjectParser parser);
- public AutoCloseable registerEROSubobjectSerializer(Class<? extends SubobjectType> subobjectClass, EROSubobjectSerializer serializer);
+ AutoCloseable registerEROSubobjectSerializer(Class<? extends SubobjectType> subobjectClass, EROSubobjectSerializer serializer);
- public AutoCloseable registerMessageParser(int messageType, MessageParser parser);
+ AutoCloseable registerMessageParser(int messageType, MessageParser parser);
- public AutoCloseable registerMessageSerializer(Class<? extends Message> msgClass, MessageSerializer serializer);
+ AutoCloseable registerMessageSerializer(Class<? extends Message> msgClass, MessageSerializer serializer);
- public AutoCloseable registerObjectParser(int objectClass, int objectType, ObjectParser parser);
+ AutoCloseable registerObjectParser(int objectClass, int objectType, ObjectParser parser);
- public AutoCloseable registerObjectSerializer(Class<? extends Object> objClass, ObjectSerializer serializer);
+ AutoCloseable registerObjectSerializer(Class<? extends Object> objClass, ObjectSerializer serializer);
- public AutoCloseable registerRROSubobjectParser(int subobjectType, RROSubobjectParser parser);
+ AutoCloseable registerRROSubobjectParser(int subobjectType, RROSubobjectParser parser);
- public AutoCloseable registerRROSubobjectSerializer(
+ AutoCloseable registerRROSubobjectSerializer(
Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.SubobjectType> subobjectClass,
RROSubobjectSerializer serializer);
- public AutoCloseable registerTlvSerializer(Class<? extends Tlv> tlvClass, TlvSerializer serializer);
+ AutoCloseable registerTlvSerializer(Class<? extends Tlv> tlvClass, TlvSerializer serializer);
- public AutoCloseable registerTlvParser(int tlvType, TlvParser parser);
+ AutoCloseable registerTlvParser(int tlvType, TlvParser parser);
- public AutoCloseable registerXROSubobjectSerializer(Class<? extends SubobjectType> subobjectClass, XROSubobjectSerializer serializer);
+ AutoCloseable registerXROSubobjectSerializer(Class<? extends SubobjectType> subobjectClass, XROSubobjectSerializer serializer);
- public AutoCloseable registerXROSubobjectParser(int subobjectType, XROSubobjectParser parser);
+ AutoCloseable registerXROSubobjectParser(int subobjectType, XROSubobjectParser parser);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.SubobjectType;
public interface RROSubobjectHandlerRegistry {
- public RROSubobjectParser getSubobjectParser(int subobjectType);
-
- public RROSubobjectSerializer getSubobjectSerializer(SubobjectType subobject);
+ RROSubobjectParser getSubobjectParser(int subobjectType);
+ RROSubobjectSerializer getSubobjectSerializer(SubobjectType subobject);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.Subobjects;
public interface RROSubobjectParser {
- public Subobjects parseSubobject(final byte[] buffer) throws PCEPDeserializerException;
+ Subobjects parseSubobject(byte[] buffer) throws PCEPDeserializerException;
}
public interface RROSubobjectSerializer {
@Deprecated
- public int getType();
+ int getType();
- public byte[] serializeSubobject(Subobjects subobject);
+ byte[] serializeSubobject(Subobjects subobject);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Tlv;
public interface TlvHandlerRegistry {
- public TlvParser getTlvParser(int tlvType);
- public TlvSerializer getTlvSerializer(Tlv tlv);
+ TlvParser getTlvParser(int tlvType);
+ TlvSerializer getTlvSerializer(Tlv tlv);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Tlv;
public interface TlvParser {
- public Tlv parseTlv(final byte[] buffer) throws PCEPDeserializerException;
+ Tlv parseTlv(byte[] buffer) throws PCEPDeserializerException;
}
public interface TlvSerializer {
@Deprecated
- public int getType();
+ int getType();
- public byte[] serializeTlv(Tlv tlv);
+ byte[] serializeTlv(Tlv tlv);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.SubobjectType;
public interface XROSubobjectHandlerRegistry {
- public XROSubobjectParser getSubobjectParser(int subobjectType);
-
- public XROSubobjectSerializer getSubobjectSerializer(SubobjectType subobject);
+ XROSubobjectParser getSubobjectParser(int subobjectType);
+ XROSubobjectSerializer getSubobjectSerializer(SubobjectType subobject);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.exclude.route.object.xro.Subobjects;
public interface XROSubobjectParser {
- public Subobjects parseSubobject(final byte[] buffer, final boolean mandatory) throws PCEPDeserializerException;
+ Subobjects parseSubobject(byte[] buffer, boolean mandatory) throws PCEPDeserializerException;
}
public interface XROSubobjectSerializer {
@Deprecated
- public int getType();
+ int getType();
- public byte[] serializeSubobject(Subobjects subobject);
+ byte[] serializeSubobject(Subobjects subobject);
}
private List<AutoCloseable> registrations;
@GuardedBy("this")
- protected abstract List<AutoCloseable> startImpl(PCEPExtensionProviderContext context) throws Exception;
+ protected abstract List<AutoCloseable> startImpl(PCEPExtensionProviderContext context);
@Override
- public synchronized final void start(final PCEPExtensionProviderContext context) throws Exception {
+ public synchronized final void start(final PCEPExtensionProviderContext context) {
Preconditions.checkState(this.registrations == null);
this.registrations = Preconditions.checkNotNull(startImpl(context));
Code Review / bgpcep.git / commitdiff