MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 37 callersFunctionNewClient
NewClient returns a new light client. It returns an error if it fails to obtain the light block from the primary or they are invalid (e.g. trust hash
light/client.go:155
↓ 37 callersFunctionmakeParams
( blockBytes, blockGas int64, evidenceAge int64, maxEvidenceBytes int64, pubkeyTypes []string, )
types/params_test.go:53
↓ 36 callersMethodGetProposer
GetProposer returns the current proposer. If the validator set is empty, nil is returned.
types/validator_set.go:325
↓ 36 callersFunctionResetTestRoot
****** these are for test settings ***********/
config/toml.go:612
↓ 36 callersMethodValidate
()
internal/p2p/shim.go:22
↓ 36 callersFunctionnewValidator
(address []byte, power int64)
types/validator_set_test.go:367
↓ 35 callersMethodRemove
(net.Conn)
internal/p2p/conn_set.go:14
↓ 35 callersMethodValidatorUpdates
XXX: panics on nil or unknown pubkey type
types/protobuf.go:36
↓ 34 callersMethodDBDir
DBDir returns the full path to the database directory
config/config.go:323
↓ 34 callersMethodDialed
Dialed marks a peer as successfully dialed. Any further connections will be rejected, and once disconnected the peer may be dialed again.
internal/p2p/peermanager.go:667
↓ 34 callersMethodNewReader
NewReader returns a new group reader. CONTRACT: Caller must close the returned GroupReader.
internal/libs/autofile/group.go:331
↓ 34 callersMethodNext
Next returns the next chunk from the queue, or errDone if all chunks have been returned. It blocks until the chunk is available. Concurrent Next() cal
internal/statesync/chunks.go:248
↓ 34 callersFunctionnewTestEvents
newTestEvents constructs a slice of Event messages by applying newTestEvent to each element of ss.
libs/pubsub/query/query_test.go:264
↓ 33 callersMethodCleanup
(func())
internal/consensus/mocks/cons_sync_reactor.go:32
↓ 33 callersFunctionLogger
Logger option can be used to set a logger for the client.
light/client.go:92
↓ 33 callersMethodNext
Nonblocking, may return nil if at the end.
internal/libs/clist/clist.go:116
↓ 33 callersFunctionNodeSuite
(t *testing.T)
rpc/client/main_test.go:17
↓ 33 callersMethodString
()
libs/pubsub/pubsub.go:75
↓ 33 callersMethodUnmarshal
(dAtA []byte)
rpc/grpc/types.pb.go:535
↓ 33 callersFunctionnewTestScheduler
(params scTestParams)
internal/blocksync/v2/scheduler_test.go:42
↓ 32 callersMethodEquals
(PubKey)
crypto/crypto.go:26
↓ 32 callersMethodSize
()
internal/p2p/pex/addrbook.go:77
↓ 32 callersMethodUpdate
Update informs the mempool that the given txs were committed and can be discarded. NOTE: 1. This should be called *after* block is committed by conse
internal/mempool/mempool.go:65
↓ 32 callersMethodVerify
Verify verifies all the entries in the BatchVerifier, and returns if every signature in the batch is valid, and a vector of bools indicating the verif
crypto/crypto.go:53
↓ 31 callersMethodAddAddress
Add and remove an address
internal/p2p/pex/addrbook.go:47
↓ 31 callersMethodCheck
Check is a method required by the rapid state machine testing library. Check is run after each action and is used to verify that the state of the obje
internal/libs/clist/clist_property_test.go:59
↓ 31 callersMethodMakeBlock
------------------------------------------------------------------------ Create a block from the latest state MakeBlock builds a block from the curren
internal/state/state.go:255
↓ 31 callersMethodValue
Value returns the value of the argument text as a string, or "".
libs/pubsub/query/syntax/parser.go:105
↓ 31 callersFunctionensurePrecommit
(voteCh <-chan tmpubsub.Message, height int64, round int32)
internal/consensus/common_test.go:658
↓ 31 callersFunctionrandState
(cfg *config.Config, nValidators int)
internal/consensus/common_test.go:466
↓ 30 callersFunctionNewBlockStore
NewBlockStore returns a new BlockStore with the given DB, initialized to the last height that was committed to the DB.
internal/store/store.go:39
↓ 30 callersMethodSubscribe
Subscribe subscribes given subscriber to query. Returns a channel with cap=1 onto which events are published. An error is returned if it fails to subs
rpc/client/interface.go:139
↓ 30 callersMethodVerifyLightBlockAtHeight
VerifyLightBlockAtHeight fetches the light block at the given height and verifies it. It returns the block immediately if it exists in the trustedStor
light/client.go:396
↓ 30 callersFunctionensureNewProposal
(proposalCh <-chan tmpubsub.Message, height int64, round int32)
internal/consensus/common_test.go:572
↓ 30 callersFunctionensureNewTimeout
(timeoutCh <-chan tmpubsub.Message, height int64, round int32, timeout int64)
internal/consensus/common_test.go:566
↓ 29 callersFunctionNewNopLogger
()
libs/log/nop.go:7
↓ 29 callersFunctionNodeIDFromPubKey
NodeIDFromPubKey creates a node ID from a given PubKey address.
types/node_id.go:39
↓ 29 callersMethodSize
()
types/vote_set.go:686
↓ 29 callersMethodSizeBytes
SizeBytes returns the total size of all txs in the mempool.
internal/mempool/mempool.go:98
↓ 29 callersMethodStart
Start the service. If it's already started or stopped, will return an error. If OnStart() returns an error, it's returned by Start()
libs/service/service.go:28
↓ 29 callersMethodStatus
peer's info
internal/p2p/peer.go:36
↓ 29 callersFunctioncombineCloseError
(err error, cl closer)
node/setup.go:60
↓ 29 callersFunctionstartTestRound
------------------------------------------------------------------------------- Functions for transitioning the consensus state
internal/consensus/common_test.go:221
↓ 28 callersMethodSize
()
proto/tendermint/consensus/wal.pb.go:245
↓ 28 callersFunctionbz
(s string)
crypto/merkle/proof_test.go:136
↓ 28 callersFunctionsignAddVote
(privVal PrivValidator, vote *Vote, voteSet *VoteSet)
types/test_util.go:39
↓ 27 callersMethodAddListenerForEvent
(listenerID, eventValue string, cb EventCallback)
libs/events/events.go:49
↓ 27 callersMethodDial
Dial creates an outbound connection to an endpoint.
internal/p2p/transport.go:53
↓ 27 callersMethodLightBlock
LightBlock returns the LightBlock that corresponds to the given height. height must be > 0. If LightBlock is not found, ErrLightBlockNotFound is ret
light/store/store.go:25
↓ 27 callersMethodLoadValidators
LoadValidators loads the validator set at a given height
internal/state/store.go:81
↓ 27 callersMethodNewBatch
NewBatch creates a new batch client for this HTTP client.
rpc/client/http/http.go:168
↓ 27 callersFunctionNewCommit
NewCommit returns a new Commit.
types/block.go:764
↓ 27 callersMethodOpen
(dst, nonce, ciphertext, additionalData []byte)
crypto/xchacha20poly1305/xchachapoly.go:82
↓ 27 callersMethodSize
()
internal/state/services.go:21
↓ 27 callersFunctionmockNodeFromHeadersAndVals
(headers map[int64]*types.SignedHeader, vals map[int64]*types.ValidatorSet)
light/helpers_test.go:231
↓ 27 callersFunctionsovTypes
(x uint64)
proto/tendermint/statesync/types.pb.go:1422
↓ 26 callersMethodConsensus
Consensus connection
internal/proxy/multi_app_conn.go:28
↓ 26 callersMethodListen
Listen asynchronously listens for inbound connections on the given endpoint. It must be called exactly once before calling Accept(), and the caller mu
internal/p2p/transport_mconn.go:109
↓ 26 callersMethodPushBack
Panics if list grows beyond its max length.
internal/libs/clist/clist.go:313
↓ 26 callersMethodSign
(msg []byte)
crypto/crypto.go:32
↓ 26 callersMethodSignVote
(ctx context.Context, in *SignVoteRequest, opts ...grpc.CallOption)
proto/tendermint/privval/service.pb.go:62
↓ 26 callersMethodValid
For IPv4 these are either a 0 or all bits set address. For IPv6 a zero address or one that matches the RFC3849 documentation address format.
types/netaddress.go:193
↓ 26 callersMethodWriteMsg
(proto.Message)
internal/libs/protoio/io.go:40
↓ 26 callersFunctionensurePrevoteMatch
(t *testing.T, voteCh <-chan tmpubsub.Message, height int64, round int32, hash []byte)
internal/consensus/common_test.go:666
↓ 26 callersFunctionrandVoteSet
NOTE: privValidators are in order
types/vote_set_test.go:480
↓ 25 callersMethodAddSnapshot
AddSnapshot adds a snapshot to the snapshot pool. It returns true if a new, previously unseen snapshot was accepted and added.
internal/statesync/syncer.go:129
↓ 25 callersMethodChainID
()
light/rpc/client.go:30
↓ 25 callersFunctionDefaultConsensusParams
DefaultConsensusParams returns a default ConsensusParams.
types/params.go:79
↓ 25 callersMethodFront
()
internal/libs/clist/clist.go:257
↓ 25 callersMethodIncrementProposerPriority
IncrementProposerPriority increments ProposerPriority of each validator and updates the proposer. Panics if validator set is empty. `times` must be po
types/validator_set.go:116
↓ 25 callersFunctionNewValidator
NewValidator returns a new validator with the given pubkey and voting power.
types/validator.go:26
↓ 25 callersMethodRemoteAddr
remote IP of the connection
internal/p2p/peer.go:28
↓ 25 callersMethodStop
Stop the service. If it's already stopped, will return an error. OnStop must never error.
libs/service/service.go:34
↓ 25 callersFunctioncleanup
(cfg TestHarnessConfig)
tools/tm-signer-harness/internal/test_harness_test.go:183
↓ 25 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/statesync/types.pb.go:1174
↓ 25 callersFunctionincrementRound
(vss ...*validatorStub)
internal/consensus/common_test.go:182
↓ 25 callersFunctionmakeCloser
(cs []closer)
node/setup.go:45
↓ 25 callersFunctionsovTypes
(x uint64)
proto/tendermint/privval/types.pb.go:1619
↓ 25 callersFunctionsovTypes
(x uint64)
proto/tendermint/state/types.pb.go:925
↓ 25 callersFunctionvalidatePrecommit
( t *testing.T, cs *State, thisRound, lockRound int32, privVal *validatorStub, votedBlockHash, lockedBl
internal/consensus/common_test.go:307
↓ 25 callersFunctionwithValidator
Convenience: Return new vote with different validator address/index
types/vote_set_test.go:519
↓ 24 callersMethodLoadBlockMeta
(height int64)
internal/evidence/services.go:10
↓ 24 callersFunctionNewAddrBook
NewAddrBook creates a new address book. Use Start to begin processing asynchronous address updates.
internal/p2p/pex/addrbook.go:121
↓ 24 callersFunctionNewMockDuplicateVoteEvidenceWithValidator
assumes voting power to be 10 and validator to be the only one in the set
types/evidence.go:680
↓ 24 callersFunctionNopMetrics
NopMetrics constructs a Metrics instance that discards all samples and is suitable for testing.
internal/proxy/metrics.go:43
↓ 24 callersFunctionQueryForEvent
(eventValue string)
types/events.go:238
↓ 24 callersMethodRead
Read reads up to len(p) bytes into p without exceeding the current transfer rate limit. It returns (0, nil) immediately if r is non-blocking and no ne
internal/libs/flowrate/io.go:44
↓ 24 callersMethodTwoThirdsMajority
If there was a +2/3 majority for blockID, return blockID and true. Else, return the empty BlockID{} and false.
types/vote_set.go:450
↓ 24 callersMethodVerifySignature
(msg []byte, sig []byte)
crypto/crypto.go:25
↓ 23 callersMethodCleanup
(func())
light/provider/mocks/provider.go:57
↓ 23 callersFunctionGetClients
GetClients returns a slice of clients for table-driven tests
rpc/client/rpc_test.go:56
↓ 23 callersFunctionNewAppConns
NewAppConns calls NewMultiAppConn.
internal/proxy/multi_app_conn.go:36
↓ 23 callersMethodSub
Sub subtracts the two bit-arrays bitwise, without carrying the bits. Note that carryless subtraction of a - b is (a and not b). The output is the same
libs/bits/bit_array.go:187
↓ 23 callersMethodToValidators
GenSecpPrivKeys produces an array of secp256k1 private keys to generate commits. func GenSecpPrivKeys(n int) privKeys { res := make(privKeys, n) for
light/helpers_test.go:68
↓ 23 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/privval/types.pb.go:1359
↓ 23 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/state/types.pb.go:793
↓ 23 callersFunctiontestValSet
(nVals int, power int64)
types/validator_set_test.go:817
↓ 22 callersMethodHas
(net.Conn)
internal/p2p/conn_set.go:11
↓ 22 callersMethodNetAddress
NetAddress returns the first address the switch is listening on, or nil if no addresses are found.
internal/p2p/switch.go:125
↓ 22 callersFunctionNow
Now returns the current time in UTC with no monotonic component.
libs/time/time.go:8
← previousnext →101–200 of 9,600, ranked by callers