MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

⨍ Functions 9,600◇ Types & classes 1,209
↓ 1 callersMethodstart
()
internal/blocksync/v0/pool_test.go:54
↓ 1 callersFunctionstartApp
startApp starts the application server, listening for connections from Tendermint.
test/e2e/node/main.go:100
↓ 1 callersFunctionstartLightNode
(cfg *Config)
test/e2e/node/main.go:158
↓ 1 callersFunctionstartNewStateAndWaitForBlock
These tests ensure we can always recover from failure at any part of the consensus process. There are two general failure scenarios: failure during co
internal/consensus/replay_test.go:57
↓ 1 callersFunctionstartNode
startNode starts a Tendermint node running the application directly. It assumes the Tendermint configuration is in $TMHOME/config/tendermint.toml. FI
test/e2e/node/main.go:121
↓ 1 callersMethodstartPrometheusServer
startPrometheusServer starts a Prometheus HTTP server, listening for metrics collectors on addr.
node/node.go:1037
↓ 1 callersMethodstartRPC
()
node/node.go:909
↓ 1 callersFunctionstartRPCServers
(ctx context.Context, cfg *config.RPCConfig, logger log.Logger, routes rpccore.RoutesMap)
internal/inspect/inspect.go:110
↓ 1 callersFunctionstartSeedNode
(cfg *Config)
test/e2e/node/main.go:143
↓ 1 callersFunctionstartSigner
startSigner starts a signer server connecting to the given endpoint.
test/e2e/node/main.go:216
↓ 1 callersMethodstop
()
internal/blocksync/v0/pool_test.go:60
↓ 1 callersMethodstringIndented
(indent string)
libs/bits/bit_array.go:316
↓ 1 callersMethodsubscribeToBroadcastEvents
subscribeToBroadcastEvents subscribes for new round steps and votes using the internal pubsub defined in the consensus state to broadcast them to peer
internal/consensus/reactor.go:395
↓ 1 callersMethodsynced
synced returns true when at most the last verified block remains in the queue
internal/blocksync/v2/processor.go:93
↓ 1 callersMethodtargetSyncBlocks
()
internal/blocksync/v0/pool.go:451
↓ 1 callersFunctiontcpListenerTestCase
(t *testing.T, timeoutAccept, timeoutReadWrite time.Duration)
privval/socket_listeners_test.go:42
↓ 1 callersFunctiontestABCIPubKey
(t *testing.T, pk crypto.PubKey, typeStr string)
types/protobuf_test.go:21
↓ 1 callersFunctiontestDial
(addr *NetAddress, cfg *config.P2PConfig)
internal/p2p/peer_test.go:103
↓ 1 callersFunctiontestGRPCSync
(t *testing.T, app types.ABCIApplicationServer)
abci/example/example_test.go:131
↓ 1 callersFunctiontestHairpin
(listener net.Listener, extAddr string, logger log.Logger)
internal/p2p/upnp/probe.go:43
↓ 1 callersFunctiontestNodeInfoWithNetwork
(id NodeID, name, network string)
types/node_info_test.go:104
↓ 1 callersFunctiontestNodeInfoWithNetwork
(id types.NodeID, name, network string)
internal/p2p/test_util.go:234
↓ 1 callersFunctiontestOutboundPeerConn
( transport *MConnTransport, addr *NetAddress, config *config.P2PConfig, persistent bool, ourNodePrivKey
internal/p2p/peer_test.go:115
↓ 1 callersFunctiontestTxProofUnchangable
(t *testing.T)
types/tx_test.go:109
↓ 1 callersFunctiontestWithWSClient
(t *testing.T, cl *client.WSClient)
rpc/jsonrpc/jsonrpc_test.go:253
↓ 1 callersMethodtimeoutRoutine
send on tickChan to start a new timer. timers are interupted and replaced by new ticks from later steps timeouts of 0 on the tickChan will be immediat
internal/consensus/ticker.go:94
↓ 1 callersMethodtoAllRoundVotes
()
internal/consensus/types/height_vote_set.go:243
↓ 1 callersMethodtoBytes
()
types/validator_set_test.go:409
↓ 1 callersFunctiontokLabel
tokLabel makes a human-readable summary string for the given token types.
libs/pubsub/query/syntax/parser.go:193
↓ 1 callersMethodtriggerReconnect
()
privval/signer_listener_endpoint.go:170
↓ 1 callersMethodtryAddVote
Attempt to add the vote. if its a duplicate signature, dupeout the validator
internal/consensus/state.go:2001
↓ 1 callersMethodtrySendBytes
Queues message to send to this channel. Nonblocking, returns true if successful. Goroutine-safe
internal/p2p/conn/connection.go:818
↓ 1 callersMethodtrySwitchToConsensus
(state state.State, skipWAL bool)
internal/blocksync/v2/io.go:26
↓ 1 callersFunctiontxResultWithEvents
txResultWithEvents constructs a fresh transaction result with fixed values for testing, that includes the specified events.
internal/state/indexer/sink/psql/psql_test.go:258
↓ 1 callersFunctionunixListenerTestCase
(t *testing.T, timeoutAccept, timeoutReadWrite time.Duration)
privval/socket_listeners_test.go:58
↓ 1 callersFunctionunmarshalResponseBytesArray
( responseBytes []byte, expectedIDs []rpctypes.JSONRPCIntID, results []interface{}, )
rpc/jsonrpc/client/decode.go:41
↓ 1 callersFunctionunmarshalSize
(bz []byte)
light/store/db/db.go:318
↓ 1 callersMethodunsubscribeFromBroadcastEvents
()
internal/consensus/reactor.go:434
↓ 1 callersMethodupdateFadedMemory
Performs the update for our Faded Memories process, which allows the trust metric tracking window to be large while maintaining a small number of hist
internal/p2p/trust/metric.go:390
↓ 1 callersMethodupdateHeight
------------------------------------------------------------ internal functions for managing the state
internal/consensus/state.go:570
↓ 1 callersMethodupdateMaxPeerHeight
If no peers are left, maxPeerHeight is set to 0.
internal/blocksync/v0/pool.go:361
↓ 1 callersMethodupdateRoundStateRoutine
()
internal/consensus/reactor.go:461
↓ 1 callersMethodupdateState
(state sm.State)
internal/evidence/pool.go:506
↓ 1 callersMethodupdateStats
Call this periodically to update stats for throttling purposes. Not goroutine-safe
internal/p2p/conn/connection.go:898
↓ 1 callersFunctionvalSetTotalProposerPriority
(valSet *ValidatorSet)
types/validator_set_test.go:776
↓ 1 callersFunctionvalidateAndVerifyID
From the JSON-RPC 2.0 spec: id: It MUST be the same as the value of the id member in the Request Object.
rpc/jsonrpc/client/decode.go:107
↓ 1 callersFunctionvalidateBlock
----------------------------------------------------- Validate block
internal/state/validation.go:14
↓ 1 callersFunctionvalidateHeight
(height int64)
light/provider/http/http.go:320
↓ 1 callersFunctionvalidateLastPrecommit
(t *testing.T, cs *State, privVal *validatorStub, blockHash []byte)
internal/consensus/common_test.go:293
↓ 1 callersFunctionvalidatePage
(pagePtr *int, perPage, totalCount int)
light/rpc/client.go:673
↓ 1 callersFunctionvalidatePerPage
(perPagePtr *int)
light/rpc/client.go:694
↓ 1 callersFunctionvalidatePrevote
(t *testing.T, cs *State, round int32, privVal *validatorStub, blockHash []byte)
internal/consensus/common_test.go:273
↓ 1 callersFunctionvalidatePrevoteAndPrecommit
( t *testing.T, cs *State, thisRound, lockRound int32, privVal *validatorStub, votedBlockHash, lockedBl
internal/consensus/common_test.go:355
↓ 1 callersFunctionvalidateResponseIDs
(ids, expectedIDs []rpctypes.JSONRPCIntID)
rpc/jsonrpc/client/decode.go:88
↓ 1 callersFunctionvalidateSkipCount
(page, perPage int)
light/rpc/client.go:708
↓ 1 callersMethodvalidatorAtHeight
(h int64)
internal/rpc/core/status.go:93
↓ 1 callersMethodvalidatorSet
(ctx context.Context, height *int64)
light/provider/http/http.go:156
↓ 1 callersFunctionvarintWrittenBytes
(m marshaler, size int)
internal/libs/protoio/writer.go:94
↓ 1 callersMethodverifyCommit
(chainID string, blockID types.BlockID, height int64, commit *types.Commit)
internal/blocksync/v2/processor_context.go:13
↓ 1 callersFunctionverifyRemovals
Checks that the validators to be removed are part of the validator set. No changes are made to the validator set 'vals'.
types/validator_set.go:538
↓ 1 callersFunctionverifyScheduler
(sc *scheduler)
internal/blocksync/v2/scheduler_test.go:32
↓ 1 callersFunctionverifyUpdates
verifyUpdates verifies a list of updates against a validator set, making sure the allowed total voting power would not be exceeded if these updates wo
types/validator_set.go:424
↓ 1 callersFunctionverifyValSetUpdatePriorityOrder
(t *testing.T, valSet *ValidatorSet, cfg testVSetCfg, nMaxElections int32)
types/validator_set_test.go:1271
↓ 1 callersFunctionvoteToStep
A vote is either stepPrevote or stepPrecommit.
privval/file.go:35
↓ 1 callersFunctionwaitForBlock
(ctx context.Context, t *testing.T, c client.Client, height int64)
rpc/client/evidence_test.go:174
↓ 1 callersMethodwaitForClose
(closeConn chan error, connID int)
abci/server/socket_server.go:136
↓ 1 callersFunctionwaitForGRPC
(ctx context.Context, conf *config.Config)
rpc/test/helpers.go:45
↓ 1 callersFunctionwaitForInterrupt
waitForInterrupt blocks until a SIGINT is received by the process.
internal/state/indexer/sink/psql/psql_test.go:342
↓ 1 callersFunctionwaitForRPC
(ctx context.Context, conf *config.Config)
rpc/test/helpers.go:27
↓ 1 callersFunctionwaitGroup1
()
abci/client/client.go:152
↓ 1 callersMethodwaitNextSample
waitNextSample sleeps for the remainder of the current sample. The lock is released and reacquired during the actual sleep period, so it's possible fo
internal/libs/flowrate/flowrate.go:260
↓ 1 callersFunctionwaitTimeout
Wait for timeout (no result)
libs/async/async_test.go:149
↓ 1 callersMethodwaitUntilNextRequest
()
internal/p2p/pex/reactor.go:406
↓ 1 callersMethodweightedDerivative
Strengthens the derivative component when the change is negative
internal/p2p/trust/metric.go:348
↓ 1 callersMethodwillSendReq
(reqres *ReqRes)
abci/client/socket_client.go:175
↓ 1 callersFunctionwithHeight
Convenience: Return new vote with different height
types/vote_set_test.go:527
↓ 1 callersFunctionwithRound
Convenience: Return new vote with different round
types/vote_set_test.go:534
↓ 1 callersFunctionwithType
Convenience: Return new vote with different type
types/vote_set_test.go:541
↓ 1 callersFunctionwriteDefaultConfigFileIfNone
(rootDir string)
config/toml.go:65
↓ 1 callersFunctionwriteListOfEndpoints
writes a list of available rpc endpoints as an html page
rpc/jsonrpc/server/http_json_handler.go:247
↓ 1 callersMethodwritePacketMsgTo
Writes next PacketMsg to w and updates c.recentlySent. Not goroutine-safe
internal/p2p/conn/connection.go:871
↓ 1 callersMethodwriteRoutine
The client ensures that there is at most one writer to a connection by executing all writes from this goroutine.
rpc/jsonrpc/client/ws_client.go:359
↓ 1 callersMethodwriteRoutine
receives on a write channel and writes out on the socket
rpc/jsonrpc/server/ws_handler.go:425
↓ 1 callersMethodwrite_to_cache
Writes data in JSON format to a file
networks/remote/ansible/inventory/digital_ocean.py:514
MethodABCI
ABCI returns the application relevant representation of the evidence
types/evidence.go:82
MethodABCI
ABCI forms an array of abci evidence for each byzantine validator
types/evidence.go:250
MethodABCIInfo
ABCIInfo gets some info about the application. More: https://docs.tendermint.com/master/rpc/#/ABCI/abci_info
internal/rpc/core/abci.go:35
MethodABCIInfo
(ctx context.Context)
light/rpc/client.go:120
MethodABCIInfo
(ctx context.Context)
rpc/client/http/http.go:213
MethodABCIInfo
ABCIInfo provides a mock function with given fields: _a0
rpc/client/mocks/client.go:24
MethodABCIInfo
(ctx context.Context)
rpc/client/local/local.go:79
MethodABCIInfo
(ctx context.Context)
rpc/client/mock/client.go:82
MethodABCIQuery
ABCIQuery queries the application for some information. More: https://docs.tendermint.com/master/rpc/#/ABCI/abci_query
internal/rpc/core/abci.go:13
MethodABCIQuery
ABCIQuery requests proof by default.
light/rpc/client.go:125
MethodABCIQuery
( ctx context.Context, path string, data bytes.HexBytes, )
rpc/client/http/http.go:223
MethodABCIQuery
ABCIQuery provides a mock function with given fields: ctx, path, data
rpc/client/mocks/client.go:47
MethodABCIQuery
(ctx context.Context, path string, data bytes.HexBytes)
rpc/client/local/local.go:83
MethodABCIQuery
(ctx context.Context, path string, data bytes.HexBytes)
rpc/client/mock/abci.go:31
MethodABCIQuery
(ctx context.Context, path string, data bytes.HexBytes)
rpc/client/mock/abci.go:111
MethodABCIQuery
( ctx context.Context, path string, data bytes.HexBytes, )
rpc/client/mock/abci.go:187
← previousnext →4,101–4,200 of 9,600, ranked by callers