Functions — github.com/tendermint/tendermint

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

⨍ Functions 9,600◇ Types & classes 1,209

Update returns a copy of the params with updates from the non-zero fields of p2. NOTE: note: must not modify the original

types/params.go:213

↓ 4 callersMethodValidate

Validate validates the message returning an error upon failure.

proto/tendermint/blocksync/message.go:65

↓ 4 callersMethodValidateBasic

ValidateBasic performs basic validation such that the evidence is consistent and can now be used for verification.

types/evidence.go:383

↓ 4 callersFunctionValidateTrustLevel

ValidateTrustLevel checks that trustLevel is within the allowed range [1/3, 1]. If not, it returns an error. 1/3 is the minimum amount of trust needed

light/verifier.go:173

↓ 4 callersFunctionValidatorFromProto

FromProto sets a protobuf Validator to the given pointer. It returns an error if the public key is invalid.

types/validator.go:157

↓ 4 callersMethodValidators

--------------------------------------------- update validators

abci/example/kvstore/persistent_kvstore.go:176

↓ 4 callersMethodValueToMetricLabel

ValueToMetricLabel is a method that is used to produce a prometheus label value of the golang type that is passed in. This method uses a map on the Me

internal/p2p/metrics.go:230

↓ 4 callersFunctionVoteFromProto

FromProto converts a proto generetad type to a handwritten type return type, nil if everything converts safely, otherwise nil, error

types/vote.go:225

↓ 4 callersMethodWaitChan

WaitChan can be used to wait until Front or Back becomes not nil. Once it does, channel will be closed.

internal/libs/clist/clist.go:305

↓ 4 callersMethodWrap

Wrap implements the p2p Wrapper interface and wraps a blockchain message.

proto/tendermint/blocksync/message.go:16

↓ 4 callersMethodabciClientFor

(conn string)

internal/proxy/multi_app_conn.go:183

↓ 4 callersFunctionabciResponsesKey

(height int64)

internal/state/store.go:54

↓ 4 callersFunctionaddVotes

(to *State, votes ...*types.Vote)

internal/consensus/common_test.go:255

↓ 4 callersMethodapplyChunks

applyChunks applies chunks to the app. It returns various errors depending on the app's response, or nil once the snapshot is fully restored.

internal/statesync/syncer.go:418

↓ 4 callersMethodassertMempoolChannelsDrained

(t *testing.T)

internal/mempool/v0/reactor_test.go:107

↓ 4 callersFunctionassertPeersWithTimeout

( t *testing.T, switches []*p2p.Switch, checkPeriod, timeout time.Duration, nPeers int, )

internal/p2p/pex/pex_reactor_test.go:505

↓ 4 callersMethodattemptDisconnects

attemptDisconnects checks if we've been with each peer long enough to disconnect

internal/p2p/pex/pex_reactor.go:749

↓ 4 callersFunctionbuildLightBlockChain

(t *testing.T, fromHeight, toHeight int64, startTime time.Time)

internal/statesync/reactor_test.go:757

↓ 4 callersFunctionchDesc

(chID p2p.ChannelID)

internal/consensus/reactor_test.go:53

↓ 4 callersFunctionconditionArg

(c syntax.Condition)

internal/state/indexer/query_range.go:125

↓ 4 callersMethodconnectN

connects all nodes with n other nodes

internal/p2p/pex/reactor_test.go:692

↓ 4 callersFunctionconsensusLogger

------------------------------------------------------------------------------- consensus nets consensusLogger is a TestingLogger which uses a differe

internal/consensus/common_test.go:744

↓ 4 callersFunctioncreateAddrBookWithMOldAndNNewAddrs

(t *testing.T, nOld, nNew int)

internal/p2p/pex/addrbook_test.go:711

↓ 4 callersFunctiondefaultGenesisDocProviderFunc

defaultGenesisDocProviderFunc returns a GenesisDocProvider that loads the GenesisDoc from the config.GenesisFile() on the filesystem.

node/node.go:1111

↓ 4 callersFunctiondefaultTestPool

(t *testing.T, height int64)

internal/evidence/pool_test.go:466

↓ 4 callersFunctionderiveSecrets

( dhSecret *[32]byte, locIsLeast bool, )

internal/p2p/conn/secret_connection.go:337

↓ 4 callersFunctiondialAcceptHandshake

dialAcceptHandshake is a helper that dials and handshakes b from a and returns both sides of the connection.

internal/p2p/transport_test.go:621

↓ 4 callersFunctionencodeVarintBlock

(dAtA []byte, offset int, v uint64)

proto/tendermint/types/block.pb.go:186

↓ 4 callersFunctionensureNewValidBlock

(validBlockCh <-chan tmpubsub.Message, height int64, round int32)

internal/consensus/common_test.go:591

↓ 4 callersFunctionensureNoNewEvent

-------------------------------------------------------------------------------

internal/consensus/common_test.go:488

↓ 4 callersFunctionexampleVote

