MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 5 callersFunctiondialAccept
dialAccept is a helper that dials b from a and returns both sides of the connection.
internal/p2p/transport_test.go:588
↓ 5 callersFunctionencodeReflect
(w io.Writer, rv reflect.Value)
libs/json/encoder.go:63
↓ 5 callersFunctionensureDir
(dir string, mode os.FileMode)
internal/consensus/common_test.go:76
↓ 5 callersMethodenterPrecommit
Enter: `timeoutPrevote` after any +2/3 prevotes. Enter: `timeoutPrecommit` after any +2/3 precommits. Enter: +2/3 precomits for block or nil. Lock & p
internal/consensus/state.go:1393
↓ 5 callersMethodenterPrevote
Enter: `timeoutPropose` after entering Propose. Enter: proposal block and POL is ready. Prevote for LockedBlock if we're locked, or ProposalBlock if v
internal/consensus/state.go:1297
↓ 5 callersFunctionexecuteProcessorTests
(t *testing.T, tests []testFields)
internal/blocksync/v2/processor_test.go:71
↓ 5 callersMethodfinal
()
internal/blocksync/v2/routine.go:157
↓ 5 callersMethodfindNewPrimary
findNewPrimary concurrently sends a light block request, promoting the first witness to return a valid light block as the new primary. The remove opti
light/client.go:988
↓ 5 callersMethodget
(i int)
internal/p2p/pqueue.go:28
↓ 5 callersFunctiongetChannelsFromShim
(reactorShim *p2p.ReactorShim)
node/node.go:1303
↓ 5 callersFunctiongetMempool
(t *testing.T, srv service.Service)
rpc/client/rpc_test.go:454
↓ 5 callersMethodhash
(b []byte)
internal/p2p/pex/addrbook.go:944
↓ 5 callersFunctioninitFilesWithConfig
(config *cfg.Config)
cmd/tendermint/commands/init.go:45
↓ 5 callersFunctioninsertEvents
insertEvents inserts a slice of events and any indexed attributes of those events into the database associated with dbtx. If txID > 0, the event is a
internal/state/indexer/sink/psql/psql.go:91
↓ 5 callersFunctionintInSlice
IntInSlice returns true if a is found in the list.
internal/state/indexer/tx/kv/utils.go:4
↓ 5 callersFunctionmakeChannelsFromShims
FIXME: Temporary helper function, shims should be removed.
node/node.go:1285
↓ 5 callersFunctionmakeHTTPDialer
-------------------------------------------------------------
rpc/jsonrpc/client/http_json_client.go:367
↓ 5 callersFunctionmakeKeyFromPrefix
(ids ...int64)
scripts/scmigrate/migrate.go:31
↓ 5 callersFunctionmakeLunaticEvidence
( t *testing.T, height, commonHeight int64, totalVals, byzVals, phantomVals int, commonTime, attackTime ti
internal/evidence/verify_test.go:471
↓ 5 callersFunctionmakeSecretConnPair
(tb testing.TB)
internal/p2p/conn/secret_connection_test.go:333
↓ 5 callersMethodmaxHeight
returns max peer height or the last processed block, i.e. sc.height
internal/blocksync/v2/scheduler.go:447
↓ 5 callersFunctionnewBuffer
()
internal/libs/protoio/io_test.go:116
↓ 5 callersFunctionnewClientAndServerConnsForReadErrors
(t *testing.T, chOnErr chan struct{})
internal/p2p/conn/connection_test.go:391
↓ 5 callersFunctionnewEvilConn
(shareEphKey, badEphKey, shareAuthSignature, badAuthSignature bool)
internal/p2p/conn/evil_secret_connection_test.go:60
↓ 5 callersFunctionnewStateWithConfig
( thisConfig *config.Config, state sm.State, pv types.PrivValidator, app abci.Application, )
internal/consensus/common_test.go:401
↓ 5 callersFunctionparseNumber
(s string)
libs/pubsub/query/query.go:207
↓ 5 callersMethodpruneRange
pruneRange is a generic function for deleting a range of keys in reverse order. we keep filling up batches of at most 1000 keys, perform a deletion an
internal/state/store.go:341
↓ 5 callersFunctionrandBitArray
(bits int)
libs/bits/bit_array_test.go:17
↓ 5 callersFunctionrandConsensusState
( t *testing.T, cfg *config.Config, nValidators int, testName string, tickerFunc func() TimeoutTicker, a
internal/consensus/common_test.go:748
↓ 5 callersFunctionrandLocalIPv4
()
internal/p2p/conn_tracker_test.go:17
↓ 5 callersFunctionrandTestVSetCfg
(t *testing.T, nBase, nAddMax int)
types/validator_set_test.go:1151
↓ 5 callersMethodremoveTxByElement
removeTxByElement removes the specified transaction element from the mempool. The caller must hold txmp.mtx exclusively.
internal/mempool/v1/mempool.go:271
↓ 5 callersMethodrequire
require advances the scanner and requires that the resulting token is one of the specified token types.
libs/pubsub/query/syntax/parser.go:179
↓ 5 callersMethodrequireNumberOfPeers
( t *testing.T, nodeIndex, numPeers int, waitPeriod time.Duration, )
internal/p2p/pex/reactor_test.go:671
↓ 5 callersFunctionseenCommitKey
()
internal/store/store.go:630
↓ 5 callersMethodsendInternalMessage
send a msg into the receiveRoutine regarding our own proposal, block part, or vote
internal/consensus/state.go:601
↓ 5 callersMethodsetStateAtHeight
(height int64, state blockState)
internal/blocksync/v2/scheduler.go:363
↓ 5 callersFunctionsetup
(t *testing.T, peers []p2p.Peer)
internal/p2p/shim_test.go:51
↓ 5 callersFunctionsetupSimulator
This is actually not a test, it's for storing validator change tx data for testHandshakeReplay
internal/consensus/replay_test.go:313
↓ 5 callersMethodsize
()
internal/p2p/pex/addrbook.go:485
↓ 5 callersFunctionskipConn
(dAtA []byte)
proto/tendermint/p2p/conn.pb.go:1201
↓ 5 callersFunctionskipProof
(dAtA []byte)
proto/tendermint/crypto/proof.pb.go:1353
↓ 5 callersFunctionskipTypes
(dAtA []byte)
proto/tendermint/state/types.pb.go:1890
↓ 5 callersFunctionskipTypes
(dAtA []byte)
proto/tendermint/p2p/types.pb.go:1740
↓ 5 callersFunctionskipWal
(dAtA []byte)
proto/tendermint/consensus/wal.pb.go:1472
↓ 5 callersFunctionsovEvents
(x uint64)
proto/tendermint/types/events.pb.go:177
↓ 5 callersFunctionsovKeys
(x uint64)
proto/tendermint/crypto/keys.pb.go:550
↓ 5 callersFunctionsovTypes
(x uint64)
proto/tendermint/libs/bits/types.pb.go:174
↓ 5 callersFunctionsovTypes
(x uint64)
proto/tendermint/rpc/grpc/types.pb.go:529
↓ 5 callersFunctionsovTypes
(x uint64)
rpc/grpc/types.pb.go:529
↓ 5 callersMethodstart
(t *testing.T)
internal/mempool/v0/reactor_test.go:98
↓ 5 callersMethodstopForError
(err error)
abci/client/socket_client.go:569
↓ 5 callersMethodsuccess
Success is called when a light block has been successfully verified and processed
internal/statesync/block_queue.go:203
↓ 5 callersFunctiontestCreatePeerWithConfig
Creates a peer with the provided config
internal/p2p/pex/pex_reactor_test.go:551
↓ 5 callersMethodupdate
update accumulates the transferred byte count for the current sample until clock() - m.sLast >= m.sRate. The monitor status is updated once the curren
internal/libs/flowrate/flowrate.go:222
↓ 5 callersFunctionvalidatePage
----------------------------------------------
internal/rpc/core/env.go:113
↓ 5 callersFunctionvalsEqual
order doesn't matter
abci/example/kvstore/kvstore_test.go:217
↓ 5 callersMethodverifyNext
VerifyNext pulls the next block off the pending queue and adds it to a channel if it's already there or creates a waiter to add it to the channel once
internal/statesync/block_queue.go:146
↓ 5 callersFunctionverifyNotImplemented
verifyNotImplemented calls f and verifies that it returns both a false-valued flag and a non-nil error whose string matching the expected "not support
internal/state/indexer/sink/psql/psql_test.go:330
↓ 5 callersMethodwaitForEvidence
(t *testing.T, evList types.EvidenceList, ids ...types.NodeID)
internal/evidence/reactor_test.go:127
↓ 5 callersFunctionwaitForNode
waitForNode waits for a node to become available and catch up to the given block height.
test/e2e/runner/rpc.go:132
↓ 4 callersMethodAdd
(key crypto.PubKey, msg, signature []byte)
crypto/sr25519/batch.go:22
↓ 4 callersMethodAdd
Add or update an entry for the given result.Index.
internal/state/indexer/indexer.go:55
↓ 4 callersMethodAdd
Add adds the peer to the PeerSet. It returns an error carrying the reason, if the peer is already present.
internal/p2p/peer_set.go:44
↓ 4 callersMethodAddUnconditionalPeerIDs
([]string)
internal/rpc/core/env.go:56
↓ 4 callersMethodAddVote
Duplicate votes return added=false, err=nil. By convention, peerID is "" if origin is self.
internal/consensus/types/height_vote_set.go:116
↓ 4 callersMethodAddrBookFile
AddrBookFile returns the full path to the address book
config/config.go:813
↓ 4 callersMethodAll
()
internal/statesync/dispatcher.go:295
↓ 4 callersMethodAnd
And returns a bit array resulting from a bitwise AND of the two bit arrays. If the two bit-arrys have different lengths, this truncates the larger of
libs/bits/bit_array.go:144
↓ 4 callersMethodApplyBlock
(state state.State, blockID types.BlockID, block *types.Block)
internal/blocksync/v2/reactor.go:59
↓ 4 callersMethodAttemptsToDial
AttemptsToDial returns the number of attempts to dial specific address. It returns 0 if never attempted or successfully connected.
internal/p2p/pex/pex_reactor.go:646
↓ 4 callersMethodBadEvents
BadEvents indicates that an undesirable event(s) took place
internal/p2p/trust/metric.go:176
↓ 4 callersFunctionBadMessage
BadMessage returns a badMessage PeerBehavior.
internal/blocksync/v2/internal/behavior/peer_behaviour.go:18
↓ 4 callersMethodBase
()
internal/blocksync/v2/reactor.go:30
↓ 4 callersMethodBest
Best returns the "best" currently known snapshot, if any.
internal/statesync/snapshots.go:123
↓ 4 callersMethodBitArrayByBlockID
(blockID BlockID)
types/vote_set.go:354
↓ 4 callersFunctionBlockMetaFromProto
(pb *tmproto.BlockMeta)
types/block_meta.go:43
↓ 4 callersMethodBlockSearch
BlockSearch defines a method to search for a paginated set of blocks by BeginBlock and EndBlock event search criteria.
rpc/client/interface.go:99
↓ 4 callersMethodCertFile
()
config/config.go:647
↓ 4 callersMethodChangeKeys
(delta int)
light/helpers_test.go:169
↓ 4 callersMethodCheckTx
It blocks if we're waiting on Update() or Reap(). cb: A callback from the CheckTx command. It gets called from another goroutine. CONTRACT: Either cb
internal/mempool/v0/clist_mempool.go:201
↓ 4 callersMethodCheckTxSync
(context.Context, types.RequestCheckTx)
internal/proxy/app_conn.go:34
↓ 4 callersMethodCleanup
Cleanup removes all the data (headers and validator sets) stored. Note: the client must be stopped at this point.
light/client.go:837
↓ 4 callersMethodClose
()
abci/example/kvstore/persistent_kvstore.go:54
↓ 4 callersMethodClose
Close implements Transport.
internal/p2p/transport_mconn.go:179
↓ 4 callersFunctionConsensusParamsFromProto
(pbParams tmproto.ConsensusParams)
types/params.go:261
↓ 4 callersFunctionDefaultConfig
DefaultConfig returns a default configuration.
rpc/jsonrpc/server/http_server.go:38
↓ 4 callersFunctionDefaultMempoolConfig
DefaultMempoolConfig returns a default configuration for the Tendermint mempool.
config/config.go:900
↓ 4 callersMethodDialPeersAsync
([]string)
internal/rpc/core/env.go:58
↓ 4 callersMethodDialTimeout
DialTimeout calls net.DialTimeout on the address.
types/netaddress.go:173
↓ 4 callersMethodEcho
(ctx context.Context, in *RequestEcho, opts ...grpc.CallOption)
abci/types/types.pb.go:3147
↓ 4 callersMethodEndpoints
Endpoints implements Transport.
internal/p2p/transport_mconn.go:83
↓ 4 callersMethodError
Error returns an error if the client was stopped abruptly.
abci/client/socket_client.go:104
↓ 4 callersMethodFirstLightBlockHeight
FirstLightBlockHeight returns the first (oldest) LightBlock height. If the store is empty, -1 and nil error are returned.
light/store/store.go:35
↓ 4 callersMethodGet
Get gets transaction from the TxIndex storage and returns it or nil if the transaction is not found.
internal/state/indexer/tx/kv/kv.go:40
↓ 4 callersMethodGetBeginBlock
()
abci/types/types.pb.go:321
↓ 4 callersMethodGetByIndex
GetByIndex returns the validator's address and validator itself (copy) by index. It returns nil values if index is less than 0 or greater or equal to
types/validator_set.go:283
↓ 4 callersMethodGetByzantineValidators
GetByzantineValidators finds out what style of attack LightClientAttackEvidence was and then works out who the malicious validators were and returns t
types/evidence.go:280
↓ 4 callersMethodGetChannel
GetChannel returns the receive only channel that fires at each time interval
internal/p2p/trust/ticker.go:13
↓ 4 callersFunctionGetFreeLocalhostAddrPort
GetFreeLocalhostAddrPort returns a free localhost:port address
privval/utils.go:56
← previousnext →1,001–1,100 of 9,600, ranked by callers