1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
|
/*
* Copyright 2014-2015 Open Networking Laboratory
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.onosproject.segmentrouting.config;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.node.ArrayNode;
import com.fasterxml.jackson.databind.node.ObjectNode;
import com.google.common.collect.ImmutableMap;
import org.onlab.packet.Ip4Address;
import org.onlab.packet.MacAddress;
import org.onosproject.net.DeviceId;
import org.onosproject.net.config.Config;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
/**
* Configuration object for Segment Routing Application.
*/
public class SegmentRoutingConfig extends Config<DeviceId> {
public static final String NAME = "name";
public static final String IP = "routerIp";
public static final String MAC = "routerMac";
public static final String SID = "nodeSid";
public static final String EDGE = "isEdgeRouter";
public static final String ADJSIDS = "adjacencySids";
public static final String ADJSID = "adjSid";
public static final String PORTS = "ports";
@Override
public boolean isValid() {
return hasOnlyFields(NAME, IP, MAC, SID, EDGE, ADJSIDS, ADJSID, PORTS) &&
this.name() != null &&
this.routerIp() != null &&
this.routerMac() != null &&
this.nodeSid() != -1 &&
this.isEdgeRouter() != null &&
this.adjacencySids() != null;
}
/**
* Gets the name of the router.
*
* @return Optional name of the router. May be empty if not configured.
*/
public Optional<String> name() {
String name = get(NAME, null);
return name != null ? Optional.of(name) : Optional.empty();
}
/**
* Sets the name of the router.
*
* @param name name of the router.
* @return the config of the router.
*/
public SegmentRoutingConfig setName(String name) {
return (SegmentRoutingConfig) setOrClear(NAME, name);
}
/**
* Gets the IP address of the router.
*
* @return IP address of the router. Or null if not configured.
*/
public Ip4Address routerIp() {
String ip = get(IP, null);
return ip != null ? Ip4Address.valueOf(ip) : null;
}
/**
* Sets the IP address of the router.
*
* @param ip IP address of the router.
* @return the config of the router.
*/
public SegmentRoutingConfig setRouterIp(String ip) {
return (SegmentRoutingConfig) setOrClear(IP, ip);
}
/**
* Gets the MAC address of the router.
*
* @return MAC address of the router. Or null if not configured.
*/
public MacAddress routerMac() {
String mac = get(MAC, null);
return mac != null ? MacAddress.valueOf(mac) : null;
}
/**
* Sets the MAC address of the router.
*
* @param mac MAC address of the router.
* @return the config of the router.
*/
public SegmentRoutingConfig setRouterMac(String mac) {
return (SegmentRoutingConfig) setOrClear(MAC, mac);
}
/**
* Gets the node SID of the router.
*
* @return node SID of the router. Or -1 if not configured.
*/
public int nodeSid() {
return get(SID, -1);
}
/**
* Sets the node SID of the router.
*
* @param sid node SID of the router.
* @return the config of the router.
*/
public SegmentRoutingConfig setNodeSid(int sid) {
return (SegmentRoutingConfig) setOrClear(SID, sid);
}
/**
* Checks if the router is an edge router.
*
* @return true if the router is an edge router.
* false if the router is not an edge router.
* null if the value is not configured.
*/
public Boolean isEdgeRouter() {
String isEdgeRouter = get(EDGE, null);
return isEdgeRouter != null ?
Boolean.valueOf(isEdgeRouter) :
null;
}
/**
* Specifies if the router is an edge router.
*
* @param isEdgeRouter true if the router is an edge router.
* @return the config of the router.
*/
public SegmentRoutingConfig setIsEdgeRouter(boolean isEdgeRouter) {
return (SegmentRoutingConfig) setOrClear(EDGE, isEdgeRouter);
}
/**
* Gets the adjacency SIDs of the router.
*
* @return adjacency SIDs of the router. Or null if not configured.
*/
public Map<Integer, Set<Integer>> adjacencySids() {
if (!object.has(ADJSIDS)) {
return null;
}
Map<Integer, Set<Integer>> adjacencySids = new HashMap<>();
ArrayNode adjacencySidsNode = (ArrayNode) object.path(ADJSIDS);
for (JsonNode adjacencySidNode : adjacencySidsNode) {
int asid = adjacencySidNode.path(ADJSID).asInt(-1);
if (asid == -1) {
return null;
}
HashSet<Integer> ports = new HashSet<>();
ArrayNode portsNode = (ArrayNode) adjacencySidNode.path(PORTS);
for (JsonNode portNode : portsNode) {
int port = portNode.asInt(-1);
if (port == -1) {
return null;
}
ports.add(port);
}
adjacencySids.put(asid, ports);
}
return ImmutableMap.copyOf(adjacencySids);
}
/**
* Sets the adjacency SIDs of the router.
*
* @param adjacencySids adjacency SIDs of the router.
* @return the config of the router.
*/
public SegmentRoutingConfig setAdjacencySids(Map<Integer, Set<Integer>> adjacencySids) {
if (adjacencySids == null) {
object.remove(ADJSIDS);
} else {
ArrayNode adjacencySidsNode = mapper.createArrayNode();
adjacencySids.forEach((sid, ports) -> {
ObjectNode adjacencySidNode = mapper.createObjectNode();
adjacencySidNode.put(ADJSID, sid);
ArrayNode portsNode = mapper.createArrayNode();
ports.forEach(port -> {
portsNode.add(port.toString());
});
adjacencySidNode.set(PORTS, portsNode);
adjacencySidsNode.add(adjacencySidNode);
});
object.set(ADJSIDS, adjacencySidsNode);
}
return this;
}
}
|
