From 60d096098e8a9c8284baa800c1431d4fe126a092 Mon Sep 17 00:00:00 2001 From: Jeromy Date: Wed, 6 Apr 2016 11:32:17 -0700 Subject: [PATCH] use different protocol tag for unencrypted transport --- p2p/net/conn/dial.go | 7 ++++++- p2p/net/conn/listen.go | 7 ++++++- 2 files changed, 12 insertions(+), 2 deletions(-) diff --git a/p2p/net/conn/dial.go b/p2p/net/conn/dial.go index a2ce3c0..b2d4908 100644 --- a/p2p/net/conn/dial.go +++ b/p2p/net/conn/dial.go @@ -63,7 +63,12 @@ func (d *Dialer) Dial(ctx context.Context, raddr ma.Multiaddr, remote peer.ID) ( maconn = d.Wrapper(maconn) } - err = msmux.SelectProtoOrFail(SecioTag, maconn) + cryptoProtoChoice := SecioTag + if !EncryptConnections { + cryptoProtoChoice = NoEncryptionTag + } + + err = msmux.SelectProtoOrFail(cryptoProtoChoice, maconn) if err != nil { errOut = err return diff --git a/p2p/net/conn/listen.go b/p2p/net/conn/listen.go index 99d4826..b5ea522 100644 --- a/p2p/net/conn/listen.go +++ b/p2p/net/conn/listen.go @@ -18,6 +18,7 @@ import ( ) const SecioTag = "/secio" +const NoEncryptionTag = "/plaintext" // ConnWrapper is any function that wraps a raw multiaddr connection type ConnWrapper func(transport.Conn) transport.Conn @@ -164,7 +165,11 @@ func WrapTransportListener(ctx context.Context, ml transport.Listener, local pee } l.proc = goprocessctx.WithContextAndTeardown(ctx, l.teardown) - l.mux.AddHandler(SecioTag, nil) + if EncryptConnections { + l.mux.AddHandler(SecioTag, nil) + } else { + l.mux.AddHandler(NoEncryptionTag, nil) + } log.Debugf("Conn Listener on %s", l.Multiaddr()) log.Event(ctx, "swarmListen", l) -- GitLab