apply waterfall to all logivew

cat-home/src/main/java/com/dianping/cat/report/page/model/logview/HistoricalLogViewService.java

@@ -60,12 +60,24 @@ public class HistoricalLogViewService extends BaseHistoricalModelService<String>
 		if (tree != null) {
 			ChannelBuffer buf = ChannelBuffers.dynamicBuffer(8192);
 
-			m_codec.encode(tree, buf);
-			buf.readInt(); // get rid of length
-			return buf.toString(Charset.forName("utf-8"));
-		} else {
-			return null;
+			if (request.getProperty("waterfall", "false").equals("true")) {
+				// to work around a plexus injection bug
+				MessageCodec codec = lookup(MessageCodec.class, "waterfall");
+
+				codec.encode(tree, buf);
+			} else {
+				m_codec.encode(tree, buf);
+			}
+
+			try {
+				buf.readInt(); // get rid of length
+				return buf.toString(Charset.forName("utf-8"));
+			} catch (Exception e) {
+				// ignore it
+			}
 		}
+
+		return null;
 	}
 
 	@Override

cat-home/src/main/java/com/dianping/cat/report/page/model/logview/HistoricalMessageService.java

@@ -80,7 +80,13 @@ public class HistoricalMessageService extends BaseLocalModelService<String> {
 			m_codec.encode(tree, buf);
 		}
 
-		buf.readInt(); // get rid of length
-		return buf.toString(Charset.forName("utf-8"));
+		try {
+			buf.readInt(); // get rid of length
+			return buf.toString(Charset.forName("utf-8"));
+		} catch (Exception e) {
+			// ignore it
+		}
+		
+		return null;
 	}
 }

cat-home/src/main/java/com/dianping/cat/report/page/model/logview/LocalLogViewService.java

@@ -77,12 +77,24 @@ public class LocalLogViewService extends BaseLocalModelService<String> {
 		if (tree != null) {
 			ChannelBuffer buf = ChannelBuffers.dynamicBuffer(8192);
 
-			m_codec.encode(tree, buf);
-			buf.readInt(); // get rid of length
-			return buf.toString(Charset.forName("utf-8"));
-		} else {
-			return null;
+			if (request.getProperty("waterfall", "false").equals("true")) {
+				// to work around a plexus injection bug
+				MessageCodec codec = lookup(MessageCodec.class, "waterfall");
+
+				codec.encode(tree, buf);
+			} else {
+				m_codec.encode(tree, buf);
+			}
+
+			try {
+				buf.readInt(); // get rid of length
+				return buf.toString(Charset.forName("utf-8"));
+			} catch (Exception e) {
+				// ignore it
+			}
 		}
+
+		return null;
 	}
 
 	@Override

cat-home/src/main/java/com/dianping/cat/report/page/model/logview/LocalMessageService.java

@@ -52,9 +52,8 @@ public class LocalMessageService extends BaseLocalModelService<String> {
 				buf.readInt(); // get rid of length
 				return buf.toString(Charset.forName("utf-8"));
 			} catch (Exception e) {
+				// ignore it
 			}
-			
-			return null;
 		}
 
 		return null;