MCPcopy Create free account

hub / github.com/dddengyunjie/fabric / functions

Functions19,835 in github.com/dddengyunjie/fabric

↓ 27 callersFunctionnewPushPullTestInstance
(name string, peers map[string]*pullTestInstance)
gossip/gossip/algo/pull_test.go:60
↓ 27 callersFunctionnewTestEnv
(t testing.TB, conf *Conf)
common/ledger/blkstorage/fsblkstorage/pkg_test.go:49
↓ 27 callersMethodsampleVal
(val, ledgerid string)
core/ledger/kvledger/tests/sample_data_helper.go:246
↓ 27 callersFunctiontestPath
()
common/ledger/blkstorage/fsblkstorage/pkg_test.go:36
↓ 26 callersMethodAddCallCount
()
common/metrics/metricsfakes/gauge.go:96
↓ 26 callersMethodFormat
(w io.Writer, entry zapcore.Entry, fields []zapcore.Field)
common/flogging/fabenc/encoder.go:28
↓ 26 callersMethodGetTxSimulationResults
GetTxSimulationResults returns the proto bytes of public rwset (public data + hashes of private data) and the private rwset for the transaction
core/ledger/kvledger/txmgmt/rwsetutil/rwset_builder.go:132
↓ 26 callersFunctionInitMSP
InitMSP init MSP
peer/channel/create_test.go:127
↓ 26 callersMethodMockInvoke
Invoke this chaincode, also starts and ends a transaction.
core/chaincode/shim/mockstub.go:136
↓ 26 callersMethodProcessProposal
(ctx context.Context, in *SignedProposal, opts ...grpc.CallOption)
protos/peer/peer.pb.go:127
↓ 26 callersMethodRelease
()
core/comm/throttle.go:18
↓ 26 callersMethodWithOptions
(opts ...zap.Option)
common/flogging/zap.go:100
↓ 26 callersFunctionassertBlockReception
assertBlockReception asserts that the given orderers have expected heights for the given channel--> height mapping
integration/e2e/etcdraft_reconfig_test.go:1247
↓ 26 callersFunctioncreateRWset
(t *testing.T, ccnames ...string)
core/committer/txvalidator/validator_test.go:133
↓ 26 callersFunctionnewConfigUpdateEnv
(chainID string, oldValues, newValues map[string]*common.ConfigValue)
orderer/consensus/etcdraft/chain_test.go:3984
↓ 26 callersMethodrecordInvocation
(key string, args []interface{})
core/chaincode/mock/tx_simulator.go:2052
↓ 25 callersMethodBytes
Bytes converts this key to its byte representation, if this operation is allowed.
bccsp/bccsp.go:29
↓ 25 callersMethodClone
Clone makes a copy of this TransportCredentials.
core/comm/creds.go:84
↓ 25 callersMethodConnCount
()
core/deliverservice/mocks/orderer.go:74
↓ 25 callersMethodDecodeVarint
DecodeVarint wraps the actual method and updates the position
common/ledger/util/protobuf_util.go:37
↓ 25 callersMethodHandleInvokeChaincode
Handles requests that modify ledger state
core/chaincode/handler.go:1093
↓ 25 callersMethodIsTagLegal
IsTagLegal checks the GossipMessage tags and inner type and returns an error if the tag doesn't match the type.
protos/gossip/extensions.go:244
↓ 25 callersMethodJoinChan
JoinChan makes the Gossip instance join a channel
gossip/gossip/gossip.go:69
↓ 25 callersMethodMSPID
MSPID returns the MSP ID associated with this org
common/channelconfig/api.go:26
↓ 25 callersFunctionNew
New creates a new instance of the LSCC Typically there is only one of these per peer
core/scc/lscc/lscc.go:146
↓ 25 callersFunctionNewTreeVertex
NewTreeVertex creates a new vertex with a given unique id and a given arbitrary data
common/graph/tree.go:26
↓ 25 callersMethodNextBlock
NextBlock constructs next block in sequence that includes a number of transactions - one per simulationResults
common/ledger/testutil/test_helper.go:52
↓ 25 callersMethodObserveArgsForCall
(i int)
common/metrics/metricsfakes/histogram.go:97
↓ 25 callersMethodPutState
PutState writes the specified `value` and `key` into the ledger.
core/chaincode/shim/mockstub.go:207
↓ 25 callersMethodSetNextExpectedSeek
(seq uint64)
core/deliverservice/mocks/orderer.go:86
↓ 25 callersMethodUpdateLedgerHeight
UpdateLedgerHeight updates the ledger height the peer publishes to other peers in the channel
gossip/gossip/gossip.go:49
↓ 25 callersFunctionconfigureAdapter
(adapter *gossipAdapterMock, members ...discovery.NetworkMember)
gossip/gossip/channel/channel_test.go:275
↓ 25 callersFunctiongetSignedByMSPMemberPolicy
(mspID string)
core/handlers/validation/builtin/v13/validation_logic_test.go:289
↓ 25 callersFunctiongetSignedByMSPMemberPolicy
(mspID string)
core/handlers/validation/builtin/v12/validation_logic_test.go:288
↓ 25 callersFunctionnewClusterNode
(t *testing.T)
orderer/common/cluster/deliver_test.go:261
↓ 25 callersFunctionnewCollectionStore
()
gossip/privdata/pull_test.go:68
↓ 25 callersFunctionprocessDone
(t *testing.T, done chan error, expecterr bool)
core/chaincode/shim/shim_test.go:552
↓ 24 callersMethodAddArgsForCall
(i int)
orderer/consensus/kafka/mock/metrics_gauge.go:102
↓ 24 callersMethodAddToReadSet
AddToReadSet adds a key and corresponding version to the read-set
core/ledger/kvledger/txmgmt/rwsetutil/rwset_builder.go:77
↓ 24 callersMethodCapabilities
Capabilities defines the capabilities for the application portion of this channel
core/committer/txvalidator/validator.go:55
↓ 24 callersMethodDiscover
Discover receives a signed request, and returns a response.
protos/discovery/protocol.pb.go:1403
↓ 24 callersMethodGetDataMsg
()
protos/gossip/message.pb.go:551
↓ 24 callersMethodGetOrCreate
GetOrCreate gets an existing ledger (if it exists) or creates it if it does not
common/ledger/blockledger/ledger.go:18
↓ 24 callersMethodGetStateReturnsOnCall
(i int, result1 []byte, result2 error)
token/ledger/mock/ledger_reader.go:86
↓ 24 callersMethodIsDataMsg
IsDataMsg returns whether this GossipMessage is a data message
protos/gossip/extensions.go:130
↓ 24 callersMethodKeyDeriv
KeyDeriv derives a key from k using opts. The opts argument should be appropriate for the primitive used.
bccsp/sw/internals.go:37
↓ 24 callersMethodNotify
(msg *pb.ChaincodeMessage)
core/chaincode/handler.go:529
↓ 24 callersMethodOpen
Open opens the db
core/ledger/kvledger/txmgmt/statedb/statedb.go:71
↓ 24 callersMethodReadDoc
ReadDoc method provides function to retrieve a document and its revision from the database by id
core/ledger/util/couchdb/couchdb.go:746
↓ 24 callersMethodSendBlock
(seq uint64)
core/deliverservice/mocks/orderer.go:90
↓ 24 callersMethodSetStateContext
SetStateContext sets the consensus-type migration state and context of the underlying chain.
orderer/consensus/migration/migration.go:23
↓ 24 callersMethodWithReturns
(result1 metrics.Gauge)
common/metrics/metricsfakes/gauge.go:65
↓ 24 callersMethodWriteBatch
WriteBatch writes a batch
common/ledger/util/leveldbhelper/leveldb_helper.go:147
↓ 24 callersMethodWriteBlockArgsForCall
(i int)
orderer/consensus/mocks/mock_consenter_support.go:1186
↓ 24 callersMethodWriteBlockCallCount
()
orderer/consensus/mocks/mock_consenter_support.go:1174
↓ 24 callersFunctioncreateDiscoveryInstance
(port int, id string, bootstrapPeers []string)
gossip/discovery/discovery_test.go:343
↓ 24 callersMethodelect
elect deterministically elects a node as leader
orderer/consensus/etcdraft/chain_test.go:3920
↓ 24 callersFunctionextractSimpleMsgPlainField
(source []byte)
common/tools/protolator/statically_opaque_test.go:29
↓ 24 callersMethodretryOptions
()
orderer/consensus/kafka/consenter.go:98
↓ 24 callersMethodstop
()
gossip/gossip/algo/pull_test.go:128
↓ 23 callersMethodAssertExpectations
AssertExpectations overrider the mock method for convenience
core/aclmgmt/mocks/mocks.go:43
↓ 23 callersMethodBuild
()
core/container/controller.go:26
↓ 23 callersMethodExists
Exists tells whether the ledger with given id exists
core/ledger/ledger_interface.go:41
↓ 23 callersMethodGetDBHandle
GetDBHandle returns a handle to a VersionedDB
core/ledger/kvledger/txmgmt/statedb/statedb.go:24
↓ 23 callersMethodIterator
Iterator returns an Iterator, as specified by an ab.SeekInfo message, and its starting block number
common/ledger/blockledger/ledger.go:40
↓ 23 callersMethodLen
()
discovery/client/selection.go:142
↓ 23 callersMethodStop
Stop stops the chaincode give
core/common/ccprovider/ccprovider.go:531
↓ 23 callersFunctionaliveMessage
(id int)
discovery/client/client_test.go:878
↓ 23 callersFunctionconstructVersionedKV
(ns string, key string, value []byte, version *version.Height)
core/ledger/kvledger/txmgmt/validator/statebasedval/combined_iterator_test.go:119
↓ 23 callersFunctioncreateTestKey
(i int)
core/ledger/kvledger/txmgmt/txmgr/lockbasedtxmgr/txmgr_test.go:651
↓ 23 callersFunctionnewMockEnvelope
(content string)
orderer/consensus/kafka/consenter_test.go:176
↓ 23 callersMethodvalidateAndCommitRWSet
(txRWSet *rwset.TxReadWriteSet)
core/ledger/kvledger/txmgmt/txmgr/lockbasedtxmgr/pkg_test.go:125
↓ 23 callersMethodverifyPvtState
(ns, coll, key string, expectedVal string)
core/ledger/kvledger/tests/verifier.go:55
↓ 22 callersMethodEligibleForChannel
EligibleForChannel returns whether the given member should get blocks for this channel
gossip/gossip/channel/channel.go:82
↓ 22 callersMethodExecute
Execute executes a standard chaincode invocation for a chaincode and an input
core/common/ccprovider/ccprovider.go:526
↓ 22 callersMethodGetSignedProposal
GetSignedProposal returns the SignedProposal object, which contains all data elements part of a transaction proposal.
core/chaincode/shim/interfaces.go:332
↓ 22 callersMethodInit
Init initializes the Filter with the next EndorserServer
core/handlers/auth/auth.go:18
↓ 22 callersMethodLevel
(ctx context.Context, fullMethod string)
common/grpclogging/server.go:23
↓ 22 callersMethodOpen
Open opens an already created ledger
core/ledger/ledger_interface.go:39
↓ 22 callersMethodProcessProposal
(context.Context, *SignedProposal)
protos/peer/peer.pb.go:149
↓ 22 callersMethodWarnf
(template string, args ...interface{})
core/operations/system.go:36
↓ 22 callersFunctionputCCInfo
(theLedger ledger.PeerLedger, ccname string, policy []byte, t *testing.T)
core/committer/txvalidator/validator_test.go:322
↓ 21 callersMethodAddDescendant
AddDescendant creates a new vertex who's parent is the invoker vertex, with a given id and data. Returns the new vertex
common/graph/tree.go:41
↓ 21 callersFunctionBasePort
()
integration/e2e/e2e_suite_test.go:47
↓ 21 callersMethodDiscoveredPeer
the function creates a new DiscoveredPeer from the peer and chaincodes passed as arguments
integration/nwo/network.go:1083
↓ 21 callersMethodGetContent
()
protos/gossip/message.pb.go:523
↓ 21 callersMethodGetIterator
GetIterator returns an iterator over key-value store. The iterator should be released after the use. The resultset contains all the keys that are pres
common/ledger/util/leveldbhelper/leveldb_helper.go:142
↓ 21 callersMethodGetPolicy
GetPolicy returns a policy and true if it was the policy requested, or false if it is the default policy
common/policies/policy.go:129
↓ 21 callersMethodGetStaticCollectionConfig
()
protos/common/collection.pb.go:115
↓ 21 callersMethodIsSetTo
IsSetTo returns true if the specified transaction equals flag; false otherwise.
core/ledger/util/txvalidationflags.go:58
↓ 21 callersMethodMigrationStatus
Status provides access to the consensus-type migration status of the underlying chain.
orderer/consensus/consensus.go:71
↓ 21 callersMethodNewConnection
NewConnection creates a new connection. Returns the connection, the endpoint selected, nil on success. Returns nil, "", error on failure
core/comm/producer.go:32
↓ 21 callersMethodNewGauge
NewGauge creates a new instance of a Gauge.
orderer/common/cluster/metrics.go:105
↓ 21 callersMethodNewStream
NewStream creates a new stream. It is not thread safe, and Send() or Recv() block only until the timeout expires.
orderer/common/cluster/comm.go:641
↓ 21 callersMethodOfChannel
OfChannel sets the next queries added to be in the given channel's context
discovery/client/client.go:139
↓ 21 callersMethodSetup
(requiredPeerCount int, maxPeerCount int, accessFilter privdata.Filter, orgs []string, memberOnlyRead bool)
gossip/privdata/distributor_test.go:67
↓ 21 callersMethodSize
size returns the amount of messages in the store
gossip/gossip/msgstore/msgs.go:88
↓ 21 callersMethodStoreKey
StoreKey stores the key k in this KeyStore. If this KeyStore is read only then the method will fail.
bccsp/keystore.go:33
↓ 21 callersMethodValidate
Validate implements the function of the StateBasedValidator interface
core/common/validation/statebased/validator_keylevel.go:198
↓ 21 callersMethodWriteBlock
WriteBlock commits a block to the ledger.
orderer/consensus/consensus.go:100
← previousnext →301–400 of 19,835, ranked by callers