Disabling channels

src/server/handlers.go

@@ -11,11 +11,11 @@ func (g *Gossiper) handleStatusPacket(msg common.StatusPacket, relay *net.UDPAdd
 	relayStr := getRelayStr(relay)
 	log.Println("Got status packet from", relayStr)
 
-	g.channelsLock.RLock()
+	/*g.channelsLock.RLock()
 	if ch, ok := g.channels[relayStr]; ok {
 		ch <- true
 	}
-	g.channelsLock.RUnlock()
+	g.channelsLock.RUnlock()*/
 
 	remoteWant := parseWant(msg)
 	g.wantLock.RLock()

src/server/senders.go

@@ -5,7 +5,6 @@ import (
 	"log"
 	"github.com/dedis/protobuf"
 	"github.com/pauarge/decWebRTC/src/common"
-	"time"
 )
 
 func (g *Gossiper) sendStatusPacket(relay *net.UDPAddr) {
@@ -51,24 +50,24 @@ func (g *Gossiper) rumorMongering(address string, msg common.RumorMessage) {
 	if err != nil {
 		log.Println(err)
 	} else {
-		g.channelsLock.RLock()
+		/*g.channelsLock.RLock()
 		ch := g.channels[address]
-		g.channelsLock.RUnlock()
+		g.channelsLock.RUnlock()*/
 
 		addr, err := net.ResolveUDPAddr("udp4", address)
 		_, err = g.gossipConn.WriteToUDP(packetBytes, addr)
 		if err != nil {
 			log.Println(err)
 			g.deletePeer(address)
-			ch <- true
+			//ch <- true
 		}
-		select {
+		/*select {
 		case _ = <-ch:
 			log.Println("Unlocked channel")
 		case <-time.After(time.Second * common.TimeOutSecs):
 			log.Println("Timeout on mongering")
 			g.deletePeer(address)
-		}
+		}*/
 	}
 	log.Println("Finished mongering to", address)
 }

src/server/utils.go

@@ -66,9 +66,9 @@ func (g *Gossiper) addPeer(addr string) {
 			g.peersLock.Lock()
 			g.peers[addr] = true
 			g.peersLock.Unlock()
-			g.channelsLock.Lock()
+			/*g.channelsLock.Lock()
 			g.channels[addr] = make(chan bool)
-			g.channelsLock.Unlock()
+			g.channelsLock.Unlock()*/
 			g.sendUserList()
 			log.Println("Added peer", addr)
 		}
@@ -88,9 +88,9 @@ func (g *Gossiper) deletePeer(addr string) {
 	delete(g.want, addr)
 	g.wantLock.Unlock()
 
-	g.channelsLock.Lock()
+	/*g.channelsLock.Lock()
 	delete(g.channels, addr)
-	g.channelsLock.Unlock()
+	g.channelsLock.Unlock()*/
 
 	g.sendUserList()
 	log.Println("Delted peer", addr)