improved comments, start exchange 1on1 works

lib/membership.js

@@ -58,7 +58,7 @@ Membership.prototype.launch = function(callback){
     setTimeout(function(){
         if (self.rps.pending.contains({id:id})){
             self.rps.pending.removeSocket({id:id});
-            socket.destroy(true);
+            socket.destroy();
         };
     }, this.rps.TIMEOUT);
 };
@@ -125,9 +125,8 @@ Membership.prototype.handshake = function(message){
         self.rps.receive(receivedMessage, socket);
     });
     // #C disconnection
-    socket.on('close', function(regular){
+    socket.on('close', function(){
         console.log('wrtc: a connection has been closed');
-        if (!regular){ self.rps.onPeerDown(peer); };
     });
 
     socket.signal(ticket);
@@ -138,4 +137,24 @@ Membership.prototype.ready = function(callback){
 };
 
 
+/*!
+ * \brief leave the network
+ */
+Membership.prototype.disconnect = function(){
+    // #A clean the partial view
+    for (var i = 0; i < this.rps.partialView.length(); ++i){
+        var socket = this.rps.sockets.getSocket(
+            this.rps.partialView.array.arr[i]);
+        socket.destroy();
+    };
+    this.rps.partialView.array.arr.splice(0, this.rps.partialView.length());
+    // #B clean the forward routes
+    for (var i = 0; i < this.rps.forwards.length(); ++i){
+        var socket = this.rps.forwards.array.arr[i].socket;
+        socket.close();
+    };
+    this.rps.forwards.array.arr.splice(0,this.rps.forwards.length());
+    // #C clean inview ? (TODO)
+};
+
 module.exports = Membership;

lib/messages.js

@@ -3,7 +3,7 @@
  * MRequestTicket(id)
  * MOfferTicket(id, ticket, peer)
  * MStampedTicket(id, ticket, peer)
- * MExchange(id, peer, occ)
+ * MExchange(id, peer)
  */
 
 /*!
@@ -59,10 +59,9 @@ module.exports.MStampedTicket = MStampedTicket;
 /*!
  * \brief message requesting an exchange of neighborhood
  * \param id the identifier of the request message
- * \param peer the identity of the peer requesting the exchange
- * \param occ the number of occurrence to the peer in the exchange
+ * \param peer the identity of the initiator of the exchange
  */
-function MExchange(id, peer, occ){
+function MExchange(id, peer){
     this.type = "MExchange";
     this.id = id;
     this.peer = peer;