fix: fix upgrade header detect (#2134)
This commit is contained in:
parent
c19c8418b3
commit
11834c4592
1 changed files with 9 additions and 1 deletions
|
@ -15,7 +15,15 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
func isUpgradeRequest(req *http.Request) bool {
|
func isUpgradeRequest(req *http.Request) bool {
|
||||||
return strings.EqualFold(req.Header.Get("Connection"), "Upgrade")
|
for _, header := range req.Header["Connection"] {
|
||||||
|
for _, elm := range strings.Split(header, ",") {
|
||||||
|
if strings.EqualFold(strings.TrimSpace(elm), "Upgrade") {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
func handleUpgrade(localConn net.Conn, source net.Addr, request *http.Request, in chan<- C.ConnContext) (resp *http.Response) {
|
func handleUpgrade(localConn net.Conn, source net.Addr, request *http.Request, in chan<- C.ConnContext) (resp *http.Response) {
|
||||||
|
|
Loading…
Reference in a new issue