gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

stream handle headers with no space after colon

Browse Source
This commit is contained in:
scottf
2021-01-03 09:47:15 -05:00
parent e04d3d5a0a
commit bd954561bf
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server/stream.go
View File

@@ -878,12 +878,19 @@ func getHdrVal(key string, hdr []byte) []byte {
if index < 0 {
return nil
}
var value []byte
for i := index + len(key) + 2; i > 0 && i < len(hdr); i++ {
if hdr[i] == '\r' && i < len(hdr)-1 && hdr[i+1] == '\n' {
hdrLen := len(hdr)
index += len(key) + 1
for hdr[index] == ' ' && index < hdrLen {
index++
}
for index < hdrLen {
if hdr[index] == '\r' && index < hdrLen-1 && hdr[index+1] == '\n' {
break
}
value = append(value, hdr[i])
value = append(value, hdr[index])
index++
}
return value
}
@@ -948,6 +955,7 @@ func (mset *Stream) processInboundJetStreamMsg(_ *subscription, pc *client, subj
}
return
}
// Expected stream.
if sname := getExpectedStream(hdr); sname != _EMPTY_ && sname != name {
mset.mu.Unlock()