From e1701c718986eae1a6709159409fc77446ca122e Mon Sep 17 00:00:00 2001 From: vyzo Date: Fri, 14 Jan 2022 12:25:55 +0200 Subject: [PATCH] rename txn to span --- scope.go | 16 ++++++++-------- scope_test.go | 22 +++++++++++----------- 2 files changed, 19 insertions(+), 19 deletions(-) diff --git a/scope.go b/scope.go index 9d838bb..48e2611 100644 --- a/scope.go +++ b/scope.go @@ -21,10 +21,10 @@ type resources struct { // A resourceScope can be a DAG, where a downstream node is not allowed to outlive an upstream node // (ie cannot call Done in the upstream node before the downstream node) and account for resources // using a linearized parent set. -// A resourceScope can be a txn scope, where it has a specific owner; txn scopes create a tree rooted +// A resourceScope can be a span scope, where it has a specific owner; span scopes create a tree rooted // at the owner (which can be a DAG scope) and can outlive their parents -- this is important because -// txn scopes are the main *user* interface for memory management, and the user may call -// Done in a txn scope after the system has closed the root of the txn tree in some background +// span scopes are the main *user* interface for memory management, and the user may call +// Done in a span scope after the system has closed the root of the span tree in some background // goroutine. // If we didn't make this distinction we would have a double release problem in that case. type resourceScope struct { @@ -33,14 +33,14 @@ type resourceScope struct { refCnt int rc resources - owner *resourceScope // set in transaction scopes, which define trees + owner *resourceScope // set in span scopes, which define trees constraints []*resourceScope // set in DAG scopes, it's the linearized parent set name string // for debugging purposes } var _ network.ResourceScope = (*resourceScope)(nil) -var _ network.TransactionalScope = (*resourceScope)(nil) +var _ network.ResourceScopeSpan = (*resourceScope)(nil) func newResourceScope(limit Limit, constraints []*resourceScope, name string) *resourceScope { for _, cst := range constraints { @@ -53,7 +53,7 @@ func newResourceScope(limit Limit, constraints []*resourceScope, name string) *r } } -func newTxnResourceScope(owner *resourceScope) *resourceScope { +func newResourceScopeSpan(owner *resourceScope) *resourceScope { return &resourceScope{ rc: resources{limit: owner.rc.limit}, owner: owner, @@ -539,7 +539,7 @@ func (s *resourceScope) ReleaseResources(st network.ScopeStat) { } } -func (s *resourceScope) BeginTransaction() (network.TransactionalScope, error) { +func (s *resourceScope) BeginSpan() (network.ResourceScopeSpan, error) { s.Lock() defer s.Unlock() @@ -548,7 +548,7 @@ func (s *resourceScope) BeginTransaction() (network.TransactionalScope, error) { } s.refCnt++ - return newTxnResourceScope(s), nil + return newResourceScopeSpan(s), nil } func (s *resourceScope) Done() { diff --git a/scope_test.go b/scope_test.go index 94766e3..2214a67 100644 --- a/scope_test.go +++ b/scope_test.go @@ -368,7 +368,7 @@ func TestResourceScopeTxnBasic(t *testing.T) { nil, "test", ) - txn, err := s.BeginTransaction() + txn, err := s.BeginSpan() if err != nil { t.Fatal(err) } @@ -403,12 +403,12 @@ func TestResourceScopeTxnZombie(t *testing.T) { nil, "test", ) - txn1, err := s.BeginTransaction() + txn1, err := s.BeginSpan() if err != nil { t.Fatal(err) } - txn2, err := txn1.BeginTransaction() + txn2, err := txn1.BeginSpan() if err != nil { t.Fatal(err) } @@ -445,27 +445,27 @@ func TestResourceScopeTxnTree(t *testing.T) { nil, "test", ) - txn1, err := s.BeginTransaction() + txn1, err := s.BeginSpan() if err != nil { t.Fatal(err) } - txn2, err := txn1.BeginTransaction() + txn2, err := txn1.BeginSpan() if err != nil { t.Fatal(err) } - txn3, err := txn1.BeginTransaction() + txn3, err := txn1.BeginSpan() if err != nil { t.Fatal(err) } - txn4, err := txn2.BeginTransaction() + txn4, err := txn2.BeginSpan() if err != nil { t.Fatal(err) } - txn5, err := txn2.BeginTransaction() + txn5, err := txn2.BeginSpan() if err != nil { t.Fatal(err) } @@ -1089,17 +1089,17 @@ func TestResourceScopeDAGTxn(t *testing.T) { []*resourceScope{s3, s1}, "test", ) - txn4, err := s4.BeginTransaction() + txn4, err := s4.BeginSpan() if err != nil { t.Fatal(err) } - txn5, err := s5.BeginTransaction() + txn5, err := s5.BeginSpan() if err != nil { t.Fatal(err) } - txn6, err := s6.BeginTransaction() + txn6, err := s6.BeginSpan() if err != nil { t.Fatal(err) }