Changeset 43 for sample/hadoop-0.16/tw/org/nchc/code/SnortParser.java

Timestamp:

Jul 23, 2008, 5:08:53 PM (17 years ago)

Author:

waue

Message:

HBaseRecordPro.java -> only modified for debuging SnortUploadHbase?.java

SnortParser?.java -> catch a bug and fix it

SnortUploadHbase?.java -> it can run finally ..

File:

• sample/hadoop-0.16/tw/org/nchc/code/SnortParser.java (modified) (4 diffs)

sample/hadoop-0.16/tw/org/nchc/code/SnortParser.java

@@ -3 +3 @@
  * Editor: Waue Chen 
  * From :  NCHC. Taiwn
- * Last Update Date: 07/17/2008
+ * Last Update Date: 07/23/2008
  */
 
@@ -43 +43 @@
     case 1:
       patten_line = Pattern
-          .compile("^\\[\\**\\] \\[([1-9]*):([1-9]*):([1-9]*)\\] ([^\\[]*)\\[\\**\\]$");
+          .compile("^\\[\\**\\] \\[([0-9]*):([0-9]*):([0-9]*)\\] ([^\\[]*)\\[\\**\\]$");
       break;
     case 2:
@@ -80 +80 @@
     int count = 0;
     do {
-      String tmp = fi.readLine();
-      if (tmp == null) {
+      line = fi.readLine();
+      if (line == null) {
         break;
-      } else if (count < 4) {
-        line = tmp;
+      }else if(line.isEmpty()){
+        fw.write(this.logData.toString() + "\n");
+        this.logData = "";
+        count = 0;        
+      }else if (count < 4) {
         // System.out.println(line);
         snortParser(line, count + 1);
         count++;
-      } else if (count == 4) {
+      } else {
         count++;
-      } else if (count == 5) {
-        fw.write(this.logData.toString() + "\n");
-        this.logData = "";
-        count = 0;
-      } else {
-        System.err.print(" Error ! ");
-        return;
       }
     } while (true);
@@ -105 +101 @@
 
   public static void main(String[] args) throws ParseException, Exception {
-    String in = new String("/home/waue/Desktop/alert");
-    String ou = new String("/home/waue/Desktop/bb");
+    String in = new String("/home/waue/Desktop/alert_m");
+    String ou = new String("/tmp/alert_my");
     SnortParser a = new SnortParser(in, ou);
     a.parseToLine();