diff --git a/client/lib/webrtc.go b/client/lib/webrtc.go index 3fe8410..389e02b 100644 --- a/client/lib/webrtc.go +++ b/client/lib/webrtc.go @@ -239,8 +239,8 @@ func (c *WebRTCPeer) establishDataChannel() error { if len(msg.Data) <= 0 { log.Println("0 length message---") } - c.BytesLogger.AddInbound(len(msg.Data)) n, err := c.writePipe.Write(msg.Data) + c.BytesLogger.AddInbound(n) if err != nil { // TODO: Maybe shouldn't actually close. log.Println("Error writing to SOCKS pipe") @@ -248,10 +248,6 @@ func (c *WebRTCPeer) establishDataChannel() error { log.Printf("c.writePipe.CloseWithError returned error: %v", inerr) } } - if n != len(msg.Data) { - log.Println("Error: short write") - panic("short write") - } c.lastReceive = time.Now() }) log.Println("WebRTC: DataChannel created.")