Batyka/soundcloak
1
0
Fork 0
mirror of https://git.maid.zone/stuff/soundcloak.git synced 2025-12-23 04:09:37 +05:00
Code Issues Packages Projects Releases Wiki Activity

restream: increase default parts list capacity allocation (16 => 24)

Browse Source
This commit is contained in:
Laptop
2024-12-21 20:48:42 +02:00
parent 5aa6bdf354
commit 616db41ead
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
lib/restream/init.go
View File

@@ -20,6 +20,8 @@ var httpc *fasthttp.HostClient
var httpc_aac *fasthttp.HostClient var httpc_aac *fasthttp.HostClient
var httpc_image *fasthttp.HostClient var httpc_image *fasthttp.HostClient
const defaultPartsCapacity = 24
type reader struct { type reader struct {
parts [][]byte parts [][]byte
leftover []byte leftover []byte
@@ -72,7 +74,7 @@ func (r *reader) Setup(url string, aac bool) error {
if r.parts == nil { if r.parts == nil {
cfg.Log("make() r.parts") cfg.Log("make() r.parts")
r.parts = make([][]byte, 0, 16) r.parts = make([][]byte, 0, defaultPartsCapacity)
} else { } else {
cfg.Log(cap(r.parts), len(r.parts)) cfg.Log(cap(r.parts), len(r.parts))
} }
@@ -310,7 +312,7 @@ func Load(r fiber.Router) {
data = resp.Body() data = resp.Body()
} }
parts := make([][]byte, 0, 16) parts := make([][]byte, 0, defaultPartsCapacity)
for _, s := range bytes.Split(data, []byte{'\n'}) { for _, s := range bytes.Split(data, []byte{'\n'}) {
if len(s) == 0 || s[0] == '#' { if len(s) == 0 || s[0] == '#' {
continue continue
@@ -389,7 +391,7 @@ func Load(r fiber.Router) {
data = resp.Body() data = resp.Body()
} }
parts := make([][]byte, 0, 16) parts := make([][]byte, 0, defaultPartsCapacity)
// clone needed to mitigate memory skill issues here // clone needed to mitigate memory skill issues here
for _, s := range bytes.Split(data, []byte{'\n'}) { for _, s := range bytes.Split(data, []byte{'\n'}) {
if len(s) == 0 { if len(s) == 0 {