peer, stats, warm: unplug chunks sent/recv report (closes #71)

Author: flavioribeiro

src/peer.js

@@ -6,6 +6,7 @@
 var BaseObject = require('base_object');
 var Storage = require('./storage');
 var UploadHandler = require('./upload_handler')
+var Stats = require('./stats')
 var log = require('./log');
 
 class Peer extends BaseObject {
@@ -16,6 +17,7 @@ class Peer extends BaseObject {
     this.dataChannel = params.dataChannel
     this.dataChannel.on("data", (data) => this.messageReceived(data))
     this.uploadHandler = UploadHandler.getInstance()
+    this.stats = Stats.getInstance()
     this.score = 1000
     this.sendPing()
   }
@@ -37,7 +39,7 @@ class Peer extends BaseObject {
   sendSatisfy(resource) {
     if (this.uploadHandler.getSlot(this.ident)) {
       this.send('satisfy', resource, this.storage.getItem(resource))
-      this.swarm.chunksSent += 1
+      this.stats.updateStats('p2psent')
     } else {
       log.warn("cannot send satisfy, no upload slot available")
       this.send("busy", resource)

src/stats.js

@@ -11,6 +11,7 @@ class Stats extends BaseObject {
   constructor() {
     this.recv_cdn = 0
     this.recv_p2p = 0
+    this.sent_p2p = 0
     this.bufferLength = 0
   }
 
@@ -19,7 +20,6 @@ class Stats extends BaseObject {
     if (Settings.statsReport) {
       this.addEventListeners()
       this.bufferLengthTimer = setInterval(() => this.updateBufferLength(), 1000)
-      this.updateStats()
       this.triggerStats({status: "on"})
     }
   }
@@ -44,8 +44,8 @@ class Stats extends BaseObject {
   updateStats(method=null) {
     if (method === "p2p") this.recv_p2p++
     else if (method === "cdn") this.recv_cdn++
-    var chunksSent = this.main.resourceRequester.p2pManager.swarm.chunksSent
-    var stats = {chunksFromP2P: this.recv_p2p, chunksFromCDN: this.recv_cdn, chunksSent: chunksSent}
+    else if (method === "p2psent") this.sent_p2p++
+    var stats = {chunksFromP2P: this.recv_p2p, chunksFromCDN: this.recv_cdn, chunksSent: this.sent_p2p}
     this.triggerStats(stats)
   }
 

src/swarm.js

@@ -17,7 +17,6 @@ class Swarm extends BaseObject {
     this.utils = new SwarmUtils(this)
     this.peers = []
     this.satisfyCandidate = undefined
-    this.chunksSent = 0
     this.chokedClients = 0
     this.avgSegmentSize = 0
     this.peersContainsResource = []
@@ -51,8 +50,6 @@ class Swarm extends BaseObject {
     this.utils.decrementScore(badPeers)
   }
 
-
-
   sendTo(recipients, command, resource, content='') {
     if (recipients === 'contributors') {
       _.each(this.utils.contributors, function(peer) { peer.send(command, resource, content) }, this)