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