-
Notifications
You must be signed in to change notification settings - Fork 8.8k
/
transaction_contexts.go
96 lines (79 loc) · 2.78 KB
/
transaction_contexts.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
/*
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package chaincode
import (
"sync"
pb "github.com/hyperledger/fabric-protos-go/peer"
commonledger "github.com/hyperledger/fabric/common/ledger"
"github.com/hyperledger/fabric/core/common/ccprovider"
"github.com/pkg/errors"
)
// TransactionContexts maintains active transaction contexts for a Handler.
type TransactionContexts struct {
mutex sync.Mutex
contexts map[string]*TransactionContext
}
// NewTransactionContexts creates a registry for active transaction contexts.
func NewTransactionContexts() *TransactionContexts {
return &TransactionContexts{
contexts: map[string]*TransactionContext{},
}
}
// contextID creates a transaction identifier that is scoped to a channel.
func contextID(channelID, txID string) string {
return channelID + txID
}
// Create creates a new TransactionContext for the specified channel and
// transaction ID. An error is returned when a transaction context has already
// been created for the specified channel and transaction ID.
func (c *TransactionContexts) Create(txParams *ccprovider.TransactionParams) (*TransactionContext, error) {
c.mutex.Lock()
defer c.mutex.Unlock()
ctxID := contextID(txParams.ChannelID, txParams.TxID)
if c.contexts[ctxID] != nil {
return nil, errors.Errorf("txid: %s(%s) exists", txParams.TxID, txParams.ChannelID)
}
txctx := &TransactionContext{
NamespaceID: txParams.NamespaceID,
ChannelID: txParams.ChannelID,
SignedProp: txParams.SignedProp,
Proposal: txParams.Proposal,
ResponseNotifier: make(chan *pb.ChaincodeMessage, 1),
TXSimulator: txParams.TXSimulator,
HistoryQueryExecutor: txParams.HistoryQueryExecutor,
CollectionStore: txParams.CollectionStore,
IsInitTransaction: txParams.IsInitTransaction,
queryIteratorMap: map[string]commonledger.ResultsIterator{},
pendingQueryResults: map[string]*PendingQueryResult{},
}
txctx.InitializeCollectionACLCache()
c.contexts[ctxID] = txctx
return txctx, nil
}
// Get retrieves the transaction context associated with the channel and
// transaction ID.
func (c *TransactionContexts) Get(channelID, txID string) *TransactionContext {
ctxID := contextID(channelID, txID)
c.mutex.Lock()
tc := c.contexts[ctxID]
c.mutex.Unlock()
return tc
}
// Delete removes the transaction context associated with the specified channel
// and transaction ID.
func (c *TransactionContexts) Delete(channelID, txID string) {
ctxID := contextID(channelID, txID)
c.mutex.Lock()
delete(c.contexts, ctxID)
c.mutex.Unlock()
}
// Close closes all query iterators assocated with the context.
func (c *TransactionContexts) Close() {
c.mutex.Lock()
defer c.mutex.Unlock()
for _, txctx := range c.contexts {
txctx.CloseQueryIterators()
}
}