libp2p/go-libp2p-resource-manager
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-resource-manager.git synced 2025-01-28 05:10:26 +08:00
Code Issues Projects Releases Wiki Activity

Add size hint to slice to hopefully have the tag slice allocated on the stack

Browse Source
This commit is contained in:
Marco Munizaga 2022-07-27 04:28:44 -07:00
parent 7dda49c55d
commit 3ecce6cc34
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
obs/stats.go
View File

@ -317,15 +317,21 @@ func (r StatsTraceReporter) ConsumeEvent(evt rcmgr.TraceEvt) {
// Drop the connection or stream id // Drop the connection or stream id
scopeName = strings.SplitN(scopeName, "-", 2)[0] scopeName = strings.SplitN(scopeName, "-", 2)[0]
// If something else gets added here, make sure to update the size hint
// below when we make `tagsWithDir`.
tags := []tag.Mutator{tag.Upsert(scopeTag, scopeName), tag.Upsert(resourceTag, resource)} tags := []tag.Mutator{tag.Upsert(scopeTag, scopeName), tag.Upsert(resourceTag, resource)}
if evt.DeltaIn != 0 { if evt.DeltaIn != 0 {
tagsWithDir := append([]tag.Mutator{tag.Insert(directionTag, "inbound")}, tags...) tagsWithDir := make([]tag.Mutator, 3)
stats.RecordWithTags(ctx, tagsWithDir, blockedResources.M(int64(1))) tagsWithDir = append(tagsWithDir, tag.Insert(directionTag, "inbound"))
tagsWithDir = append(tagsWithDir, tags...)
stats.RecordWithTags(ctx, tagsWithDir[0:], blockedResources.M(int64(1)))
} }
if evt.DeltaOut != 0 { if evt.DeltaOut != 0 {
tagsWithDir := append([]tag.Mutator{tag.Insert(directionTag, "outbound")}, tags...) tagsWithDir := make([]tag.Mutator, 3)
tagsWithDir = append(tagsWithDir, tag.Insert(directionTag, "outbound"))
tagsWithDir = append(tagsWithDir, tags...)
stats.RecordWithTags(ctx, tagsWithDir, blockedResources.M(int64(1))) stats.RecordWithTags(ctx, tagsWithDir, blockedResources.M(int64(1)))
} }