MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 1 callersFunctiongraduallyAddPeers
graduallyAddPeers delivers a new randomly-generated peer update on peerUpdateCh once per interval, until closeCh is closed. Each peer update is assign
internal/statesync/reactor_test.go:798
↓ 1 callersFunctionhChaCha20Generic
(out *[32]byte, nonce *[16]byte, key *[32]byte)
crypto/xchacha20poly1305/xchachapoly.go:134
↓ 1 callersMethodhandle
(event Event)
internal/blocksync/v2/scheduler.go:676
↓ 1 callersMethodhandleBlockSyncMessage
handleBlockSyncMessage handles envelopes sent from peers on the BlockSyncChannel. It returns an error only if the Envelope.Message is unknown for this
internal/blocksync/v0/reactor.go:237
↓ 1 callersMethodhandleChunkMessage
handleChunkMessage handles envelopes sent from peers on the ChunkChannel. It returns an error only if the Envelope.Message is unknown for this channel
internal/statesync/reactor.go:615
↓ 1 callersFunctionhandleChunkRequests
( t *testing.T, receivingCh chan p2p.Envelope, sendingCh chan p2p.Envelope, closeCh chan struct{}, chunk
internal/statesync/reactor_test.go:854
↓ 1 callersMethodhandleCompleteProposal
(blockHeight int64)
internal/consensus/state.go:1965
↓ 1 callersMethodhandleConflictingHeaders
handleConflictingHeaders handles the primary style of attack, which is where a primary and witness have two headers of the same height but with differ
light/detector.go:215
↓ 1 callersMethodhandleDataMessage
handleDataMessage handles envelopes sent from peers on the DataChannel. If we fail to find the peer state for the envelope sender, we perform a no-op
internal/consensus/reactor.go:1136
↓ 1 callersMethodhandleEvidenceMessage
handleEvidenceMessage handles envelopes sent from peers on the EvidenceChannel. It returns an error only if the Envelope.Message is unknown for this c
internal/evidence/reactor.go:132
↓ 1 callersFunctionhandleInvalidJSONRPCPaths
(next http.HandlerFunc)
rpc/jsonrpc/server/http_json_handler.go:157
↓ 1 callersMethodhandleLightBlockMessage
(envelope p2p.Envelope)
internal/statesync/reactor.go:702
↓ 1 callersMethodhandleMempoolMessage
handleMempoolMessage handles envelopes sent from peers on the MempoolChannel. For every tx in the message, we execute CheckTx. It returns an error if
internal/mempool/v0/reactor.go:142
↓ 1 callersMethodhandleMempoolMessage
handleMempoolMessage handles envelopes sent from peers on the MempoolChannel. For every tx in the message, we execute CheckTx. It returns an error if
internal/mempool/v1/reactor.go:149
↓ 1 callersMethodhandleMessage
handleMessage handles an Envelope sent from a peer on a specific p2p Channel. It will handle errors and any possible panics gracefully. A caller can h
internal/mempool/v0/reactor.go:182
↓ 1 callersMethodhandleMessage
handleMessage handles an Envelope sent from a peer on a specific p2p Channel. It will handle errors and any possible panics gracefully. A caller can h
internal/mempool/v1/reactor.go:189
↓ 1 callersMethodhandleMessage
handleMessage handles an Envelope sent from a peer on a specific p2p Channel. It will handle errors and any possible panics gracefully. A caller can h
internal/statesync/reactor.go:799
↓ 1 callersMethodhandleMessage
handleMessage handles an Envelope sent from a peer on a specific p2p Channel. It will handle errors and any possible panics gracefully. A caller can h
internal/p2p/pex/reactor.go:362
↓ 1 callersMethodhandleMessage
handleMessage handles an Envelope sent from a peer on a specific p2p Channel. It will handle errors and any possible panics gracefully. A caller can h
internal/evidence/reactor.go:168
↓ 1 callersMethodhandleMessage
handleMessage handles an Envelope sent from a peer on a specific p2p Channel. It will handle errors and any possible panics gracefully. A caller can h
internal/blocksync/v0/reactor.go:278
↓ 1 callersMethodhandleParamsMessage
(envelope p2p.Envelope)
internal/statesync/reactor.go:753
↓ 1 callersMethodhandlePeerErrors
handlePeerErrors iterates over each p2p Channel and starts a separate go-routine where we listen for peer errors. For each peer error, we find the pee
internal/p2p/shim.go:169
↓ 1 callersMethodhandlePexMessage
handlePexMessage handles envelopes sent from peers on the PexChannel.
internal/p2p/pex/reactor.go:198
↓ 1 callersMethodhandleRecheckResult
handleRecheckResult handles the responses from ABCI CheckTx calls issued during the recheck phase of a block Update. It removes any transactions inva
internal/mempool/v1/mempool.go:615
↓ 1 callersMethodhandleRemovePeer
(event bcRemovePeer)
internal/blocksync/v2/scheduler.go:596
↓ 1 callersMethodhandleRequest
(req *types.Request, responses chan<- *types.Response)
abci/server/socket_server.go:194
↓ 1 callersMethodhandleRequests
Read requests from conn and deal with them
abci/server/socket_server.go:155
↓ 1 callersMethodhandleResponses
Pull responses from 'responses' and write them to conn.
abci/server/socket_server.go:242
↓ 1 callersMethodhandleSnapshotMessage
handleSnapshotMessage handles envelopes sent from peers on the SnapshotChannel. It returns an error only if the Envelope.Message is unknown for this c
internal/statesync/reactor.go:546
↓ 1 callersFunctionhandleSnapshotRequests
( t *testing.T, receivingCh chan p2p.Envelope, sendingCh chan p2p.Envelope, closeCh chan struct{}, snapsh
internal/statesync/reactor_test.go:823
↓ 1 callersMethodhandleStateMessage
handleStateMessage handles envelopes sent from peers on the StateChannel. An error is returned if the message is unrecognized or if validation fails.
internal/consensus/reactor.go:1052
↓ 1 callersMethodhandleTxsAvailable
()
internal/consensus/state.go:1005
↓ 1 callersMethodhandleVoteMessage
handleVoteMessage handles envelopes sent from peers on the VoteChannel. If we fail to find the peer state for the envelope sender, we perform a no-op
internal/consensus/reactor.go:1178
↓ 1 callersMethodhandleVoteSetBitsMessage
handleVoteSetBitsMessage handles envelopes sent from peers on the VoteSetBitsChannel. If we fail to find the peer state for the envelope sender, we pe
internal/consensus/reactor.go:1217
↓ 1 callersMethodhandshake
handshake is a helper for Handshake, simplifying error handling so we can keep context handling and panic recovery in Handshake. It returns an unstart
internal/p2p/transport_mconn.go:317
↓ 1 callersFunctionhasDefaultHeight
(r rpctypes.RPCRequest, h []reflect.Value)
rpc/jsonrpc/server/http_json_handler.go:271
↓ 1 callersMethodhasIP
hasIP does not acquire a lock so it can be used in public methods which already lock.
internal/p2p/peer_set.go:80
↓ 1 callersFunctionhashFromByteSlices
(sha hash.Hash, items [][]byte)
crypto/merkle/tree.go:15
↓ 1 callersFunctionhexBytesFromString
(s string)
types/block_test.go:454
↓ 1 callersFunctionhostnameOrIP
(i int)
cmd/tendermint/commands/testnet.go:252
↓ 1 callersMethodincrPending
()
internal/blocksync/v0/pool.go:511
↓ 1 callersMethodincrementProposerPriority
()
types/validator_set.go:166
↓ 1 callersMethodindexEvents
(result *abci.TxResult, hash []byte, store dbm.Batch)
internal/state/indexer/tx/kv/kv.go:99
↓ 1 callersFunctioninitCorpus
(baseDir string)
test/fuzz/p2p/addrbook/init-corpus/main.go:26
↓ 1 callersFunctioninitCorpus
(baseDir string)
test/fuzz/p2p/secretconnection/init-corpus/main.go:20
↓ 1 callersFunctioninitCorpus
(rootDir string)
test/fuzz/p2p/pex/init-corpus/main.go:27
↓ 1 callersFunctioninitDBs
( cfg *config.Config, dbProvider config.DBProvider, )
node/setup.go:73
↓ 1 callersFunctioninitEnv
initEnv sets to use ENV variables if set.
libs/cli/setup.go:48
↓ 1 callersFunctioninitSwitchFunc
(i int, sw *Switch)
internal/p2p/switch_test.go:102
↓ 1 callersFunctioninitializeStateFromValidatorSet
(t *testing.T, valSet *types.ValidatorSet, height int64)
internal/evidence/pool_test.go:388
↓ 1 callersMethodinitializeWithTrustOptions
initializeWithTrustOptions fetches the weakly-trusted light block from primary provider, matches it to the trusted hash, and sets it as the lastTruste
light/client.go:287
↓ 1 callersFunctionint64FromBytes
(bz []byte)
internal/state/indexer/block/kv/util.go:23
↓ 1 callersFunctionintInSlice
(a int, list []int)
internal/state/indexer/block/kv/util.go:13
↓ 1 callersFunctioninvalidDoPrevoteFunc
(t *testing.T, height int64, round int32, cs *State, r *Reactor, pv types.PrivValidator)
internal/consensus/invalid_test.go:72
↓ 1 callersFunctionipNet
ipNet returns a net.IPNet struct given the passed IP address string, number of one bits to include at the start of the mask, and the total number of b
types/netaddress.go:327
↓ 1 callersMethodisBad
* An address is bad if the address in question is a New address, has not been tried in the last minute, and meets one of the following criteria:
internal/p2p/pex/known_address.go:110
↓ 1 callersMethodisBanned
()
internal/p2p/pex/known_address.go:65
↓ 1 callersFunctionisEmpty
Returns true if it has zero length.
types/utils.go:21
↓ 1 callersFunctionisErrAlreadySubscribed
(err error)
rpc/client/http/ws.go:215
↓ 1 callersMethodisExpired
IsExpired checks whether evidence or a polc is expired by checking whether a height and time is older than set by the evidence consensus parameters
internal/evidence/pool.go:270
↓ 1 callersMethodisLegacy
()
scripts/keymigrate/migrate.go:71
↓ 1 callersMethodisLegacyPeer
all addresses must use a MCONN protocol for the peer to be considered part of the legacy p2p pex system
internal/p2p/pex/reactor.go:520
↓ 1 callersMethodisPersistent
isPersistentPeer checks if a peer is in PersistentPeers. It will panic if called before optimize().
internal/p2p/peermanager.go:246
↓ 1 callersFunctionisPrivateAddr
(err error)
internal/p2p/switch.go:502
↓ 1 callersMethodisProposer
(address []byte)
internal/consensus/state.go:1186
↓ 1 callersMethodisSendPending
Returns true if any PacketMsgs are pending to be sent. Call before calling nextPacketMsg() Goroutine-safe
internal/p2p/conn/connection.go:842
↓ 1 callersFunctionisTypedNil
Go lacks a simple and safe way to see if something is a typed nil. See: - https://dave.cheney.net/2017/08/09/typed-nils-in-go-2 - https://groups.googl
types/utils.go:10
↓ 1 callersFunctionjsonFilenames
jsonFilenames returns a list of files in jsonDir directory
light/mbt/driver_test.go:89
↓ 1 callersFunctionkeyFromEvent
(compositeKey string, value string, result *abci.TxResult)
internal/state/indexer/tx/kv/kv.go:550
↓ 1 callersFunctionkeyPeerInfoRange
keyPeerInfoRange generates start/end keys for the entire peerInfo key range.
internal/p2p/peermanager.go:1677
↓ 1 callersFunctionkill
()
internal/proxy/multi_app_conn.go:195
↓ 1 callersFunctionkillProc
killProc attempts to kill the Tendermint process with a given PID with an ABORT signal which should result in a goroutine stacktrace. The PID's STDERR
cmd/tendermint/commands/debug/kill.go:108
↓ 1 callersMethodkillTMOnClientError
()
internal/proxy/multi_app_conn.go:130
↓ 1 callersFunctionkiller
()
libs/os/os_test.go:109
↓ 1 callersFunctionleafHashOpt
returns tmhash(0x00 || leaf)
crypto/merkle/hash.go:26
↓ 1 callersMethodlistenForLegacyResponse
( t *testing.T, fromNode, toNode int, waitPeriod time.Duration, addresses []p2pproto.PexAddress, )
internal/p2p/pex/reactor_test.go:557
↓ 1 callersMethodlistenForPeerUpdate
( t *testing.T, onNode, withNode int, status p2p.PeerStatus, waitPeriod time.Duration, )
internal/p2p/pex/reactor_test.go:576
↓ 1 callersMethodlistenForResponse
( t *testing.T, fromNode, toNode int, waitPeriod time.Duration, addresses []p2pproto.PexAddressV2, )
internal/p2p/pex/reactor_test.go:537
↓ 1 callersMethodload
load loads state from disk. It does not take out a lock, since it is called during construction.
test/e2e/app/state.go:54
↓ 1 callersMethodloadFromDB
* Loading & Saving */ * Both loadFromDB and savetoDB assume the mutex has been acquired */ Loads the history data for all peers from the store DB cmn.
internal/p2p/trust/store.go:154
↓ 1 callersMethodloadFromFile
Returns false if file does not exist. cmn.Panics if file is corrupt.
internal/p2p/pex/file.go:46
↓ 1 callersFunctionloadGenerate
loadGenerate generates jobs until the context is canceled. The chTx has multiple consumers, thus the rate limiting of the load generation is primaril
test/e2e/runner/load.go:89
↓ 1 callersFunctionloadGenerateWaitTime
(r *rand.Rand, size int)
test/e2e/runner/load.go:119
↓ 1 callersMethodloadMetadata
loadMetadata loads snapshot metadata. Does not take out locks, since it's called internally on construction.
test/e2e/app/snapshots.go:47
↓ 1 callersMethodloadPeers
loadPeers loads all peers from the database into memory.
internal/p2p/peermanager.go:1317
↓ 1 callersFunctionloadProcess
loadProcess processes transactions
test/e2e/runner/load.go:135
↓ 1 callersMethodloadSendQueueSize
Goroutine-safe
internal/p2p/conn/connection.go:829
↓ 1 callersMethodloadState
(key []byte)
internal/state/store.go:117
↓ 1 callersFunctionloadStatefromGenesis
(t *testing.T)
node/node_test.go:647
↓ 1 callersFunctionloadTxResult
(hash []byte)
internal/state/indexer/sink/psql/psql_test.go:272
↓ 1 callersMethodload_droplet_variables_for_host
Generate a JSON response to a --host call
networks/remote/ansible/inventory/digital_ocean.py:482
↓ 1 callersMethodload_from_cache
Reads the data from the cache file and assigns it to member variables as Python Objects
networks/remote/ansible/inventory/digital_ocean.py:502
↓ 1 callersFunctionlocalIPv4
()
internal/p2p/upnp/upnp.go:179
↓ 1 callersFunctionlogNodeStartupInfo
(state sm.State, pubKey crypto.PubKey, logger, consensusLogger log.Logger, mode string)
node/setup.go:160
↓ 1 callersFunctionlookForHash
(conditions []syntax.Condition)
internal/state/indexer/tx/kv/kv.go:239
↓ 1 callersFunctionlookForHeight
(conditions []syntax.Condition)
internal/state/indexer/block/kv/util.go:88
↓ 1 callersFunctionlookForHeight
lookForHeight returns a height if there is an "height=X" condition.
internal/state/indexer/tx/kv/kv.go:250
↓ 1 callersMethodlookup
lookup looks up a type from a name, or nil if not registered.
libs/json/types.go:87
↓ 1 callersMethodloop
(state state)
libs/pubsub/pubsub.go:381
↓ 1 callersFunctionmakeABCIInfoFunc
(c *lrpc.Client)
light/proxy/routes.go:291
← previousnext →3,701–3,800 of 9,600, ranked by callers