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
8 package org.opendaylight.bgpcep.pcep.topology.provider;
10 import static org.junit.Assert.assertEquals;
11 import static org.junit.Assert.assertFalse;
12 import static org.opendaylight.protocol.pcep.pcc.mock.spi.MsgBuilderUtil.createLsp;
13 import static org.opendaylight.protocol.pcep.pcc.mock.spi.MsgBuilderUtil.createPath;
14 import static org.opendaylight.protocol.util.CheckTestUtil.readDataOperational;
16 import java.util.Collections;
17 import java.util.Optional;
18 import org.junit.Before;
19 import org.junit.Test;
20 import org.opendaylight.protocol.pcep.PCEPSession;
21 import org.opendaylight.protocol.pcep.pcc.mock.spi.MsgBuilderUtil;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs3;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs3Builder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.lsp.db.version.tlv.LspDbVersion;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.lsp.db.version.tlv.LspDbVersionBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev181109.Stateful1;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev181109.Stateful1Builder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.OperationalStatus;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Pcrpt;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.PlspId;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.SymbolicPathName;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Tlvs1;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Tlvs1Builder;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp.identifiers.tlv.LspIdentifiersBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp.object.LspBuilder;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.stateful.capability.tlv.StatefulBuilder;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.symbolic.path.name.tlv.SymbolicPathNameBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.Open;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.OpenBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.open.TlvsBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.LspId;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev200120.PccSyncState;
43 import org.opendaylight.yangtools.yang.common.Uint32;
44 import org.opendaylight.yangtools.yang.common.Uint64;
46 public class IncrementalSynchronizationProcedureTest
47 extends AbstractPCEPSessionTest<Stateful07TopologySessionListenerFactory> {
49 private Stateful07TopologySessionListener listener;
53 public void setUp() throws Exception {
55 this.listener = (Stateful07TopologySessionListener) getSessionListener();
59 public void testStateSynchronizationPerformed() throws Exception {
60 PCEPSession session = getPCEPSession(getOpen(null), getOpen(null));
61 this.listener.onSessionUp(session);
62 //report LSP + LSP-DB version number
63 final Pcrpt pcRpt = getPcrpt(Uint32.ONE, "test");
64 this.listener.onMessage(session, pcRpt);
65 readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
66 assertFalse(pcc.getReportedLsp().isEmpty());
70 this.listener.onSessionDown(session, new IllegalArgumentException());
71 this.listener = (Stateful07TopologySessionListener) getSessionListener();
73 //session up - expect sync (LSP-DBs do not match)
74 final LspDbVersion localDbVersion = new LspDbVersionBuilder()
75 .setLspDbVersionValue(Uint64.TWO).build();
76 session = getPCEPSession(getOpen(localDbVersion), getOpen(null));
77 this.listener.onSessionUp(session);
78 readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
79 //check node - IncrementalSync state
80 assertEquals(PccSyncState.IncrementalSync, pcc.getStateSync());
81 //check reported LSP - persisted from previous session
82 assertFalse(pcc.getReportedLsp().isEmpty());
86 //report LSP2 + LSP-DB version number 2
87 final Pcrpt pcRpt2 = getPcrpt(Uint32.TWO, "testsecond");
88 this.listener.onMessage(session, pcRpt2);
89 readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
90 //check node - synchronized
91 assertEquals(PccSyncState.IncrementalSync, pcc.getStateSync());
92 //check reported LSP is not empty
93 assertEquals(2, pcc.getReportedLsp().size());
98 final Pcrpt syncMsg = getSyncPcrt();
99 this.listener.onMessage(session, syncMsg);
100 readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
101 //check node - synchronized
102 assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
103 //check reported LSP is empty, LSP state from previous session was purged
104 assertEquals(2, pcc.getReportedLsp().size());
108 //report LSP3 + LSP-DB version number 4
109 final Pcrpt pcRpt3 = getPcrpt(Uint32.valueOf(3), "testthird");
110 this.listener.onMessage(session, pcRpt3);
111 readDataOperational(getDataBroker(), this.pathComputationClientIId, pcc -> {
112 //check node - synchronized
113 assertEquals(PccSyncState.Synchronized, pcc.getStateSync());
114 assertEquals(3,pcc.getReportedLsp().size());
119 private Open getOpen(final LspDbVersion dbVersion) {
120 return new OpenBuilder(super.getLocalPref()).setTlvs(new TlvsBuilder().addAugmentation(Tlvs1.class,
121 new Tlvs1Builder().setStateful(new StatefulBuilder().addAugmentation(Stateful1.class,
122 new Stateful1Builder().setInitiation(Boolean.TRUE).build())
123 .addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync
124 .optimizations.rev181109.Stateful1.class, new org.opendaylight.yang.gen.v1.urn.opendaylight.params
125 .xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Stateful1Builder()
126 .setIncludeDbVersion(Boolean.TRUE).setDeltaLspSyncCapability(Boolean.TRUE).build())
127 .build()).build()).addAugmentation(Tlvs3.class, new Tlvs3Builder().setLspDbVersion(dbVersion).build())
131 private static Pcrpt getPcrpt(final Uint32 val, final String pathname) {
132 return MsgBuilderUtil.createPcRtpMessage(new LspBuilder().setPlspId(new PlspId(val)).setTlvs(
133 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.lsp
134 .object.lsp.TlvsBuilder().setLspIdentifiers(new LspIdentifiersBuilder()
135 .setLspId(new LspId(val)).build())
136 .setSymbolicPathName(new SymbolicPathNameBuilder().setPathName(new SymbolicPathName(
137 pathname.getBytes())).build()).addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params
138 .xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs1.class, new org.opendaylight.yang.gen.v1
139 .urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs1Builder()
140 .setLspDbVersion(new LspDbVersionBuilder().setLspDbVersionValue(Uint64.valueOf(val)).build())
141 .build()).build()).setPlspId(new PlspId(val)
142 ).setSync(true).setRemove(false).setOperational(OperationalStatus.Active).build(), Optional.empty(),
143 createPath(Collections.emptyList()));
146 private static Pcrpt getSyncPcrt() {
147 return MsgBuilderUtil.createPcRtpMessage(createLsp(Uint32.ZERO, false, Optional.of(
148 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109
149 .lsp.object.lsp.TlvsBuilder().addAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight
150 .params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs1.class,
151 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync
152 .optimizations.rev181109.Tlvs1Builder().setLspDbVersion(new LspDbVersionBuilder()
153 .setLspDbVersionValue(Uint64.valueOf(3L)).build()).build()).build()),
154 true, false), Optional.empty(),
155 createPath(Collections.emptyList()));