2 * Copyright (c) 2016 Cisco Systems, Inc. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.lispflowmapping.implementation.timebucket.implementation;
11 import java.util.Date;
12 import org.opendaylight.lispflowmapping.implementation.MappingSystem;
13 import org.opendaylight.lispflowmapping.implementation.timebucket.containers.TimeBucketWheel;
14 import org.opendaylight.lispflowmapping.implementation.timebucket.interfaces.ISouthBoundMappingTimeoutService;
15 import org.opendaylight.lispflowmapping.lisp.type.MappingData;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.eid.container.Eid;
19 * Created by Shakib Ahmed on 12/1/16.
21 public class TimeBucketMappingTimeoutService implements ISouthBoundMappingTimeoutService {
22 private final TimeBucketWheel timeBucketWheel;
24 public TimeBucketMappingTimeoutService(int numberOfBucket, long mappingRecordValidityInMillis,
25 MappingSystem mappingSystem) {
26 timeBucketWheel = new TimeBucketWheel(numberOfBucket, mappingRecordValidityInMillis, mappingSystem);
30 public int addMapping(Eid key, MappingData mappingData) {
31 return timeBucketWheel.add(key, mappingData, getTimestamp(mappingData));
35 public int refreshMapping(Eid key, MappingData newMappingData, int presentBucketId) {
36 return timeBucketWheel.refreshMappping(key, newMappingData, getTimestamp(newMappingData), presentBucketId);
40 public void removeMappingFromTimeoutService(Eid key, int presentBucketId) {
41 timeBucketWheel.removeMapping(key, presentBucketId);
45 public void removeExpiredMappings() {
46 timeBucketWheel.clearExpiredMappingAndRotate();
49 private static long getTimestamp(MappingData mappingData) {
50 final Date stamp = mappingData.getTimestamp();
51 return stamp != null ? stamp.getTime() : System.currentTimeMillis();