diff --git a/node/node.go b/node/node.go index 72e08b8b..e8099c7f 100644 --- a/node/node.go +++ b/node/node.go @@ -68,6 +68,9 @@ func NewNode(config cfg.Config, privValidator *types.PrivValidator, clientCreato // Create the proxyApp, which houses three connections: // query, consensus, and mempool proxyApp := proxy.NewAppConns(config, clientCreator, state, blockStore) + if _, err := proxyApp.Start(); err != nil { + Exit(Fmt("Error starting proxy app connections: %v", err)) + } // add the chainid and number of validators to the global config config.Set("chain_id", state.ChainID) diff --git a/proxy/client.go b/proxy/client.go index ea3218d3..c6e03e78 100644 --- a/proxy/client.go +++ b/proxy/client.go @@ -54,7 +54,6 @@ func NewRemoteClientCreator(addr, transport string, mustConnect bool) ClientCrea func (r *remoteClientCreator) NewTMSPClient() (tmspcli.Client, error) { // Run forever in a loop - fmt.Println("ADDR", r.addr, r.transport) remoteApp, err := tmspcli.NewClient(r.addr, r.transport, r.mustConnect) if err != nil { return nil, fmt.Errorf("Failed to connect to proxy: %v", err) @@ -75,7 +74,7 @@ func DefaultClientCreator(config cfg.Config) ClientCreator { case "nilapp": return NewLocalClientCreator(nilapp.NewNilApplication()) default: - mustConnect := true + mustConnect := false // loop retrying return NewRemoteClientCreator(addr, transport, mustConnect) } } diff --git a/proxy/multi_app_conn.go b/proxy/multi_app_conn.go index fe009e1d..9ff38862 100644 --- a/proxy/multi_app_conn.go +++ b/proxy/multi_app_conn.go @@ -7,6 +7,8 @@ import ( // Tendermint's interface to the application consists of multiple connections type AppConns interface { + Service + Mempool() AppConnMempool Consensus() AppConnConsensus Query() AppConnQuery @@ -42,7 +44,6 @@ func NewMultiAppConn(config cfg.Config, clientCreator ClientCreator, state State clientCreator: clientCreator, } multiAppConn.QuitService = *NewQuitService(log, "multiAppConn", multiAppConn) - multiAppConn.Start() return multiAppConn } diff --git a/version/version.go b/version/version.go index 5dc83a23..10435314 100644 --- a/version/version.go +++ b/version/version.go @@ -2,6 +2,6 @@ package version const Maj = "0" const Min = "7" // tmsp useability (protobuf, unix); optimizations; broadcast_tx_commit -const Fix = "1" // query conn, peer filter, fast sync fix +const Fix = "2" // query conn, peer filter, fast sync fix (+hot fix to tmsp connecting) const Version = Maj + "." + Min + "." + Fix