haskal
/
jiti-meet
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add stats logging with max 600 values backlog - fixes #2

This commit is contained in:
Philipp Hancke 2014-01-16 13:34:21 +01:00
parent cfc1ea86cc
commit c1d9917e00
2 changed files with 36 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app.js
View File

@ -513,8 +513,13 @@ function dump(elem, filename){
var session = connection.jingle.sessions[sid]; var session = connection.jingle.sessions[sid];
if (session.peerconnection && session.peerconnection.updateLog) { if (session.peerconnection && session.peerconnection.updateLog) {
// FIXME: should probably be a .dump call // FIXME: should probably be a .dump call
var stats = JSON.parse(JSON.stringify(session.peerconnection.stats));
Object.keys(stats).forEach(function (name) {
stats[name].values = JSON.stringify(stats[name].values);
});
data["jingle_" + session.sid] = { data["jingle_" + session.sid] = {
updateLog: session.peerconnection.updateLog, updateLog: session.peerconnection.updateLog,
stats: stats,
url: window.location.href} url: window.location.href}
; ;
} }

35
libs/strophejingle.bundle.js
View File

@ -4,6 +4,7 @@ function TraceablePeerConnection(ice_config, constraints) {
var RTCPeerconnection = navigator.mozGetUserMedia ? mozRTCPeerConnection : webkitRTCPeerConnection; var RTCPeerconnection = navigator.mozGetUserMedia ? mozRTCPeerConnection : webkitRTCPeerConnection;
this.peerconnection = new RTCPeerconnection(ice_config, constraints); this.peerconnection = new RTCPeerconnection(ice_config, constraints);
this.updateLog = []; this.updateLog = [];
this.stats = {};
// override as desired // override as desired
this.trace = function(what, info) { this.trace = function(what, info) {
@ -16,7 +17,7 @@ function TraceablePeerConnection(ice_config, constraints) {
}; };
this.onicecandidate = null; this.onicecandidate = null;
this.peerconnection.onicecandidate = function (event) { this.peerconnection.onicecandidate = function (event) {
self.trace('onicecandidate', JSON.stringify(event.candidate)); self.trace('onicecandidate', JSON.stringify(event.candidate, null, ' '));
if (self.onicecandidate !== null) { if (self.onicecandidate !== null) {
self.onicecandidate(event); self.onicecandidate(event);
} }
@ -63,6 +64,32 @@ function TraceablePeerConnection(ice_config, constraints) {
self.ondatachannel(event); self.ondatachannel(event);
} }
} }
this.maxstats = 600; // limit to 600 values, i.e. 10 minutes
this.statsinterval = window.setInterval(function() {
self.peerconnection.getStats(function(stats) {
var results = stats.result();
for (var i = 0; i < results.length; ++i) {
//console.log(results[i].type, results[i].id, results[i].names())
var now = new Date();
results[i].names().forEach(function (name) {
var id = results[i].id + '-' + name;
if (!self.stats[id]) {
self.stats[id] = {
startTime: now,
endTime: now,
values: []
};
}
self.stats[id].values.push(results[i].stat(name));
if (self.stats[id].values.length > self.maxstats) {
self.stats[id].values.shift();
}
self.stats[id].endTime = now;
});
}
});
}, 1000);
}; };
dumpSDP = function(description) { dumpSDP = function(description) {
@ -126,7 +153,7 @@ TraceablePeerConnection.prototype.close = function () {
TraceablePeerConnection.prototype.createOffer = function (successCallback, failureCallback, constraints) { TraceablePeerConnection.prototype.createOffer = function (successCallback, failureCallback, constraints) {
var self = this; var self = this;
this.trace('createOffer', JSON.stringify(constraints, null, " ")); this.trace('createOffer', JSON.stringify(constraints, null, ' '));
this.peerconnection.createOffer( this.peerconnection.createOffer(
function (offer) { function (offer) {
self.trace('createOfferOnSuccess', dumpSDP(offer)); self.trace('createOfferOnSuccess', dumpSDP(offer));
@ -142,7 +169,7 @@ TraceablePeerConnection.prototype.createOffer = function (successCallback, failu
TraceablePeerConnection.prototype.createAnswer = function (successCallback, failureCallback, constraints) { TraceablePeerConnection.prototype.createAnswer = function (successCallback, failureCallback, constraints) {
var self = this; var self = this;
this.trace('createAnswer', JSON.stringify(constraints, null, " ")); this.trace('createAnswer', JSON.stringify(constraints, null, ' '));
this.peerconnection.createAnswer( this.peerconnection.createAnswer(
function (answer) { function (answer) {
self.trace('createAnswerOnSuccess', dumpSDP(answer)); self.trace('createAnswerOnSuccess', dumpSDP(answer));
@ -158,7 +185,7 @@ TraceablePeerConnection.prototype.createAnswer = function (successCallback, fail
TraceablePeerConnection.prototype.addIceCandidate = function (candidate, successCallback, failureCallback) { TraceablePeerConnection.prototype.addIceCandidate = function (candidate, successCallback, failureCallback) {
var self = this; var self = this;
this.trace('addIceCandidate', JSON.stringify(candidate)); this.trace('addIceCandidate', JSON.stringify(candidate, null, ' '));
this.peerconnection.addIceCandidate(candidate); this.peerconnection.addIceCandidate(candidate);
/* maybe later /* maybe later
this.peerconnection.addIceCandidate(candidate, this.peerconnection.addIceCandidate(candidate,