(t byte)

types/vote_test.go:27

↓ 4 callersFunctionexec

execute executes a shell command.

test/e2e/runner/exec.go:12

↓ 4 callersFunctionfetchBlockChain

fetchBlockChain fetches a complete, up-to-date block history from the freshest testnet archive node.

test/e2e/tests/e2e_test.go:93

↓ 4 callersMethodflush

()

internal/p2p/conn/connection.go:334

↓ 4 callersFunctionfreshBlockStore

()

internal/store/store_test.go:62

↓ 4 callersMethodgetRoundState

()

internal/consensus/reactor.go:475

↓ 4 callersFunctiongetSplitPoint

getSplitPoint returns the largest power of 2 less than length

crypto/merkle/tree.go:101

↓ 4 callersFunctiongetTestNode

(t *testing.T, conf *config.Config, logger log.Logger)

node/node_test.go:85

↓ 4 callersMethodgroupKey

Return a string representing the network group of this address. This is the /16 for IPv4 (e.g. 1.2.0.0), the /32 (/36 for he.net) for IPv6, the string

internal/p2p/pex/addrbook.go:890

↓ 4 callersFunctionhandleLightBlockRequests

(t *testing.T, chain map[int64]*types.LightBlock, receiving chan p2p.Envelope, sending chan p2p.Envelope,

internal/statesync/reactor_test.go:680

↓ 4 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/consensus/reactor.go:1275

↓ 4 callersFunctionharnessTest

For running relatively standard tests.

tools/tm-signer-harness/internal/test_harness_test.go:148

↓ 4 callersFunctionhashItems

hashItems hashes a set of key/value items.

test/e2e/app/state.go:175

↓ 4 callersMethodheight

()

internal/blocksync/v2/processor.go:107

↓ 4 callersFunctioninnerHash

returns tmhash(0x01 || left || right)

crypto/merkle/hash.go:34

↓ 4 callersMethodisOld

()

internal/p2p/pex/known_address.go:38

↓ 4 callersMethodisPending

IsPending checks whether the evidence is already pending. DB errors are passed to the logger.

internal/evidence/pool.go:291

↓ 4 callersMethodisProposalComplete

Returns true if the proposal block is complete && (if POLRound was proposed, we have +2/3 prevotes from there).

internal/consensus/state.go:1239

↓ 4 callersFunctionleafHash

returns tmhash(0x00 || leaf)

crypto/merkle/hash.go:21

↓ 4 callersMethodlistenFor

( t *testing.T, node types.NodeID, conditional func(msg p2p.Envelope) bool, assertion func(t *testing.T, m

internal/p2p/pex/reactor_test.go:470

↓ 4 callersMethodloadConsensusParamsInfo

(height int64)

internal/state/store.go:625

↓ 4 callersFunctionloadStateAndBlockStore

(cfg *tmcfg.Config)

cmd/tendermint/commands/reindex_event.go:134

↓ 4 callersFunctionloadValidatorsInfo

CONTRACT: Returned ValidatorsInfo can be mutated.

internal/state/store.go:535

↓ 4 callersFunctionmakeKVStoreConnPair

Each returned ReadWriteCloser is akin to a net.Connection

internal/p2p/conn/secret_connection_test.go:327

↓ 4 callersFunctionmakeScBlock

makeScBlock makes an empty block.

internal/blocksync/v2/scheduler_test.go:1351

↓ 4 callersFunctionmakeToMigrate

(val []byte)

scripts/scmigrate/migrate.go:44

↓ 4 callersMethodmatch

match returns all matching txs by hash that meet a given condition and start key. An already filtered result (filteredHashes) is provided such that an

internal/state/indexer/tx/kv/kv.go:264

↓ 4 callersFunctionmustParseConfig

(t *testing.T, path string)

internal/libs/confix/confix_test.go:15

↓ 4 callersFunctionnewMempoolWithAppAndConfig

(cc abciclient.Creator, cfg *config.Config)

internal/mempool/v0/clist_mempool_test.go:46

↓ 4 callersFunctionnewMockPeer

Returns a mock peer

internal/p2p/peer_set_test.go:37

↓ 4 callersFunctionnewMockSignerServer

( t *testing.T, th *TestHarness, privKey crypto.PrivKey, breakProposalSigning bool, breakVoteSigning bool

tools/tm-signer-harness/internal/test_harness_test.go:126

↓ 4 callersFunctionnewState

------------------------------------------------------------------------------- consensus states

internal/consensus/common_test.go:393

↓ 4 callersFunctionnextStatus

(m *Monitor)

internal/libs/flowrate/io_test.go:22

↓ 4 callersMethodopenFile

()

internal/libs/autofile/autofile.go:160

↓ 4 callersFunctionprefixFromCompositeKey

Prefixes: these represent an initial part of the key and are used by iterators to iterate over a small section of the kv store during searches.

internal/state/indexer/tx/kv/kv.go:561

↓ 4 callersMethodprocessCh

processCh routes state sync messages to their respective handlers. Any error encountered during message execution will result in a PeerError being sen

internal/statesync/reactor.go:859

↓ 4 callersMethodprocessPeerEvent

(pu PeerUpdate)

internal/p2p/peermanager.go:1128

↓ 4 callersFunctionqueryWithID

queryWithID executes the specified SQL query with the given arguments, expecting a single-row, single-column result containing an ID. If the query suc

internal/state/indexer/sink/psql/psql.go:78

↓ 4 callersFunctionratesAreEqual

(r1 int64, r2 int64, maxDeviation int64)

internal/libs/flowrate/io_test.go:188

↓ 4 callersMethodremove

(clientID string, qStr, id string, reason error)

libs/pubsub/pubsub.go:428

↓ 4 callersMethodremovePeer

(peerID types.NodeID)

internal/blocksync/v0/pool.go:337

↓ 4 callersMethodscanWhile

(ok func(rune) bool)

libs/pubsub/query/syntax/scanner.go:266

↓ 4 callersMethodsendError

(err error, peerID types.NodeID)

internal/blocksync/v0/pool.go:425

↓ 4 callersMethodsendRequest

(t *testing.T, fromNode, toNode int, v2 bool)

internal/p2p/pex/reactor_test.go:630

↓ 4 callersFunctionsetup

( t *testing.T, genDoc *types.GenesisDoc, privVal types.PrivValidator, maxBlockHeights []int64, chBuf uin

internal/blocksync/v0/reactor_test.go:43

↓ 4 callersFunctionsetupClientServer

(t *testing.T, app types.Application)

abci/client/socket_client_test.go:103

↓ 4 callersMethodsizeKey

()

light/store/db/db.go:281

↓ 4 callersFunctionskipCanonical

(dAtA []byte)

proto/tendermint/types/canonical.pb.go:1307

↓ 4 callersFunctionskipEvidence

(dAtA []byte)

proto/tendermint/types/evidence.pb.go:1323

↓ 4 callersFunctionskipTypes

(dAtA []byte)

proto/tendermint/rpc/grpc/types.pb.go:853

↓ 4 callersFunctionskipTypes

(dAtA []byte)

rpc/grpc/types.pb.go:841

↓ 4 callersFunctionsovTypes

(x uint64)

proto/tendermint/mempool/types.pb.go:300

↓ 4 callersFunctionsovTypes

(x uint64)

proto/tendermint/version/types.pb.go:189

↓ 4 callersMethodstart

start starts non-blocking process that starts the priority queue scheduler.

internal/p2p/pqueue.go:151

↓ 4 callersMethodstart

(t *testing.T)

internal/blocksync/v0/reactor_test.go:175

↓ 4 callersFunctionstartClient

(t *testing.T, addr string)

rpc/jsonrpc/client/ws_client_test.go:204

↓ 4 callersMethodstartRoutines

timeoutRoutine: receive requests for timeouts on tickChan and fire timeouts on tockChan receiveRoutine: serializes processing of proposoals, block par

internal/consensus/state.go:428

↓ 4 callersFunctionstatusOK

(code int)

rpc/jsonrpc/server/http_json_handler_test.go:30

↓ 4 callersMethodstop

()

internal/blocksync/v2/routine.go:148

↓ 4 callersMethodstopAllClients

()

internal/proxy/multi_app_conn.go:160

↓ 4 callersMethodstopCtx

stopCtx returns a new context that is canceled when the router stops.

internal/p2p/router.go:1086

↓ 4 callersFunctiontestKVStore

(t *testing.T, app types.Application, tx []byte, key, value string)

abci/example/kvstore/kvstore_test.go:29

↓ 4 callersFunctiontestNodeID

()

types/node_info_test.go:96

↓ 4 callersFunctiontoHex

(bits []byte)

crypto/xchacha20poly1305/vector_test.go:9

↓ 4 callersMethodunrune

()

libs/pubsub/query/syntax/scanner.go:288

↓ 4 callersMethodupdateTotalVotingPower

Forces recalculation of the set's total voting power. Panics if total voting power is bigger than MaxTotalVotingPower.

types/validator_set.go:298

↓ 4 callersFunctionwaitForBlock

(ctx context.Context, p provider.Provider, height int64)

light/light_test.go:148

↓ 4 callersFunctionwaitForBlockWithUpdatedValsAndValidateIt

( t *testing.T, n int, updatedVals map[string]struct{}, blocksSubs []types.Subscription, css []*State, )

internal/consensus/reactor_test.go:230

↓ 4 callersFunctionwaitForHeight

waitForHeight waits for the network to reach a certain height (or above), returning the block at the height seen. Errors if the network is not making

test/e2e/runner/rpc.go:19

↓ 4 callersFunctionweightedMedian

weightedMedian computes weighted median time for a given array of WeightedTime and the total voting power.

internal/state/time.go:23

← previous next →1,201–1,300 of 9,600, ranked by callers