protocol: swallow header parsing error

Signed-off-by: Pires <[email protected]>

Author: pires

protocol.go

@@ -117,11 +117,7 @@ func (p *Conn) SetWriteDeadline(t time.Time) error {
 }
 
 func (p *Conn) readHeader() error {
-	hdr, err := Read(p.bufReader)
-	if err != nil {
-		return err
-	}
-	p.header = hdr
+	p.header, _ = Read(p.bufReader)
 	return nil
 
 }

protocol_test.go

@@ -26,18 +26,6 @@ func TestPassthrough(t *testing.T) {
 		}
 		defer conn.Close()
 
-		// Write out the header!
-		header := &Header{
-			Version:            2,
-			Command:            PROXY,
-			TransportProtocol:  TCPv4,
-			SourceAddress:      net.ParseIP("10.1.1.1"),
-			SourcePort:         1000,
-			DestinationAddress: net.ParseIP("20.2.2.2"),
-			DestinationPort:    2000,
-		}
-		header.WriteTo(conn)
-
 		conn.Write([]byte("ping"))
 		recv := make([]byte, 4)
 		_, err = conn.Read(recv)
@@ -89,18 +77,6 @@ func TestTimeout(t *testing.T) {
 		// Do not send data for a while
 		time.Sleep(clientWriteDelay)
 
-		// Write out the header!
-		header := &Header{
-			Version: 1,
-			//Command:            PROXY, // not needed in v1
-			TransportProtocol:  TCPv4,
-			SourceAddress:      net.ParseIP("127.0.0.1"),
-			SourcePort:         1000,
-			DestinationAddress: net.ParseIP("20.2.2.2"),
-			DestinationPort:    2000,
-		}
-		header.WriteTo(conn)
-
 		conn.Write([]byte("ping"))
 		recv := make([]byte, 4)
 		_, err = conn.Read(recv)