murali-reddy

// Copied from https://github.com/bboreham/mballs
// mweb is a program to demo multicast.
// Run it multiple times on different machines/containers and each
// instance will learn about the others through multicast.
// It will log to stdout every second the list of peers that it's seen.
// Flag --iface makes it use (and wait for) a particular interface (e.g. ethwe)
package main

import (
	"bytes"

murali-reddy

± git diff vendor/github.com/weaveworks/mesh/gossip_channel.go vendor/github.com/weaveworks/mesh/peers.go
diff --git a/vendor/github.com/weaveworks/mesh/gossip_channel.go b/vendor/github.com/weaveworks/mesh/gossip_channel.go
index d95688b8..f457ec11 100644
--- a/vendor/github.com/weaveworks/mesh/gossip_channel.go
+++ b/vendor/github.com/weaveworks/mesh/gossip_channel.go
@@ -4,6 +4,7 @@ import (
        "bytes"
        "encoding/gob"
        "fmt"
+       "runtime"

murali-reddy

Flag --insecure-bind-address has been deprecated, This flag will be removed in a future version.
Flag --insecure-port has been deprecated, This flag will be removed in a future version.
I0924 07:12:31.773769       1 flags.go:33] FLAG: --address="127.0.0.1"
I0924 07:12:31.773805       1 flags.go:33] FLAG: --admission-control="[]"
I0924 07:12:31.773813       1 flags.go:33] FLAG: --admission-control-config-file=""
I0924 07:12:31.773819       1 flags.go:33] FLAG: --advertise-address="<nil>"
I0924 07:12:31.773824       1 flags.go:33] FLAG: --allow-privileged="true"
I0924 07:12:31.773829       1 flags.go:33] FLAG: --alsologtostderr="false"
I0924 07:12:31.773835       1 flags.go:33] FLAG: --anonymous-auth="false"
I0924 07:12:31.773840       1 flags.go:33] FLAG: --api-audiences="[]"

murali-reddy

diff --git a/vendor/github.com/weaveworks/mesh/local_peer.go b/vendor/github.com/weaveworks/mesh/local_peer.go
index 9e99aecf..442d31c1 100644
--- a/vendor/github.com/weaveworks/mesh/local_peer.go
+++ b/vendor/github.com/weaveworks/mesh/local_peer.go
@@ -15,6 +15,7 @@ type localPeer struct {
        *Peer
        router     *Router
        actionChan chan<- localPeerAction
+       topologyUpdatesChan chan<- []*Peer
 }

murali-reddy

Flag --insecure-bind-address has been deprecated, This flag will be removed in a future version.
Flag --insecure-port has been deprecated, This flag will be removed in a future version.
I0913 04:06:33.365507       1 flags.go:33] FLAG: --address="127.0.0.1"
I0913 04:06:33.365555       1 flags.go:33] FLAG: --admission-control="[]"
I0913 04:06:33.365564       1 flags.go:33] FLAG: --admission-control-config-file=""
I0913 04:06:33.365570       1 flags.go:33] FLAG: --advertise-address="<nil>"
I0913 04:06:33.365651       1 flags.go:33] FLAG: --allow-privileged="true"
I0913 04:06:33.365659       1 flags.go:33] FLAG: --alsologtostderr="false"
I0913 04:06:33.365665       1 flags.go:33] FLAG: --anonymous-auth="false"
I0913 04:06:33.365670       1 flags.go:33] FLAG: --api-audiences="[]"

murali-reddy

2019-09-10 8:21:10 connectionMaker.refresh(): 31
2019-09-10 8:21:11 connectionMaker.refresh(): 34
2019-09-10 8:21:12 connectionMaker.refresh(): 23
2019-09-10 8:21:13 connectionMaker.refresh(): 22
2019-09-10 8:21:14 connectionMaker.refresh(): 30
2019-09-10 8:21:15 connectionMaker.refresh(): 28
2019-09-10 8:21:16 connectionMaker.refresh(): 32
2019-09-10 8:21:17 connectionMaker.refresh(): 25
2019-09-10 8:21:18 connectionMaker.refresh(): 22

murali-reddy

diff --git a/vendor/github.com/weaveworks/mesh/peers.go b/vendor/github.com/weaveworks/mesh/peers.go
index 1190450e..8fb59cc7 100644
--- a/vendor/github.com/weaveworks/mesh/peers.go
+++ b/vendor/github.com/weaveworks/mesh/peers.go
@@ -363,7 +363,7 @@ func (peers *Peers) applyUpdate(update []byte) (peerNameSet, peerNameSet, error)

 	// Now apply the updates
 	newUpdate := peers.applyDecodedUpdate(decodedUpdate, decodedConns, &pending)
-	peers.garbageCollect(&pending)
+	//peers.garbageCollect(&pending)

murali-reddy

diff --git a/vendor/github.com/weaveworks/mesh/connection_maker.go b/vendor/github.com/weaveworks/mesh/connection_maker.go
index 3eb02754..ac6c3215 100644
--- a/vendor/github.com/weaveworks/mesh/connection_maker.go
+++ b/vendor/github.com/weaveworks/mesh/connection_maker.go
@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"math/rand"
 	"net"
+	"sync"
 	"time"

murali-reddy

/home/weave # curl 127.0.0.1:6784/debug/pprof/goroutine?debug=1
goroutine profile: total 2111
626 @ 0x42db5a 0x43d810 0x1218beb 0x45b1a1
#	0x1218bea	github.com/weaveworks/weave/router.(*overlaySwitchForwarder).run+0xda	/go/src/github.com/weaveworks/weave/router/overlay_switch.go:285

581 @ 0x42db5a 0x43d810 0x1218973 0x45b1a1
#	0x1218972	github.com/weaveworks/weave/router.monitorForwarder+0x1d2	/go/src/github.com/weaveworks/weave/router/overlay_switch.go:253

238 @ 0x42db5a 0x43d810 0x121e656 0x45b1a1
#	0x121e655	github.com/weaveworks/weave/router.(*sleeveForwarder).run+0x365	/go/src/github.com/weaveworks/weave/router/sleeve.go:640

murali-reddy

diff --git a/vendor/github.com/weaveworks/mesh/routes.go b/vendor/github.com/weaveworks/mesh/routes.go
index 10ff3152..c839b30d 100644
--- a/vendor/github.com/weaveworks/mesh/routes.go
+++ b/vendor/github.com/weaveworks/mesh/routes.go
@@ -3,6 +3,7 @@ package mesh
 import (
        "math"
        "sync"
+       "time"
 )