Update for logging inboundrtp and outboundrtp

usv-public · Sep 26, 2016 · 02099fb · 02099fb
1 parent dd7cbe2
commit 02099fb
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/src/main/java/org/kurento/tutorial/kmsmonitor/SendStats.java b/src/main/java/org/kurento/tutorial/kmsmonitor/SendStats.java
@@ -25,8 +25,19 @@ public static void main(String[] args) throws InterruptedException {
 				System.out.println("Sending stats for hostname: " + hostname + " to graphite... ");
 				dos.writeBytes("server."+hostname+".pipelines " + kmsStats.getNumPipelines() +" "+ System.currentTimeMillis() / 1000L +"\n");
 				dos.writeBytes("server."+hostname+".elements " + kmsStats.getNumElements() +" "+ System.currentTimeMillis() / 1000L +"\n");
-				dos.writeBytes("server."+hostname+".inboundrtp "+ kmsStats.getWebRtcStats().getInbound() + " "+ System.currentTimeMillis() / 1000L +"\n");
-				dos.writeBytes("server."+hostname+".outboundrtp "+ kmsStats.getWebRtcStats().getOutbound() + " "+ System.currentTimeMillis() / 1000L +"\n");
+
+				dos.writeBytes("server."+hostname+".inboudJitter "+ kmsStats.getWebRtcStats().getInbound().getJitter() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".inboundByteCount "+ kmsStats.getWebRtcStats().getInbound().getByteCount() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".inboundPacketLost "+ kmsStats.getWebRtcStats().getInbound().getPacketLostCount() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".inboundDeltaNacks "+ kmsStats.getWebRtcStats().getInbound().getDeltaNacks() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".inboundDeltaPlis "+ kmsStats.getWebRtcStats().getInbound().getDeltaPlis() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".inboundFractionLost "+ kmsStats.getWebRtcStats().getInbound().getFractionLost() + " "+ System.currentTimeMillis() / 1000L +"\n");
+
+				dos.writeBytes("server."+hostname+".outboundByteCount "+ kmsStats.getWebRtcStats().getOutbound().getByteCount() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".outboundRtt "+ kmsStats.getWebRtcStats().getOutbound().getRtt() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".outboundDeltaPlis "+ kmsStats.getWebRtcStats().getOutbound().getDeltaPlis() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".outboundDeltaNacks "+ kmsStats.getWebRtcStats().getOutbound().getDeltaNacks() + " "+ System.currentTimeMillis() / 1000L +"\n");
+				dos.writeBytes("server."+hostname+".outboundTargetBitrate "+ kmsStats.getWebRtcStats().getOutbound().getTargetBitrate() + " "+ System.currentTimeMillis() / 1000L +"\n");
 
 				conn.close();
 			} catch (Exception e) {

diff --git a/target/kms-monitoring-java-6.5.0.jar b/target/kms-monitoring-java-6.5.0.jar