Commit 4a260476 authored by Henry's avatar Henry
Browse files

protocolEOF: demoted EOF to Debug, kept the else as Warning

parent 8bcd3e59
...@@ -98,9 +98,9 @@ func (h *BasicHost) newStreamHandler(s inet.Stream) { ...@@ -98,9 +98,9 @@ func (h *BasicHost) newStreamHandler(s inet.Stream) {
protoID, handle, err := h.Mux().ReadHeader(s) protoID, handle, err := h.Mux().ReadHeader(s)
if err != nil { if err != nil {
if err == io.EOF { if err == io.EOF {
log.Warningf("protocol EOF: %s", s.Conn().RemotePeer()) log.Debugf("protocol EOF: %s", s.Conn().RemotePeer())
} else { } else {
log.Errorf("protocol mux failed: %s", err) log.Warning("protocol mux failed: %s", err)
} }
return return
} }
...@@ -120,7 +120,7 @@ func (h *BasicHost) Peerstore() peer.Peerstore { ...@@ -120,7 +120,7 @@ func (h *BasicHost) Peerstore() peer.Peerstore {
return h.Network().Peerstore() return h.Network().Peerstore()
} }
// Networks returns the Network interface of the Host // Network returns the Network interface of the Host
func (h *BasicHost) Network() inet.Network { func (h *BasicHost) Network() inet.Network {
return h.network return h.network
} }
...@@ -130,6 +130,7 @@ func (h *BasicHost) Mux() *protocol.Mux { ...@@ -130,6 +130,7 @@ func (h *BasicHost) Mux() *protocol.Mux {
return h.mux return h.mux
} }
// IDService returns
func (h *BasicHost) IDService() *identify.IDService { func (h *BasicHost) IDService() *identify.IDService {
return h.ids return h.ids
} }
...@@ -142,6 +143,7 @@ func (h *BasicHost) SetStreamHandler(pid protocol.ID, handler inet.StreamHandler ...@@ -142,6 +143,7 @@ func (h *BasicHost) SetStreamHandler(pid protocol.ID, handler inet.StreamHandler
h.Mux().SetHandler(pid, handler) h.Mux().SetHandler(pid, handler)
} }
// RemoveStreamHandler returns ..
func (h *BasicHost) RemoveStreamHandler(pid protocol.ID) { func (h *BasicHost) RemoveStreamHandler(pid protocol.ID) {
h.Mux().RemoveHandler(pid) h.Mux().RemoveHandler(pid)
} }
...@@ -238,6 +240,7 @@ func (h *BasicHost) Close() error { ...@@ -238,6 +240,7 @@ func (h *BasicHost) Close() error {
return h.proc.Close() return h.proc.Close()
} }
// GetBandwidthReporter exposes the Host's bandiwth metrics reporter
func (h *BasicHost) GetBandwidthReporter() metrics.Reporter { func (h *BasicHost) GetBandwidthReporter() metrics.Reporter {
return h.bwc return h.bwc
} }
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment