handle possibly null (invalid) records

flewton · Dec 20, 2010 · db97d53 · eevans · Dec 20, 2010 · gdusbabek
1 parent 2ad5070
commit db97d53
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/com/rackspace/flewton/CollectorHandler.java b/src/com/rackspace/flewton/CollectorHandler.java
@@ -69,6 +69,7 @@ record = new Recordv5(buff);
                     break;
                 default:
                     if (logUnhandledVersions) {
+                        // this means the record stays null. we need to check for that when handling.
                         logger.warn(String.format("Netflow v%d is not supported", version));
                         if (logger.isDebugEnabled())
                             logPacket(e.getRemoteAddress(), buff.duplicate());
@@ -82,8 +83,9 @@ record = new Recordv5(buff);
         }
 
         // Send record to backends
-        for (AbstractBackend backend : backEnds)
-            backend.write(record);
+        if (record != null)
+            for (AbstractBackend backend : backEnds)
+                backend.write(record);
     }
 
     // dumps the contents of a buffer