libp2p/go-libp2p-resource-manager
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-resource-manager.git synced 2025-01-27 12:50:07 +08:00
Code Issues Projects Releases Wiki Activity

Fix usage of make to reserve capacity, not values

Browse Source
This commit is contained in:
Marco Munizaga 2022-08-11 10:52:49 -07:00
parent 2692b757e6
commit 65fb641b27
2 changed files with 25 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
obs/stats.go
View File

@ -322,14 +322,14 @@ func (r StatsTraceReporter) ConsumeEvent(evt rcmgr.TraceEvt) {
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 := make([]tag.Mutator, 3) tagsWithDir := make([]tag.Mutator, 0, 3)
tagsWithDir = append(tagsWithDir, tag.Insert(directionTag, "inbound")) tagsWithDir = append(tagsWithDir, tag.Insert(directionTag, "inbound"))
tagsWithDir = append(tagsWithDir, tags...) tagsWithDir = append(tagsWithDir, tags...)
stats.RecordWithTags(ctx, tagsWithDir[0:], blockedResources.M(int64(1))) stats.RecordWithTags(ctx, tagsWithDir[0:], blockedResources.M(int64(1)))
} }
if evt.DeltaOut != 0 { if evt.DeltaOut != 0 {
tagsWithDir := make([]tag.Mutator, 3) tagsWithDir := make([]tag.Mutator, 0, 3)
tagsWithDir = append(tagsWithDir, tag.Insert(directionTag, "outbound")) tagsWithDir = append(tagsWithDir, tag.Insert(directionTag, "outbound"))
tagsWithDir = append(tagsWithDir, tags...) tagsWithDir = append(tagsWithDir, tags...)
stats.RecordWithTags(ctx, tagsWithDir, blockedResources.M(int64(1))) stats.RecordWithTags(ctx, tagsWithDir, blockedResources.M(int64(1)))

23
obs/stats_test.go
View File

@ -2,9 +2,11 @@ package obs_test
import ( import (
"testing" "testing"
"time"
rcmgr "github.com/libp2p/go-libp2p-resource-manager" rcmgr "github.com/libp2p/go-libp2p-resource-manager"
"github.com/libp2p/go-libp2p-resource-manager/obs" "github.com/libp2p/go-libp2p-resource-manager/obs"
"go.opencensus.io/stats/view"
) )
func TestTraceReporterStartAndClose(t *testing.T) { func TestTraceReporterStartAndClose(t *testing.T) {
@ -14,3 +16,24 @@ func TestTraceReporterStartAndClose(t *testing.T) {
} }
defer rcmgr.Close() defer rcmgr.Close()
} }
func TestConsumeEvent(t *testing.T) {
evt := rcmgr.TraceEvt{
Type: rcmgr.TraceBlockAddStreamEvt,
Name: "conn-1",
DeltaOut: 1,
Time: time.Now().Format(time.RFC3339Nano),
}
err := view.Register(obs.DefaultViews...)
if err != nil {
t.Fatal(err)
}
str, err := obs.NewStatsTraceReporter()
if err != nil {
t.Fatal(err)
}
str.ConsumeEvent(evt)
}