slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 1 | /* |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 2 | * Copyright 2015-present Open Networking Foundation |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
| 17 | package org.onosproject.xran.entities; |
| 18 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 19 | import com.fasterxml.jackson.annotation.JsonCreator; |
| 20 | import com.fasterxml.jackson.annotation.JsonIgnore; |
| 21 | import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
| 22 | import com.fasterxml.jackson.annotation.JsonProperty; |
| 23 | import com.fasterxml.jackson.annotation.JsonPropertyOrder; |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 24 | import com.fasterxml.jackson.databind.JsonNode; |
| 25 | import org.onosproject.net.DeviceId; |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 26 | import org.onosproject.store.service.WallClockTimestamp; |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 27 | import org.onosproject.xran.codecs.api.ECGI; |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 28 | import org.onosproject.xran.codecs.api.PRBUsage; |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 29 | import org.onosproject.xran.codecs.api.XICICPA; |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 30 | import org.onosproject.xran.codecs.ber.BerByteArrayOutputStream; |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 31 | import org.onosproject.xran.codecs.ber.types.BerBitString; |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 32 | import org.onosproject.xran.codecs.ber.types.BerInteger; |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 33 | import org.onosproject.xran.codecs.pdu.CellConfigReport; |
| 34 | import org.onosproject.xran.codecs.pdu.L2MeasConfig; |
| 35 | import org.onosproject.xran.codecs.pdu.RRMConfig; |
| 36 | import org.onosproject.xran.codecs.pdu.SchedMeasReportPerCell; |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 37 | |
| 38 | import javax.xml.bind.DatatypeConverter; |
| 39 | import java.io.ByteArrayInputStream; |
| 40 | import java.io.IOException; |
| 41 | import java.io.InputStream; |
| 42 | import java.net.URI; |
| 43 | import java.net.URISyntaxException; |
slowr | 67d05e4 | 2017-08-11 20:37:22 -0700 | [diff] [blame] | 44 | import java.util.List; |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 45 | import java.util.stream.Collectors; |
| 46 | import java.util.stream.Stream; |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 47 | |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 48 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 49 | /** |
| 50 | * R-NIB Cell and its properties. |
| 51 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 52 | @JsonPropertyOrder({ |
| 53 | "ECGI", |
| 54 | "Configuration", |
| 55 | "PRB-Usage", |
| 56 | "QCI", |
| 57 | "RRMConfiguration", |
| 58 | "MeasurementConfiguration" |
| 59 | }) |
| 60 | @JsonIgnoreProperties(ignoreUnknown = true) |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 61 | public class RnibCell { |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 62 | @JsonIgnore |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 63 | private static final String SCHEME = "xran"; |
| 64 | |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 65 | @JsonProperty("ECGI") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 66 | private ECGI ecgi; |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 67 | @JsonProperty("Configuration") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 68 | private CellConfigReport conf; |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 69 | @JsonProperty("PRB-Usage") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 70 | private PrbUsageContainer prbUsage; |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 71 | @JsonProperty("QCI") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 72 | private SchedMeasReportPerCell.QciVals qci; |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 73 | @JsonProperty("RRMConfiguration") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 74 | private RRMConfig rrmConfig; |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 75 | @JsonProperty("MeasurementConfiguration") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 76 | private L2MeasConfig measConfig; |
| 77 | |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 78 | @JsonIgnore |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 79 | private String version; |
| 80 | |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 81 | public RnibCell() { |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 82 | version = "3"; |
slowr | 89c2ac1 | 2017-08-15 16:20:06 -0700 | [diff] [blame] | 83 | |
| 84 | rrmConfig = new RRMConfig(); |
| 85 | rrmConfig.setEcgi(ecgi); |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 86 | } |
| 87 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 88 | /** |
| 89 | * Encode ECGI and obtain its URI. |
| 90 | * |
| 91 | * @param ecgi ECGI |
| 92 | * @return URI |
| 93 | */ |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 94 | public static URI uri(ECGI ecgi) { |
| 95 | if (ecgi != null) { |
| 96 | try { |
| 97 | BerByteArrayOutputStream os = new BerByteArrayOutputStream(4096); |
| 98 | ecgi.encode(os); |
| 99 | String message = DatatypeConverter.printHexBinary(os.getArray()); |
| 100 | return new URI(SCHEME, message, null); |
| 101 | } catch (URISyntaxException | IOException e) { |
| 102 | return null; |
| 103 | } |
| 104 | } |
| 105 | return null; |
| 106 | } |
| 107 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 108 | /** |
| 109 | * Obtain ECGI from the device ID. |
| 110 | * |
| 111 | * @param deviceId ID of the device |
| 112 | * @return ECGI |
| 113 | * @throws IOException I0 Exception for ByteArrayInputStream |
| 114 | */ |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 115 | public static ECGI decodeDeviceId(DeviceId deviceId) throws IOException { |
| 116 | String uri = deviceId.toString(); |
| 117 | String hexEcgi = uri.substring(uri.lastIndexOf("xran:") + 5); |
| 118 | |
| 119 | ECGI ecgi = new ECGI(); |
| 120 | byte[] bytearray = DatatypeConverter.parseHexBinary(hexEcgi); |
| 121 | InputStream inputStream = new ByteArrayInputStream(bytearray); |
| 122 | |
| 123 | ecgi.decode(inputStream); |
| 124 | return ecgi; |
| 125 | } |
| 126 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 127 | /** |
| 128 | * Get version ID. |
| 129 | * |
| 130 | * @return version ID |
| 131 | */ |
slowr | ed74ec7 | 2017-08-17 11:25:01 -0700 | [diff] [blame] | 132 | public int getVersion() { |
| 133 | return Integer.parseInt(version); |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 134 | } |
| 135 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 136 | /** |
| 137 | * Set version ID. |
| 138 | * |
| 139 | * @param version version ID |
| 140 | */ |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 141 | public void setVersion(String version) { |
| 142 | this.version = version; |
| 143 | } |
| 144 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 145 | /** |
| 146 | * Get RRMConfig. |
| 147 | * |
| 148 | * @return RRMConfig |
| 149 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 150 | @JsonProperty("RRMConfiguration") |
slowr | 67d05e4 | 2017-08-11 20:37:22 -0700 | [diff] [blame] | 151 | public RRMConfig getRrmConfig() { |
| 152 | return rrmConfig; |
| 153 | } |
| 154 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 155 | /** |
| 156 | * Set RRMConfig properties. |
| 157 | * |
| 158 | * @param rrmConfig RRMConfig |
| 159 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 160 | @JsonProperty("RRMConfiguration") |
slowr | 67d05e4 | 2017-08-11 20:37:22 -0700 | [diff] [blame] | 161 | public void setRrmConfig(RRMConfig rrmConfig) { |
| 162 | this.rrmConfig = rrmConfig; |
| 163 | } |
| 164 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 165 | /** |
| 166 | * Get PRB Usage. |
| 167 | * @return prb usage |
| 168 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 169 | @JsonProperty("PRB-Usage") |
slowr | 67d05e4 | 2017-08-11 20:37:22 -0700 | [diff] [blame] | 170 | public PrbUsageContainer getPrbUsage() { |
| 171 | return prbUsage; |
| 172 | } |
| 173 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 174 | /** |
| 175 | * Set PRB Usage. |
| 176 | * |
| 177 | * @param prbUsage prb Usage |
| 178 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 179 | @JsonProperty("PRB-Usage") |
slowr | 67d05e4 | 2017-08-11 20:37:22 -0700 | [diff] [blame] | 180 | public void setPrbUsage(PrbUsageContainer prbUsage) { |
| 181 | this.prbUsage = prbUsage; |
| 182 | } |
| 183 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 184 | /** |
| 185 | * Get ECGI. |
| 186 | * |
| 187 | * @return ECGI |
| 188 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 189 | @JsonProperty("ECGI") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 190 | public ECGI getEcgi() { |
| 191 | return ecgi; |
| 192 | } |
| 193 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 194 | /** |
| 195 | * Set ECGI. |
| 196 | * |
| 197 | * @param ecgi ECGI |
| 198 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 199 | @JsonProperty("ECGI") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 200 | public void setEcgi(ECGI ecgi) { |
| 201 | this.ecgi = ecgi; |
| 202 | } |
| 203 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 204 | /** |
| 205 | * Get cell config report. |
| 206 | * |
| 207 | * @return CellConfig Report |
| 208 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 209 | @JsonProperty("Configuration") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 210 | public CellConfigReport getConf() { |
| 211 | return conf; |
| 212 | } |
| 213 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 214 | /** |
| 215 | * Set cell config report. |
| 216 | * |
| 217 | * @param conf Cell config report |
| 218 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 219 | @JsonProperty("Configuration") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 220 | public void setConf(CellConfigReport conf) { |
| 221 | this.conf = conf; |
| 222 | } |
| 223 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 224 | /** |
| 225 | * Modify the RRM Config parameters of cell. |
| 226 | * |
| 227 | * @param rrmConfigNode RRMConfig parameters to modify obtained from REST call |
| 228 | * @param ueList List of all UEs |
| 229 | * @throws Exception p_a size not equal to UE size |
| 230 | */ |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 231 | public void modifyRrmConfig(JsonNode rrmConfigNode, List<RnibUe> ueList) throws Exception { |
slowr | 67d05e4 | 2017-08-11 20:37:22 -0700 | [diff] [blame] | 232 | RRMConfig.Crnti crnti = new RRMConfig.Crnti(); |
slowr | c86750e | 2017-08-22 17:26:47 -0700 | [diff] [blame] | 233 | ueList.forEach(ue -> crnti.addCRNTI(ue.getCrnti())); |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 234 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 235 | JsonNode pA = rrmConfigNode.path("p_a"); |
| 236 | if (!pA.isMissingNode()) { |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 237 | RRMConfig.Pa pa = new RRMConfig.Pa(); |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 238 | if (pA.isArray()) { |
| 239 | if (ueList.size() == pA.size()) { |
| 240 | List<XICICPA> collect = Stream.of(pA) |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 241 | .map(val -> new XICICPA(val.asInt())) |
| 242 | .collect(Collectors.toList()); |
| 243 | pa.setXICICPA(collect); |
| 244 | } else { |
| 245 | throw new Exception("p_a size is not the same as UE size"); |
| 246 | } |
| 247 | } |
| 248 | rrmConfig.setPa(pa); |
| 249 | } |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 250 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 251 | JsonNode startPrbDl1 = rrmConfigNode.path("start_prb_dl"); |
| 252 | if (!startPrbDl1.isMissingNode()) { |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 253 | RRMConfig.StartPrbDl startPrbDl = new RRMConfig.StartPrbDl(); |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 254 | if (startPrbDl1.isArray()) { |
| 255 | if (ueList.size() == startPrbDl1.size()) { |
| 256 | List<BerInteger> collect = Stream.of(startPrbDl1) |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 257 | .map(val -> new BerInteger(val.asInt())) |
| 258 | .collect(Collectors.toList()); |
| 259 | startPrbDl.setSeqOf(collect); |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 260 | } else { |
| 261 | throw new Exception("start_prb_dl size is not the same as UE size"); |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 262 | } |
| 263 | } |
| 264 | rrmConfig.setStartPrbDl(startPrbDl); |
slowr | 67d05e4 | 2017-08-11 20:37:22 -0700 | [diff] [blame] | 265 | } |
slowr | 67d05e4 | 2017-08-11 20:37:22 -0700 | [diff] [blame] | 266 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 267 | JsonNode endPrbDl1 = rrmConfigNode.path("end_prb_dl"); |
| 268 | if (!endPrbDl1.isMissingNode()) { |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 269 | RRMConfig.EndPrbDl endPrbDl = new RRMConfig.EndPrbDl(); |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 270 | if (endPrbDl1.isArray()) { |
| 271 | if (ueList.size() == endPrbDl1.size()) { |
| 272 | List<BerInteger> collect = Stream.of(endPrbDl1) |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 273 | .map(val -> new BerInteger(val.asInt())) |
| 274 | .collect(Collectors.toList()); |
| 275 | endPrbDl.setSeqOf(collect); |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 276 | } else { |
| 277 | throw new Exception("end_prb_dl size is not the same as UE size"); |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 278 | } |
| 279 | } |
| 280 | rrmConfig.setEndPrbDl(endPrbDl); |
| 281 | } |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 282 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 283 | JsonNode frameBitmaskDl = rrmConfigNode.path("sub_frame_bitmask_dl"); |
| 284 | if (!frameBitmaskDl.isMissingNode()) { |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 285 | RRMConfig.SubframeBitmaskDl subframeBitmaskDl = new RRMConfig.SubframeBitmaskDl(); |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 286 | if (frameBitmaskDl.isArray()) { |
| 287 | List<BerBitString> collect = Stream.of(frameBitmaskDl) |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 288 | .map(val -> new BerBitString(DatatypeConverter.parseHexBinary(val.asText()), 10)) |
| 289 | .collect(Collectors.toList()); |
| 290 | |
| 291 | subframeBitmaskDl.setSeqOf(collect); |
| 292 | } else { |
| 293 | throw new Exception("sub_frame_bitmask_dl size is not the same as UE size"); |
| 294 | } |
| 295 | rrmConfig.setSubframeBitmaskDl(subframeBitmaskDl); |
| 296 | } |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 297 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 298 | JsonNode startPrbUl1 = rrmConfigNode.path("start_prb_ul"); |
| 299 | if (!startPrbUl1.isMissingNode()) { |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 300 | RRMConfig.StartPrbUl startPrbUl = new RRMConfig.StartPrbUl(); |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 301 | if (startPrbUl1.isArray()) { |
| 302 | if (ueList.size() == startPrbUl1.size()) { |
| 303 | List<BerInteger> collect = Stream.of(startPrbUl1) |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 304 | .map(val -> new BerInteger(val.asInt())) |
| 305 | .collect(Collectors.toList()); |
| 306 | startPrbUl.setSeqOf(collect); |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 307 | } else { |
| 308 | throw new Exception("start_prb_ul size is not the same as UE size"); |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 309 | } |
| 310 | } |
| 311 | rrmConfig.setStartPrbUl(startPrbUl); |
| 312 | } |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 313 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 314 | JsonNode endPrbUl1 = rrmConfigNode.path("end_prb_ul"); |
| 315 | if (!endPrbUl1.isMissingNode()) { |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 316 | RRMConfig.EndPrbUl endPrbUl = new RRMConfig.EndPrbUl(); |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 317 | if (endPrbUl1.isArray()) { |
| 318 | if (ueList.size() == endPrbUl1.size()) { |
| 319 | List<BerInteger> collect = Stream.of(endPrbUl1) |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 320 | .map(val -> new BerInteger(val.asInt())) |
| 321 | .collect(Collectors.toList()); |
| 322 | endPrbUl.setSeqOf(collect); |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 323 | } else { |
| 324 | throw new Exception("end_prb_ul size is not the same as UE size"); |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 325 | } |
| 326 | } |
| 327 | rrmConfig.setEndPrbUl(endPrbUl); |
| 328 | } |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 329 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 330 | JsonNode uePusch = rrmConfigNode.path("p0_ue_pusch"); |
| 331 | if (!uePusch.isMissingNode()) { |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 332 | RRMConfig.P0UePusch p0UePusch = new RRMConfig.P0UePusch(); |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 333 | if (uePusch.isArray()) { |
| 334 | if (ueList.size() == uePusch.size()) { |
| 335 | List<BerInteger> collect = Stream.of(uePusch) |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 336 | .map(val -> new BerInteger(val.asInt())) |
| 337 | .collect(Collectors.toList()); |
| 338 | p0UePusch.setSeqOf(collect); |
| 339 | } else { |
| 340 | throw new Exception("p0_ue_pusch size is not the same as UE size"); |
| 341 | } |
| 342 | } |
| 343 | rrmConfig.setP0UePusch(p0UePusch); |
| 344 | } |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 345 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 346 | JsonNode frameBitmaskUl = rrmConfigNode.path("sub_frame_bitmask_ul"); |
| 347 | if (!frameBitmaskUl.isMissingNode()) { |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 348 | RRMConfig.SubframeBitmaskUl subframeBitmaskUl = new RRMConfig.SubframeBitmaskUl(); |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 349 | if (frameBitmaskUl.isArray()) { |
| 350 | List<BerBitString> collect = Stream.of(frameBitmaskUl) |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 351 | .map(val -> new BerBitString(DatatypeConverter.parseHexBinary(val.asText()), 10)) |
| 352 | .collect(Collectors.toList()); |
| 353 | |
| 354 | subframeBitmaskUl.setSeqOf(collect); |
| 355 | } else { |
| 356 | throw new Exception("sub_frame_bitmask_ul size is not the same as UE size"); |
| 357 | } |
| 358 | rrmConfig.setSubframeBitmaskUl(subframeBitmaskUl); |
| 359 | } |
slowr | 73b4eae | 2017-08-17 16:09:09 -0700 | [diff] [blame] | 360 | |
slowr | 8ddc2b1 | 2017-08-14 14:13:38 -0700 | [diff] [blame] | 361 | rrmConfig.setCrnti(crnti); |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 362 | } |
| 363 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 364 | /** |
| 365 | * Get QCI values. |
| 366 | * |
| 367 | * @return QCI values |
| 368 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 369 | @JsonProperty("QCI") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 370 | public SchedMeasReportPerCell.QciVals getQci() { |
| 371 | return qci; |
| 372 | } |
| 373 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 374 | /** |
| 375 | * Set QCI values. |
| 376 | * |
| 377 | * @param qci QCI |
| 378 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 379 | @JsonProperty("QCI") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 380 | public void setQci(SchedMeasReportPerCell.QciVals qci) { |
| 381 | this.qci = qci; |
| 382 | } |
| 383 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 384 | /** |
| 385 | * Get L2 measurement config. |
| 386 | * |
| 387 | * @return L2MeasConfig |
| 388 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 389 | @JsonProperty("MeasurementConfiguration") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 390 | public L2MeasConfig getMeasConfig() { |
| 391 | return measConfig; |
| 392 | } |
| 393 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 394 | /** |
| 395 | * Set L2 measurement config. |
| 396 | * |
| 397 | * @param measConfig l2MeasConfig |
| 398 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 399 | @JsonProperty("MeasurementConfiguration") |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 400 | public void setMeasConfig(L2MeasConfig measConfig) { |
| 401 | this.measConfig = measConfig; |
| 402 | } |
| 403 | |
| 404 | @Override |
| 405 | public String toString() { |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 406 | return "RnibCell{" + |
| 407 | "ecgi=" + ecgi + |
| 408 | ", conf=" + conf + |
| 409 | ", prbUsage=" + prbUsage + |
| 410 | ", qci=" + qci + |
| 411 | ", rrmConfig=" + rrmConfig + |
| 412 | ", measConfig=" + measConfig + |
| 413 | ", version='" + version + '\'' + |
| 414 | '}'; |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 415 | } |
| 416 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 417 | /* |
| 418 | * (non-Javadoc) |
| 419 | * |
| 420 | * @see java.lang.Object#equals() |
| 421 | */ |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 422 | @Override |
| 423 | public boolean equals(Object o) { |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 424 | if (this == o) { |
| 425 | return true; |
| 426 | } |
| 427 | if (o == null || getClass() != o.getClass()) { |
| 428 | return false; |
| 429 | } |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 430 | |
| 431 | RnibCell rnibCell = (RnibCell) o; |
| 432 | |
| 433 | return ecgi.equals(rnibCell.ecgi); |
| 434 | } |
| 435 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 436 | /* |
| 437 | * (non-Javadoc) |
| 438 | * |
| 439 | * @see java.lang.Object#hashCode() |
| 440 | */ |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 441 | @Override |
| 442 | public int hashCode() { |
| 443 | return ecgi.hashCode(); |
| 444 | } |
| 445 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 446 | /** |
| 447 | * Container class for PRBUsage. |
| 448 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 449 | @JsonPropertyOrder({ |
| 450 | "primary", |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 451 | "secondary", |
| 452 | "timesincelastupdate" |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 453 | }) |
| 454 | @JsonIgnoreProperties(ignoreUnknown = true) |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 455 | public static class PrbUsageContainer { |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 456 | PRBUsage primary; |
| 457 | PRBUsage secondary; |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 458 | WallClockTimestamp timesincelastupdate; |
| 459 | |
| 460 | @JsonCreator |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 461 | public PrbUsageContainer(@JsonProperty("primary") PRBUsage primary, |
| 462 | @JsonProperty("secondary") PRBUsage secondary) { |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 463 | this.primary = primary; |
| 464 | this.secondary = secondary; |
| 465 | this.timesincelastupdate = new WallClockTimestamp(); |
| 466 | } |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 467 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 468 | /** |
| 469 | * Get primary PRBUsage. |
| 470 | * |
| 471 | * @return PRBUsage |
| 472 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 473 | public PRBUsage getPrimary() { |
| 474 | return primary; |
| 475 | } |
| 476 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 477 | /** |
| 478 | * Set secondary PRBUsage. |
| 479 | * |
| 480 | * @param primary PRBUsage |
| 481 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 482 | public void setPrimary(PRBUsage primary) { |
| 483 | this.primary = primary; |
| 484 | } |
| 485 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 486 | /** |
| 487 | * Get secondary PRBUsage. |
| 488 | * |
| 489 | * @return PRBUsage |
| 490 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 491 | public PRBUsage getSecondary() { |
| 492 | return secondary; |
| 493 | } |
| 494 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 495 | /** |
| 496 | * Set secondary PRBUsage. |
| 497 | * |
| 498 | * @param secondary PRBUsage |
| 499 | */ |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 500 | public void setSecondary(PRBUsage secondary) { |
| 501 | this.secondary = secondary; |
| 502 | } |
| 503 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 504 | /** |
| 505 | * Get time since last update. |
| 506 | * |
| 507 | * @return long Time |
| 508 | */ |
| 509 | public long getTimeSinceLastUpdate() { |
slowr | 7bebd7b | 2017-08-17 11:46:11 -0700 | [diff] [blame] | 510 | return new WallClockTimestamp().unixTimestamp() - timesincelastupdate.unixTimestamp(); |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 511 | } |
slowr | 7bebd7b | 2017-08-17 11:46:11 -0700 | [diff] [blame] | 512 | |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 513 | |
| 514 | /** |
| 515 | * Set time since last update. |
| 516 | * |
| 517 | * @param timesincelastupdate time since last update |
| 518 | */ |
| 519 | public void setTimeSinceLastUpdate(WallClockTimestamp timesincelastupdate) { |
slowr | c153ad9 | 2017-08-16 19:47:52 -0700 | [diff] [blame] | 520 | this.timesincelastupdate = timesincelastupdate; |
| 521 | } |
| 522 | |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 523 | @Override |
| 524 | public String toString() { |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 525 | return "PrbUsageContainer{" + |
| 526 | "primary=" + primary + |
| 527 | ", secondary=" + secondary + |
slowr | 577f322 | 2017-08-28 10:49:08 -0700 | [diff] [blame^] | 528 | ", timesincelastupdate=" + (new WallClockTimestamp().unixTimestamp() - |
| 529 | timesincelastupdate.unixTimestamp()) + |
slowr | 60d4d10 | 2017-08-16 18:33:58 -0700 | [diff] [blame] | 530 | '}'; |
slowr | 13fa5b0 | 2017-08-08 16:32:31 -0700 | [diff] [blame] | 531 | } |
| 532 | } |
| 533 | } |