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