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.math.BigInteger;
  19 import java.util.Collections;
  20 import java.util.List;
  21 import java.util.Optional;
  22 import org.junit.Before;
  23 import org.junit.Test;
  24 import org.opendaylight.protocol.pcep.PCEPSession;
  25 import org.opendaylight.protocol.pcep.pcc.mock.spi.MsgBuilderUtil;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev171025.Tlvs3;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev171025.Tlvs3Builder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev171025.lsp.db.version.tlv.LspDbVersion;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev171025.lsp.db.version.tlv.LspDbVersionBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev171025.Stateful1;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev171025.Stateful1Builder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.OperationalStatus;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.Pcrpt;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.PlspId;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.SrpIdNumber;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.SymbolicPathName;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.Tlvs1;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.Tlvs1Builder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.lsp.identifiers.tlv.LspIdentifiersBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.lsp.object.LspBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.srp.object.SrpBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.stateful.capability.tlv.StatefulBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.symbolic.path.name.tlv.SymbolicPathNameBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.LspId;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev171025.PccSyncState;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev171025.TriggerSyncInputBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev171025.pcep.client.attributes.path.computation.client.ReportedLsp;
  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(BigInteger.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.getReportedLsp().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 List<?> 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             final List<ReportedLsp> reportedLspPcc = pcc.getReportedLsp();
 133             assertFalse(reportedLspPcc.isEmpty());
 134             return pcc;
 135         });
 136
 137         //Trigger Full Resync
 138         this.listener.triggerSync(new TriggerSyncInputBuilder().setNode(this.nodeId).setName("test").build());
 139         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 140             assertEquals(PccSyncState.PcepTriggeredResync, pcc.getStateSync());
 141             assertFalse(pcc.getReportedLsp().isEmpty());
 142             return pcc;
 143         });
 144
 145         this.listener.onMessage(this.session, pcRpt);
 146         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 147             assertFalse(pcc.getReportedLsp().isEmpty());
 148             return pcc;
 149         });
 150
 151         //sync rpt + LSP-DB
 152         final Pcrpt syncMsg = getSyncMsg();
 153         this.listener.onMessage(this.session, syncMsg);
 154         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 155             //check node - synchronized
 156             assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
 157             //check reported LSP
 158             assertEquals(1, pcc.getReportedLsp().size());
 159             return pcc;
 160         });
 161
 162         //Trigger Full Resync
 163         this.listener.triggerSync(new TriggerSyncInputBuilder().setNode(this.nodeId).setName("test").build());
 164         this.listener.onMessage(this.session, syncMsg);
 165         readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
 166             //check node - synchronized
 167             assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
 168             //check reported LSP
 169             assertNull(pcc.getReportedLsp());
 170             return pcc;
 171         });
 172     }
 173
 174     private Open getOpen() {
 175         return new OpenBuilder(super.getLocalPref()).setTlvs(new TlvsBuilder().addAugmentation(Tlvs1.class,
 176             new Tlvs1Builder().setStateful(new StatefulBuilder().addAugmentation(Stateful1.class, new Stateful1Builder()
 177                 .setInitiation(Boolean.TRUE).build()).addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight
 178                     .params.xml.ns.yang.controller.pcep.sync.optimizations.rev171025.Stateful1.class,
 179                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations
 180                     .rev171025.Stateful1Builder().setIncludeDbVersion(Boolean.TRUE).setTriggeredResync(Boolean.TRUE)
 181                     .build()).build()).build()).addAugmentation(Tlvs3.class, new Tlvs3Builder()
 182             .setLspDbVersion(this.lspDbVersion).build()).build()).build();
 183     }
 184
 185     private Pcrpt getSyncMsg() {
 186         final SrpBuilder srpBuilder = new SrpBuilder();
 187         // not sue whether use 0 instead of nextRequest() or do not insert srp == SRP-ID-number = 0
 188         srpBuilder.setOperationId(new SrpIdNumber(1L));
 189         return MsgBuilderUtil.createPcRtpMessage(createLsp(0, false, Optional.of(
 190                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.lsp
 191                         .object.lsp.TlvsBuilder().addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params
 192                                 .xml.ns.yang.controller.pcep.sync.optimizations.rev171025.Tlvs1.class,
 193                     new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync
 194                             .optimizations.rev171025.Tlvs1Builder()
 195                         .setLspDbVersion(new LspDbVersionBuilder().setLspDbVersionValue(BigInteger.valueOf(3L))
 196                                 .build()).build()).build()), true, false),
 197                             Optional.of(srpBuilder.build()), createPath(Collections.emptyList()));
 198     }
 199
 200     private Pcrpt getPcrt() {
 201         return MsgBuilderUtil.createPcRtpMessage(new LspBuilder().setPlspId(new PlspId(1L)).setTlvs(
 202                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev171025.lsp
 203                         .object.lsp.TlvsBuilder().setLspIdentifiers(new LspIdentifiersBuilder()
 204                         .setLspId(new LspId(1L)).build()).setSymbolicPathName(
 205                     new SymbolicPathNameBuilder().setPathName(new SymbolicPathName("test".getBytes())).build())
 206                     .addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep
 207                                     .sync.optimizations.rev171025.Tlvs1.class,
 208                         new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync
 209                                 .optimizations.rev171025.Tlvs1Builder().setLspDbVersion(new LspDbVersionBuilder()
 210                                 .setLspDbVersionValue(BigInteger.ONE).build()).build()).build())
 211                 .setPlspId(new PlspId(1L)).setSync(true).setRemove(false)
 212                         .setOperational(OperationalStatus.Active).build(), Optional.empty(),
 213             createPath(Collections.emptyList()));
 214     }
 215 }