MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 7 callersMethodSetLogger
SetLogger implements Service.
internal/consensus/state.go:205
↓ 7 callersMethodStop
()
internal/p2p/conn/connection_test.go:587
↓ 7 callersMethodString
String representation of the service
libs/service/service.go:49
↓ 7 callersMethodSubscribe
( ctx context.Context, subscriber string, query tmpubsub.Query, outCapacity ...int, )
types/event_bus.go:77
↓ 7 callersMethodToProto
ToProto encodes DuplicateVoteEvidence to protobuf
types/evidence.go:187
↓ 7 callersMethodTx
(ctx context.Context, hash bytes.HexBytes, prove bool)
rpc/client/interface.go:85
↓ 7 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/state/types.pb.go:1421
↓ 7 callersMethodVerifyCommitLightTrusting
VerifyCommitLightTrusting verifies that trustLevel of the validator set signed this commit.
types/validator_set.go:672
↓ 7 callersMethodWaitFor
WaitFor returns a channel that receives a chunk index when it arrives in the queue, or immediately if it has already arrived. The channel is closed wi
internal/statesync/chunks.go:332
↓ 7 callersMethodWaitSync
WaitSync returns whether the consensus reactor is waiting for state/block sync.
internal/consensus/reactor.go:257
↓ 7 callersFunctionbenchmarkWalDecode
(b *testing.B, n int)
internal/consensus/wal_test.go:231
↓ 7 callersFunctionblockCommitKey
(height int64)
internal/store/store.go:622
↓ 7 callersFunctioncheckResult
Wait for result
libs/async/async_test.go:132
↓ 7 callersFunctioncreateNewValidatorList
(testValList []testVal)
types/validator_set_test.go:764
↓ 7 callersFunctioncreateTestGroupWithHeadSizeLimit
(t *testing.T, headSizeLimit int64)
internal/libs/autofile/group_test.go:17
↓ 7 callersFunctiondestroyTestGroup
(t *testing.T, g *Group)
internal/libs/autofile/group_test.go:31
↓ 7 callersFunctionencodeVarintConn
(dAtA []byte, offset int, v uint64)
proto/tendermint/p2p/conn.pb.go:574
↓ 7 callersMethodenqueue
enqueue returns a channel for submitting envelopes.
internal/p2p/queue.go:17
↓ 7 callersFunctionensureNewEventOnChannel
(ch <-chan tmpubsub.Message)
internal/consensus/common_test.go:731
↓ 7 callersFunctionexpectSend
(ch chan struct{})
internal/p2p/conn/connection_test.go:420
↓ 7 callersMethodisRunning
()
internal/blocksync/v2/routine.go:136
↓ 7 callersFunctionmakeBlockID
(hash []byte, partSetSize uint32, partSetHash []byte)
internal/evidence/verify_test.go:578
↓ 7 callersFunctionnewBlockQueue
( startHeight, stopHeight, initialHeight int64, stopTime time.Time, maxRetries int, )
internal/statesync/block_queue.go:48
↓ 7 callersFunctionnewPeerConn
(outbound, persistent bool, conn Connection)
internal/p2p/peer.go:56
↓ 7 callersFunctionnewVote
(addr types.Address, idx int32, height int64, round int32, typ tmproto.SignedMsgType, blockID types.BlockID)
privval/file_test.go:332
↓ 7 callersFunctionrandCommit
(now time.Time)
types/block_test.go:443
↓ 7 callersMethodretry
Retry is called when a dispatcher failed to fetch a light block or the fetched light block failed verification. It signals to the queue to add the hei
internal/statesync/block_queue.go:171
↓ 7 callersFunctionskipPex
(dAtA []byte)
proto/tendermint/p2p/pex.pb.go:1604
↓ 7 callersMethodstopForError
(r interface{})
internal/p2p/conn/connection.go:350
↓ 7 callersFunctiontoTestValList
(valList []*Validator)
types/validator_set_test.go:808
↓ 7 callersMethodupdateRoundStep
(round int32, step cstypes.RoundStepType)
internal/consensus/state.go:575
↓ 7 callersMethodvalidatePerPage
(perPagePtr *int)
internal/rpc/core/env.go:135
↓ 7 callersFunctionwaitForAndValidateBlockWithTx
( t *testing.T, n int, activeVals map[string]struct{}, blocksSubs []types.Subscription, states []*State,
internal/consensus/reactor_test.go:185
↓ 6 callersMethodAbsent
Absent returns true if CommitSig is absent.
types/block.go:641
↓ 6 callersMethodAddPersistentPeers
([]string)
internal/rpc/core/env.go:55
↓ 6 callersMethodBeginBlock
Initialize blockchain w validators/other info from TendermintCore
abci/types/application.go:21
↓ 6 callersMethodBlockByHash
(ctx context.Context, hash bytes.HexBytes)
rpc/client/interface.go:79
↓ 6 callersMethodBroadcast
--------------------------------------------------------------------- Peers Broadcast runs a go routine for each attempted send, which will block tryi
internal/p2p/switch.go:313
↓ 6 callersFunctionCReader
Returns a crand.Reader.
crypto/random.go:33
↓ 6 callersMethodCloseConn
do we redial this peer when we disconnect
internal/p2p/peer.go:33
↓ 6 callersMethodCommit
Commit returns the commit at the given height.
internal/statesync/stateprovider.go:38
↓ 6 callersMethodCount
Count returns the number of enqueued requests waiting to be sent.
rpc/client/http/http.go:196
↓ 6 callersMethodCreate
Create creates a snapshot of the given application state's key/value pairs.
test/e2e/app/snapshots.go:86
↓ 6 callersMethodDeliverTxSync
(context.Context, types.RequestDeliverTx)
abci/client/client.go:54
↓ 6 callersMethodDetachPrev
()
internal/libs/clist/clist.go:148
↓ 6 callersMethodDone
Done returns the internal done channel allowing the caller either block or wait for the Closer to be terminated/closed.
internal/libs/sync/closer.go:21
↓ 6 callersMethodDumpConsensusState
(context.Context)
rpc/client/interface.go:123
↓ 6 callersMethodEndBlock
Deliver a tx for full processing
abci/types/application.go:23
↓ 6 callersFunctionGenesisDocFromFile
GenesisDocFromFile reads JSON data from a file and unmarshalls it into a GenesisDoc.
types/genesis.go:127
↓ 6 callersMethodGetAddress
GetAddress returns the address of the validator. Implements PrivValidator.
privval/file.go:257
↓ 6 callersMethodGetChunkResponse
()
proto/tendermint/statesync/types.pb.go:141
↓ 6 callersMethodGetForPeer
GetForPeer returns an ID reserved for the peer.
internal/mempool/ids.go:53
↓ 6 callersMethodGetResponse
GetResponse will generate the apporiate response for us, when using the Call struct to configure a Mock handler. When configuring a response, if only
rpc/client/mock/client.go:59
↓ 6 callersMethodHandshake
TODO: retry the handshake/replay if it fails ?
internal/consensus/replay.go:242
↓ 6 callersMethodHasHeader
(header PartSetHeader)
types/part_set.go:218
↓ 6 callersMethodID
--------------------------------------------------- Implements Peer ID returns the peer's ID - the hex encoded hash of its pubkey.
internal/p2p/peer.go:206
↓ 6 callersFunctionKVSinkEnabled
KVSinkEnabled returns the given eventSinks is containing KVEventSink.
internal/state/indexer/indexer_service.go:150
↓ 6 callersMethodLastLightBlockHeight
LastLightBlockHeight returns the last (newest) LightBlock height. If the store is empty, -1 and nil error are returned.
light/store/store.go:30
↓ 6 callersMethodLightBlockBefore
LightBlockBefore returns the LightBlock before a certain height. height must be > 0 && <= LastLightBlockHeight.
light/store/store.go:40
↓ 6 callersFunctionLightBlockFromProto
LightBlockFromProto converts from protobuf back into the Lightblock. An error is returned if either the validator set or signed header are invalid
types/light.go:88
↓ 6 callersMethodLimit
Limit restricts the instantaneous (per-sample) data flow to rate bytes per second. It returns the maximum number of bytes (0 <= n <= want) that may be
internal/libs/flowrate/flowrate.go:177
↓ 6 callersMethodLoadSeenCommit
()
internal/state/services.go:36
↓ 6 callersFunctionMakeBlock
(state sm.State, height int64, c *types.Commit)
internal/state/test/factory/block.go:38
↓ 6 callersMethodMakeChannels
MakeChannels makes a channel on all nodes and returns them, automatically doing error checks and cleanups.
internal/p2p/p2ptest/network.go:136
↓ 6 callersFunctionMakeRandHeader
exposed for testing
types/block_test.go:753
↓ 6 callersMethodMarkBad
(*p2p.NetAddress, time.Duration)
internal/p2p/pex/addrbook.go:65
↓ 6 callersMethodMarshal
()
proto/tendermint/types/params.pb.go:664
↓ 6 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/types/validator.pb.go:311
↓ 6 callersFunctionNewChannel
NewChannel creates a new channel. It is primarily for internal and test use, reactors should use Router.OpenChannel().
internal/p2p/router.go:78
↓ 6 callersFunctionNewEndpoint
NewEndpoint constructs an Endpoint from a types.NetAddress structure.
internal/p2p/transport.go:160
↓ 6 callersFunctionNewHandshaker
(stateStore sm.Store, state sm.State, store sm.BlockStore, genDoc *types.GenesisDoc)
internal/consensus/replay.go:212
↓ 6 callersFunctionNewPartSetFromData
Returns an immutable, full PartSet from the data bytes. The data bytes are split into "partSize" chunks, and merkle tree computed. CONTRACT: partSize
types/part_set.go:166
↓ 6 callersFunctionNewRPCErrorResponse
(id jsonrpcid, code int, msg string, data string)
rpc/jsonrpc/types/types.go:202
↓ 6 callersFunctionNewTrustMetricStore
NewTrustMetricStore returns a store that saves data to the DB and uses the config when creating new trust metrics. Use Start to to initialize the trus
internal/p2p/trust/store.go:41
↓ 6 callersFunctionNewWAL
NewWAL returns a new write-ahead logger based on `baseWAL`, which implements WAL. It's flushed and synced to disk every 2s and once when stopped.
internal/consensus/wal.go:91
↓ 6 callersFunctionNewWS
NewWS returns a new client. The endpoint argument must begin with a `/`. An error is returned on invalid remote. It uses DefaultWSOptions.
rpc/jsonrpc/client/ws_client.go:95
↓ 6 callersMethodNodeAddress
NodeAddress converts the endpoint into a NodeAddress for the given node ID.
internal/p2p/transport.go:169
↓ 6 callersFunctionNopMetrics
NopMetrics returns no-op Metrics.
internal/mempool/metrics.go:99
↓ 6 callersMethodOnStart
()
libs/service/service.go:29
↓ 6 callersFunctionParseDate
ParseDate parses s as a date string in the format used by DATE values.
libs/pubsub/query/syntax/parser.go:206
↓ 6 callersFunctionParseTime
ParseTime parses s as a timestamp in the format used by TIME values.
libs/pubsub/query/syntax/parser.go:211
↓ 6 callersMethodPrevote
Prevote returns the amount of time to wait for straggler votes after receiving any +2/3 prevotes
config/config.go:1199
↓ 6 callersMethodRead
(buf []byte)
crypto/internal/benchmarking/bench.go:18
↓ 6 callersMethodRequestAddrs
RequestAddrs asks peer for more addresses if we do not already have a request out for this peer.
internal/p2p/pex/pex_reactor.go:344
↓ 6 callersFunctionRequireUpdate
RequireUpdate requires that a PeerUpdates subscription yields the given update.
internal/p2p/p2ptest/require.go:117
↓ 6 callersMethodReserveForPeer
ReserveForPeer searches for the next unused ID and assigns it to the provided peer.
internal/mempool/ids.go:31
↓ 6 callersFunctionRunWithArgs
RunWithArgs executes the given command with the specified command line args and environmental variables set. It returns any error returned from cmd.Ex
libs/cli/helper.go:27
↓ 6 callersMethodSaveAs
SaveAs persists the NodeKey to filePath.
types/node_key.go:31
↓ 6 callersMethodSearch
Search performs a search using the given query. It breaks the query into conditions (like "tx.height > 5"). For each condition, it queries the DB ind
internal/state/indexer/tx/kv/kv.go:140
↓ 6 callersMethodSetLogger
SetLogger sets the logger.
rpc/jsonrpc/server/ws_handler.go:69
↓ 6 callersMethodSetPrivValidator
SetPrivValidator sets the private validator account for signing votes. It immediately requests pubkey and caches it.
internal/consensus/state.go:277
↓ 6 callersMethodSetWriteDeadline
(t time.Time)
privval/secret_connection.go:287
↓ 6 callersFunctionSha256
(bytes []byte)
crypto/hash.go:7
↓ 6 callersMethodState
State returns a state object at the given height.
internal/statesync/stateprovider.go:40
↓ 6 callersMethodStateless
Stateless returns true if the node is either a seed node or a light node
test/e2e/pkg/testnet.go:479
↓ 6 callersMethodStatus
Status returns the status for a peer, primarily for testing.
internal/p2p/peermanager.go:1220
↓ 6 callersMethodStatus
()
internal/libs/flowrate/io.go:20
↓ 6 callersMethodStore
()
internal/state/execution.go:88
↓ 6 callersMethodStringIndented
StringIndented returns an indented string representation of the transactions.
types/block.go:1024
↓ 6 callersFunctionToRequestEcho
----------------------------------------
abci/types/messages.go:29
← previousnext →701–800 of 9,600, ranked by callers