package org.opendaylight.protocol.bgp.rib.impl;
+import static java.util.Objects.requireNonNull;
+
import com.google.common.base.MoreObjects;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
@Override
public synchronized void addPeer(final IpAddress ip, final BGPSessionListener peer, final BGPSessionPreferences preferences) {
- Preconditions.checkNotNull(ip);
+ requireNonNull(ip);
Preconditions.checkArgument(!this.peers.containsKey(ip), "Peer for %s already present", ip);
- this.peers.put(ip, Preconditions.checkNotNull(peer));
- Preconditions.checkNotNull(preferences.getMyAs());
- Preconditions.checkNotNull(preferences.getHoldTime());
- Preconditions.checkNotNull(preferences.getParams());
- Preconditions.checkNotNull(preferences.getBgpId());
+ this.peers.put(ip, requireNonNull(peer));
+ requireNonNull(preferences.getMyAs());
+ requireNonNull(preferences.getHoldTime());
+ requireNonNull(preferences.getParams());
+ requireNonNull(preferences.getBgpId());
this.peerPreferences.put(ip, preferences);
for (final PeerRegistryListener peerRegistryListener : this.listeners) {
peerRegistryListener.onPeerAdded(ip, preferences);
@Override
public synchronized void removePeer(final IpAddress ip) {
- Preconditions.checkNotNull(ip);
+ requireNonNull(ip);
this.peers.remove(ip);
for (final PeerRegistryListener peerRegistryListener : this.listeners) {
peerRegistryListener.onPeerRemoved(ip);
@Override
public synchronized void removePeerSession(final IpAddress ip) {
- Preconditions.checkNotNull(ip);
+ requireNonNull(ip);
this.sessionIds.remove(ip);
for (final PeerRegistrySessionListener peerRegistrySessionListener : this.sessionListeners) {
peerRegistrySessionListener.onSessionRemoved(ip);
@Override
public boolean isPeerConfigured(final IpAddress ip) {
- Preconditions.checkNotNull(ip);
+ requireNonNull(ip);
return this.peers.containsKey(ip);
}
@Override
public synchronized BGPSessionListener getPeer(final IpAddress ip, final Ipv4Address sourceId,
final Ipv4Address remoteId, final Open openObj) throws BGPDocumentedException {
- Preconditions.checkNotNull(ip);
- Preconditions.checkNotNull(sourceId);
- Preconditions.checkNotNull(remoteId);
+ requireNonNull(ip);
+ requireNonNull(sourceId);
+ requireNonNull(remoteId);
final AsNumber remoteAsNumber = AsNumberUtil.advertizedAsNumber(openObj);
- Preconditions.checkNotNull(remoteAsNumber);
+ requireNonNull(remoteAsNumber);
final BGPSessionPreferences prefs = getPeerPreferences(ip);
@Override
public BGPSessionPreferences getPeerPreferences(final IpAddress ip) {
- Preconditions.checkNotNull(ip);
+ requireNonNull(ip);
checkPeerConfigured(ip);
return this.peerPreferences.get(ip);
}
* @throws IllegalArgumentException if submitted socket address is not InetSocketAddress[ipv4 | ipv6]
*/
public static IpAddress getIpAddress(final SocketAddress socketAddress) {
- Preconditions.checkNotNull(socketAddress);
+ requireNonNull(socketAddress);
Preconditions.checkArgument(socketAddress instanceof InetSocketAddress, "Expecting InetSocketAddress but was %s", socketAddress.getClass());
final InetAddress inetAddress = ((InetSocketAddress) socketAddress).getAddress();
private final AsNumber asNumber;
BGPSessionId(final Ipv4Address from, final Ipv4Address to, final AsNumber asNumber) {
- this.from = Preconditions.checkNotNull(from);
- this.to = Preconditions.checkNotNull(to);
- this.asNumber = Preconditions.checkNotNull(asNumber);
+ this.from = requireNonNull(from);
+ this.to = requireNonNull(to);
+ this.asNumber = requireNonNull(asNumber);
}
/**