libp2p/go-libp2p-resource-manager
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-resource-manager.git synced 2026-08-22 19:43:28 +08:00
Code Issues Projects Releases Wiki Activity
Files
55dfd14ea601a8b6e915ff6f3c8ec6c6c7b1dbc7
go-libp2p-resource-manager/scope_test.go
vyzo 55dfd14ea6 more resource scope tests, fix bug
2022-01-17 12:33:01 +02:00

1186 lines
38 KiB
Go
Raw Blame History

package rcmgr
import (
"testing"
"github.com/libp2p/go-libp2p-core/network"
)
func checkResources(t *testing.T, rc *Resources, st network.ScopeStat) {
t.Helper()
if rc.nconnsIn != st.NumConnsInbound {
t.Fatalf("expected %d inbound conns, got %d", st.NumConnsInbound, rc.nconnsIn)
}
if rc.nconnsOut != st.NumConnsOutbound {
t.Fatalf("expected %d outbound conns, got %d", st.NumConnsOutbound, rc.nconnsOut)
}
if rc.nstreamsIn != st.NumStreamsInbound {
t.Fatalf("expected %d inbound streams, got %d", st.NumStreamsInbound, rc.nstreamsIn)
}
if rc.nstreamsOut != st.NumStreamsOutbound {
t.Fatalf("expected %d outbound streams, got %d", st.NumStreamsOutbound, rc.nstreamsOut)
}
if rc.nfd != st.NumFD {
t.Fatalf("expected %d file descriptors, got %d", st.NumFD, rc.nfd)
}
if rc.memory != st.Memory {
t.Fatalf("expected %d reserved bytes of memory, got %d", st.Memory, rc.memory)
}
}
func TestResources(t *testing.T) {
rc := NewResources(&StaticLimit{
Memory: 4096,
StreamsInbound: 1,
StreamsOutbound: 1,
ConnsInbound: 1,
ConnsOutbound: 1,
FD: 1,
})
checkResources(t, rc, network.ScopeStat{})
if err := rc.checkMemory(1024); err != nil {
t.Fatal(err)
}
if err := rc.checkMemory(4096); err != nil {
t.Fatal(err)
}
if err := rc.checkMemory(8192); err == nil {
t.Fatal("expected memory check to fail")
}
if err := rc.reserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, rc, network.ScopeStat{Memory: 1024})
if err := rc.reserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, rc, network.ScopeStat{Memory: 2048})
if err := rc.reserveMemory(4096); err == nil {
t.Fatal("expected memory reservation to fail")
}
checkResources(t, rc, network.ScopeStat{Memory: 2048})
rc.releaseMemory(1024)
checkResources(t, rc, network.ScopeStat{Memory: 1024})
if err := rc.reserveMemory(2048); err != nil {
t.Fatal(err)
}
checkResources(t, rc, network.ScopeStat{Memory: 3072})
buf, key, err := rc.getBuffer(1024)
if err != nil {
t.Fatal(err)
}
if len(buf) != 1024 {
t.Fatalf("expected buffer of length %d, got %d", 1024, len(buf))
}
if len(rc.buffers) != 1 {
t.Fatal("expected buffer map to have one buffer")
}
checkResources(t, rc, network.ScopeStat{Memory: 4096})
rc.releaseMemory(3072)
checkResources(t, rc, network.ScopeStat{Memory: 1024})
buf[0] = 1
buf[1] = 2
buf[2] = 3
buf, err = rc.growBuffer(key, 2048)
if err != nil {
t.Fatal(err)
}
if len(buf) != 2048 {
t.Fatalf("expected buffer of length %d, got %d", 2048, len(buf))
}
if buf[0] != 1 || buf[1] != 2 || buf[2] != 3 {
t.Fatal("buffer was not properly copied")
}
if len(rc.buffers) != 1 {
t.Fatal("expected buffer map to have one buffer")
}
checkResources(t, rc, network.ScopeStat{Memory: 2048})
rc.releaseBuffer(key)
if len(rc.buffers) != 0 {
t.Fatal("expected buffer map to be empty")
}
checkResources(t, rc, network.ScopeStat{})
if err := rc.addStream(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, rc, network.ScopeStat{NumStreamsInbound: 1})
if err := rc.addStream(network.DirInbound); err == nil {
t.Fatal("expected addStream to fail")
}
checkResources(t, rc, network.ScopeStat{NumStreamsInbound: 1})
rc.removeStream(network.DirInbound)
checkResources(t, rc, network.ScopeStat{})
if err := rc.addStream(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, rc, network.ScopeStat{NumStreamsOutbound: 1})
if err := rc.addStream(network.DirOutbound); err == nil {
t.Fatal("expected addStream to fail")
}
checkResources(t, rc, network.ScopeStat{NumStreamsOutbound: 1})
rc.removeStream(network.DirOutbound)
checkResources(t, rc, network.ScopeStat{})
if err := rc.addConn(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, rc, network.ScopeStat{NumConnsInbound: 1})
if err := rc.addConn(network.DirInbound); err == nil {
t.Fatal("expected addConn to fail")
}
checkResources(t, rc, network.ScopeStat{NumConnsInbound: 1})
rc.removeConn(network.DirInbound)
checkResources(t, rc, network.ScopeStat{})
if err := rc.addConn(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, rc, network.ScopeStat{NumConnsOutbound: 1})
if err := rc.addConn(network.DirOutbound); err == nil {
t.Fatal("expected addConn to fail")
}
checkResources(t, rc, network.ScopeStat{NumConnsOutbound: 1})
rc.removeConn(network.DirOutbound)
checkResources(t, rc, network.ScopeStat{})
if err := rc.addFD(1); err != nil {
t.Fatal(err)
}
checkResources(t, rc, network.ScopeStat{NumFD: 1})
if err := rc.addFD(1); err == nil {
t.Fatal("expected addFD to fail")
}
checkResources(t, rc, network.ScopeStat{NumFD: 1})
rc.removeFD(1)
checkResources(t, rc, network.ScopeStat{})
}
func TestResourceScopeSimple(t *testing.T) {
s := NewResourceScope(
&StaticLimit{
Memory: 4096,
StreamsInbound: 1,
StreamsOutbound: 1,
ConnsInbound: 1,
ConnsOutbound: 1,
FD: 1,
},
nil,
)
s.IncRef()
if s.refCnt != 1 {
t.Fatal("expected refcnt of 1")
}
s.DecRef()
if s.refCnt != 0 {
t.Fatal("expected refcnt of 0")
}
testResourceScopeBasic(t, s)
testResourceScopeBuffer(t, s)
}
func testResourceScopeBasic(t *testing.T, s *ResourceScope) {
if err := s.ReserveMemory(2048); err != nil {
t.Fatal(err)
}
checkResources(t, s.rc, network.ScopeStat{Memory: 2048})
if err := s.ReserveMemory(2048); err != nil {
t.Fatal(err)
}
checkResources(t, s.rc, network.ScopeStat{Memory: 4096})
if err := s.ReserveMemory(1024); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
checkResources(t, s.rc, network.ScopeStat{Memory: 4096})
s.ReleaseMemory(4096)
checkResources(t, s.rc, network.ScopeStat{})
if err := s.AddStream(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, s.rc, network.ScopeStat{NumStreamsInbound: 1})
if err := s.AddStream(network.DirInbound); err == nil {
t.Fatal("expected AddStream to fail")
}
checkResources(t, s.rc, network.ScopeStat{NumStreamsInbound: 1})
s.RemoveStream(network.DirInbound)
checkResources(t, s.rc, network.ScopeStat{})
if err := s.AddStream(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, s.rc, network.ScopeStat{NumStreamsOutbound: 1})
if err := s.AddStream(network.DirOutbound); err == nil {
t.Fatal("expected AddStream to fail")
}
checkResources(t, s.rc, network.ScopeStat{NumStreamsOutbound: 1})
s.RemoveStream(network.DirOutbound)
checkResources(t, s.rc, network.ScopeStat{})
if err := s.AddConn(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, s.rc, network.ScopeStat{NumConnsInbound: 1})
if err := s.AddConn(network.DirInbound); err == nil {
t.Fatal("expected AddConn to fail")
}
checkResources(t, s.rc, network.ScopeStat{NumConnsInbound: 1})
s.RemoveConn(network.DirInbound)
checkResources(t, s.rc, network.ScopeStat{})
if err := s.AddConn(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, s.rc, network.ScopeStat{NumConnsOutbound: 1})
if err := s.AddConn(network.DirOutbound); err == nil {
t.Fatal("expected AddConn to fail")
}
checkResources(t, s.rc, network.ScopeStat{NumConnsOutbound: 1})
s.RemoveConn(network.DirOutbound)
checkResources(t, s.rc, network.ScopeStat{})
if err := s.AddFD(1); err != nil {
t.Fatal(err)
}
checkResources(t, s.rc, network.ScopeStat{NumFD: 1})
if err := s.AddFD(1); err == nil {
t.Fatal("expected AddFD to fail")
}
checkResources(t, s.rc, network.ScopeStat{NumFD: 1})
s.RemoveFD(1)
checkResources(t, s.rc, network.ScopeStat{})
}
func testResourceScopeBuffer(t *testing.T, s *ResourceScope) {
buf, err := s.GetBuffer(2048)
if err != nil {
t.Fatal(err)
}
if len(buf.Data()) != 2048 {
t.Fatalf("expected buffer of length %d but got %d", 2048, len(buf.Data()))
}
if len(s.rc.buffers) != 1 {
t.Fatalf("expected %d buffers to be tracked but got %d", 1, len(s.rc.buffers))
}
if err = buf.Grow(4096); err != nil {
t.Fatal(err)
}
if len(buf.Data()) != 4096 {
t.Fatalf("expected buffer of length %d but got %d", 4096, len(buf.Data()))
}
if len(s.rc.buffers) != 1 {
t.Fatalf("expected %d buffers to be tracked but got %d", 1, len(s.rc.buffers))
}
if err = buf.Grow(8192); err == nil {
t.Fatal("expected grow to fail")
}
if len(buf.Data()) != 4096 {
t.Fatalf("expected buffer of length %d but got %d", 4096, len(buf.Data()))
}
if len(s.rc.buffers) != 1 {
t.Fatalf("expected %d buffers to be tracked but got %d", 1, len(s.rc.buffers))
}
buf.Release()
if len(buf.Data()) != 0 {
t.Fatalf("expected buffer of length %d but got %d", 0, len(buf.Data()))
}
if len(s.rc.buffers) != 0 {
t.Fatalf("expected %d buffers to be tracked but got %d", 0, len(s.rc.buffers))
}
buf1, err := s.GetBuffer(2048)
if err != nil {
t.Fatal(err)
}
buf2, err := s.GetBuffer(2048)
if err != nil {
t.Fatal(err)
}
if _, err := s.GetBuffer(2048); err == nil {
t.Fatal("expected GetBuffer to fail")
}
if len(s.rc.buffers) != 2 {
t.Fatalf("expected %d buffers to be tracked but got %d", 2, len(s.rc.buffers))
}
buf1.Release()
buf3, err := s.GetBuffer(2048)
if err != nil {
t.Fatal(err)
}
if len(s.rc.buffers) != 2 {
t.Fatalf("expected %d buffers to be tracked but got %d", 2, len(s.rc.buffers))
}
buf2.Release()
buf3.Release()
if len(s.rc.buffers) != 0 {
t.Fatalf("expected %d buffers to be tracked but got %d", 0, len(s.rc.buffers))
}
}
func TestResourceScopeTxnBasic(t *testing.T) {
s := NewResourceScope(
&StaticLimit{
Memory: 4096,
StreamsInbound: 1,
StreamsOutbound: 1,
ConnsInbound: 1,
ConnsOutbound: 1,
FD: 1,
},
nil,
)
txn, err := s.BeginTxn()
if err != nil {
t.Fatal(err)
}
testResourceScopeBasic(t, txn.(*ResourceScope))
checkResources(t, s.rc, network.ScopeStat{})
testResourceScopeBuffer(t, txn.(*ResourceScope))
checkResources(t, s.rc, network.ScopeStat{})
// check constraint propagation
if err := txn.ReserveMemory(4096); err != nil {
t.Fatal(err)
}
checkResources(t, txn.(*ResourceScope).rc, network.ScopeStat{Memory: 4096})
checkResources(t, s.rc, network.ScopeStat{Memory: 4096})
txn.Done()
checkResources(t, s.rc, network.ScopeStat{})
txn.Done() // idempotent
checkResources(t, s.rc, network.ScopeStat{})
}
func TestResourceScopeTxnZombie(t *testing.T) {
s := NewResourceScope(
&StaticLimit{
Memory: 4096,
StreamsInbound: 1,
StreamsOutbound: 1,
ConnsInbound: 1,
ConnsOutbound: 1,
FD: 1,
},
nil,
)
txn1, err := s.BeginTxn()
if err != nil {
t.Fatal(err)
}
txn2, err := txn1.BeginTxn()
if err != nil {
t.Fatal(err)
}
if err := txn2.ReserveMemory(4096); err != nil {
t.Fatal(err)
}
checkResources(t, txn2.(*ResourceScope).rc, network.ScopeStat{Memory: 4096})
checkResources(t, txn1.(*ResourceScope).rc, network.ScopeStat{Memory: 4096})
checkResources(t, s.rc, network.ScopeStat{Memory: 4096})
txn1.Done()
checkResources(t, s.rc, network.ScopeStat{})
if err := txn2.ReserveMemory(4096); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
txn2.Done()
checkResources(t, s.rc, network.ScopeStat{})
}
func TestResourceScopeTxnTree(t *testing.T) {
s := NewResourceScope(
&StaticLimit{
Memory: 4096,
StreamsInbound: 1,
StreamsOutbound: 1,
ConnsInbound: 1,
ConnsOutbound: 1,
FD: 1,
},
nil,
)
txn1, err := s.BeginTxn()
if err != nil {
t.Fatal(err)
}
txn2, err := txn1.BeginTxn()
if err != nil {
t.Fatal(err)
}
txn3, err := txn1.BeginTxn()
if err != nil {
t.Fatal(err)
}
txn4, err := txn2.BeginTxn()
if err != nil {
t.Fatal(err)
}
txn5, err := txn2.BeginTxn()
if err != nil {
t.Fatal(err)
}
if err := txn3.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, txn3.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn1.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, s.rc, network.ScopeStat{Memory: 1024})
if err := txn4.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, txn4.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn3.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn2.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn1.(*ResourceScope).rc, network.ScopeStat{Memory: 2048})
checkResources(t, s.rc, network.ScopeStat{Memory: 2048})
if err := txn5.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, txn5.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn4.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn3.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn2.(*ResourceScope).rc, network.ScopeStat{Memory: 2048})
checkResources(t, txn1.(*ResourceScope).rc, network.ScopeStat{Memory: 3072})
checkResources(t, s.rc, network.ScopeStat{Memory: 3072})
if err := txn1.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, txn5.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn4.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn3.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn2.(*ResourceScope).rc, network.ScopeStat{Memory: 2048})
checkResources(t, txn1.(*ResourceScope).rc, network.ScopeStat{Memory: 4096})
checkResources(t, s.rc, network.ScopeStat{Memory: 4096})
if err := txn5.ReserveMemory(1024); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
if err := txn4.ReserveMemory(1024); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
if err := txn3.ReserveMemory(1024); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
if err := txn2.ReserveMemory(1024); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
checkResources(t, txn5.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn4.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn3.(*ResourceScope).rc, network.ScopeStat{Memory: 1024})
checkResources(t, txn2.(*ResourceScope).rc, network.ScopeStat{Memory: 2048})
checkResources(t, txn1.(*ResourceScope).rc, network.ScopeStat{Memory: 4096})
checkResources(t, s.rc, network.ScopeStat{Memory: 4096})
txn1.Done()
checkResources(t, s.rc, network.ScopeStat{})
}
func TestResourceScopeDAG(t *testing.T) {
// A small DAG of scopes
// s1
// +---> s2
// +------------> s5
// +----
// +---> s3 +. \
// | \ -----+-> s4 (a diamond!)
// | ------/
// \
// ------> s6
s1 := NewResourceScope(
&StaticLimit{
Memory: 4096,
StreamsInbound: 4,
StreamsOutbound: 4,
ConnsInbound: 4,
ConnsOutbound: 4,
FD: 4,
},
nil,
)
s2 := NewResourceScope(
&StaticLimit{
Memory: 2048,
StreamsInbound: 2,
StreamsOutbound: 2,
ConnsInbound: 2,
ConnsOutbound: 2,
FD: 2,
},
[]*ResourceScope{s1},
)
s3 := NewResourceScope(
&StaticLimit{
Memory: 2048,
StreamsInbound: 2,
StreamsOutbound: 2,
ConnsInbound: 2,
ConnsOutbound: 2,
FD: 2,
},
[]*ResourceScope{s1},
)
s4 := NewResourceScope(
&StaticLimit{
Memory: 2048,
StreamsInbound: 2,
StreamsOutbound: 2,
ConnsInbound: 2,
ConnsOutbound: 2,
FD: 2,
},
[]*ResourceScope{s2, s3, s1},
)
s5 := NewResourceScope(
&StaticLimit{
Memory: 2048,
StreamsInbound: 2,
StreamsOutbound: 2,
ConnsInbound: 2,
ConnsOutbound: 2,
FD: 2,
},
[]*ResourceScope{s2, s1},
)
s6 := NewResourceScope(
&StaticLimit{
Memory: 2048,
StreamsInbound: 2,
StreamsOutbound: 2,
ConnsInbound: 2,
ConnsOutbound: 2,
FD: 2,
},
[]*ResourceScope{s3, s1},
)
if err := s4.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s3.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s2.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s1.rc, network.ScopeStat{Memory: 1024})
if err := s5.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s3.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s2.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s1.rc, network.ScopeStat{Memory: 2048})
if err := s6.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s3.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s2.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s1.rc, network.ScopeStat{Memory: 3072})
if err := s4.ReserveMemory(1024); err == nil {
t.Fatal("expcted ReserveMemory to fail")
}
if err := s5.ReserveMemory(1024); err == nil {
t.Fatal("expcted ReserveMemory to fail")
}
if err := s6.ReserveMemory(1024); err == nil {
t.Fatal("expcted ReserveMemory to fail")
}
checkResources(t, s6.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s3.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s2.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s1.rc, network.ScopeStat{Memory: 3072})
s4.ReleaseMemory(1024)
checkResources(t, s6.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s2.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s1.rc, network.ScopeStat{Memory: 2048})
s5.ReleaseMemory(1024)
checkResources(t, s6.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{Memory: 1024})
s6.ReleaseMemory(1024)
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{})
if err := s4.AddStream(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsInbound: 1})
if err := s5.AddStream(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsInbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsInbound: 2})
if err := s6.AddStream(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsInbound: 2})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsInbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsInbound: 3})
if err := s4.AddStream(network.DirInbound); err == nil {
t.Fatal("expected AddStream to fail")
}
if err := s5.AddStream(network.DirInbound); err == nil {
t.Fatal("expected AddStream to fail")
}
if err := s6.AddStream(network.DirInbound); err == nil {
t.Fatal("expected AddStream to fail")
}
checkResources(t, s6.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsInbound: 2})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsInbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsInbound: 3})
s4.RemoveStream(network.DirInbound)
checkResources(t, s6.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsInbound: 2})
s5.RemoveStream(network.DirInbound)
checkResources(t, s6.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsInbound: 1})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsInbound: 1})
s6.RemoveStream(network.DirInbound)
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{})
if err := s4.AddStream(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsOutbound: 1})
if err := s5.AddStream(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsOutbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsOutbound: 2})
if err := s6.AddStream(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsOutbound: 2})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsOutbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsOutbound: 3})
if err := s4.AddStream(network.DirOutbound); err == nil {
t.Fatal("expected AddStream to fail")
}
if err := s5.AddStream(network.DirOutbound); err == nil {
t.Fatal("expected AddStream to fail")
}
if err := s6.AddStream(network.DirOutbound); err == nil {
t.Fatal("expected AddStream to fail")
}
checkResources(t, s6.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsOutbound: 2})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsOutbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsOutbound: 3})
s4.RemoveStream(network.DirOutbound)
checkResources(t, s6.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsOutbound: 2})
s5.RemoveStream(network.DirOutbound)
checkResources(t, s6.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumStreamsOutbound: 1})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{NumStreamsOutbound: 1})
s6.RemoveStream(network.DirOutbound)
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{})
if err := s4.AddConn(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s1.rc, network.ScopeStat{NumConnsInbound: 1})
if err := s5.AddConn(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumConnsInbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumConnsInbound: 2})
if err := s6.AddConn(network.DirInbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumConnsInbound: 2})
checkResources(t, s2.rc, network.ScopeStat{NumConnsInbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumConnsInbound: 3})
if err := s4.AddConn(network.DirInbound); err == nil {
t.Fatal("expected AddConn to fail")
}
if err := s5.AddConn(network.DirInbound); err == nil {
t.Fatal("expected AddConn to fail")
}
if err := s6.AddConn(network.DirInbound); err == nil {
t.Fatal("expected AddConn to fail")
}
checkResources(t, s6.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumConnsInbound: 2})
checkResources(t, s2.rc, network.ScopeStat{NumConnsInbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumConnsInbound: 3})
s4.RemoveConn(network.DirInbound)
checkResources(t, s6.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s1.rc, network.ScopeStat{NumConnsInbound: 2})
s5.RemoveConn(network.DirInbound)
checkResources(t, s6.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumConnsInbound: 1})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{NumConnsInbound: 1})
s6.RemoveConn(network.DirInbound)
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{})
if err := s4.AddConn(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s1.rc, network.ScopeStat{NumConnsOutbound: 1})
if err := s5.AddConn(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumConnsOutbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumConnsOutbound: 2})
if err := s6.AddConn(network.DirOutbound); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumConnsOutbound: 2})
checkResources(t, s2.rc, network.ScopeStat{NumConnsOutbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumConnsOutbound: 3})
if err := s4.AddConn(network.DirOutbound); err == nil {
t.Fatal("expected AddConn to fail")
}
if err := s5.AddConn(network.DirOutbound); err == nil {
t.Fatal("expected AddConn to fail")
}
if err := s6.AddConn(network.DirOutbound); err == nil {
t.Fatal("expected AddConn to fail")
}
checkResources(t, s6.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s4.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s3.rc, network.ScopeStat{NumConnsOutbound: 2})
checkResources(t, s2.rc, network.ScopeStat{NumConnsOutbound: 2})
checkResources(t, s1.rc, network.ScopeStat{NumConnsOutbound: 3})
s4.RemoveConn(network.DirOutbound)
checkResources(t, s6.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s5.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s2.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s1.rc, network.ScopeStat{NumConnsOutbound: 2})
s5.RemoveConn(network.DirOutbound)
checkResources(t, s6.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumConnsOutbound: 1})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{NumConnsOutbound: 1})
s6.RemoveConn(network.DirOutbound)
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{})
if err := s4.AddFD(1); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s3.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s2.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s1.rc, network.ScopeStat{NumFD: 1})
if err := s5.AddFD(1); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s4.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s3.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s2.rc, network.ScopeStat{NumFD: 2})
checkResources(t, s1.rc, network.ScopeStat{NumFD: 2})
if err := s6.AddFD(1); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s5.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s4.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s3.rc, network.ScopeStat{NumFD: 2})
checkResources(t, s2.rc, network.ScopeStat{NumFD: 2})
checkResources(t, s1.rc, network.ScopeStat{NumFD: 3})
if err := s4.AddFD(1); err == nil {
t.Fatal("expected AddConn to fail")
}
if err := s5.AddFD(1); err == nil {
t.Fatal("expected AddConn to fail")
}
if err := s6.AddFD(1); err == nil {
t.Fatal("expected AddConn to fail")
}
checkResources(t, s6.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s5.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s4.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s3.rc, network.ScopeStat{NumFD: 2})
checkResources(t, s2.rc, network.ScopeStat{NumFD: 2})
checkResources(t, s1.rc, network.ScopeStat{NumFD: 3})
s4.RemoveFD(1)
checkResources(t, s6.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s5.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s2.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s1.rc, network.ScopeStat{NumFD: 2})
s5.RemoveFD(1)
checkResources(t, s6.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{NumFD: 1})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{NumFD: 1})
s6.RemoveFD(1)
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{})
}
func TestResourceScopeDAGTxn(t *testing.T) {
// A small DAG of scopes
// s1
// +---> s2
// +------------> s5
// +----
// +---> s3 +. \
// | \ -----+-> s4 (a diamond!)
// | ------/
// \
// ------> s6
s1 := NewResourceScope(
&StaticLimit{
Memory: 8192,
},
nil,
)
s2 := NewResourceScope(
&StaticLimit{
Memory: 4096 + 2048,
},
[]*ResourceScope{s1},
)
s3 := NewResourceScope(
&StaticLimit{
Memory: 4096 + 2048,
},
[]*ResourceScope{s1},
)
s4 := NewResourceScope(
&StaticLimit{
Memory: 4096 + 1024,
},
[]*ResourceScope{s2, s3, s1},
)
s5 := NewResourceScope(
&StaticLimit{
Memory: 4096 + 1024,
},
[]*ResourceScope{s2, s1},
)
s6 := NewResourceScope(
&StaticLimit{
Memory: 4096 + 1024,
},
[]*ResourceScope{s3, s1},
)
txn4, err := s4.BeginTxn()
if err != nil {
t.Fatal(err)
}
txn5, err := s5.BeginTxn()
if err != nil {
t.Fatal(err)
}
txn6, err := s6.BeginTxn()
if err != nil {
t.Fatal(err)
}
if err := txn4.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s3.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s2.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s1.rc, network.ScopeStat{Memory: 1024})
if err := txn5.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s3.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s2.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s1.rc, network.ScopeStat{Memory: 2048})
if err := txn6.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s3.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s2.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s1.rc, network.ScopeStat{Memory: 3072})
if err := txn4.ReserveMemory(4096); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024 + 4096})
checkResources(t, s3.rc, network.ScopeStat{Memory: 2048 + 4096})
checkResources(t, s2.rc, network.ScopeStat{Memory: 2048 + 4096})
checkResources(t, s1.rc, network.ScopeStat{Memory: 3072 + 4096})
if err := txn4.ReserveMemory(1024); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
if err := txn5.ReserveMemory(1024); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
if err := txn6.ReserveMemory(1024); err == nil {
t.Fatal("expected ReserveMemory to fail")
}
checkResources(t, s6.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{Memory: 1024 + 4096})
checkResources(t, s3.rc, network.ScopeStat{Memory: 2048 + 4096})
checkResources(t, s2.rc, network.ScopeStat{Memory: 2048 + 4096})
checkResources(t, s1.rc, network.ScopeStat{Memory: 3072 + 4096})
txn4.Done()
checkResources(t, s6.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s5.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s2.rc, network.ScopeStat{Memory: 1024})
checkResources(t, s1.rc, network.ScopeStat{Memory: 2048})
if err := txn5.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
if err := txn6.ReserveMemory(1024); err != nil {
t.Fatal(err)
}
checkResources(t, s6.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s5.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s2.rc, network.ScopeStat{Memory: 2048})
checkResources(t, s1.rc, network.ScopeStat{Memory: 4096})
txn5.Done()
txn6.Done()
checkResources(t, s6.rc, network.ScopeStat{})
checkResources(t, s5.rc, network.ScopeStat{})
checkResources(t, s4.rc, network.ScopeStat{})
checkResources(t, s3.rc, network.ScopeStat{})
checkResources(t, s2.rc, network.ScopeStat{})
checkResources(t, s1.rc, network.ScopeStat{})
}
Reference in New Issue View Git Blame Copy Permalink