Phaneendra Manda

[ONOS-3116] Port chain service implementation

Change-Id: I50a84b1273a9b269e5e46462f3e6d20886453c04
/*
* Copyright 2015 Open Networking Laboratory
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.onosproject.vtnrsc.portchain.impl;
import static com.google.common.base.Preconditions.checkNotNull;
import static org.slf4j.LoggerFactory.getLogger;
import java.util.Collections;
import org.apache.felix.scr.annotations.Activate;
import org.apache.felix.scr.annotations.Component;
import org.apache.felix.scr.annotations.Deactivate;
import org.apache.felix.scr.annotations.Reference;
import org.apache.felix.scr.annotations.ReferenceCardinality;
import org.apache.felix.scr.annotations.Service;
import org.onlab.util.KryoNamespace;
import org.onosproject.store.serializers.KryoNamespaces;
import org.onosproject.store.service.EventuallyConsistentMap;
import org.onosproject.store.service.MultiValuedTimestamp;
import org.onosproject.store.service.StorageService;
import org.onosproject.store.service.WallClockTimestamp;
import org.onosproject.vtnrsc.PortChain;
import org.onosproject.vtnrsc.PortChainId;
import org.onosproject.vtnrsc.portchain.PortChainService;
import org.slf4j.Logger;
/**
* Provides implementation of the portChainService.
*/
@Component(immediate = true)
@Service
public class PortChainManager implements PortChainService {
private final Logger log = getLogger(getClass());
private static final String PORT_CHAIN_ID_NULL = "PortChain ID cannot be null";
private static final String PORT_CHAIN_NULL = "PortChain cannot be null";
private EventuallyConsistentMap<PortChainId, PortChain> portChainStore;
@Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
protected StorageService storageService;
@Activate
public void activate() {
KryoNamespace.Builder serializer = KryoNamespace.newBuilder()
.register(KryoNamespaces.API)
.register(MultiValuedTimestamp.class)
.register(PortChain.class);
portChainStore = storageService
.<PortChainId, PortChain>eventuallyConsistentMapBuilder()
.withName("portchainstore").withSerializer(serializer)
.withTimestampProvider((k, v) -> new WallClockTimestamp()).build();
log.info("Started");
}
@Deactivate
public void deactivate() {
portChainStore.destroy();
log.info("Stopped");
}
@Override
public boolean exists(PortChainId portChainId) {
checkNotNull(portChainId, PORT_CHAIN_ID_NULL);
return portChainStore.containsKey(portChainId);
}
@Override
public int getPortChainCount() {
return portChainStore.size();
}
@Override
public Iterable<PortChain> getPortChains() {
return Collections.unmodifiableCollection(portChainStore.values());
}
@Override
public PortChain getPortChain(PortChainId portChainId) {
checkNotNull(portChainId, PORT_CHAIN_ID_NULL);
return portChainStore.get(portChainId);
}
@Override
public boolean createPortChain(PortChain portChain) {
checkNotNull(portChain, PORT_CHAIN_NULL);
portChainStore.put(portChain.portChainId(), portChain);
if (!portChainStore.containsKey(portChain.portChainId())) {
log.debug("The portChain is created failed which identifier was {}", portChain.portChainId()
.toString());
return false;
}
return true;
}
@Override
public boolean updatePortChain(PortChain portChain) {
checkNotNull(portChain, PORT_CHAIN_NULL);
if (!portChainStore.containsKey(portChain.portChainId())) {
log.debug("The portChain is not exist whose identifier was {} ",
portChain.portChainId().toString());
return false;
}
portChainStore.put(portChain.portChainId(), portChain);
if (!portChain.equals(portChainStore.get(portChain.portChainId()))) {
log.debug("The portChain is updated failed whose identifier was {} ",
portChain.portChainId().toString());
return false;
}
return true;
}
@Override
public boolean removePortChain(PortChainId portChainId) {
checkNotNull(portChainId, PORT_CHAIN_NULL);
portChainStore.remove(portChainId);
if (portChainStore.containsKey(portChainId)) {
log.debug("The portChain is removed failed whose identifier was {}",
portChainId.toString());
return false;
}
return true;
}
}
/*
* Copyright 2015 Open Networking Laboratory
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/**
* Implementation of service for interacting with the inventory of port chains.
*/
package org.onosproject.vtnrsc.portchain.impl;