MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 15 callersMethodPublish
Publish publishes the given message. An error will be returned to the caller if the context is canceled.
libs/pubsub/pubsub.go:329
↓ 15 callersMethodReady
Ready marks a peer as ready, broadcasting status updates to subscribers. The peer must already be marked as connected. This is separate from Dialed()
internal/p2p/peermanager.go:812
↓ 15 callersMethodReceive
Receive is called by the switch when msgBytes is received from the peer. NOTE reactor can not keep msgBytes around after Receive completes without co
internal/p2p/base_reactor.go:50
↓ 15 callersMethodSubscribe
Subscribe subscribes to peer updates. The caller must consume the peer updates in a timely fashion and close the subscription when done, otherwise the
internal/p2p/peermanager.go:1079
↓ 15 callersMethodSum
(b []byte)
crypto/tmhash/hash.go:37
↓ 15 callersMethodToProto
ToProto converts Data to protobuf
types/block.go:1044
↓ 15 callersMethodUnmarshal
(dAtA []byte)
abci/types/types.pb.go:9219
↓ 15 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/types/types.pb.go:2288
↓ 15 callersFunctionassertMempool
for testing
internal/consensus/mempool_test.go:24
↓ 15 callersFunctionblockMetaKey
(height int64)
internal/store/store.go:591
↓ 15 callersFunctionfromHex
(bits string)
crypto/xchacha20poly1305/vector_test.go:13
↓ 15 callersFunctiongenLightBlocksWithKeys
genLightBlocksWithKeys generates the header and validator set to create blocks to height. BlockIntervals are in per minute. NOTE: Expected to have a l
light/helpers_test.go:177
↓ 15 callersFunctionsetup
(t testing.TB, cacheSize int, options ...TxMempoolOption)
internal/mempool/v1/mempool_test.go:76
↓ 15 callersFunctionsovCanonical
(x uint64)
proto/tendermint/types/canonical.pb.go:670
↓ 15 callersFunctionsovEvidence
(x uint64)
proto/tendermint/types/evidence.pb.go:717
↓ 15 callersFunctionsovParams
(x uint64)
proto/tendermint/types/params.pb.go:941
↓ 15 callersFunctionsovProof
(x uint64)
proto/tendermint/crypto/proof.pb.go:678
↓ 15 callersFunctionsovWal
(x uint64)
proto/tendermint/consensus/wal.pb.go:818
↓ 15 callersFunctionstopAll
(t *testing.T, stoppers ...stopper)
internal/p2p/conn/connection_test.go:590
↓ 14 callersMethodDialString
()
types/netaddress.go:153
↓ 14 callersMethodEndpoints
Endpoints returns the local endpoints the transport is listening on, if any. How to listen is transport-dependent, e.g. MConnTransport uses Listen()
internal/p2p/transport.go:45
↓ 14 callersMethodGetValue
()
abci/types/types.pb.go:279
↓ 14 callersFunctionHashFromByteSlices
HashFromByteSlices computes a Merkle tree where the leaves are the byte slice, in the provided order. It follows RFC-6962.
crypto/merkle/tree.go:11
↓ 14 callersMethodHashesTo
HashesTo is a convenience function that checks if a block hashes to the given argument. Returns false if the block is nil or the hash is empty.
types/block.go:149
↓ 14 callersMethodIndex
Index analyzes, indexes and stores transactions. For indexing multiple Transacions must guarantee the Index of the TxResult is in order. See Batch str
internal/state/indexer/indexer.go:17
↓ 14 callersMethodList
()
internal/p2p/peer_set.go:15
↓ 14 callersFunctionLoadFilePV
LoadFilePV loads a FilePV from the filePaths. The FilePV handles double signing prevention by persisting data to the stateFilePath. If either file p
privval/file.go:191
↓ 14 callersFunctionNew
Return CList with MaxLength. CList will panic if it goes beyond MaxLength.
internal/libs/clist/clist.go:233
↓ 14 callersFunctionNewProposal
NewProposal returns a new Proposal. If there is no POLRound, polRound should be -1.
types/proposal.go:37
↓ 14 callersMethodNodeInfo
close original connection
internal/p2p/peer.go:35
↓ 14 callersMethodPublishWithEvents
PublishWithEvents publishes the given message with the set of events. The set is matched with clients queries. If there is a match, the message is sen
libs/pubsub/pubsub.go:336
↓ 14 callersFunctionRandomHash
()
internal/test/factory/block.go:31
↓ 14 callersFunctionRequireEmpty
RequireEmpty requires that the given channel is empty.
internal/p2p/p2ptest/require.go:15
↓ 14 callersMethodStart
These methods define the operational structure of the client. Start the client. Start must report an error if the client is running.
rpc/client/interface.go:38
↓ 14 callersMethodState
State returns the current state of the evpool.
internal/evidence/pool.go:258
↓ 14 callersMethodStop
()
internal/p2p/peer_test.go:175
↓ 14 callersMethodTotal
()
types/part_set.go:259
↓ 14 callersMethodUnmarshal
Unmarshal needed for protobuf compatibility
libs/bytes/bytes.go:25
↓ 14 callersFunctioncreateTempFileName
(t *testing.T, prefix string)
internal/p2p/pex/addrbook_test.go:694
↓ 14 callersFunctionensurePrevote
(voteCh <-chan tmpubsub.Message, height int64, round int32)
internal/consensus/common_test.go:662
↓ 14 callersMethodfinishAsyncCall
finishAsyncCall creates a ReqRes for an async call, and immediately populates it with the response. We don't complete it until it's been ordered via t
abci/client/grpc_client.go:320
↓ 14 callersFunctionnewMempoolWithApp
(cc abciclient.Creator)
internal/mempool/v0/clist_mempool_test.go:36
↓ 14 callersFunctionnewTestHarnessError
(code int, err error, info string)
tools/tm-signer-harness/internal/test_harness.go:388
↓ 14 callersMethodqueueRequestAsync
( ctx context.Context, req *types.Request, )
abci/client/socket_client.go:472
↓ 14 callersFunctionrandIPv4Address
(t *testing.T)
internal/p2p/pex/addrbook_test.go:189
↓ 14 callersFunctionsetupTestCase
setupTestCase does setup common to all test cases.
internal/state/state_test.go:28
↓ 14 callersFunctionsubscribeToVoter
(cs *State, addr []byte)
internal/consensus/common_test.go:372
↓ 14 callersFunctionteardown
(t *testing.T, pool *dockertest.Pool)
internal/state/indexer/indexer_service_test.go:192
↓ 13 callersMethodDialFailed
DialFailed reports a failed dial attempt. This will make the peer available for dialing again when appropriate (possibly after a retry timeout).
internal/p2p/peermanager.go:614
↓ 13 callersMethodError
()
abci/client/grpc_client.go:152
↓ 13 callersMethodInfo
Info/Query Connection
abci/types/application.go:13
↓ 13 callersMethodLoadBlock
(height int64)
internal/state/services.go:25
↓ 13 callersMethodMarshal
()
proto/tendermint/types/types.pb.go:1173
↓ 13 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/statesync/types.pb.go:692
↓ 13 callersFunctionNewVoteSet
Constructs a new VoteSet struct used to accumulate votes for given height/round.
types/vote_set.go:78
↓ 13 callersMethodPriority
()
internal/blocksync/v2/types.go:12
↓ 13 callersFunctionRandGenesisDoc
( cfg *config.Config, numValidators int, randPower bool, minPower int64)
internal/test/factory/genesis.go:11
↓ 13 callersMethodRead
CONTRACT: data smaller than dataMaxSize is read atomically.
internal/p2p/conn/secret_connection.go:232
↓ 13 callersMethodSetAddrBook
SetAddrBook allows to set address book on Switch.
internal/p2p/switch.go:483
↓ 13 callersMethodSetRoot
SetRoot sets the RootDir for all Config structs
config/config.go:129
↓ 13 callersMethodTrustedLightBlock
TrustedLightBlock returns a trusted light block at the given height (0 - the latest). It returns an error if: - there are some issues with the truste
light/client.go:324
↓ 13 callersMethodValidateBasic
()
internal/consensus/msgs.go:20
↓ 13 callersMethodWake
Wake wakes up the sleeper.
internal/libs/sync/waker.go:23
↓ 13 callersMethodWalFile
WalFile returns the full path to the write-ahead log file
config/config.go:1219
↓ 13 callersMethodWitnesses
Witnesses returns the witness providers. NOTE: providers may be not safe for concurrent access.
light/client.go:820
↓ 13 callersFunctionassertReceive
HELPERS
libs/pubsub/pubsub_test.go:559
↓ 13 callersMethodcallback
-------------------------------------------------------
abci/client/local_client.go:349
↓ 13 callersFunctioncloseAll
(t *testing.T, closers ...closer)
internal/p2p/conn/connection_test.go:604
↓ 13 callersFunctionencodeVarintCanonical
(dAtA []byte, offset int, v uint64)
proto/tendermint/types/canonical.pb.go:569
↓ 13 callersFunctionencodeVarintEvidence
(dAtA []byte, offset int, v uint64)
proto/tendermint/types/evidence.pb.go:603
↓ 13 callersFunctionencodeVarintParams
(dAtA []byte, offset int, v uint64)
proto/tendermint/types/params.pb.go:831
↓ 13 callersFunctionencodeVarintProof
(dAtA []byte, offset int, v uint64)
proto/tendermint/crypto/proof.pb.go:568
↓ 13 callersFunctionencodeVarintWal
(dAtA []byte, offset int, v uint64)
proto/tendermint/consensus/wal.pb.go:685
↓ 13 callersMethodfinishSyncCall
finishSyncCall waits for an async call to complete. It is necessary to call all sync calls asynchronously as well, to maintain call and response order
abci/client/grpc_client.go:334
↓ 13 callersFunctioninitializeValidatorState
(t *testing.T, privVal types.PrivValidator, height int64)
internal/evidence/pool_test.go:422
↓ 13 callersFunctionnewWeightedTime
newWeightedTime with time and weight.
internal/state/time.go:15
↓ 13 callersMethodqueueRequestAndFlushSync
( ctx context.Context, req *types.Request, )
abci/client/socket_client.go:485
↓ 13 callersFunctionrootify
----------------------------------------------------------------------------- Utils helper function to make config creation independent of root dir
config/config.go:1362
↓ 13 callersFunctionsetupChunkQueue
(t *testing.T)
internal/statesync/chunks_test.go:14
↓ 13 callersFunctionskipTypes
(dAtA []byte)
proto/tendermint/types/types.pb.go:4528
↓ 13 callersFunctionwithTransports
withTransports is a test helper that runs a test against all transports registered in testTransports.
internal/p2p/transport_test.go:28
↓ 12 callersMethodCanceled
()
types/event_bus.go:28
↓ 12 callersMethodCheckEvidence
CheckEvidence takes an array of evidence from a block and verifies all the evidence there. If it has already verified the evidence then it jumps to th
internal/evidence/pool.go:201
↓ 12 callersMethodCleanup
(func())
internal/statesync/mocks/state_provider.go:88
↓ 12 callersMethodCommit
Signals the end of a block, returns changes to the validator set
abci/types/application.go:24
↓ 12 callersFunctionDefaultConfig
DefaultConfig returns a default configuration for a Tendermint node
config/config.go:90
↓ 12 callersMethodGetByIndex
(index int)
crypto/merkle/types.go:15
↓ 12 callersMethodGetIndex
GetIndex returns the bit at index i within the bit array. The behavior is undefined if i >= bA.Bits
libs/bits/bit_array.go:49
↓ 12 callersMethodGetPeers
GetPeers returns the peers for a snapshot.
internal/statesync/snapshots.go:141
↓ 12 callersMethodGetPubKey
Implements PrivValidator.
types/priv_validator.go:81
↓ 12 callersMethodHeight
()
internal/blocksync/v2/reactor.go:31
↓ 12 callersMethodIndex
Index indexes transactions using the given list of events. Each key that indexed from the tx's events is a composite of the event type and the respect
internal/state/indexer/tx/kv/kv.go:66
↓ 12 callersMethodIsOK
IsOK returns true if Code is OK.
abci/types/result.go:38
↓ 12 callersFunctionPubKeyFromProto
PubKeyFromProto takes a protobuf Pubkey and transforms it to a crypto.Pubkey
crypto/encoding/codec.go:49
↓ 12 callersMethodRemoteEndpoint
RemoteEndpoint returns the remote endpoint for the connection.
internal/p2p/transport.go:113
↓ 12 callersMethodRoundStateEvent
RoundStateEvent returns the H/R/S of the RoundState as an event.
internal/consensus/types/round_state.go:165
↓ 12 callersMethodSave
()
crypto/merkle/types.go:20
↓ 12 callersFunctionTestRPCConfig
TestRPCConfig returns a configuration for testing the RPC server
config/config.go:587
↓ 12 callersMethodType
Type checks the eventsink structure type.
internal/state/indexer/eventsink.go:52
↓ 12 callersMethodValidateBlock
ValidateBlock validates the given block against the given state. If the block is invalid, it returns an error. Validation does not mutate state, but d
internal/state/execution.go:125
← previousnext →301–400 of 9,600, ranked by callers