2 * Copyright (c) 2015 Cisco Systems, Inc. and others. 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.bgpcep.pcep.topology.provider;
11 import static org.junit.Assert.assertEquals;
12 import static org.junit.Assert.assertFalse;
13 import static org.junit.Assert.assertTrue;
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;
18 import java.util.Collections;
19 import java.util.Optional;
20 import org.junit.Before;
21 import org.junit.Test;
22 import org.opendaylight.protocol.pcep.PCEPSession;
23 import org.opendaylight.protocol.pcep.pcc.mock.spi.MsgBuilderUtil;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs3;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs3Builder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.lsp.db.version.tlv.LspDbVersion;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.lsp.db.version.tlv.LspDbVersionBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev181109.Stateful1;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev181109.Stateful1Builder;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.OperationalStatus;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Pcrpt;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.PlspId;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.SymbolicPathName;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Tlvs1;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Tlvs1Builder;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp.identifiers.tlv.LspIdentifiersBuilder;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp.object.LspBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.stateful.capability.tlv.StatefulBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.symbolic.path.name.tlv.SymbolicPathNameBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.Open;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.OpenBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.open.TlvsBuilder;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.LspId;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev181109.PccSyncState;
45 import org.opendaylight.yangtools.yang.common.Uint32;
46 import org.opendaylight.yangtools.yang.common.Uint64;
48 public class PCETriggeredInitialSyncProcedureTest
49 extends AbstractPCEPSessionTest<Stateful07TopologySessionListenerFactory> {
50 private Stateful07TopologySessionListener listener;
54 public void setUp() throws Exception {
56 this.listener = (Stateful07TopologySessionListener) getSessionListener();
60 * Test Triggered Initial Sync procedure.
63 public void testPcepTriggeredInitialSyncPerformed() throws Exception {
64 this.listener = (Stateful07TopologySessionListener) getSessionListener();
66 //session up - expect triggered sync (LSP-DBs do not match)
67 final LspDbVersion localDbVersion = new LspDbVersionBuilder()
68 .setLspDbVersionValue(Uint64.ONE).build();
69 final LspDbVersion localDbVersion2 = new LspDbVersionBuilder()
70 .setLspDbVersionValue(Uint64.TWO).build();
71 final PCEPSession session = getPCEPSession(getOpen(localDbVersion, Boolean.FALSE),
72 getOpen(localDbVersion2, Boolean.FALSE));
73 this.listener.onSessionUp(session);
75 readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
76 //check node - not synchronized and TriggeredInitialSync state
77 assertEquals(PccSyncState.TriggeredInitialSync, pcc.getStateSync());
82 final Pcrpt syncMsg = getsyncMsg();
83 this.listener.onMessage(session, syncMsg);
84 readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
85 //check node - synchronized
86 assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
87 //check reported LSP is empty, LSP state from previous session was purged
88 assertTrue(pcc.getReportedLsp().isEmpty());
92 //report LSP + LSP-DB version number
93 final Pcrpt pcRpt = getPcrpt();
94 this.listener.onMessage(session, pcRpt);
96 readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
97 assertFalse(pcc.getReportedLsp().isEmpty());
103 private Open getOpen(final LspDbVersion dbVersion, final boolean incremental) {
104 return new OpenBuilder(super.getLocalPref()).setTlvs(new TlvsBuilder().addAugmentation(Tlvs1.class,
105 new Tlvs1Builder().setStateful(new StatefulBuilder()
106 .addAugmentation(Stateful1.class, new Stateful1Builder().setInitiation(Boolean.TRUE).build())
107 .addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller
108 .pcep.sync.optimizations.rev181109.Stateful1.class,
109 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep
110 .sync.optimizations.rev181109.Stateful1Builder()
111 .setIncludeDbVersion(Boolean.TRUE)
112 .setTriggeredInitialSync(Boolean.TRUE)
113 .setDeltaLspSyncCapability(incremental).build()).build()).build())
114 .addAugmentation(Tlvs3.class, new Tlvs3Builder().setLspDbVersion(dbVersion).build())
118 private static Pcrpt getsyncMsg() {
119 return MsgBuilderUtil.createPcRtpMessage(createLsp(Uint32.ZERO, false, Optional.of(
120 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp
121 .object.lsp.TlvsBuilder().addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params
122 .xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs1.class, new org.opendaylight
123 .yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109
124 .Tlvs1Builder().setLspDbVersion(new LspDbVersionBuilder().setLspDbVersionValue(Uint64
125 .valueOf(2L)).build()).build()).build()), true, false), Optional.empty(),
126 createPath(Collections.emptyList()));
129 private static Pcrpt getPcrpt() {
130 return MsgBuilderUtil.createPcRtpMessage(new LspBuilder().setPlspId(new PlspId(Uint32.ONE)).setTlvs(
131 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp
132 .object.lsp.TlvsBuilder().setLspIdentifiers(new LspIdentifiersBuilder()
133 .setLspId(new LspId(Uint32.ONE)).build()).setSymbolicPathName(new SymbolicPathNameBuilder()
134 .setPathName(new SymbolicPathName("test".getBytes())).build()).addAugmentation(org.opendaylight
135 .yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109
136 .Tlvs1.class, new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller
137 .pcep.sync.optimizations.rev181109.Tlvs1Builder().setLspDbVersion(new LspDbVersionBuilder()
138 .setLspDbVersionValue(Uint64.valueOf(3L)).build())
139 .build()).build()).setPlspId(new PlspId(Uint32.ONE)).setSync(true).setRemove(false)
140 .setOperational(OperationalStatus.Active).build(), Optional.empty(),
141 createPath(Collections.emptyList()));