MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 3 callersFunctionemptyHash
returns tmhash(<empty>)
crypto/merkle/hash.go:16
↓ 3 callersFunctionencodeKey
(prefix int64, height int64)
internal/state/store.go:38
↓ 3 callersFunctionencodeVarintEvents
(dAtA []byte, offset int, v uint64)
proto/tendermint/types/events.pb.go:147
↓ 3 callersFunctionencodeVarintKeys
(dAtA []byte, offset int, v uint64)
proto/tendermint/crypto/keys.pb.go:490
↓ 3 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/rpc/grpc/types.pb.go:470
↓ 3 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
rpc/grpc/types.pb.go:470
↓ 3 callersFunctionensureFire
(t *testing.T, ch <-chan struct{}, timeoutMS int)
internal/mempool/v0/clist_mempool_test.go:69
↓ 3 callersFunctionensureNewBlockHeader
(blockCh <-chan tmpubsub.Message, height int64, blockHash tmbytes.HexBytes)
internal/consensus/common_test.go:612
↓ 3 callersFunctionensureNewEvent
(ch <-chan tmpubsub.Message, height int64, round int32, timeout time.Duration, errorMessage string)
internal/consensus/common_test.go:527
↓ 3 callersFunctionensureNoNewEventOnChannel
(ch <-chan tmpubsub.Message)
internal/consensus/common_test.go:498
↓ 3 callersMethodensurePeer
(peerID types.NodeID)
internal/blocksync/v2/scheduler.go:218
↓ 3 callersMethodenterPropose
Enter (CreateEmptyBlocks): from enterNewRound(height,round) Enter (CreateEmptyBlocks, CreateEmptyBlocksInterval > 0 ): after enterNewRound(height,ro
internal/consensus/state.go:1119
↓ 3 callersFunctionequalBehaviors
equalBehaviors returns true if a and b contain the same PeerBehaviors with the same freequencies and otherwise false.
internal/blocksync/v2/internal/behavior/reporter_test.go:43
↓ 3 callersFunctionevMapKey
(ev types.Evidence)
internal/evidence/pool.go:609
↓ 3 callersFunctionexecComposeVerbose
execComposeVerbose runs a Docker Compose command for a testnet and displays its output.
test/e2e/runner/exec.go:41
↓ 3 callersFunctionexecDocker
execDocker runs a Docker command.
test/e2e/runner/exec.go:48
↓ 3 callersFunctionexecuteValSetErrTestCase
(t *testing.T, idx int, tt valSetErrTestCase)
types/validator_set_test.go:830
↓ 3 callersFunctionfilePathForIndex
(headPath string, index int, maxIndex int)
internal/libs/autofile/group.go:413
↓ 3 callersMethodfindUpgradeCandidate
findUpgradeCandidate looks for a lower-scored peer that we could evict to make room for the given peer. Returns an empty ID if none is found. If the p
internal/p2p/peermanager.go:1235
↓ 3 callersFunctiongenPrivKey
genPrivKey generates a new secp256k1 private key using the provided reader.
crypto/secp256k1/secp256k1.go:73
↓ 3 callersFunctiongenValSet
(size int)
internal/state/helpers_test.go:130
↓ 3 callersFunctiongenerateNode
generateNode randomly generates a node, with some constraints to avoid generating invalid configurations. We do not set Seeds or PersistentPeers here,
test/e2e/generator/generate.go:386
↓ 3 callersFunctiongetAllSeenCommits
(ctx context.Context, db dbm.DB)
scripts/scmigrate/migrate.go:76
↓ 3 callersMethodgetIndex
(i int)
libs/bits/bit_array.go:58
↓ 3 callersMethodgetPeerID
()
internal/blocksync/v0/pool.go:595
↓ 3 callersFunctiongetSignedHeader
(blockStore BlockStore, height int64)
internal/evidence/verify.go:254
↓ 3 callersMethodgetVoteBitArray
(height int64, round int32, votesType tmproto.SignedMsgType)
internal/consensus/peer_state.go:203
↓ 3 callersFunctiongroupKeyFor
(na *p2p.NetAddress, routabilityStrict bool)
internal/p2p/pex/addrbook.go:894
↓ 3 callersMethodinsertTx
(wtx *WrappedTx)
internal/mempool/v1/mempool.go:599
↓ 3 callersFunctioniotest
(writer protoio.WriteCloser, reader protoio.ReadCloser)
internal/libs/protoio/io_test.go:47
↓ 3 callersMethodisCommitted
IsCommitted returns true if we have already seen this exact evidence and it is already marked as committed.
internal/evidence/pool.go:281
↓ 3 callersMethodisConnected
()
privval/signer_endpoint.go:145
↓ 3 callersFunctionjsonParamsToArgs
raw is unparsed json (from json.RawMessage) encoding either a map or an array. Example: rpcFunc.args = [rpctypes.Context string] rpcFunc.argNames = [
rpc/jsonrpc/server/http_json_handler.go:224
↓ 3 callersFunctionkeyPending
(evidence types.Evidence)
internal/evidence/pool.go:630
↓ 3 callersFunctionlastStoredHeightFor
(height, lastHeightChanged int64)
internal/state/store.go:529
↓ 3 callersMethodlatestUncommittedHeight
()
internal/rpc/core/env.go:209
↓ 3 callersFunctionloadTestnet
loadTestnet loads the testnet based on the E2E_MANIFEST envvar.
test/e2e/tests/e2e_test.go:71
↓ 3 callersFunctionmBlockResponse
(peerID types.NodeID, height int64)
internal/blocksync/v2/processor_test.go:50
↓ 3 callersFunctionmakeAndCommitGoodBlock
( state sm.State, height int64, lastCommit *types.Commit, proposerAddr []byte, blockExec *sm.BlockExecuto
internal/state/helpers_test.go:37
↓ 3 callersFunctionmakeApplyBlock
( t *testing.T, kvstore types.Application, heightInt int, diff []types.ValidatorUpdate, txs ...[]byte)
abci/example/kvstore/kvstore_test.go:190
↓ 3 callersFunctionmakeBlockID
(hash []byte, partSetSize uint32, partSetHash []byte)
test/e2e/runner/evidence.go:276
↓ 3 callersFunctionmakeCommit
(height int64, valAddr []byte)
internal/evidence/pool_test.go:455
↓ 3 callersFunctionmakeHeaderRandom
()
types/evidence_test.go:259
↓ 3 callersFunctionmakeSeedNode
makeSeedNode returns a new seed node, containing only p2p, pex reactor
node/node.go:533
↓ 3 callersFunctionmakeState
makeState takes test parameters and creates a specific processor state.
internal/blocksync/v2/processor_test.go:34
↓ 3 callersFunctionmakeStateAndBlockStore
(logger log.Logger)
internal/store/store_test.go:48
↓ 3 callersFunctionmakeTempFile
(name, content string)
tools/tm-signer-harness/internal/test_harness_test.go:189
↓ 3 callersFunctionmakeVoteHR
(t *testing.T, height int64, valIndex, round int32, privVals []types.PrivValidator)
internal/consensus/types/height_vote_set_test.go:64
↓ 3 callersFunctionmarshalSize
(size uint16)
light/store/db/db.go:312
↓ 3 callersFunctionmockLB
(t *testing.T, height int64, time time.Time, lastBlockID types.BlockID, currentVals *types.ValidatorSet, curr
internal/statesync/reactor_test.go:770
↓ 3 callersMethodname
name looks up the name of a type, or empty if not registered. Unwraps pointers as necessary.
libs/json/types.go:98
↓ 3 callersFunctionnewAppConnTest
(appConn abciclient.Client)
internal/proxy/app_conn_test.go:29
↓ 3 callersFunctionnewMConnConnection
newMConnConnection creates a new mConnConnection.
internal/p2p/transport_mconn.go:239
↓ 3 callersFunctionnewProviderBenchmarkImpl
(headers map[int64]*types.SignedHeader, vals map[int64]*types.ValidatorSet)
light/client_benchmark_test.go:31
↓ 3 callersFunctionnewScheduler
(initHeight int64, startTime time.Time)
internal/blocksync/v2/scheduler.go:199
↓ 3 callersFunctionnewTestApp
()
internal/state/helpers_test.go:31
↓ 3 callersFunctionnewValidatorSchedule
(testnet e2e.Testnet)
test/e2e/tests/validator_test.go:138
↓ 3 callersFunctionnewWDRRScheduler
( logger log.Logger, m *Metrics, chDescs []ChannelDescriptor, enqueueBuf, dequeueBuf, capacity uint, )
internal/p2p/wdrr_queue.go:57
↓ 3 callersMethodnext
()
internal/blocksync/v2/routine.go:140
↓ 3 callersMethodnotifyTxsAvailable
()
internal/mempool/v0/clist_mempool.go:513
↓ 3 callersMethodnotifyTxsAvailable
()
internal/mempool/v1/mempool.go:761
↓ 3 callersMethodnumChunksReturned
()
internal/statesync/chunks.go:359
↓ 3 callersFunctionnumElems
(bits int)
libs/bits/bit_array.go:471
↓ 3 callersMethodopenFile
IF index > gr.Group.maxIndex, returns io.EOF CONTRACT: caller should hold gr.mtx
internal/libs/autofile/group.go:500
↓ 3 callersFunctionprefixKey
(key []byte)
abci/example/kvstore/kvstore.go:58
↓ 3 callersMethodproviderShouldBeRemoved
providerShouldBeRemoved analyzes the nature of the error and whether the provider should be removed from the light clients set
light/client.go:1130
↓ 3 callersMethodpruneRange
pruneRange is a generic function for deleting a range of values based on the lowest height up to but excluding retainHeight. For each key/value pair,
internal/store/store.go:360
↓ 3 callersFunctionptrUint64
(i uint64)
test/e2e/generator/generate.go:463
↓ 3 callersMethodpurgePeer
purgePeer moves all unprocessed blocks from the queue
internal/blocksync/v2/processor.go:112
↓ 3 callersFunctionqueueErr
(e error)
abci/client/socket_client.go:502
↓ 3 callersMethodqueueRequest
---------------------------------------- queueRequest enqueues req onto the queue. The request can break early if the the context is canceled. If the
abci/client/socket_client.go:460
↓ 3 callersFunctionrandByte
()
internal/p2p/conn_tracker_test.go:13
↓ 3 callersFunctionrandBytes
(t *testing.T)
rpc/jsonrpc/jsonrpc_test.go:387
↓ 3 callersFunctionrandInt
(low, high int)
types/tx_test.go:24
↓ 3 callersFunctionrandModuloValidator
(totalVotingPower int64)
types/validator_set_test.go:377
↓ 3 callersFunctionrandPort
()
rpc/test/helpers.go:55
↓ 3 callersFunctionrandValidator
(randPower bool, minPower int64)
types/validator_set_test.go:385
↓ 3 callersMethodrandomSleep
sleep for interval plus some random amount of ms on [0, dialRandomizerIntervalMilliseconds]
internal/p2p/switch.go:598
↓ 3 callersMethodreadGroupInfo
Index includes the head. CONTRACT: caller should have called g.mtx.Lock
internal/libs/autofile/group.go:357
↓ 3 callersFunctionreadLots
(t *testing.T, wg *sync.WaitGroup, conn io.Reader, n int)
internal/p2p/conn/secret_connection_test.go:298
↓ 3 callersMethodreadReplayMessage
Functionality to replay blocks and messages on recovery from a crash. There are two general failure scenarios: 1. failure during consensus 2. failure
internal/consensus/replay.go:39
↓ 3 callersMethodreconnectToPeer
reconnectToPeer tries to reconnect to the addr, first repeatedly with a fixed interval, then with exponential backoff. If no success after all that, i
internal/p2p/switch.go:434
↓ 3 callersMethodremoveFromBucket
(ka *knownAddress, bucketType byte, bucketIdx int)
internal/p2p/pex/addrbook.go:597
↓ 3 callersMethodremoveSnapshot
removeSnapshot removes a snapshot. The caller must hold the mutex lock.
internal/statesync/snapshots.go:276
↓ 3 callersMethodremoveTx
Called from: - Update (lock held) if tx was committed - resCbRecheck (lock not held) if tx was invalidated
internal/mempool/v0/clist_mempool.go:334
↓ 3 callersMethodremoveWitnesses
NOTE: requires a providerMutex lock
light/client.go:961
↓ 3 callersMethodreplayBlock
ApplyBlock on the proxyApp with the last block.
internal/consensus/replay.go:508
↓ 3 callersMethodsaveToDB
Saves the history data for all peers to the store DB
internal/p2p/trust/store.go:186
↓ 3 callersMethodsaveToFile
(filePath string)
internal/p2p/pex/file.go:18
↓ 3 callersMethodsendResponse
( t *testing.T, fromNode, toNode int, withNodes []int, v2 bool, )
internal/p2p/pex/reactor_test.go:645
↓ 3 callersMethodsendSomePacketMsgs
Returns true if messages from channels were exhausted. Blocks in accordance to .sendMonitor throttling.
internal/p2p/conn/connection.go:513
↓ 3 callersFunctionsetupNode
()
test/e2e/node/main.go:263
↓ 3 callersFunctionsetupStateStore
(t *testing.T, height int64)
internal/state/rollback_test.go:113
↓ 3 callersMethodshiftByAvgProposerPriority
()
types/validator_set.go:226
↓ 3 callersFunctionshouldBatchVerify
(vals *ValidatorSet, commit *Commit)
types/validation.go:14
↓ 3 callersMethodsignVote
CONTRACT: cs.privValidator is not nil.
internal/consensus/state.go:2224
↓ 3 callersFunctionsignVotes
( cfg *config.Config, voteType tmproto.SignedMsgType, hash []byte, header types.PartSetHeader, vss ...*va
internal/consensus/common_test.go:163
↓ 3 callersFunctionsimplePeer
(t *testing.T, id string)
internal/p2p/shim_test.go:81
↓ 3 callersFunctionskipValidator
(dAtA []byte)
proto/tendermint/types/validator.pb.go:870
↓ 3 callersFunctionsoapRequest
(url, function, message, domain string)
internal/p2p/upnp/upnp.go:260
← previousnext →1,801–1,900 of 9,600, ranked by callers