zishuo/ipchub
1
0
Fork 0
mirror of https://github.com/cnotch/ipchub.git synced 2025-09-26 19:41:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

rename vars

Browse Source
This commit is contained in:
notch
2020-12-30 14:28:45 +08:00
parent ec764fb131
commit 59a98630f5
4 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
av/format/rtsp/request.go
View File

@@ -208,12 +208,12 @@ func (req *Request) DigestAuth() (username, response string, ok bool) {
auth = auth[len(digestAuthPrefix):]
tailing := auth
substr := ""
advance := auth
token := ""
continueScan := true
for continueScan {
tailing, substr, continueScan = scan.Comma.Scan(tailing)
k, v, _ := scan.EqualPair.Scan(substr)
advance, token, continueScan = scan.Comma.Scan(advance)
k, v, _ := scan.EqualPair.Scan(token)
switch k {
case "username":
username = v

16
av/format/rtsp/response.go
View File

@@ -253,12 +253,12 @@ func (resp *Response) BasicAuth() (realm string, ok bool) {
auth = auth[len(basicAuthPrefix):]
tailing := auth
substr := ""
advance := auth
token := ""
continueScan := true
for continueScan {
tailing, substr, continueScan = scan.Comma.Scan(tailing)
k, v, _ := scan.EqualPair.Scan(substr)
advance, token, continueScan = scan.Comma.Scan(advance)
k, v, _ := scan.EqualPair.Scan(token)
switch k {
case "realm":
realm = v
@@ -288,12 +288,12 @@ func (resp *Response) DigestAuth() (realm, nonce string, ok bool) {
}
auth = auth[len(digestAuthPrefix):]
tailing := auth
substr := ""
advance := auth
token := ""
continueScan := true
for continueScan {
tailing, substr, continueScan = scan.Comma.Scan(tailing)
k, v, _ := scan.EqualPair.Scan(substr)
advance, token, continueScan = scan.Comma.Scan(advance)
k, v, _ := scan.EqualPair.Scan(token)
switch k {
case "realm":
realm = v

14
service/rtsp/rtptransport.go
View File

@@ -100,25 +100,25 @@ func (t *RTPTransport) ParseTransport(rtpType int, ts string) (err error) {
}
// 扫描参数
tailing := ts
substr := ""
advance := ts
token := ""
continueScan := true
for continueScan {
tailing, substr, continueScan = scan.Semicolon.Scan(tailing)
if substr == "unicast" && t.Type == RTPMulticast {
advance, token, continueScan = scan.Semicolon.Scan(advance)
if token == "unicast" && t.Type == RTPMulticast {
t.Type = RTPUDPUnicast
continue
}
if substr == "multicast" && t.Type == RTPTCPUnicast {
if token == "multicast" && t.Type == RTPTCPUnicast {
err = errors.New("malformed trannsport")
continue
}
if substr == "append" {
if token == "append" {
t.Append = true
continue
}
k, v, _ := scan.EqualPair.Scan(substr)
k, v, _ := scan.EqualPair.Scan(token)
switch k {
case "mode":
if v == "record" {

4
service/streamapis.go
View File

@@ -109,7 +109,7 @@ func permissionInterceptor(w http.ResponseWriter, r *http.Request) bool {
// 提取请求路径中的流path和格式后缀
func extractStreamPathAndExt(requestPath string) (streamPath, ext string) {
ext = path.Ext(requestPath)
_, substr, _ := scan.NewScanner('/', nil).Scan(requestPath[1:])
streamPath = requestPath[1+len(substr) : len(requestPath)-len(ext)]
_, token, _ := scan.NewScanner('/', nil).Scan(requestPath[1:])
streamPath = requestPath[1+len(token) : len(requestPath)-len(ext)]
return
}