MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 2 callersMethodSetRunning
SetRunning sets the running state of the peer.
internal/consensus/peer_state.go:67
↓ 2 callersMethodSetTicker
SetTicker allows a TestTicker to be provided that will manually control the passing of time from the perspective of the Metric. The ticker must be set
internal/p2p/trust/metric.go:250
↓ 2 callersFunctionSignedHeaderFromProto
FromProto sets a protobuf SignedHeader to the given pointer. It returns an error if the header or the commit is invalid.
types/light.go:197
↓ 2 callersMethodSize
------------------------------------------------ Size returns the number of addresses in the book.
internal/p2p/pex/addrbook.go:478
↓ 2 callersMethodSize
Size returns the number of evidence in the pool.
internal/evidence/pool.go:253
↓ 2 callersMethodSnapshotChunksCount
()
internal/statesync/reactor.go:134
↓ 2 callersMethodSnapshotChunksTotal
()
internal/statesync/reactor.go:135
↓ 2 callersMethodSnapshotHeight
()
internal/statesync/reactor.go:133
↓ 2 callersMethodStopPeerGracefully
StopPeerGracefully disconnects from a peer gracefully. TODO: handle graceful disconnects.
internal/p2p/switch.go:401
↓ 2 callersMethodStringShort
StringShort returns a shortened string representation of the block.
types/block.go:201
↓ 2 callersMethodSubscribe
(ctx context.Context, subscriber string, query tmpubsub.Query, outCapacity ...int)
types/event_bus.go:17
↓ 2 callersFunctionSwitchPeerFilters
SwitchPeerFilters sets the filters for rejection of new peers.
internal/p2p/switch.go:180
↓ 2 callersMethodSwitchToConsensus
for when we switch from blockchain reactor and block sync to the consensus machine
internal/blocksync/v2/io.go:47
↓ 2 callersMethodSync
Sync commits the current contents of the file to stable storage. Typically, this means flushing the file system's in-memory copy of recently written d
internal/libs/autofile/autofile.go:148
↓ 2 callersMethodSyntax
Syntax returns the syntax tree representation of q.
libs/pubsub/query/query.go:88
↓ 2 callersFunctionTest
Test runs test cases under tests/
test/e2e/runner/test.go:10
↓ 2 callersFunctionTestBaseConfig
TestBaseConfig returns a base configuration for testing a Tendermint node
config/config.go:264
↓ 2 callersFunctionTestBlockSyncConfig
TestBlockSyncConfig returns a default configuration for the block sync.
config/config.go:1091
↓ 2 callersFunctionTestMempoolConfig
TestMempoolConfig returns a configuration for testing the Tendermint mempool
config/config.go:917
↓ 2 callersFunctionTestP2PConfig
TestP2PConfig returns a configuration for testing the peer-to-peer layer
config/config.go:804
↓ 2 callersFunctionTestStateSyncConfig
TestStateSyncConfig returns a default configuration for the state sync service
config/config.go:1015
↓ 2 callersMethodToJSON
ToJSON returns a json of PeerState.
internal/consensus/peer_state.go:94
↓ 2 callersMethodToProto
ToProto converts PartSetHeader to protobuf
types/part_set.go:125
↓ 2 callersMethodToProto
ToProto converts Block to protobuf
types/block.go:209
↓ 2 callersMethodToProto
ToProto converts Commit to protobuf
types/block.go:948
↓ 2 callersMethodToProto
ToProto converts BlockID to protobuf
types/block.go:1231
↓ 2 callersMethodToProto
()
crypto/merkle/proof.go:119
↓ 2 callersMethodToProto
ToProto converts the peerInfo to p2pproto.PeerInfo for database storage. The Protobuf type only contains persisted fields, while ephemeral fields are
internal/p2p/peermanager.go:1506
↓ 2 callersFunctionToResponseApplySnapshotChunk
(res ResponseApplySnapshotChunk)
abci/types/messages.go:198
↓ 2 callersFunctionToResponseBeginBlock
(res ResponseBeginBlock)
abci/types/messages.go:168
↓ 2 callersFunctionToResponseCheckTx
(res ResponseCheckTx)
abci/types/messages.go:144
↓ 2 callersFunctionToResponseCommit
(res ResponseCommit)
abci/types/messages.go:150
↓ 2 callersFunctionToResponseDeliverTx
(res ResponseDeliverTx)
abci/types/messages.go:138
↓ 2 callersFunctionToResponseEcho
(message string)
abci/types/messages.go:121
↓ 2 callersFunctionToResponseEndBlock
(res ResponseEndBlock)
abci/types/messages.go:174
↓ 2 callersFunctionToResponseInfo
(res ResponseInfo)
abci/types/messages.go:133
↓ 2 callersFunctionToResponseInitChain
(res ResponseInitChain)
abci/types/messages.go:162
↓ 2 callersFunctionToResponseListSnapshots
(res ResponseListSnapshots)
abci/types/messages.go:180
↓ 2 callersFunctionToResponseLoadSnapshotChunk
(res ResponseLoadSnapshotChunk)
abci/types/messages.go:192
↓ 2 callersFunctionToResponseOfferSnapshot
(res ResponseOfferSnapshot)
abci/types/messages.go:186
↓ 2 callersFunctionToResponseQuery
(res ResponseQuery)
abci/types/messages.go:156
↓ 2 callersMethodTotalSnapshots
()
internal/statesync/reactor.go:131
↓ 2 callersMethodTrustHashBytes
()
config/config.go:995
↓ 2 callersMethodTrustValue
TrustValue gets the dependable trust value; always between 0 and 1
internal/p2p/trust/metric.go:194
↓ 2 callersMethodTrustedLightBlock
(height int64)
light/rpc/client.go:33
↓ 2 callersFunctionTxProofFromProto
(pb tmproto.TxProof)
types/tx.go:125
↓ 2 callersMethodTxsFront
TxsFront returns the first transaction in the ordered list for peer goroutines to call .NextWait() on. FIXME: leaking implementation details! Safe fo
internal/mempool/v0/clist_mempool.go:182
↓ 2 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/mempool/types.pb.go:306
↓ 2 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/crypto/proof.pb.go:841
↓ 2 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/p2p/types.pb.go:959
↓ 2 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/p2p/pex.pb.go:1411
↓ 2 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/consensus/wal.pb.go:824
↓ 2 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/blocksync/types.pb.go:1225
↓ 2 callersMethodUnsubscribeAll
(ctx context.Context, subscriber string)
types/event_bus.go:19
↓ 2 callersMethodUnsubscribeAll
UnsubscribeAll removes all client subscriptions. An error will be returned to the caller if the context is canceled or if subscription does not exist.
libs/pubsub/pubsub.go:290
↓ 2 callersMethodUpdate
(State, types.EvidenceList)
internal/state/services.go:48
↓ 2 callersMethodUpperBoundValue
UpperBoundValue returns the value for the upper bound. If the upper bound is nil, nil will be returned.
internal/state/indexer/query_range.go:57
↓ 2 callersMethodValidate
Validate validates a NodeAddress.
internal/p2p/address.go:163
↓ 2 callersMethodValidateBasic
ValidateBasic checks that the data is correct and consistent This does no verification of the signatures
types/light.go:21
↓ 2 callersMethodValidateBasic
ValidateBasic performs basic validation.
types/evidence.go:127
↓ 2 callersMethodValidateBasic
ValidateBasic performs basic validation.
types/proposal.go:49
↓ 2 callersMethodValidateBasic
ValidateBasic performs basic validation.
internal/consensus/msgs.go:186
↓ 2 callersMethodValidateBasic
ValidateBasic performs basic validation (checking param bounds, etc.) and returns an error if any check fails.
config/config.go:141
↓ 2 callersMethodValidateHeight
ValidateHeight validates the height given the chain's initial height.
internal/consensus/msgs.go:70
↓ 2 callersMethodVerify
(proof *tmcrypto.ProofOps, root []byte, keypath string, args [][]byte)
crypto/merkle/proof_op.go:124
↓ 2 callersMethodVerify
()
crypto/ed25519/ed25519.go:225
↓ 2 callersFunctionVerifyNonAdjacent
VerifyNonAdjacent verifies non-adjacent untrustedHeader against trustedHeader. It ensures that: a) trustedHeader can still be trusted (if not, ErrOl
light/verifier.go:33
↓ 2 callersMethodVoteStrings
Returns a list of votes compressed to more readable strings.
types/vote_set.go:547
↓ 2 callersFunctionWALFromProto
WALFromProto takes a proto wal message and return a consensus walMessage and error.
internal/consensus/msgs.go:631
↓ 2 callersFunctionWALToProto
WALToProto takes a WAL message and return a proto walMessage and error.
internal/consensus/msgs.go:573
↓ 2 callersFunctionWALWithNBlocks
WALWithNBlocks returns a WAL content with numBlocks.
internal/consensus/wal_generator.go:129
↓ 2 callersFunctionWaitForOneEvent
WaitForOneEvent subscribes to a websocket event for the given event time and returns upon receiving it one time, or when the timeout duration has expi
rpc/client/helpers.go:62
↓ 2 callersMethodWaitSync
()
internal/rpc/core/env.go:63
↓ 2 callersMethodWrite
Write writes len(p) bytes from p to the underlying data stream without exceeding the current transfer rate limit. It returns (n, ErrLimit) if w is non
internal/libs/flowrate/io.go:96
↓ 2 callersMethod_recover
Catch panics, usually caused by remote disconnects.
internal/p2p/conn/connection.go:343
↓ 2 callersFunctionaVote
()
internal/libs/protoio/writer_test.go:17
↓ 2 callersMethodaddBucketRef
(bucketIdx int)
internal/p2p/pex/known_address.go:69
↓ 2 callersFunctionaddDBFlags
(cmd *cobra.Command)
cmd/tendermint/commands/run_node.go:103
↓ 2 callersMethodaddNode
(t *testing.T, nodeID types.NodeID, genDoc *types.GenesisDoc, privVal types.PrivValidator, maxBlockHeight
internal/blocksync/v0/reactor_test.go:92
↓ 2 callersMethodaddNodes
(t *testing.T, nodes int)
internal/p2p/pex/reactor_test.go:443
↓ 2 callersMethodaddOutboundPeerWithConfig
dial the peer; make secret connection; authenticate against the dialed ID; add the peer. if dialing fails, start the reconnect loop. If handshake fail
internal/p2p/switch.go:789
↓ 2 callersMethodaddPeerWithConnection
(conn net.Conn)
internal/p2p/test_util.go:121
↓ 2 callersMethodaddToOldBucket
Adds ka to old bucket. Returns false if it couldn't do it cuz buckets full.
internal/p2p/pex/addrbook.go:561
↓ 2 callersMethodallEntriesSorted
allEntriesSorted returns a slice of all the transactions currently in the mempool, sorted in nonincreasing order by priority with ties broken by incre
internal/mempool/v1/mempool.go:301
↓ 2 callersFunctionapplyChangesToValSet
(t *testing.T, expErr error, valSet *ValidatorSet, valsLists ...[]testVal)
types/validator_set_test.go:1206
↓ 2 callersMethodapplyUpdates
Merges the vals' validator list with the updates list. When two elements with same address are seen, the one from updates is selected. Expects updates
types/validator_set.go:499
↓ 2 callersFunctionargsToJSON
(args map[string]interface{})
rpc/jsonrpc/client/encode.go:29
↓ 2 callersMethodassertEvidenceChannelsEmpty
(t *testing.T)
internal/evidence/reactor_test.go:196
↓ 2 callersFunctionassertMOldAndNNewAddrsInSelection
(t *testing.T, m, n int, addrs []*p2p.NetAddress, book *addrBook)
internal/p2p/pex/addrbook_test.go:688
↓ 2 callersFunctionassertNoPeersAfterTimeout
(t *testing.T, sw *Switch, timeout time.Duration)
internal/p2p/switch_test.go:388
↓ 2 callersFunctionassertWellOrderedMigrations
(t *testing.T, testData []toMigrate)
scripts/scmigrate/migrate_test.go:30
↓ 2 callersMethodbackfill
( ctx context.Context, chainID string, startHeight, stopHeight, initialHeight int64, trustedBlockID types.
internal/statesync/reactor.go:370
↓ 2 callersFunctionbackoffTimeout
exponential backoff (with jitter) 0.5s -> 2s -> 4.5s -> 8s -> 12.5 with 1s variation
light/provider/http/http.go:334
↓ 2 callersMethodbatchDelete
batchDelete runs an iterator over a set of keys, first preforming a pre deletion hook before adding it to the batch. The function ends when either 100
internal/store/store.go:410
↓ 2 callersFunctionbenchmarkMarshalDelimited
(b *testing.B, msgs []proto.Message)
internal/libs/protoio/writer_test.go:73
↓ 2 callersMethodbitArrayString
()
types/vote_set.go:540
↓ 2 callersMethodbroadcast
broadcast broadcasts a peer update to all subscriptions. The caller must already hold the mutex lock, to make sure updates are sent in the same order
internal/p2p/peermanager.go:1157
↓ 2 callersMethodbroadcastTX
( ctx context.Context, route string, tx types.Tx, )
rpc/client/http/http.go:273
↓ 2 callersMethodbroadcastTxRoutine
(peerID types.NodeID, closer *tmsync.Closer)
internal/mempool/v1/reactor.go:310
↓ 2 callersFunctionbuildString
(length int, picker func() int64)
libs/rand/random.go:53
← previousnext →2,201–2,300 of 9,600, ranked by callers