You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by mp...@apache.org on 2012/07/20 21:35:49 UTC

svn commit: r1363911 - /flume/trunk/flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java

Author: mpercy
Date: Fri Jul 20 19:35:49 2012
New Revision: 1363911

URL: http://svn.apache.org/viewvc?rev=1363911&view=rev
Log:
FLUME-1387. Ganglia graphs should work with Flume.

(Hari Shreedharan via Mike Percy)

Modified:
    flume/trunk/flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java

Modified: flume/trunk/flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java
URL: http://svn.apache.org/viewvc/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java?rev=1363911&r1=1363910&r2=1363911&view=diff
==============================================================================
--- flume/trunk/flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java (original)
+++ flume/trunk/flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java Fri Jul 20 19:35:49 2012
@@ -237,7 +237,8 @@ public class GangliaServer implements Mo
   }
 
   protected void createGangliaMessage(String name, String value) {
-    logger.debug("Sending ganglia3 formatted message.");
+    logger.debug("Sending ganglia3 formatted message."
+            + name + ": " + value);
     name = hostname + "." + name;
     xdr_int(0);
     xdr_string("float");
@@ -250,12 +251,13 @@ public class GangliaServer implements Mo
   }
 
   protected void createGangliaMessage31(String name, String value) {
-    logger.debug("Sending ganglia 3.1 formatted message.");
+    logger.debug("Sending ganglia 3.1 formatted message: "
+            + name + ": " + value);
     xdr_int(128); // metric_id = metadata_msg
     xdr_string(hostname); // hostname
     xdr_string(name); // metric name
     xdr_int(0); // spoof = False
-    xdr_string("string"); // metric type
+    xdr_string("float"); // metric type
     xdr_string(name); // metric name
     xdr_string(DEFAULT_UNITS); // units
     xdr_int(DEFAULT_SLOPE); // slope