Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/tendermint/tendermint
/ functions
Functions
9,600 in github.com/tendermint/tendermint
⨍
Functions
9,600
◇
Types & classes
1,209
↓ 2 callers
Method
handleAddNewPeer
(event bcAddNewPeer)
internal/blocksync/v2/scheduler.go:591
↓ 2 callers
Method
handleBlockProcessError
Handles an error from the processor. The processor had already cleaned the blocks from the peers included in this event. Just attempt to remove the pe
internal/blocksync/v2/scheduler.go:577
↓ 2 callers
Method
handleBlockProcessed
(event pcBlockProcessed)
internal/blocksync/v2/scheduler.go:558
↓ 2 callers
Method
handleBlockResponse
Handlers This handler gets the block, performs some validation and then passes it on to the processor.
internal/blocksync/v2/scheduler.go:527
↓ 2 callers
Function
handleConsensusParamsRequest
(t *testing.T, receiving, sending chan p2p.Envelope, closeCh chan struct{})
internal/statesync/reactor_test.go:733
↓ 2 callers
Method
handleNoBlockResponse
(event bcNoBlockResponse)
internal/blocksync/v2/scheduler.go:543
↓ 2 callers
Function
handleRequests
handleRequests is a helper function usually run in a separate go routine to imitate the expected responses of the reactor wired to the dispatcher
internal/statesync/dispatcher_test.go:267
↓ 2 callers
Method
handleResetState
(event bcResetState)
internal/blocksync/v2/scheduler.go:635
↓ 2 callers
Method
handleStatusResponse
(event bcStatusResponse)
internal/blocksync/v2/scheduler.go:668
↓ 2 callers
Method
handleTimeout
(ti timeoutInfo, rs cstypes.RoundState)
internal/consensus/state.go:955
↓ 2 callers
Method
handleTryPrunePeer
(event rTryPrunePeer)
internal/blocksync/v2/scheduler.go:608
↓ 2 callers
Method
handleTrySchedule
(event rTrySchedule)
internal/blocksync/v2/scheduler.go:647
↓ 2 callers
Method
handshakePeer
handshakePeer handshakes with a peer, validating the peer's information. If expectID is given, we check that the peer's info matches it.
internal/p2p/router.go:808
↓ 2 callers
Method
handshakePeer
( c Connection, expectPeerID types.NodeID, )
internal/p2p/switch.go:864
↓ 2 callers
Method
hasChannel
hasChannel returns true if the peer reported knowing about the given chID.
internal/p2p/peer.go:308
↓ 2 callers
Function
heightKey
(height int64)
internal/state/indexer/block/kv/util.go:34
↓ 2 callers
Function
httpParamsToArgs
Covert an http query to a list of properly typed values. To be properly decoded the arg must be a concrete type from tendermint (if its an interface).
rpc/jsonrpc/server/http_uri_handler.go:98
↓ 2 callers
Function
idFromInterface
(idInterface interface{})
rpc/jsonrpc/types/types.go:32
↓ 2 callers
Function
incrNonce
-------------------------------------------------------------------------------- Increment nonce little-endian by 1 with wraparound. Due to chacha20po
privval/secret_connection.go:457
↓ 2 callers
Function
incrNonce
-------------------------------------------------------------------------------- Increment nonce little-endian by 1 with wraparound. Due to chacha20po
internal/p2p/conn/secret_connection.go:455
↓ 2 callers
Method
indexEvents
(batch dbm.Batch, events []abci.Event, typ string, height int64)
internal/state/indexer/block/kv/kv.go:457
↓ 2 callers
Method
init
Initialize the buckets. When modifying this, don't forget to update loadFromFile()
internal/p2p/pex/addrbook.go:137
↓ 2 callers
Method
initStateProvider
(ctx context.Context, chainID string, initialHeight int64)
internal/statesync/reactor.go:1052
↓ 2 callers
Function
initializeBlockStore
initializeBlockStore creates a block storage and populates it w/ a dummy block at +height+.
internal/evidence/pool_test.go:437
↓ 2 callers
Function
innerHashOpt
(s hash.Hash, left []byte, right []byte)
crypto/merkle/hash.go:42
↓ 2 callers
Function
insertTestData
(t *testing.T, db dbm.DB, data []toMigrate)
scripts/scmigrate/migrate_test.go:63
↓ 2 callers
Function
int64ToBytes
(i int64)
internal/state/indexer/block/kv/util.go:28
↓ 2 callers
Function
intervalToHistoryOffset
Map the interval value down to an offset from the beginning of history
internal/p2p/trust/metric.go:407
↓ 2 callers
Method
invalid
(ch rune)
libs/pubsub/query/syntax/scanner.go:298
↓ 2 callers
Function
isDecimal
isDecimal reports whether buf is a non-empty sequence of Unicode decimal digits.
scripts/keymigrate/migrate.go:473
↓ 2 callers
Function
isDigit
(r rune)
libs/pubsub/query/syntax/scanner.go:302
↓ 2 callers
Method
isFull
(txSize int)
internal/mempool/v0/clist_mempool.go:358
↓ 2 callers
Function
isHex
(data []byte)
scripts/keymigrate/migrate.go:538
↓ 2 callers
Method
isNew
()
internal/p2p/pex/known_address.go:42
↓ 2 callers
Function
isTagRune
(r rune)
libs/pubsub/query/syntax/scanner.go:304
↓ 2 callers
Function
isValidatorTx
(tx []byte)
abci/example/kvstore/persistent_kvstore.go:206
↓ 2 callers
Method
is_cache_valid
Determines if the cache files have expired, or if it is still valid
networks/remote/ansible/inventory/digital_ocean.py:493
↓ 2 callers
Function
jsonStringToArg
(rt reflect.Type, arg string)
rpc/jsonrpc/server/http_uri_handler.go:134
↓ 2 callers
Function
keyCommitted
(evidence types.Evidence)
internal/evidence/pool.go:621
↓ 2 callers
Function
keyPeerInfo
keyPeerInfo generates a peerInfo database key.
internal/p2p/peermanager.go:1668
↓ 2 callers
Method
listEvidence
listEvidence retrieves lists evidence from oldest to newest within maxBytes. If maxBytes is -1, there's no cap on the size of returned evidence.
internal/evidence/pool.go:375
↓ 2 callers
Method
listen
()
light/proxy/proxy.go:87
↓ 2 callers
Method
listenForRequest
(t *testing.T, fromNode, toNode int, waitPeriod time.Duration)
internal/p2p/pex/reactor_test.go:491
↓ 2 callers
Function
listenerTestCases
(t *testing.T, timeoutAccept, timeoutReadWrite time.Duration)
privval/socket_listeners_test.go:78
↓ 2 callers
Method
load
load loads a chunk from disk, or nil if the chunk is not in the queue. The caller must hold the mutex lock.
internal/statesync/chunks.go:226
↓ 2 callers
Function
loadEventSinks
(cfg *tmcfg.Config)
cmd/tendermint/commands/reindex_event.go:84
↓ 2 callers
Function
loadFilePV
If loadState is true, we load from the stateFilePath. Otherwise, we use an empty LastSignState.
privval/file.go:202
↓ 2 callers
Function
loadPrivValidator
(cfg *config.Config)
internal/consensus/common_test.go:454
↓ 2 callers
Function
loadState
(db dbm.DB)
abci/example/kvstore/kvstore.go:30
↓ 2 callers
Function
loadStateFromDBOrGenesisDocProvider
------------------------------------------------------------------------------ loadStateFromDBOrGenesisDocProvider attempts to load the state from the
node/node.go:1162
↓ 2 callers
Method
loadWalFile
loadWalFile loads WAL data from file. It overwrites cs.wal.
internal/consensus/state.go:439
↓ 2 callers
Method
logErrAddrBook
(err error)
internal/p2p/pex/pex_reactor.go:224
↓ 2 callers
Function
makeBlockID
(hash []byte, partSetSize uint32, partSetHash []byte)
internal/state/execution_test.go:457
↓ 2 callers
Function
makeConfig
(t *testing.T, acceptDeadline, acceptRetries int)
tools/tm-signer-harness/internal/test_harness_test.go:169
↓ 2 callers
Function
makeHeaderRandom
(chainID string, height int64)
test/e2e/runner/evidence.go:253
↓ 2 callers
Function
makeMockPeerStore
(t *testing.T, peers ...peerInfo)
internal/p2p/peermanager_scoring_test.go:84
↓ 2 callers
Function
makeMockVote
(height int64, round, index int32, addr Address, blockID BlockID, time time.Time)
types/evidence.go:699
↓ 2 callers
Function
makeNode
makeNode returns a new, ready to go, Tendermint Node.
node/node.go:126
↓ 2 callers
Function
makePcBlock
makePcBlock makes an empty block.
internal/blocksync/v2/processor_test.go:29
↓ 2 callers
Function
makePeers
(numPeers int, minHeight, maxHeight int64)
internal/blocksync/v0/pool_test.go:66
↓ 2 callers
Function
makeRandomBlockID
()
test/e2e/runner/evidence.go:272
↓ 2 callers
Function
makeRandomStateFromConsensusParams
(consensusParams *types.ConsensusParams, height, lastHeightConsensusParamsChanged int64)
internal/state/helpers_test.go:246
↓ 2 callers
Function
makeRoundStepMessage
(rs *cstypes.RoundState)
internal/consensus/reactor.go:438
↓ 2 callers
Function
makeStructInfo
makeStructInfo generates structInfo for a struct as a reflect.Value.
libs/json/structs.go:54
↓ 2 callers
Function
makeVals
(valMap map[*e2e.Node]int64)
test/e2e/tests/validator_test.go:166
↓ 2 callers
Method
markPeerRequest
(peer types.NodeID)
internal/p2p/pex/reactor.go:490
↓ 2 callers
Method
markPeerResponse
(peer types.NodeID)
internal/p2p/pex/reactor.go:503
↓ 2 callers
Method
markPending
(peerID types.NodeID, height int64, time time.Time)
internal/blocksync/v2/scheduler.go:392
↓ 2 callers
Method
markProcessed
(height int64)
internal/blocksync/v2/scheduler.go:424
↓ 2 callers
Method
markReceived
CONTRACT: peer exists and in Ready state.
internal/blocksync/v2/scheduler.go:368
↓ 2 callers
Method
match
match returns all matching heights that meet a given query condition and start key. An already filtered result (filteredHeights) is provided such that
internal/state/indexer/block/kv/kv.go:326
↓ 2 callers
Method
matchRange
matchRange returns all matching block heights that match a given QueryRange and start key. An already filtered result (filteredHeights) is provided su
internal/state/indexer/block/kv/kv.go:218
↓ 2 callers
Method
matchRange
matchRange returns all matching txs by hash that meet a given queryRange and start key. An already filtered result (filteredHashes) is provided such t
internal/state/indexer/tx/kv/kv.go:394
↓ 2 callers
Function
mustParse
(path string)
scripts/condiff/condiff.go:61
↓ 2 callers
Function
mustReadFile
(t *testing.T, filePath string)
internal/libs/autofile/autofile_test.go:141
↓ 2 callers
Function
muxOnCommands
(cmd *cobra.Command, pArgs []string)
abci/cmd/abci-cli/abci-cli.go:359
↓ 2 callers
Method
needProofBlock
needProofBlock returns true on the first height (so the genesis app hash is signed right away) and where the last block (height-1) caused the app hash
internal/consensus/state.go:1102
↓ 2 callers
Function
newBlockVotes
(peerMaj23 bool, numValidators int)
types/vote_set.go:654
↓ 2 callers
Function
newLightClientAttackEvidence
newLightClientAttackEvidence determines the type of attack and then forms the evidence filling out all the fields such that it is ready to be sent to
light/detector.go:406
↓ 2 callers
Function
newLocalReqRes
(req *types.Request, res *types.Response)
abci/client/local_client.go:356
↓ 2 callers
Function
newMemoryConnection
newMemoryConnection creates a new MemoryConnection.
internal/p2p/transport_memory.go:227
↓ 2 callers
Function
newMockBlockStore
TODO: NewBlockStore(db.NewMemDB) ...
internal/consensus/replay_test.go:1186
↓ 2 callers
Function
newMockProxyApp
----------------------------------------------------------------------------- mockProxyApp uses ABCIResponses to give the right results. Useful becau
internal/consensus/replay_stubs.go:57
↓ 2 callers
Function
newNodeID
(t *testing.T, id string)
internal/p2p/pex/reactor_test.go:814
↓ 2 callers
Function
newPQScheduler
( logger log.Logger, m *Metrics, chDescs []ChannelDescriptor, enqueueBuf, dequeueBuf, capacity uint, )
internal/p2p/pqueue.go:92
↓ 2 callers
Function
newPcState
newPcState returns a pcState initialized with the last verified block enqueued
internal/blocksync/v2/processor.go:73
↓ 2 callers
Method
newPeerInfo
newPeerInfo creates a peerInfo for a new peer.
internal/p2p/peermanager.go:409
↓ 2 callers
Function
newPeerStore
newPeerStore creates a new peer store, loading all persisted peers from the database into memory.
internal/p2p/peermanager.go:1305
↓ 2 callers
Function
newPrivKey
------------------------------------------- helper funcs
privval/socket_listeners_test.go:16
↓ 2 callers
Function
newRPCFunc
(f interface{}, args string, ws bool, c bool)
rpc/jsonrpc/server/rpc_func.go:49
↓ 2 callers
Function
newReactor
XXX: unify naming in this package around tmState
internal/blocksync/v2/reactor.go:63
↓ 2 callers
Function
newSignerListenerEndpoint
(logger log.Logger, addr string, timeoutReadWrite time.Duration)
privval/signer_listener_endpoint_test.go:148
↓ 2 callers
Function
newSimplePriorityQueue
(ctx context.Context, size int, chDescs []ChannelDescriptor)
internal/p2p/rqueue.go:22
↓ 2 callers
Function
newSyncer
newSyncer creates a new syncer.
internal/statesync/syncer.go:77
↓ 2 callers
Function
newTestBlockHeader
newTestBlockHeader constructs a fresh copy of a block header containing known test values to exercise the indexer.
internal/state/indexer/sink/psql/psql_test.go:211
↓ 2 callers
Function
newTestReactor
(t *testing.T, p testReactorParams)
internal/blocksync/v2/reactor_test.go:157
↓ 2 callers
Function
newTimeoutConn
newTimeoutConn returns an instance of timeoutConn.
privval/socket_listeners.go:160
↓ 2 callers
Function
newValidatorStub
(privValidator types.PrivValidator, valIndex int32)
internal/consensus/common_test.go:100
↓ 2 callers
Function
newWithMax
Return CList with given maxLength. Will panic if list exceeds given maxLength.
internal/libs/clist/clist.go:237
↓ 2 callers
Method
nextHeightToSchedule
lowest block in sc.blockStates with state == blockStateNew or -1 if no new blocks
internal/blocksync/v2/scheduler.go:461
← previous
next →
2,401–2,500 of 9,600, ranked by callers