홍길동 / onos

Go to a project
Toggle navigation Toggle navigation pinning
Yuta HIGUCHI
Committed by Gerrit Code Review
4e3af861 1 parent a809a177

Record EDGE_EVENTS in the Event History 

Change-Id: I2e77b17bc94a1232bc896df83a18d140ccb8e227
Inline Side-by-side
Showing 1 changed file with 6 additions and 1 deletions
...@@ -45,6 +45,7 @@ import org.onosproject.mastership.MastershipService; ...@@ -45,6 +45,7 @@ import org.onosproject.mastership.MastershipService;
45 import org.onosproject.net.device.DeviceEvent; 45 import org.onosproject.net.device.DeviceEvent;
46 import org.onosproject.net.device.DeviceListener; 46 import org.onosproject.net.device.DeviceListener;
47 import org.onosproject.net.device.DeviceService; 47 import org.onosproject.net.device.DeviceService;
48 +import org.onosproject.net.edge.EdgePortService;
48 import org.onosproject.net.host.HostEvent; 49 import org.onosproject.net.host.HostEvent;
49 import org.onosproject.net.host.HostListener; 50 import org.onosproject.net.host.HostListener;
50 import org.onosproject.net.host.HostService; 51 import org.onosproject.net.host.HostService;
...@@ -88,6 +89,9 @@ public class EventHistoryManager ...@@ -88,6 +89,9 @@ public class EventHistoryManager
88 @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY) 89 @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
89 protected ClusterService clusterService; 90 protected ClusterService clusterService;
90 91
92 + @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
93 + protected EdgePortService edgeService;
94 +
91 @Property(name = "excludeStatsEvent", boolValue = true, 95 @Property(name = "excludeStatsEvent", boolValue = true,
92 label = "Exclude stats related events") 96 label = "Exclude stats related events")
93 private boolean excludeStatsEvent = true; 97 private boolean excludeStatsEvent = true;
...@@ -127,7 +131,8 @@ public class EventHistoryManager ...@@ -127,7 +131,8 @@ public class EventHistoryManager
127 .addListener(linkService, new InternalLinkListener()) 131 .addListener(linkService, new InternalLinkListener())
128 .addListener(topologyService, new InternalTopologyListener()) 132 .addListener(topologyService, new InternalTopologyListener())
129 .addListener(hostService, new InternalHostListener()) 133 .addListener(hostService, new InternalHostListener())
130 - .addListener(clusterService, new InternalClusterListener()); 134 + .addListener(clusterService, new InternalClusterListener())
135 + .addListener(edgeService, this::addEvent);
131 136
132 log.info("Started"); 137 log.info("Started");
133 } 138 }
......