MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 2 callersMethodhandleAddNewPeer
(event bcAddNewPeer)
internal/blocksync/v2/scheduler.go:591
↓ 2 callersMethodhandleBlockProcessError
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 callersMethodhandleBlockProcessed
(event pcBlockProcessed)
internal/blocksync/v2/scheduler.go:558
↓ 2 callersMethodhandleBlockResponse
Handlers This handler gets the block, performs some validation and then passes it on to the processor.
internal/blocksync/v2/scheduler.go:527
↓ 2 callersFunctionhandleConsensusParamsRequest
(t *testing.T, receiving, sending chan p2p.Envelope, closeCh chan struct{})
internal/statesync/reactor_test.go:733
↓ 2 callersMethodhandleNoBlockResponse
(event bcNoBlockResponse)
internal/blocksync/v2/scheduler.go:543
↓ 2 callersFunctionhandleRequests
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 callersMethodhandleResetState
(event bcResetState)
internal/blocksync/v2/scheduler.go:635
↓ 2 callersMethodhandleStatusResponse
(event bcStatusResponse)
internal/blocksync/v2/scheduler.go:668
↓ 2 callersMethodhandleTimeout
(ti timeoutInfo, rs cstypes.RoundState)
internal/consensus/state.go:955
↓ 2 callersMethodhandleTryPrunePeer
(event rTryPrunePeer)
internal/blocksync/v2/scheduler.go:608
↓ 2 callersMethodhandleTrySchedule
(event rTrySchedule)
internal/blocksync/v2/scheduler.go:647
↓ 2 callersMethodhandshakePeer
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 callersMethodhandshakePeer
( c Connection, expectPeerID types.NodeID, )
internal/p2p/switch.go:864
↓ 2 callersMethodhasChannel
hasChannel returns true if the peer reported knowing about the given chID.
internal/p2p/peer.go:308
↓ 2 callersFunctionheightKey
(height int64)
internal/state/indexer/block/kv/util.go:34
↓ 2 callersFunctionhttpParamsToArgs
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 callersFunctionidFromInterface
(idInterface interface{})
rpc/jsonrpc/types/types.go:32
↓ 2 callersFunctionincrNonce
-------------------------------------------------------------------------------- Increment nonce little-endian by 1 with wraparound. Due to chacha20po
privval/secret_connection.go:457
↓ 2 callersFunctionincrNonce
-------------------------------------------------------------------------------- Increment nonce little-endian by 1 with wraparound. Due to chacha20po
internal/p2p/conn/secret_connection.go:455
↓ 2 callersMethodindexEvents
(batch dbm.Batch, events []abci.Event, typ string, height int64)
internal/state/indexer/block/kv/kv.go:457
↓ 2 callersMethodinit
Initialize the buckets. When modifying this, don't forget to update loadFromFile()
internal/p2p/pex/addrbook.go:137
↓ 2 callersMethodinitStateProvider
(ctx context.Context, chainID string, initialHeight int64)
internal/statesync/reactor.go:1052
↓ 2 callersFunctioninitializeBlockStore
initializeBlockStore creates a block storage and populates it w/ a dummy block at +height+.
internal/evidence/pool_test.go:437
↓ 2 callersFunctioninnerHashOpt
(s hash.Hash, left []byte, right []byte)
crypto/merkle/hash.go:42
↓ 2 callersFunctioninsertTestData
(t *testing.T, db dbm.DB, data []toMigrate)
scripts/scmigrate/migrate_test.go:63
↓ 2 callersFunctionint64ToBytes
(i int64)
internal/state/indexer/block/kv/util.go:28
↓ 2 callersFunctionintervalToHistoryOffset
Map the interval value down to an offset from the beginning of history
internal/p2p/trust/metric.go:407
↓ 2 callersMethodinvalid
(ch rune)
libs/pubsub/query/syntax/scanner.go:298
↓ 2 callersFunctionisDecimal
isDecimal reports whether buf is a non-empty sequence of Unicode decimal digits.
scripts/keymigrate/migrate.go:473
↓ 2 callersFunctionisDigit
(r rune)
libs/pubsub/query/syntax/scanner.go:302
↓ 2 callersMethodisFull
(txSize int)
internal/mempool/v0/clist_mempool.go:358
↓ 2 callersFunctionisHex
(data []byte)
scripts/keymigrate/migrate.go:538
↓ 2 callersMethodisNew
()
internal/p2p/pex/known_address.go:42
↓ 2 callersFunctionisTagRune
(r rune)
libs/pubsub/query/syntax/scanner.go:304
↓ 2 callersFunctionisValidatorTx
(tx []byte)
abci/example/kvstore/persistent_kvstore.go:206
↓ 2 callersMethodis_cache_valid
Determines if the cache files have expired, or if it is still valid
networks/remote/ansible/inventory/digital_ocean.py:493
↓ 2 callersFunctionjsonStringToArg
(rt reflect.Type, arg string)
rpc/jsonrpc/server/http_uri_handler.go:134
↓ 2 callersFunctionkeyCommitted
(evidence types.Evidence)
internal/evidence/pool.go:621
↓ 2 callersFunctionkeyPeerInfo
keyPeerInfo generates a peerInfo database key.
internal/p2p/peermanager.go:1668
↓ 2 callersMethodlistEvidence
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 callersMethodlisten
()
light/proxy/proxy.go:87
↓ 2 callersMethodlistenForRequest
(t *testing.T, fromNode, toNode int, waitPeriod time.Duration)
internal/p2p/pex/reactor_test.go:491
↓ 2 callersFunctionlistenerTestCases
(t *testing.T, timeoutAccept, timeoutReadWrite time.Duration)
privval/socket_listeners_test.go:78
↓ 2 callersMethodload
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 callersFunctionloadEventSinks
(cfg *tmcfg.Config)
cmd/tendermint/commands/reindex_event.go:84
↓ 2 callersFunctionloadFilePV
If loadState is true, we load from the stateFilePath. Otherwise, we use an empty LastSignState.
privval/file.go:202
↓ 2 callersFunctionloadPrivValidator
(cfg *config.Config)
internal/consensus/common_test.go:454
↓ 2 callersFunctionloadState
(db dbm.DB)
abci/example/kvstore/kvstore.go:30
↓ 2 callersFunctionloadStateFromDBOrGenesisDocProvider
------------------------------------------------------------------------------ loadStateFromDBOrGenesisDocProvider attempts to load the state from the
node/node.go:1162
↓ 2 callersMethodloadWalFile
loadWalFile loads WAL data from file. It overwrites cs.wal.
internal/consensus/state.go:439
↓ 2 callersMethodlogErrAddrBook
(err error)
internal/p2p/pex/pex_reactor.go:224
↓ 2 callersFunctionmakeBlockID
(hash []byte, partSetSize uint32, partSetHash []byte)
internal/state/execution_test.go:457
↓ 2 callersFunctionmakeConfig
(t *testing.T, acceptDeadline, acceptRetries int)
tools/tm-signer-harness/internal/test_harness_test.go:169
↓ 2 callersFunctionmakeHeaderRandom
(chainID string, height int64)
test/e2e/runner/evidence.go:253
↓ 2 callersFunctionmakeMockPeerStore
(t *testing.T, peers ...peerInfo)
internal/p2p/peermanager_scoring_test.go:84
↓ 2 callersFunctionmakeMockVote
(height int64, round, index int32, addr Address, blockID BlockID, time time.Time)
types/evidence.go:699
↓ 2 callersFunctionmakeNode
makeNode returns a new, ready to go, Tendermint Node.
node/node.go:126
↓ 2 callersFunctionmakePcBlock
makePcBlock makes an empty block.
internal/blocksync/v2/processor_test.go:29
↓ 2 callersFunctionmakePeers
(numPeers int, minHeight, maxHeight int64)
internal/blocksync/v0/pool_test.go:66
↓ 2 callersFunctionmakeRandomBlockID
()
test/e2e/runner/evidence.go:272
↓ 2 callersFunctionmakeRandomStateFromConsensusParams
(consensusParams *types.ConsensusParams, height, lastHeightConsensusParamsChanged int64)
internal/state/helpers_test.go:246
↓ 2 callersFunctionmakeRoundStepMessage
(rs *cstypes.RoundState)
internal/consensus/reactor.go:438
↓ 2 callersFunctionmakeStructInfo
makeStructInfo generates structInfo for a struct as a reflect.Value.
libs/json/structs.go:54
↓ 2 callersFunctionmakeVals
(valMap map[*e2e.Node]int64)
test/e2e/tests/validator_test.go:166
↓ 2 callersMethodmarkPeerRequest
(peer types.NodeID)
internal/p2p/pex/reactor.go:490
↓ 2 callersMethodmarkPeerResponse
(peer types.NodeID)
internal/p2p/pex/reactor.go:503
↓ 2 callersMethodmarkPending
(peerID types.NodeID, height int64, time time.Time)
internal/blocksync/v2/scheduler.go:392
↓ 2 callersMethodmarkProcessed
(height int64)
internal/blocksync/v2/scheduler.go:424
↓ 2 callersMethodmarkReceived
CONTRACT: peer exists and in Ready state.
internal/blocksync/v2/scheduler.go:368
↓ 2 callersMethodmatch
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 callersMethodmatchRange
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 callersMethodmatchRange
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 callersFunctionmustParse
(path string)
scripts/condiff/condiff.go:61
↓ 2 callersFunctionmustReadFile
(t *testing.T, filePath string)
internal/libs/autofile/autofile_test.go:141
↓ 2 callersFunctionmuxOnCommands
(cmd *cobra.Command, pArgs []string)
abci/cmd/abci-cli/abci-cli.go:359
↓ 2 callersMethodneedProofBlock
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 callersFunctionnewBlockVotes
(peerMaj23 bool, numValidators int)
types/vote_set.go:654
↓ 2 callersFunctionnewLightClientAttackEvidence
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 callersFunctionnewLocalReqRes
(req *types.Request, res *types.Response)
abci/client/local_client.go:356
↓ 2 callersFunctionnewMemoryConnection
newMemoryConnection creates a new MemoryConnection.
internal/p2p/transport_memory.go:227
↓ 2 callersFunctionnewMockBlockStore
TODO: NewBlockStore(db.NewMemDB) ...
internal/consensus/replay_test.go:1186
↓ 2 callersFunctionnewMockProxyApp
----------------------------------------------------------------------------- mockProxyApp uses ABCIResponses to give the right results. Useful becau
internal/consensus/replay_stubs.go:57
↓ 2 callersFunctionnewNodeID
(t *testing.T, id string)
internal/p2p/pex/reactor_test.go:814
↓ 2 callersFunctionnewPQScheduler
( logger log.Logger, m *Metrics, chDescs []ChannelDescriptor, enqueueBuf, dequeueBuf, capacity uint, )
internal/p2p/pqueue.go:92
↓ 2 callersFunctionnewPcState
newPcState returns a pcState initialized with the last verified block enqueued
internal/blocksync/v2/processor.go:73
↓ 2 callersMethodnewPeerInfo
newPeerInfo creates a peerInfo for a new peer.
internal/p2p/peermanager.go:409
↓ 2 callersFunctionnewPeerStore
newPeerStore creates a new peer store, loading all persisted peers from the database into memory.
internal/p2p/peermanager.go:1305
↓ 2 callersFunctionnewPrivKey
------------------------------------------- helper funcs
privval/socket_listeners_test.go:16
↓ 2 callersFunctionnewRPCFunc
(f interface{}, args string, ws bool, c bool)
rpc/jsonrpc/server/rpc_func.go:49
↓ 2 callersFunctionnewReactor
XXX: unify naming in this package around tmState
internal/blocksync/v2/reactor.go:63
↓ 2 callersFunctionnewSignerListenerEndpoint
(logger log.Logger, addr string, timeoutReadWrite time.Duration)
privval/signer_listener_endpoint_test.go:148
↓ 2 callersFunctionnewSimplePriorityQueue
(ctx context.Context, size int, chDescs []ChannelDescriptor)
internal/p2p/rqueue.go:22
↓ 2 callersFunctionnewSyncer
newSyncer creates a new syncer.
internal/statesync/syncer.go:77
↓ 2 callersFunctionnewTestBlockHeader
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 callersFunctionnewTestReactor
(t *testing.T, p testReactorParams)
internal/blocksync/v2/reactor_test.go:157
↓ 2 callersFunctionnewTimeoutConn
newTimeoutConn returns an instance of timeoutConn.
privval/socket_listeners.go:160
↓ 2 callersFunctionnewValidatorStub
(privValidator types.PrivValidator, valIndex int32)
internal/consensus/common_test.go:100
↓ 2 callersFunctionnewWithMax
Return CList with given maxLength. Will panic if list exceeds given maxLength.
internal/libs/clist/clist.go:237
↓ 2 callersMethodnextHeightToSchedule
lowest block in sc.blockStates with state == blockStateNew or -1 if no new blocks
internal/blocksync/v2/scheduler.go:461
← previousnext →2,401–2,500 of 9,600, ranked by callers