pcep/topology/topology-provider/src/test/java/org/opendaylight/bgpcep/pcep/topology/provider/PCEPTriggeredReSynchronizationProcedureTest.java

   1 /*
   2  * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.bgpcep.pcep.topology.provider;
   9
  10 import static org.junit.Assert.assertEquals;
  11 import static org.junit.Assert.assertFalse;
  12 import static org.junit.Assert.assertNotNull;
  13 import static org.junit.Assert.assertNull;
  14 import static org.opendaylight.protocol.pcep.pcc.mock.spi.MsgBuilderUtil.createLsp;
  15 import static org.opendaylight.protocol.pcep.pcc.mock.spi.MsgBuilderUtil.createPath;
  16 import static org.opendaylight.protocol.util.CheckTestUtil.readDataOperational;
  17
  18 import java.util.Collections;
  19 import java.util.Map;
  20 import java.util.Optional;
  21 import org.junit.Before;
  22 import org.junit.Test;
  23 import org.opendaylight.protocol.pcep.PCEPSession;
  24 import org.opendaylight.protocol.pcep.pcc.mock.spi.MsgBuilderUtil;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs3;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs3Builder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.lsp.db.version.tlv.LspDbVersion;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.lsp.db.version.tlv.LspDbVersionBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev181109.Stateful1;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev181109.Stateful1Builder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.OperationalStatus;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Pcrpt;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.PlspId;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.SrpIdNumber;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.SymbolicPathName;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Tlvs1;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Tlvs1Builder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp.identifiers.tlv.LspIdentifiersBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp.object.LspBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.srp.object.SrpBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.stateful.capability.tlv.StatefulBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.symbolic.path.name.tlv.SymbolicPathNameBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.Open;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.OpenBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.open.TlvsBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.LspId;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev200120.PccSyncState;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev200120.TriggerSyncInputBuilder;
  49 import org.opendaylight.yangtools.yang.common.Uint32;
  50 import org.opendaylight.yangtools.yang.common.Uint64;
  51
  52 public class PCEPTriggeredReSynchronizationProcedureTest
  53         extends AbstractPCEPSessionTest<Stateful07TopologySessionListenerFactory> {
  54     private Stateful07TopologySessionListener listener;
  55
  56     private PCEPSession session;
  57     private final LspDbVersion lspDbVersion = new LspDbVersionBuilder().setLspDbVersionValue(Uint64.ONE).build();
  58
  59     @Override
  60     @Before
  61     public void setUp() throws Exception {
  62         super.setUp();
  63         this.listener = (Stateful07TopologySessionListener) getSessionListener();
  64     }
  65
  66     @Test
  67     public void testTriggeredResynchronization() throws Exception {
  68         //session up - sync skipped (LSP-DBs match)
  69         this.session = getPCEPSession(getOpen(), getOpen());
  70         this.listener.onSessionUp(this.session);
  71
  72         //report LSP + LSP-DB version number
  73         final Pcrpt pcRpt = getPcrt();
  74         this.listener.onMessage(this.session, pcRpt);
  75
  76         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
  77             assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
  78             assertFalse(pcc.nonnullReportedLsp().isEmpty());
  79             return pcc;
  80         });
  81
  82         //PCEP Trigger Full Resync
  83         this.listener.triggerSync(new TriggerSyncInputBuilder().setNode(this.nodeId).build());
  84         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
  85             assertEquals(PccSyncState.PcepTriggeredResync, pcc.getStateSync());
  86             return pcc;
  87         });
  88
  89         //end of sync
  90         final Pcrpt syncMsg = getSyncMsg();
  91         this.listener.onMessage(this.session, syncMsg);
  92         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
  93             //check node - synchronized
  94             assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
  95             return pcc;
  96         });
  97
  98         this.listener.onMessage(this.session, pcRpt);
  99         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 100             final Map<?, ?> lsp = pcc.getReportedLsp();
 101             assertNotNull(lsp);
 102             assertEquals(1, lsp.size());
 103             return pcc;
 104         });
 105
 106         //Trigger Full Resync
 107         this.listener.triggerSync(new TriggerSyncInputBuilder().setNode(this.nodeId).build());
 108         this.listener.onMessage(this.session, pcRpt);
 109         //end of sync
 110         this.listener.onMessage(this.session, syncMsg);
 111         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 112             //check node - synchronized
 113             assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
 114             //check reported LSP is not empty, Stale LSP state were purged
 115             assertEquals(1, pcc.getReportedLsp().size());
 116             return pcc;
 117         });
 118     }
 119
 120     @Test
 121     public void testTriggeredResynchronizationLsp() throws Exception {
 122         //session up - sync skipped (LSP-DBs match)
 123
 124         this.session = getPCEPSession(getOpen(), getOpen());
 125         this.listener.onSessionUp(this.session);
 126
 127         //report LSP + LSP-DB version number
 128         final Pcrpt pcRpt = getPcrt();
 129         this.listener.onMessage(this.session, pcRpt);
 130         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 131             assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
 132             assertFalse(pcc.nonnullReportedLsp().isEmpty());
 133             return pcc;
 134         });
 135
 136         //Trigger Full Resync
 137         this.listener.triggerSync(new TriggerSyncInputBuilder().setNode(this.nodeId).setName("test").build());
 138         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 139             assertEquals(PccSyncState.PcepTriggeredResync, pcc.getStateSync());
 140             assertFalse(pcc.nonnullReportedLsp().isEmpty());
 141             return pcc;
 142         });
 143
 144         this.listener.onMessage(this.session, pcRpt);
 145         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 146             assertFalse(pcc.nonnullReportedLsp().isEmpty());
 147             return pcc;
 148         });
 149
 150         //sync rpt + LSP-DB
 151         final Pcrpt syncMsg = getSyncMsg();
 152         this.listener.onMessage(this.session, syncMsg);
 153         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 154             //check node - synchronized
 155             assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
 156             //check reported LSP
 157             assertEquals(1, pcc.nonnullReportedLsp().size());
 158             return pcc;
 159         });
 160
 161         //Trigger Full Resync
 162         this.listener.triggerSync(new TriggerSyncInputBuilder().setNode(this.nodeId).setName("test").build());
 163         this.listener.onMessage(this.session, syncMsg);
 164         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 165             //check node - synchronized
 166             assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
 167             //check reported LSP
 168             assertNull(pcc.getReportedLsp());
 169             return pcc;
 170         });
 171     }
 172
 173     private Open getOpen() {
 174         return new OpenBuilder(super.getLocalPref()).setTlvs(new TlvsBuilder().addAugmentation(Tlvs1.class,
 175             new Tlvs1Builder().setStateful(new StatefulBuilder().addAugmentation(Stateful1.class, new Stateful1Builder()
 176                 .setInitiation(Boolean.TRUE).build()).addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight
 177                     .params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Stateful1.class,
 178                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations
 179                     .rev181109.Stateful1Builder().setIncludeDbVersion(Boolean.TRUE).setTriggeredResync(Boolean.TRUE)
 180                     .build()).build()).build()).addAugmentation(Tlvs3.class, new Tlvs3Builder()
 181             .setLspDbVersion(this.lspDbVersion).build()).build()).build();
 182     }
 183
 184     private static Pcrpt getSyncMsg() {
 185         final SrpBuilder srpBuilder = new SrpBuilder();
 186         // not sue whether use 0 instead of nextRequest() or do not insert srp == SRP-ID-number = 0
 187         srpBuilder.setOperationId(new SrpIdNumber(Uint32.ONE));
 188         return MsgBuilderUtil.createPcRtpMessage(createLsp(Uint32.ZERO, false, Optional.of(
 189                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp
 190                         .object.lsp.TlvsBuilder().addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params
 191                                 .xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs1.class,
 192                     new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync
 193                             .optimizations.rev181109.Tlvs1Builder()
 194                         .setLspDbVersion(new LspDbVersionBuilder().setLspDbVersionValue(Uint64.valueOf(3L))
 195                                 .build()).build()).build()), true, false),
 196                             Optional.of(srpBuilder.build()), createPath(Collections.emptyList()));
 197     }
 198
 199     private static Pcrpt getPcrt() {
 200         return MsgBuilderUtil.createPcRtpMessage(new LspBuilder().setPlspId(new PlspId(Uint32.ONE)).setTlvs(
 201                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp
 202                         .object.lsp.TlvsBuilder().setLspIdentifiers(new LspIdentifiersBuilder()
 203                         .setLspId(new LspId(Uint32.ONE)).build()).setSymbolicPathName(
 204                     new SymbolicPathNameBuilder().setPathName(new SymbolicPathName("test".getBytes())).build())
 205                     .addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep
 206                                     .sync.optimizations.rev181109.Tlvs1.class,
 207                         new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync
 208                                 .optimizations.rev181109.Tlvs1Builder().setLspDbVersion(new LspDbVersionBuilder()
 209                                 .setLspDbVersionValue(Uint64.ONE).build()).build()).build())
 210                 .setPlspId(new PlspId(Uint32.ONE)).setSync(true).setRemove(false)
 211                         .setOperational(OperationalStatus.Active).build(), Optional.empty(),
 212             createPath(Collections.emptyList()));
 213     }
 214 }