resource-assignment/provider/src/test/java/jtest/org/openecomp/sdnc/ra/TestReserve.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : SDN-C
   4  * ================================================================================
   5  * Copyright (C) 2017 ONAP Intellectual Property. All rights
   6  *                                              reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package jtest.org.openecomp.sdnc.ra;
  23
  24 import org.junit.Assert;
  25 import org.junit.FixMethodOrder;
  26 import org.junit.Test;
  27 import org.junit.runner.RunWith;
  28 import org.junit.runners.MethodSorters;
  29 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
  30 import org.onap.ccsdk.sli.core.sli.SvcLogicException;
  31 import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
  32 import org.openecomp.sdnc.ra.ResourceAllocator;
  33 import org.slf4j.Logger;
  34 import org.slf4j.LoggerFactory;
  35 import org.springframework.beans.factory.annotation.Autowired;
  36 import org.springframework.test.context.ContextConfiguration;
  37 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
  38
  39 @RunWith(SpringJUnit4ClassRunner.class)
  40 @ContextConfiguration(locations = { "classpath:test-context.xml" })
  41 @FixMethodOrder(MethodSorters.NAME_ASCENDING)
  42 public class TestReserve {
  43
  44         private static final Logger log = LoggerFactory.getLogger(TestReserve.class);
  45
  46         @Autowired(required = true)
  47         private ResourceAllocator resourceAllocator;
  48
  49         @Autowired(required = true)
  50         private DataSetup dataSetup;
  51
  52         @Test
  53         public void test001() throws Exception {
  54                 String t = "001";
  55                 log.info("============== reserve " + t + " ================================");
  56                 log.info("=== Test successful response - new start - all resources available");
  57
  58                 String service1 = "reserve" + t + "/service1";
  59
  60                 dataSetup.cleanup();
  61                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
  62                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
  63                 dataSetup.setupPserver("server1", "MTSNJA4LCP1");
  64
  65                 SvcLogicContext ctx = new SvcLogicContext();
  66                 ctx.setAttribute("tmp.resource-allocator.request-type", "New");
  67                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
  68                 ctx.setAttribute("tmp.resource-allocator.speed", "300");
  69                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
  70                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
  71
  72                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
  73
  74                 log.info("Result: " + st);
  75                 log.info("  tmp.resource-allocator-output.max-available-speed: " +
  76                         ctx.getAttribute("tmp.resource-allocator-output.max-available-speed"));
  77                 log.info("  tmp.resource-allocator-output.speed-unit: " +
  78                         ctx.getAttribute("tmp.resource-allocator-output.speed-unit"));
  79
  80                 Assert.assertTrue(st == QueryStatus.SUCCESS);
  81                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 1, 300000));
  82         }
  83
  84         @Test
  85         public void test002() throws Exception {
  86                 String t = "002";
  87                 log.info("============== reserve " + t + " ================================");
  88                 log.info("=== Test successful response - new start supp - all resources available");
  89
  90                 String service1 = "reserve" + t + "/service1";
  91
  92                 dataSetup.cleanup();
  93                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
  94                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
  95                 dataSetup.setupService(service1, "Pending", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
  96
  97                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 2, 200000));
  98
  99                 SvcLogicContext ctx = new SvcLogicContext();
 100                 // ctx.setAttribute("tmp.resource-allocator.request-type", "New"); - Default is New
 101                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 102                 ctx.setAttribute("tmp.resource-allocator.speed", "400");
 103                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 104                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 105
 106                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 107
 108                 log.info("Result: " + st);
 109                 log.info("  tmp.resource-allocator-output.max-available-speed: " +
 110                         ctx.getAttribute("tmp.resource-allocator-output.max-available-speed"));
 111                 log.info("  tmp.resource-allocator-output.speed-unit: " +
 112                         ctx.getAttribute("tmp.resource-allocator-output.speed-unit"));
 113
 114                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 115                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 400000));
 116                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 2));
 117         }
 118
 119         @Test
 120         public void test003() throws Exception {
 121                 String t = "003";
 122                 log.info("============== reserve " + t + " ================================");
 123                 log.info("=== Test successful response - change - all resources available");
 124
 125                 String service1 = "reserve" + t + "/service1";
 126
 127                 dataSetup.cleanup();
 128                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 129                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 130                 dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 131
 132                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 133
 134                 SvcLogicContext ctx = new SvcLogicContext();
 135                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 136                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 137                 ctx.setAttribute("tmp.resource-allocator.speed", "400");
 138                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 139                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 140
 141                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 142
 143                 log.info("Result: " + st);
 144                 log.info("  tmp.resource-allocator-output.max-available-speed: " +
 145                         ctx.getAttribute("tmp.resource-allocator-output.max-available-speed"));
 146                 log.info("  tmp.resource-allocator-output.speed-unit: " +
 147                         ctx.getAttribute("tmp.resource-allocator-output.speed-unit"));
 148
 149                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 150                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 151                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 400000));
 152         }
 153
 154         @Test
 155         public void test004() throws Exception {
 156                 String t = "004";
 157                 log.info("============== reserve " + t + " ================================");
 158                 log.info("=== Test successful response - change supp - all resources available");
 159
 160                 String service1 = "reserve" + t + "/service1";
 161
 162                 dataSetup.cleanup();
 163                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 164                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 165                 dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 166                 dataSetup.setupService(service1, "Pending", 3, 400000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 167
 168                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 169                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 400000));
 170
 171                 SvcLogicContext ctx = new SvcLogicContext();
 172                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 173                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 174                 ctx.setAttribute("tmp.resource-allocator.speed", "500");
 175                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 176                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 177
 178                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 179
 180                 log.info("Result: " + st);
 181                 log.info("  tmp.resource-allocator-output.max-available-speed: " +
 182                         ctx.getAttribute("tmp.resource-allocator-output.max-available-speed"));
 183                 log.info("  tmp.resource-allocator-output.speed-unit: " +
 184                         ctx.getAttribute("tmp.resource-allocator-output.speed-unit"));
 185
 186                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 187                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 188                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 4, 500000));
 189                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 3));
 190         }
 191
 192         @Test
 193         public void test005() throws Exception {
 194                 String t = "005";
 195                 log.info("============== reserve " + t + " ================================");
 196                 log.info("=== Test successful response - change - check that hard limits are applied, not soft for change");
 197
 198                 String service1 = "reserve" + t + "/service1";
 199
 200                 dataSetup.cleanup();
 201                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 202                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 203                 dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 204
 205                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 206
 207                 SvcLogicContext ctx = new SvcLogicContext();
 208                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 209                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 210                 ctx.setAttribute("tmp.resource-allocator.speed", "1200000");
 211                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "kbps");
 212                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 213
 214                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 215
 216                 log.info("Result: " + st);
 217                 log.info("  tmp.resource-allocator-output.max-available-speed: " +
 218                         ctx.getAttribute("tmp.resource-allocator-output.max-available-speed"));
 219                 log.info("  tmp.resource-allocator-output.speed-unit: " +
 220                         ctx.getAttribute("tmp.resource-allocator-output.speed-unit"));
 221
 222                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 223                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 224                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 1200000));
 225         }
 226
 227         @Test
 228         public void test006() throws Exception {
 229                 String t = "006";
 230                 log.info("============== reserve " + t + " ================================");
 231                 log.info("=== Test capacity not found - new start");
 232
 233                 String service1 = "reserve" + t + "/service1";
 234
 235                 dataSetup.cleanup();
 236                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 237                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 238
 239                 SvcLogicContext ctx = new SvcLogicContext();
 240                 ctx.setAttribute("tmp.resource-allocator.request-type", "New");
 241                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 242                 ctx.setAttribute("tmp.resource-allocator.speed", "300");
 243                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Gbps");
 244                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 245
 246                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 247
 248                 log.info("Result: " + st);
 249
 250                 Assert.assertTrue(st == QueryStatus.NOT_FOUND);
 251                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 252         }
 253
 254         @Test
 255         public void test007() throws Exception {
 256                 String t = "007";
 257                 log.info("============== reserve " + t + " ================================");
 258                 log.info("=== Test capacity not found - new start supp");
 259
 260                 String service1 = "reserve" + t + "/service1";
 261
 262                 dataSetup.cleanup();
 263                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 264                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 265                 dataSetup.setupService(service1, "Pending", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 266
 267                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 2, 200000));
 268
 269                 SvcLogicContext ctx = new SvcLogicContext();
 270                 ctx.setAttribute("tmp.resource-allocator.request-type", "New");
 271                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 272                 ctx.setAttribute("tmp.resource-allocator.speed", "2000");
 273                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 274                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 275
 276                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 277
 278                 log.info("Result: " + st);
 279
 280                 Assert.assertTrue(st == QueryStatus.NOT_FOUND);
 281                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 2, 200000));
 282                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 3));
 283         }
 284
 285         @Test
 286         public void test008() throws Exception {
 287                 String t = "008";
 288                 log.info("============== reserve " + t + " ================================");
 289                 log.info("=== Test capacity not found - change");
 290
 291                 String service1 = "reserve" + t + "/service1";
 292
 293                 dataSetup.cleanup();
 294                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 295                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 296                 dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 297
 298                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 299
 300                 SvcLogicContext ctx = new SvcLogicContext();
 301                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 302                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 303                 ctx.setAttribute("tmp.resource-allocator.speed", "2000");
 304                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 305                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 306
 307                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 308
 309                 log.info("Result: " + st);
 310
 311                 Assert.assertTrue(st == QueryStatus.NOT_FOUND);
 312                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 313                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 3));
 314         }
 315
 316         @Test
 317         public void test009() throws Exception {
 318                 String t = "009";
 319                 log.info("============== reserve " + t + " ================================");
 320                 log.info("=== Test capacity not found - change supp");
 321
 322                 String service1 = "reserve" + t + "/service1";
 323
 324                 dataSetup.cleanup();
 325                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 326                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 327                 dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 328                 dataSetup.setupService(service1, "Pending", 3, 400000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 329
 330                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 331                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 400000));
 332
 333                 SvcLogicContext ctx = new SvcLogicContext();
 334                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 335                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 336                 ctx.setAttribute("tmp.resource-allocator.speed", "2000");
 337                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 338                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 339
 340                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 341
 342                 log.info("Result: " + st);
 343
 344                 Assert.assertTrue(st == QueryStatus.NOT_FOUND);
 345                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 200000));
 346                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 400000));
 347                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 4));
 348         }
 349
 350         @Test
 351         public void test010() throws Exception {
 352                 String t = "010";
 353                 log.info("============== reserve " + t + " ================================");
 354                 log.info("=== Test border condition - connection limit - new start - adding connection " +
 355                         "when we are on the limit should fail");
 356
 357                 String service1 = "reserve" + t + "/service1";
 358
 359                 dataSetup.cleanup();
 360                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 361                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 362                 for (int i = 1; i <= 40; i++)
 363                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Active", 2, 1000, "mtanjrsv126",
 364                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 365                 for (int i = 1; i <= 40; i += 4)
 366                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Pending", 3, 1000, "mtanjrsv126",
 367                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 368
 369                 SvcLogicContext ctx = new SvcLogicContext();
 370                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 371                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 372                 ctx.setAttribute("tmp.resource-allocator.speed", "1");
 373                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 374                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 375
 376                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 377
 378                 log.info("Result: " + st);
 379
 380                 Assert.assertTrue(st == QueryStatus.NOT_FOUND);
 381                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 382         }
 383
 384         @Test
 385         public void test011() throws Exception {
 386                 String t = "011";
 387                 log.info("============== reserve " + t + " ================================");
 388                 log.info(
 389                         "=== Test border condition - connection limit - new start supp should succeed as no new connection being added");
 390
 391                 String service1 = "reserve" + t + "/service1";
 392
 393                 dataSetup.cleanup();
 394                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 395                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 396                 for (int i = 1; i <= 39; i++)
 397                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Active", 2, 1000, "mtanjrsv126",
 398                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 399                 for (int i = 1; i <= 39; i += 4)
 400                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Pending", 3, 1000, "mtanjrsv126",
 401                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 402
 403                 dataSetup.setupService(service1, "Pending", 2, 1000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 404
 405                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 2, 1000));
 406
 407                 SvcLogicContext ctx = new SvcLogicContext();
 408                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 409                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 410                 ctx.setAttribute("tmp.resource-allocator.speed", "5");
 411                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 412                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 413
 414                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 415
 416                 log.info("Result: " + st);
 417
 418                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 419                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 5000));
 420                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 2));
 421         }
 422
 423         @Test
 424         public void test012() throws Exception {
 425                 String t = "012";
 426                 log.info("============== reserve " + t + " ================================");
 427                 log.info(
 428                         "=== Test border condition - connection limit - change should succeed as no new connection being added");
 429
 430                 String service1 = "reserve" + t + "/service1";
 431
 432                 dataSetup.cleanup();
 433                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 434                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 435                 for (int i = 1; i <= 39; i++)
 436                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Active", 2, 1000, "mtanjrsv126",
 437                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 438                 for (int i = 1; i <= 39; i += 4)
 439                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Pending", 3, 1000, "mtanjrsv126",
 440                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 441
 442                 dataSetup.setupService(service1, "Active", 2, 1000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 443
 444                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 1000));
 445
 446                 SvcLogicContext ctx = new SvcLogicContext();
 447                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 448                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 449                 ctx.setAttribute("tmp.resource-allocator.speed", "5");
 450                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 451                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 452
 453                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 454
 455                 log.info("Result: " + st);
 456
 457                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 458                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 1000));
 459                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 5000));
 460         }
 461
 462         @Test
 463         public void test013() throws Exception {
 464                 String t = "013";
 465                 log.info("============== reserve " + t + " ================================");
 466                 log.info(
 467                         "=== Test border condition - connection limit - change supp should succeed as no new connection being added");
 468
 469                 String service1 = "reserve" + t + "/service1";
 470
 471                 dataSetup.cleanup();
 472                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 473                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 474                 for (int i = 1; i <= 39; i++)
 475                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Active", 2, 1000, "mtanjrsv126",
 476                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 477                 for (int i = 1; i <= 39; i += 4)
 478                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Pending", 3, 1000, "mtanjrsv126",
 479                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 480
 481                 dataSetup.setupService(service1, "Active", 2, 1000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 482                 dataSetup.setupService(service1, "Pending", 3, 5000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 483
 484                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 1000));
 485                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 3, 5000));
 486
 487                 SvcLogicContext ctx = new SvcLogicContext();
 488                 ctx.setAttribute("tmp.resource-allocator.request-type", "Change");
 489                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 490                 ctx.setAttribute("tmp.resource-allocator.speed", "10");
 491                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 492                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 493
 494                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 495
 496                 log.info("Result: " + st);
 497
 498                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 499                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Active", 2, 1000));
 500                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 4, 10000));
 501                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 3));
 502         }
 503
 504         @Test
 505         public void test014() throws Exception {
 506                 String t = "014";
 507                 log.info("============== reserve " + t + " ================================");
 508                 log.info("=== Test input validations - invalid request-type in input");
 509
 510                 String service1 = "reserve" + t + "/service1";
 511
 512                 SvcLogicContext ctx = new SvcLogicContext();
 513                 ctx.setAttribute("tmp.resource-allocator.request-type", "xxxxx");
 514                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 515                 ctx.setAttribute("tmp.resource-allocator.speed", "10");
 516                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 517                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 518
 519                 try {
 520                         resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 521                 } catch (SvcLogicException e) {
 522                         Assert.assertTrue(e.getMessage().equals(
 523                                 "Invalid tmp.resource-allocator.request-type: xxxxx. Supported values are New, Change."));
 524                         return;
 525                 }
 526                 Assert.fail("SvcLogicException expected");
 527         }
 528
 529         @Test
 530         public void test015() throws Exception {
 531                 String t = "015";
 532                 log.info("============== reserve " + t + " ================================");
 533                 log.info("=== Test server bw limit depends on number of servers - limit is 960Mbps for 1 server, 1920 for 2");
 534
 535                 String service1 = "reserve" + t + "/service1";
 536
 537                 dataSetup.cleanup();
 538                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 539                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 540                 dataSetup.setupPserver("server1", "MTSNJA4LCP1");
 541                 dataSetup.setupPserver("server2", "MTSNJA4LCP1");
 542                 dataSetup.setupPserver("server3", "MTSNJA4LCP1");
 543                 dataSetup.setupPserver("server4", "MTSNJA4LCP1");
 544
 545                 SvcLogicContext ctx = new SvcLogicContext();
 546                 ctx.setAttribute("tmp.resource-allocator.request-type", "New");
 547                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 548                 ctx.setAttribute("tmp.resource-allocator.speed", "1200");
 549                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 550                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 551
 552                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 553
 554                 log.info("Result: " + st);
 555                 log.info("  tmp.resource-allocator-output.max-available-speed: " +
 556                         ctx.getAttribute("tmp.resource-allocator-output.max-available-speed"));
 557                 log.info("  tmp.resource-allocator-output.speed-unit: " +
 558                         ctx.getAttribute("tmp.resource-allocator-output.speed-unit"));
 559
 560                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 561                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 1, 1200000));
 562         }
 563
 564         @Test
 565         public void test016() throws Exception {
 566                 String t = "016";
 567                 log.info("============== reserve " + t + " ================================");
 568                 log.info("=== Test resource threshold output");
 569
 570                 String service1 = "reserve" + t + "/service1";
 571
 572                 dataSetup.cleanup();
 573                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 574                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 575                 dataSetup.setupPserver("server1", "MTSNJA4LCP1");
 576                 dataSetup.setupPserver("server2", "MTSNJA4LCP1");
 577                 dataSetup.setupPserver("server3", "MTSNJA4LCP1");
 578                 dataSetup.setupPserver("server4", "MTSNJA4LCP1");
 579
 580                 SvcLogicContext ctx = new SvcLogicContext();
 581                 ctx.setAttribute("tmp.resource-allocator.request-type", "New");
 582                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 583                 ctx.setAttribute("tmp.resource-allocator.speed", "1605");
 584                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 585                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 586
 587                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 588
 589                 log.info("Result: " + st);
 590                 for (String key : ctx.getAttributeKeySet())
 591                         if (key.startsWith("tmp.resource-allocator-output"))
 592                                 log.info("  " + key + ": " + ctx.getAttribute(key));
 593
 594                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 595                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 1, 1605000));
 596         }
 597
 598         @Test
 599         public void test017() throws Exception {
 600                 String t = "017";
 601                 log.info("============== reserve " + t + " ================================");
 602                 log.info("=== Test if evc_count lookup in MAX_SERVER_SPEED depends on the number of primary servers.");
 603                 log.info("=== For 10 existing EVC, it should take the first row, not the second (see data.sql).");
 604                 log.info("=== Applied limit should be 1920Mbps, not 1680Mbps.");
 605
 606                 String service1 = "reserve" + t + "/service1";
 607
 608                 dataSetup.cleanup();
 609                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 610                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 611                 dataSetup.setupPserver("server1", "MTSNJA4LCP1");
 612                 dataSetup.setupPserver("server2", "MTSNJA4LCP1");
 613                 dataSetup.setupPserver("server3", "MTSNJA4LCP1");
 614                 dataSetup.setupPserver("server4", "MTSNJA4LCP1");
 615
 616                 for (int i = 1; i <= 10; i++)
 617                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Active", 2, 100000, "mtanjrsv126",
 618                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 619
 620                 SvcLogicContext ctx = new SvcLogicContext();
 621                 ctx.setAttribute("tmp.resource-allocator.request-type", "New");
 622                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 623                 ctx.setAttribute("tmp.resource-allocator.speed", "800"); // 10*100Mbps existing + 800 = 1800
 624                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 625                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 626
 627                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 628
 629                 log.info("Result: " + st);
 630                 log.info("  tmp.resource-allocator-output.max-available-speed: " +
 631                         ctx.getAttribute("tmp.resource-allocator-output.max-available-speed"));
 632                 log.info("  tmp.resource-allocator-output.speed-unit: " +
 633                         ctx.getAttribute("tmp.resource-allocator-output.speed-unit"));
 634
 635                 Assert.assertTrue(st == QueryStatus.SUCCESS);
 636                 Assert.assertTrue(dataSetup.serviceCorrectInDb("mtanjrsv126", "MTSNJA4LCP1", service1, "Pending", 1, 800000));
 637         }
 638
 639         @Test
 640         public void test018() throws Exception {
 641                 String t = "018";
 642                 log.info("============== reserve " + t + " ================================");
 643                 log.info("=== Test if evc_count lookup in MAX_SERVER_SPEED depends on the number of primary servers.");
 644                 log.info("=== For 11 existing EVC, it should take the second row (see data.sql).");
 645                 log.info("=== Applied limit should be 1680Mbps. We have 11*100 + 700, so this should fail.");
 646
 647                 String service1 = "reserve" + t + "/service1";
 648
 649                 dataSetup.cleanup();
 650                 dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 651                 dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 652                 dataSetup.setupPserver("server1", "MTSNJA4LCP1");
 653                 dataSetup.setupPserver("server2", "MTSNJA4LCP1");
 654                 dataSetup.setupPserver("server3", "MTSNJA4LCP1");
 655                 dataSetup.setupPserver("server4", "MTSNJA4LCP1");
 656
 657                 for (int i = 1; i <= 11; i++)
 658                         dataSetup.setupService("reserve" + t + "/existing-service" + i, "Active", 2, 100000, "mtanjrsv126",
 659                                 "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 660
 661                 SvcLogicContext ctx = new SvcLogicContext();
 662                 ctx.setAttribute("tmp.resource-allocator.request-type", "New");
 663                 ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 664                 ctx.setAttribute("tmp.resource-allocator.speed", "700"); // 11*100Mbps existing + 700 = 1800
 665                 ctx.setAttribute("tmp.resource-allocator.speed-unit", "Mbps");
 666                 ctx.setAttribute("tmp.resource-allocator.aic-site-id", "MTSNJA4LCP1");
 667
 668                 QueryStatus st = resourceAllocator.reserve("NetworkCapacity", null, null, null, ctx);
 669
 670                 log.info("Result: " + st);
 671                 log.info("  tmp.resource-allocator-output.max-available-speed: " +
 672                         ctx.getAttribute("tmp.resource-allocator-output.max-available-speed"));
 673                 log.info("  tmp.resource-allocator-output.speed-unit: " +
 674                         ctx.getAttribute("tmp.resource-allocator-output.speed-unit"));
 675
 676                 log.info("Result: " + st);
 677
 678                 Assert.assertTrue(st == QueryStatus.NOT_FOUND);
 679                 Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 680         }
 681 }