gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

better check for frame types

Browse Source
This commit is contained in:
Marten Seemann
2016-04-15 13:08:49 +07:00
parent 8da53885fc
commit 281706fda8
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
session.go
View File

@@ -66,9 +66,8 @@ func (s *Session) HandlePacket(addr *net.UDPAddr, publicHeaderBinary []byte, pub
frameCounter++ frameCounter++
fmt.Printf("Reading frame %d\n", frameCounter) fmt.Printf("Reading frame %d\n", frameCounter)
fmt.Printf("\ttype byte: %b\n", typeByte)
if (typeByte&0x80)>>7 == 1 { // STREAM if typeByte&0x80 == 0x80 { // STREAM
fmt.Println("Detected STREAM") fmt.Println("Detected STREAM")
frame, err := ParseStreamFrame(r, typeByte) frame, err := ParseStreamFrame(r, typeByte)
if err != nil { if err != nil {
@@ -87,11 +86,10 @@ func (s *Session) HandlePacket(addr *net.UDPAddr, publicHeaderBinary []byte, pub
fmt.Printf("%#v\n", frame) fmt.Printf("%#v\n", frame)
panic("streamid not 1") panic("streamid not 1")
} }
} else if typeByte&0xC0 == 0x40 { // ACK
} else if (typeByte&0xC0)>>6 == 1 { // ACK
fmt.Println("Detected ACK") fmt.Println("Detected ACK")
continue // not yet implemented continue // not yet implemented
} else if (typeByte&0xE0)>>5 == 1 { // CONGESTION_FEEDBACK } else if typeByte&0xE0 == 0x20 { // CONGESTION_FEEDBACK
fmt.Println("Detected CONGESTION_FEEDBACK") fmt.Println("Detected CONGESTION_FEEDBACK")
continue // not yet implemented continue // not yet implemented
} else { } else {