Thomas Vachuska
Committed by Gerrit Code Review

Adusted log-levels in flow store and packet manager.

Change-Id: I38748bfddfe1aae66bd8a6a9086575dc2e155078
...@@ -170,6 +170,7 @@ public class PacketManager ...@@ -170,6 +170,7 @@ public class PacketManager
170 * @param request the packet request 170 * @param request the packet request
171 */ 171 */
172 private void pushToAllDevices(PacketRequest request) { 172 private void pushToAllDevices(PacketRequest request) {
173 + log.debug("Pushing packet request {} to all devices", request);
173 for (Device device : deviceService.getDevices()) { 174 for (Device device : deviceService.getDevices()) {
174 pushRule(device, request); 175 pushRule(device, request);
175 } 176 }
...@@ -202,7 +203,8 @@ public class PacketManager ...@@ -202,7 +203,8 @@ public class PacketManager
202 .add(new ObjectiveContext() { 203 .add(new ObjectiveContext() {
203 @Override 204 @Override
204 public void onError(Objective objective, ObjectiveError error) { 205 public void onError(Objective objective, ObjectiveError error) {
205 - log.warn("Failed to install packet request {}: {}", request, error); 206 + log.warn("Failed to install packet request {} to {}: {}",
207 + request, device.id(), error);
206 } 208 }
207 }); 209 });
208 210
...@@ -224,7 +226,8 @@ public class PacketManager ...@@ -224,7 +226,8 @@ public class PacketManager
224 .remove(new ObjectiveContext() { 226 .remove(new ObjectiveContext() {
225 @Override 227 @Override
226 public void onError(Objective objective, ObjectiveError error) { 228 public void onError(Objective objective, ObjectiveError error) {
227 - log.warn("Failed to withdraw packet request {}: {}", request, error); 229 + log.warn("Failed to withdraw packet request {} from {}: {}",
230 + request, device.id(), error);
228 } 231 }
229 }); 232 });
230 233
...@@ -308,6 +311,7 @@ public class PacketManager ...@@ -308,6 +311,7 @@ public class PacketManager
308 case DEVICE_ADDED: 311 case DEVICE_ADDED:
309 case DEVICE_AVAILABILITY_CHANGED: 312 case DEVICE_AVAILABILITY_CHANGED:
310 if (deviceService.isAvailable(event.subject().id())) { 313 if (deviceService.isAvailable(event.subject().id())) {
314 + log.debug("Pushing packet requests to device {}", event.subject().id());
311 for (PacketRequest request : store.existingRequests()) { 315 for (PacketRequest request : store.existingRequests()) {
312 pushRule(device, request); 316 pushRule(device, request);
313 } 317 }
......
...@@ -319,7 +319,7 @@ public class NewDistributedFlowRuleStore ...@@ -319,7 +319,7 @@ public class NewDistributedFlowRuleStore
319 NodeId master = mastershipService.getMasterFor(rule.deviceId()); 319 NodeId master = mastershipService.getMasterFor(rule.deviceId());
320 320
321 if (master == null) { 321 if (master == null) {
322 - log.warn("Failed to getFlowEntry: No master for {}", rule.deviceId()); 322 + log.debug("Failed to getFlowEntry: No master for {}", rule.deviceId());
323 return null; 323 return null;
324 } 324 }
325 325
...@@ -345,7 +345,7 @@ public class NewDistributedFlowRuleStore ...@@ -345,7 +345,7 @@ public class NewDistributedFlowRuleStore
345 NodeId master = mastershipService.getMasterFor(deviceId); 345 NodeId master = mastershipService.getMasterFor(deviceId);
346 346
347 if (master == null) { 347 if (master == null) {
348 - log.warn("Failed to getFlowEntries: No master for {}", deviceId); 348 + log.debug("Failed to getFlowEntries: No master for {}", deviceId);
349 return Collections.emptyList(); 349 return Collections.emptyList();
350 } 350 }
351 351
......