commit | 64a1c8e76ea29bc56502cd443f9da3e29dc6e784 | [log] [tgz] |
---|---|---|
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 | bdfb19a6fbb13c74085f66c19c5429cd1654c825 | |
parent | b87495c31c2b15ba384ae61b77c6c9b82d5adf90 [diff] [blame] |
Offload packet processing to another thread Also update unit tests Change-Id: Ib94c796083e2d75912f77667d3cfe4ed794694e9
diff --git a/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingNeighbourDispatcher.java b/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingNeighbourDispatcher.java index f170fae..3cf0e32 100644 --- a/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/SegmentRoutingNeighbourDispatcher.java +++ b/apps/segmentrouting/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()) {