@@ 282,8 282,8 @@ func (demux *Demux) readServer(
go func() {
for {
var p = NewPacket()
- var _, err = p.ReadFrom(demux.server)
- // demux.printf("read %d bytes from upstream", n)
+ var n, err = p.ReadFrom(demux.server)
+ demux.printf("read %d bytes from upstream", n)
if err == io.EOF {
demux.printf("upstream closed connection")
close(output)
@@ 347,11 347,9 @@ func (demux *Demux) writeServer(
seq = 1
}
case keepalivePacket:
- // Forward the packet to the server as is
+ // Leave the sequence packet alone, set ack
p.header.Ack = seq
- // var n int64
_, err = p.WriteTo(demux.server)
- // demux.printf("wrote %d bytes upstream for keepalive", n)
}
if err != nil {
demux.printf("error writing packet %s", err)