commit a7601c9d9795e796bfa9b3fec9cb20e21cfa306f
author Charles Chan <rascov@gmail.com> Wed Jan 23 15:03:17 2019 -0800
committer Charles Chan <charles@opennetworking.org> Tue Mar 12 08:15:22 2019 +0000
tree cdb8f7318145f8867c9b6f26a722ad459a467a5b
parent b4f9cd1f2fb5cdc1faa23cdbcdb7ce35204f4b46

Offload packet processing to another thread

Also update unit tests

Change-Id: Ib94c796083e2d75912f77667d3cfe4ed794694e9

app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingNeighbourDispatcher.java

diff --git a/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingNeighbourDispatcher.java b/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingNeighbourDispatcher.java
index f170fae..3cf0e32 100644
--- a/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingNeighbourDispatcher.java
+++ b/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingNeighbourDispatcher.java
@@ -42,6 +42,10 @@
 
     @Override
     public void handleMessage(NeighbourMessageContext context, HostService hostService) {
+        manager.neighborExecutor.execute(() -> handleMessageInternal(context, hostService));
+    }
+
+    private void handleMessageInternal(NeighbourMessageContext context, HostService hostService) {
         log.trace("Received {} packet on {}: {}", context.protocol(),
                   context.inPort(), context.packet());
         switch (context.protocol()) {