hanzoai/psrpc
2
0
Fork 0
mirror of https://github.com/hanzoai/psrpc.git synced 2026-09-30 23:47:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix topic length check (#89)

Browse Source
This commit is contained in:
Paul Wells
2024-03-12 04:02:12 -07:00
committed by GitHub
parent 28644f0103
commit 8ae8bd90c4
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/info/channels.go
+9 -1
View File
@@ -115,7 +115,7 @@ func formatServerChannel(service string, topic []string, queue bool) string {
defer scratch.Put(p)
b := append(*p, "SRV."...)
b = append(b, service...)
if channelPartsLen(topic) > 0 {
if stringSliceLen(topic) > 0 {
b = append(b, '.')
b = appendChannelParts(b, '.', topic...)
}
@@ -125,6 +125,14 @@ func formatServerChannel(service string, topic []string, queue bool) string {
return string(b)
}
func stringSliceLen(s []string) int {
var n int
for i := range s {
n += len(s[i])
}
return n
}
func formatChannel(delim byte, parts ...any) string {
buf := make([]byte, 0, 4*channelPartsLen(parts...)/3)
return string(appendChannelParts(buf, delim, parts...))