go/tendermint/api: Add LogEventPeerExchangeDisabled

go/oasis-test-runner/oasis/log.go

@@ -4,6 +4,7 @@ import (
 	"github.com/oasislabs/oasis-core/go/common/logging"
 	"github.com/oasislabs/oasis-core/go/oasis-test-runner/log"
 	roothash "github.com/oasislabs/oasis-core/go/roothash/api"
+	tendermint "github.com/oasislabs/oasis-core/go/tendermint/api"
 )
 
 // LogAssertEvent returns a handler which checks whether a specific log event was
@@ -59,3 +60,9 @@ func LogAssertMergeDiscrepancyDetected() log.WatcherHandler {
 func LogAssertNoMergeDiscrepancyDetected() log.WatcherHandler {
 	return LogAssertNotEvent(roothash.LogEventMergeDiscrepancyDetected, "merge discrepancy detected")
 }
+
+// LogAssertPeerExchangeDisabled returns a handler which checks whether a peer
+// exchange disabled event was detected based on JSON log output.
+func LogAssertPeerExchangeDisabled() log.WatcherHandler {
+	return LogAssertEvent(tendermint.LogEventPeerExchangeDisabled, "peer exchange disabled")
+}

go/tendermint/api/api.go

@@ -34,6 +34,12 @@ const (
 	CodeNotFound           Code = Code(6)
 )
 
+const (
+	// LogEventPeerExchangeDisable is a log event that indicates that
+	// Tendermint's peer exchange has been disabled.
+	LogEventPeerExchangeDisabled = "tendermint/peer_exchange_disabled"
+)
+
 // ToInt returns an integer representation of the status code.
 func (c Code) ToInt() uint32 {
 	return uint32(c)

go/tendermint/tendermint.go

@@ -534,6 +534,12 @@ func (t *tendermintService) lazyInit() error {
 	tenderConfig.P2P.AddrBookStrict = !viper.GetBool(CfgDebugP2PAddrBookLenient)
 	tenderConfig.RPC.ListenAddress = ""
 
+	if !tenderConfig.P2P.PexReactor {
+		t.Logger.Info("pex reactor disabled",
+			logging.LogEvent, api.LogEventPeerExchangeDisabled,
+		)
+	}
+
 	tendermintPV, err := crypto.LoadOrGeneratePrivVal(tendermintDataDir, t.consensusSigner)
 	if err != nil {
 		return err