scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-08 20:07:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

WIP: figure out why config.Gossip.Port is 0 after cluster start

Browse source
This commit is contained in:
Matt Jaffee 2018-10-24 16:56:32 -05:00
parent f643487ce0
commit 28591b4a91
No known key found for this signature in database
GPG key ID: 08A3DFFF987B11BF
2 changed files with 13 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server/server_test.go
View file

@ -407,7 +407,9 @@ func TestClusteringNodesReplica1(t *testing.T) {
config.Translation.MapSize = 100000
// this isn't necessary, but makes the test run way faster
fmt.Println("!!!!!!!!!!", config.Gossip.Port)
config.Gossip.Port = strconv.Itoa(int(cluster[2].Command.GossipTransport().URI.Port))
fmt.Println("!!!!!!!!!!!!!!!!", config.Gossip.Port)
cluster[2].Command = server.NewCommand(cluster[2].Stdin, cluster[2].Stdout, cluster[2].Stderr)
cluster[2].Command.Config = config

18
test/pilosa.go
View file

@ -34,8 +34,8 @@ import (
"github.com/pilosa/pilosa/server"
"github.com/pkg/errors"
"github.com/Shopify/toxiproxy"
tox "github.com/Shopify/toxiproxy/client"
"github.com/jaffee/toxiproxy"
tox "github.com/jaffee/toxiproxy/client"
)
type portAllocator struct {
@ -283,18 +283,22 @@ func newCluster(size int, opts ...[]server.CommandOption) (Cluster, error) {
m := NewCommandNode(i == 0, commandOpts...)
m.Config.Bind = "localhost:" + strconv.Itoa(int(ports.Next()))
m.Config.Advertise = "localhost:" + aport
p, err := tclient.CreateProxy(name+aport, m.Config.Advertise, m.Config.Bind)
_, err := tclient.CreateProxy(name+aport, m.Config.Advertise, m.Config.Bind)
if err != nil {
return nil, errors.Wrap(err, "setting up toxiproxy")
}
m.Config.Gossip.Port = strconv.Itoa(int(ports.Next()))
aport = strconv.Itoa(int(ports.Next()))
gossipBindPort := strconv.Itoa(int(ports.Next()))
m.Config.Gossip.Port = gossipBindPort
gossipAdvertPort := strconv.Itoa(int(ports.Next()))
m.Config.Gossip.AdvertisePort = aport
p, err = tclient.CreateProxy(name+"-gossip"+aport, "localhost:"+m.Config.Gossip.AdvertisePort, "localhost:"+m.Config.Gossip.Port)
_, err = tclient.CreateProxy(name+"-gossip"+gossipAdvertPort, "localhost:"+m.Config.Gossip.AdvertisePort, "localhost:"+m.Config.Gossip.Port)
if err != nil {
return nil, errors.Wrap(err, "setting up toxiproxy for gossip")
}
fmt.Println(p)
_, err = tclient.CreateProxy(name+"-gossipudp"+gossipAdvertPort, "localhost:"+m.Config.Gossip.AdvertisePort, "localhost:"+m.Config.Gossip.Port, tox.CreateWithProtocol("udp"))
if err != nil {
return nil, errors.Wrap(err, "setting up toxiproxy for udp gossip")
}
err = ioutil.WriteFile(path.Join(m.Config.DataDir, ".id"), []byte(name), 0600)
if err != nil {
return nil, errors.Wrap(err, "writing node id")