MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 22 callersMethodReset
Reset the service. Panics by default - must be overwritten to enable reset.
libs/service/service.go:39
↓ 22 callersMethodSize
Size returns a number of currently existing header & validator set pairs.
light/store/store.go:47
↓ 22 callersMethodToProto
ToProto converts Proposal to protobuf
types/proposal.go:121
↓ 22 callersFunctionmakeBlockID
(hash []byte, partSetSize uint32, partSetHash []byte)
types/block_test.go:198
↓ 22 callersFunctionsovTypes
(x uint64)
proto/tendermint/p2p/types.pb.go:843
↓ 21 callersMethodGenesisFile
GenesisFile returns the full path to the genesis.json file
config/config.go:278
↓ 21 callersMethodKeyFile
()
config/config.go:639
↓ 21 callersFunctionMakeValSetChangeTx
(pubkey cryptoproto.PublicKey, power int64)
abci/example/kvstore/persistent_kvstore.go:197
↓ 21 callersFunctionNopMetrics
NopMetrics returns no-op Metrics.
internal/p2p/metrics.go:203
↓ 21 callersMethodReset
Reset resets the cache to an empty state.
internal/mempool/cache.go:17
↓ 21 callersMethodsend
XXX: look into returning OpError in the net package
internal/blocksync/v2/routine.go:120
↓ 21 callersFunctionsetup
( t *testing.T, conn *proxymocks.AppConnSnapshot, connQuery *proxymocks.AppConnQuery, stateProvider *mocks
internal/statesync/reactor_test.go:71
↓ 20 callersMethodAddr
()
internal/p2p/peer_test.go:150
↓ 20 callersMethodAddr
Addr returns the NetAddress for the rejected Peer.
internal/p2p/errors.go:33
↓ 20 callersMethodCopyIncrementProposerPriority
CopyIncrementProposerPriority increments ProposerPriority and updates the proposer on a copy, and returns it.
types/validator_set.go:107
↓ 20 callersMethodDeliverTx
Signals the beginning of a block
abci/types/application.go:22
↓ 20 callersMethodFlushAndSync
()
internal/consensus/wal.go:61
↓ 20 callersMethodLoad
Load loads the current state of the blockchain
internal/state/store.go:79
↓ 20 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/privval/types.pb.go:1134
↓ 20 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/consensus/types.pb.go:1108
↓ 20 callersMethodRemove
Remove removes the given raw transaction from the cache.
internal/mempool/cache.go:24
↓ 20 callersMethodSubscribe
Subscribe creates a subscription for the given client. An error will be returned to the caller if the context is canceled or if subscription already
libs/pubsub/pubsub.go:174
↓ 20 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/p2p/types.pb.go:710
↓ 20 callersFunctionmakeKey
(t *testing.T, elems ...interface{})
scripts/keymigrate/migrate_test.go:12
↓ 20 callersFunctionmustWrapMsg
TODO: Add ChainIDRequest
privval/msgs.go:13
↓ 19 callersMethodBroadcastTxCommit
Writing to abci app
rpc/client/interface.go:70
↓ 19 callersMethodIsErr
IsErr returns true if Code is something other than OK.
abci/types/result.go:43
↓ 19 callersMethodIsZero
IsZero returns true if this is the BlockID of a nil block.
types/block.go:1208
↓ 19 callersFunctionNewDelimitedWriter
NewDelimitedWriter writes a varint-delimited Protobuf message to a writer. It is equivalent to the gogoproto NewDelimitedWriter, except WriteMsg() als
internal/libs/protoio/writer.go:45
↓ 19 callersFunctionNewNodeID
NewNodeID returns a lowercased (normalized) NodeID, or errors if the node ID is invalid.
types/node_id.go:26
↓ 19 callersFunctionNewPool
NewPool creates an evidence pool. If using an existing evidence store, it will add all pending evidence to the concurrent list.
internal/evidence/pool.go:56
↓ 19 callersMethodReadMsg
(msg proto.Message)
internal/libs/protoio/io.go:49
↓ 19 callersMethodSend
actual address of the socket
internal/p2p/peer.go:39
↓ 19 callersMethodSetIndex
SetIndex sets the bit at index i within the bit array. The behavior is undefined if i >= bA.Bits
libs/bits/bit_array.go:67
↓ 19 callersMethodStateFile
StateFile returns the full path to the priv_validator_state.json file
config/config.go:428
↓ 19 callersMethodStop
Stop will close the data store connection, if the eventsink supports it.
internal/state/indexer/eventsink.go:55
↓ 19 callersMethodStop
Stop the client. Stop must report an error if the client is not running.
rpc/client/interface.go:41
↓ 19 callersMethodWriteSync
(WALMessage)
internal/consensus/wal.go:60
↓ 19 callersFunctionmakeCommit
(blockID BlockID, height int64, round int32, voteSet *VoteSet, validators []PrivValidator, now time.Time)
types/test_util.go:11
↓ 19 callersFunctionwriteStr
(w io.Writer, s string)
libs/json/encoder.go:251
↓ 18 callersMethodBase
()
internal/state/services.go:19
↓ 18 callersMethodChoose
(r *rand.Rand)
test/e2e/generator/random.go:57
↓ 18 callersMethodCompare
(other queue.Item)
internal/blocksync/v2/types.go:11
↓ 18 callersMethodDelete
Delete deletes a peer, or does nothing if it does not exist.
internal/p2p/peermanager.go:1404
↓ 18 callersMethodDisconnected
Disconnected unmarks a peer as connected, allowing it to be dialed or accepted again as appropriate.
internal/p2p/peermanager.go:880
↓ 18 callersFunctionExit
(s string)
libs/os/os.go:32
↓ 18 callersMethodKey
Key produces a fixed-length key for use in indexing.
types/tx.go:21
↓ 18 callersFunctionNewDelimitedReader
NewDelimitedReader reads varint-delimited Protobuf messages from a reader. Unlike the gogoproto NewDelimitedReader, this does not buffer the reader, w
internal/libs/protoio/reader.go:47
↓ 18 callersFunctionNewNetAddressString
NewNetAddressString returns a new NetAddress using the provided address in the form of "ID@IP:Port". Also resolves the host if host is not an IP. Erro
types/netaddress.go:69
↓ 18 callersFunctionNewRPCFunc
NewRPCFunc wraps a function for introspection. f is the function, args are comma separated argument names cache is a bool value to allow the client pr
rpc/jsonrpc/server/rpc_func.go:40
↓ 18 callersMethodSignProposal
(ctx context.Context, in *SignProposalRequest, opts ...grpc.CallOption)
proto/tendermint/privval/service.pb.go:63
↓ 18 callersFunctionVoteSignBytes
VoteSignBytes returns the proto-encoding of the canonicalized Vote, for signing. Panics is the marshaling fails. The encoded Protobuf message is vari
types/vote.go:93
↓ 18 callersFunctionmakeBlockIDRandom
()
types/block_test.go:188
↓ 18 callersFunctionmustWrapPacket
---------------------------------------- Packet mustWrapPacket takes a packet kind (oneof) and wraps it in a tmp2p.Packet message.
internal/p2p/conn/connection.go:908
↓ 17 callersMethodAddReactor
--------------------------------------------------------------------- Switch setup AddReactor adds the given reactor to the switch. NOTE: Not goroutin
internal/p2p/switch.go:199
↓ 17 callersMethodClose
Close closes the peer manager, releasing resources (i.e. goroutines).
internal/p2p/peermanager.go:1174
↓ 17 callersMethodFlush
Flush removes all transactions from the mempool and caches.
internal/mempool/mempool.go:81
↓ 17 callersFunctionMakeSwitch
( cfg *config.P2PConfig, i int, network, version string, initSwitch func(int, *Switch) *Switch, logger lo
internal/p2p/test_util.go:164
↓ 17 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/types/types.pb.go:1188
↓ 17 callersFunctionMustNewDefaultLogger
MustNewDefaultLogger delegates a call NewDefaultLogger where it panics on error.
libs/log/default.go:68
↓ 17 callersMethodPrevotes
(round int32)
internal/consensus/types/height_vote_set.go:138
↓ 17 callersMethodPublish
(eventValue string, eventData TMEventData)
types/event_bus.go:104
↓ 17 callersMethodRemove
(key []byte)
crypto/merkle/types.go:17
↓ 17 callersFunctionRequireSend
RequireSend requires that the given envelope is sent on the channel.
internal/p2p/p2ptest/require.go:72
↓ 17 callersFunctionResetConfig
(name string)
internal/consensus/common_test.go:82
↓ 17 callersMethodSetProposalAndBlock
SetProposalAndBlock inputs the proposal and all block parts.
internal/consensus/state.go:546
↓ 17 callersMethodStart
()
internal/p2p/peer_test.go:158
↓ 17 callersMethodStringShort
StringShort returns a string
internal/consensus/types/round_state.go:212
↓ 17 callersMethodTxSearch
TxSearch defines a method to search for a paginated set of transactions by DeliverTx event search criteria.
rpc/client/interface.go:89
↓ 17 callersMethodUpdateWithChangeSet
UpdateWithChangeSet attempts to update the validator set with 'changes'. It performs the following steps: - validates the changes making sure there ar
types/validator_set.go:651
↓ 17 callersFunctionwaitForAndValidateBlock
( t *testing.T, n int, activeVals map[string]struct{}, blocksSubs []types.Subscription, states []*State,
internal/consensus/reactor_test.go:152
↓ 16 callersMethodAllocate
Allocate allocates a chunk to the caller, making it responsible for fetching it. Returns errDone once no chunks are left or the queue is closed.
internal/statesync/chunks.go:111
↓ 16 callersMethodBlock
(ctx context.Context, height *int64)
rpc/client/interface.go:78
↓ 16 callersMethodClient
Client returns an RPC client for a node.
test/e2e/pkg/testnet.go:474
↓ 16 callersMethodContains
(id types.NodeID)
internal/statesync/dispatcher.go:301
↓ 16 callersMethodCopy
Copy each validator into a new ValidatorSet.
types/validator_set.go:249
↓ 16 callersMethodDecode
Decode reads the next custom-encoded value from its reader and returns it.
internal/consensus/wal.go:365
↓ 16 callersMethodFireEvent
(eventValue string, data EventData)
libs/events/events.go:35
↓ 16 callersMethodHandshake
Handshake executes a node handshake with the remote peer. It must be called immediately after the connection is established, and returns the remote pe
internal/p2p/transport.go:88
↓ 16 callersMethodHasAddress
Check if the address is in the book
internal/p2p/pex/addrbook.go:51
↓ 16 callersMethodIsZero
()
internal/p2p/router.go:43
↓ 16 callersFunctionMakeBlock
MakeBlock returns a new block with an empty header, except what can be computed from itself. It populates the same set of fields validated by Validate
types/block.go:310
↓ 16 callersMethodPrecommit
Precommit returns the amount of time to wait for straggler votes after receiving any +2/3 precommits
config/config.go:1206
↓ 16 callersMethodQuery
Return application info
abci/types/application.go:14
↓ 16 callersFunctionRandValidatorSet
(numValidators int, votingPower int64)
internal/test/factory/validator.go:27
↓ 16 callersMethodSignVote
(ctx context.Context, chainID string, vote *tmproto.Vote)
types/priv_validator.go:31
↓ 16 callersMethodTryEvictNext
TryEvictNext is equivalent to EvictNext, but immediately returns an empty node ID if no evictable peers are found.
internal/p2p/peermanager.go:844
↓ 16 callersMethodUnmarshal
(dAtA []byte)
abci/types/types.pb.go:12041
↓ 16 callersFunctionaddTimeSample
addTimeSample returns a function that, when called, adds an observation to m. The observation added to m is the number of seconds ellapsed since addTi
internal/proxy/app_conn.go:247
↓ 15 callersMethodAccept
Accept waits for the next inbound connection on a listening endpoint, blocking until either a connection is available or the transport is closed. On c
internal/p2p/transport.go:50
↓ 15 callersMethodCommitSig
CommitSig converts the Vote to a CommitSig.
types/vote.go:62
↓ 15 callersMethodFirstError
Returns the firstmost (by task index) error as discovered by all previous Reap() calls.
libs/async/async.go:110
↓ 15 callersMethodGetPart
(index int)
types/part_set.go:296
↓ 15 callersMethodGetValue
()
abci/types/types.pb.go:1281
↓ 15 callersFunctionMakeTxKV
MakeTxKV returns a text transaction, allong with expected key, value pair
rpc/client/event_test.go:23
↓ 15 callersMethodMarshal
()
rpc/grpc/types.pb.go:347
↓ 15 callersFunctionNewEventBus
NewEventBus returns a new event bus.
types/event_bus.go:41
↓ 15 callersFunctionNewRouter
NewRouter creates a new Router. The given Transports must already be listening on appropriate interfaces, and will be closed by the Router when it sto
internal/p2p/router.go:276
↓ 15 callersFunctionNewServer
NewServer returns a new server. See the commentary on the Option functions for a detailed description of how to configure buffering. If no options are
libs/pubsub/pubsub.go:133
↓ 15 callersMethodPrecommits
(round int32)
internal/consensus/types/height_vote_set.go:144
← previousnext →201–300 of 9,600, ranked by callers