forked from quic-go/quic-go
remove some debug messages
This commit is contained in:
@@ -91,8 +91,6 @@ func (s *Server) handlePacket(conn *net.UDPConn, remoteAddr *net.UDPAddr, packet
|
||||
}
|
||||
publicHeader.Raw = packet[:len(packet)-r.Len()]
|
||||
|
||||
// fmt.Printf("<- Got packet %d (%d bytes) from %v\n", publicHeader.PacketNumber, n, remoteAddr)
|
||||
|
||||
// Send Version Negotiation Packet if the client is speaking a different protocol version
|
||||
if publicHeader.VersionFlag && !protocol.IsSupportedVersion(publicHeader.VersionNumber) {
|
||||
fmt.Println("Sending VersionNegotiationPacket")
|
||||
|
||||
@@ -163,7 +163,6 @@ func (s *Session) HandlePacket(remoteAddr interface{}, publicHeader *PublicHeade
|
||||
|
||||
// TODO: Ignore data for closed streams
|
||||
func (s *Session) handleStreamFrame(frame *frames.StreamFrame) error {
|
||||
fmt.Printf("Got %d bytes for stream %d\n", len(frame.Data), frame.StreamID)
|
||||
if frame.StreamID == 0 {
|
||||
return errors.New("Session: 0 is not a valid Stream ID")
|
||||
}
|
||||
@@ -227,7 +226,6 @@ func (s *Session) Close(e error) error {
|
||||
if packet == nil {
|
||||
panic("Session: internal inconsistency: expected packet not to be nil")
|
||||
}
|
||||
fmt.Printf("-> Sending close packet %d (%d bytes)\n", packet.number, len(packet.raw))
|
||||
return s.conn.write(packet.raw)
|
||||
}
|
||||
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
package quic
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"io"
|
||||
|
||||
"github.com/lucas-clemente/quic-go/frames"
|
||||
@@ -159,7 +158,6 @@ func (s *stream) Write(p []byte) (int, error) {
|
||||
|
||||
// Close implements io.Closer
|
||||
func (s *stream) Close() error {
|
||||
fmt.Printf("Closing stream %d\n", s.streamID)
|
||||
return s.session.QueueStreamFrame(&frames.StreamFrame{
|
||||
StreamID: s.streamID,
|
||||
Offset: s.writeOffset,
|
||||
|
||||
Reference in New Issue
Block a user