vpp-api/java/jvpp-core/io/fd/vpp/jvpp/core/test/CallbackNotificationApiTest.java

   1 /*
   2  * Copyright (c) 2016 Cisco and/or its affiliates.
   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 io.fd.vpp.jvpp.core.test;
  18
  19 import static io.fd.vpp.jvpp.core.test.NotificationUtils.getChangeInterfaceState;
  20 import static io.fd.vpp.jvpp.core.test.NotificationUtils.getDisableInterfaceNotificationsReq;
  21 import static io.fd.vpp.jvpp.core.test.NotificationUtils.getEnableInterfaceNotificationsReq;
  22 import static io.fd.vpp.jvpp.core.test.NotificationUtils.printNotification;
  23
  24 import io.fd.vpp.jvpp.JVpp;
  25 import io.fd.vpp.jvpp.JVppRegistry;
  26 import io.fd.vpp.jvpp.JVppRegistryImpl;
  27 import io.fd.vpp.jvpp.VppCallbackException;
  28 import io.fd.vpp.jvpp.core.JVppCoreImpl;
  29 import io.fd.vpp.jvpp.core.callback.SwInterfaceSetFlagsCallback;
  30 import io.fd.vpp.jvpp.core.callback.SwInterfaceSetFlagsNotificationCallback;
  31 import io.fd.vpp.jvpp.core.callback.WantInterfaceEventsCallback;
  32 import io.fd.vpp.jvpp.core.dto.SwInterfaceSetFlagsNotification;
  33 import io.fd.vpp.jvpp.core.dto.SwInterfaceSetFlagsReply;
  34 import io.fd.vpp.jvpp.core.dto.WantInterfaceEventsReply;
  35
  36 public class CallbackNotificationApiTest {
  37
  38     private static class TestCallback implements SwInterfaceSetFlagsNotificationCallback,
  39             WantInterfaceEventsCallback, SwInterfaceSetFlagsCallback {
  40
  41         @Override
  42         public void onSwInterfaceSetFlagsNotification(
  43                 final SwInterfaceSetFlagsNotification msg) {
  44             printNotification(msg);
  45         }
  46
  47         @Override
  48         public void onWantInterfaceEventsReply(final WantInterfaceEventsReply wantInterfaceEventsReply) {
  49             System.out.println("Interface notification stream updated");
  50         }
  51
  52         @Override
  53         public void onSwInterfaceSetFlagsReply(final SwInterfaceSetFlagsReply swInterfaceSetFlagsReply) {
  54             System.out.println("Interface flags set successfully");
  55         }
  56
  57         @Override
  58         public void onError(VppCallbackException ex) {
  59             System.out.printf("Received onError exception in getNodeIndexCallback: call=%s, reply=%d, context=%d\n",
  60                     ex.getMethodName(), ex.getErrorCode(), ex.getCtxId());
  61
  62         }
  63     }
  64
  65     private static void testCallbackApi() throws Exception {
  66         System.out.println("Testing Java callback API for notifications");
  67         JVppRegistry registry = new JVppRegistryImpl("CallbackNotificationTest");
  68         JVpp jvpp = new JVppCoreImpl();
  69
  70         registry.register(jvpp, new TestCallback());
  71         System.out.println("Successfully connected to VPP");
  72
  73         getEnableInterfaceNotificationsReq().send(jvpp);
  74         System.out.println("Interface notifications started");
  75         // TODO test ifc dump which also triggers interface flags send
  76
  77         System.out.println("Changing interface configuration");
  78         getChangeInterfaceState().send(jvpp);
  79
  80         // Notifications are received
  81         Thread.sleep(500);
  82
  83         getDisableInterfaceNotificationsReq().send(jvpp);
  84         System.out.println("Interface events stopped");
  85
  86         Thread.sleep(2000);
  87
  88         System.out.println("Disconnecting...");
  89         registry.close();
  90         Thread.sleep(1000);
  91     }
  92
  93     public static void main(String[] args) throws Exception {
  94         testCallbackApi();
  95     }
  96 }