MCPcopy Create free account

hub / github.com/XTXMarkets/ternfs / functions

Functions4,832 in github.com/XTXMarkets/ternfs

⨍ Functions 4,832◇ Types & classes 1,957
↓ 1 callersFunctionprocess_client_socket_ssl
cpp/core/httplib.h:8105
↓ 1 callersFunctionprocess_server_socket
cpp/core/httplib.h:2902
↓ 1 callersFunctionprocess_server_socket_ssl
cpp/core/httplib.h:8090
↓ 1 callersMethodpushBlockServiceStateRequests
cpp/registry/RegistryWriter.hpp:41
↓ 1 callersMethodpushLogsDBRequests
Push methods for adding requests to the queue
cpp/registry/RegistryWriter.hpp:28
↓ 1 callersMethodpushLogsDBResponses
cpp/registry/RegistryWriter.hpp:31
↓ 1 callersMethodpushRegistryRequests
cpp/registry/RegistryWriter.hpp:34
↓ 1 callersMethodpushRequests
cpp/registry/RegistryReader.cpp:15
↓ 1 callersMethodpushShardResponses
cpp/registry/BlockServiceFileTracker.cpp:28
↓ 1 callersFunctionput_unaligned_be32
kmod/bincode_tests.c:70
↓ 1 callersFunctionr
()
go/ternweb/preact-hooks-10.18.1.module.js:5
↓ 1 callersMethodraiseAlert
cpp/core/Env.hpp:132
↓ 1 callersFunctionraiseAlerts
(log *log.Logger, env *env, blockServices map[msgs.BlockServiceId]*blockService)
go/ternblocks/ternblocks.go:1216
↓ 1 callersFunctionrareInnocuousShardError
These can happen but should be rare. DIRECTORY_HAS_OWNER can happen in gc (we clean it up and then remove it, but somebody else might have created st
cpp/cdc/CDC.cpp:106
↓ 1 callersFunctionreadBlocksRequest
( log *log.Logger, r io.Reader, )
go/ternblocks/ternblocks.go:922
↓ 1 callersMethodreadFd
cpp/core/XmonAgent.hpp:70
↓ 1 callersFunctionreadFile
Same as writeFile, but for reading.
cpp/ktools/ternktools.cpp:128
↓ 1 callersFunctionreadFile
(log *log.Logger, bufPool *bufpool.BufPool, client *client.Client, id msgs.InodeId, size uint64)
go/terntests/req.go:108
↓ 1 callersFunctionreadLastAppliedLogEntry
cpp/registry/RegistryDBData.hpp:28
↓ 1 callersFunctionreadLink
Same as writeFile, but for reading.
cpp/ktools/ternktools.cpp:270
↓ 1 callersFunctionreadLocationInfo
cpp/registry/RegistryDBData.hpp:49
↓ 1 callersMethodreadMirrored
(log *log.Logger, client *Client, bufPool *bufpool.BufPool, offset uint64, span *SpanWithBlockServices, p []by
go/client/span.go:813
↓ 1 callersFunctionreadRegistryRequest
( log *log.Logger, r io.Reader, )
go/ternregistryproxy/ternregistryproxy.go:260
↓ 1 callersFunctionreadRegistryResponse
( log *log.Logger, r io.Reader, )
go/client/registryreq.go:41
↓ 1 callersFunctionreadRsRecover
( log *log.Logger, startFetch startFetch, pageCache PageCache, bufPool *bufpool.BufPool, span *SpanWithBl
go/client/span.go:1171
↓ 1 callersFunctionreadRsStartFetchBlockWithCache
( log *log.Logger, bufPool *bufpool.BufPool, startFetch startFetch, pageCache PageCache, span *SpanWithBl
go/client/span.go:1023
↓ 1 callersFunctionreadRsWriteToPageCache
( log *log.Logger, pageCache PageCache, span *SpanWithBlockServices, state *readRsState, extra *readRsRec
go/client/span.go:1104
↓ 1 callersFunctionread_content_chunked
cpp/core/httplib.h:3777
↓ 1 callersFunctionread_content_without_length
cpp/core/httplib.h:3757
↓ 1 callersMethodreceiveMessages
Waits until any socket ready (or up to timeout) and receives up to `socketCount * perSockMaxRecvMsg` messages. Returns false on signal interrupt. If
cpp/core/UDPSocketPair.hpp:85
↓ 1 callersFunctionreconstructBlock
( log *log.Logger, c *client.Client, bufPool *bufpool.BufPool, fileId msgs.InodeId, scratchFile scratch.S
go/cleanup/migrate.go:170
↓ 1 callersMethodrecoverBlocksCh
()
go/client/span.go:899
↓ 1 callersMethodrecoverFetching
()
go/client/span.go:885
↓ 1 callersMethodrecoverPanics
recoverPanics is a middleware that recovers from panics in a handler, logs the stack trace, and returns an error.
go/s3/s3.go:192
↓ 1 callersFunctionregisterCDCReplica
cpp/core/RegistryClient.cpp:345
↓ 1 callersMethodregisterEpoll
cpp/core/Connect.hpp:36
↓ 1 callersFunctionregisterPeriodically
( log *log.Logger, blockServices map[msgs.BlockServiceId]*blockService, env *env, )
go/ternblocks/ternblocks.go:279
↓ 1 callersFunctionregisterRegistry
cpp/core/RegistryClient.cpp:219
↓ 1 callersFunctionregisterShard
cpp/core/RegistryClient.cpp:285
↓ 1 callersMethodrelease
cpp/core/httplib.h:346
↓ 1 callersMethodreleaseScratchFile
()
go/cleanup/scratch/scratch.go:209
↓ 1 callersMethodremoveDirectory
(log *log.Logger, dir Id, name string)
go/terntests/fstest.go:66
↓ 1 callersMethodremoveFile
(log *log.Logger, dir Id, name string)
go/terntests/fstest.go:65
↓ 1 callersFunctionremoveIx
(ix)
go/ternweb/scripts.js:184
↓ 1 callersFunctionrenderPage
( tmpl *template.Template, data *pageData, )
go/ternweb/ternweb.go:157
↓ 1 callersFunctionreplayCheckpoint
(prefix string, files *fileHistoryFiles, fullEdges []fullEdge, t msgs.TernTime)
go/terntests/filehistory.go:235
↓ 1 callersFunctionreplayStep
(prefix string, files *fileHistoryFiles, fullEdges []fullEdge, stepAny any)
go/terntests/filehistory.go:240
↓ 1 callersFunctionreqKindCount
(header []byte)
go/terncli/kernelmetrics.go:49
↓ 1 callersMethodrequestHandler
()
go/client/registryreq.go:216
↓ 1 callersMethodresendTimedOutRequests
cpp/core/LogsDB.cpp:582
↓ 1 callersMethodresetLeaderElection
cpp/core/LogsDB.cpp:953
↓ 1 callersFunctionretriableBlockError
(err error)
go/client/client.go:1397
↓ 1 callersFunctionretrieveOrCreateKey
(log *log.Logger, dir string)
go/ternblocks/ternblocks.go:1121
↓ 1 callersFunctionretrieve_certs_from_keychain
cpp/core/httplib.h:4812
↓ 1 callersFunctionretrieve_root_certs_from_keychain
cpp/core/httplib.h:4836
↓ 1 callersFunctionretry_after_block_error
kmod/file.c:254
↓ 1 callersFunctionrocksDBMetrics
cpp/core/RocksDBUtils.cpp:60
↓ 1 callersFunctionrowProps
(row)
go/ternweb/scripts.js:74
↓ 1 callersFunctionrs_cauchy_matrix
Note that we pervasively assume that the first column of the parity columns is 1s, which causes the first parity to be the XORs of the data. So you ca
cpp/rs/rs_core.c:143
↓ 1 callersFunctionrs_detect_valgrind
cpp/rs/rs.cpp:33
↓ 1 callersFunctionrs_gf_invert_matrix
From <https://github.com/intel/isa-l/blob/33a2d9484595c2d6516c920ce39a694c144ddf69/erasure_code/ec_base.c#L110>, just Gaussian elimination. TODO this
cpp/rs/rs_core.c:74
↓ 1 callersFunctionrs_new_core
cpp/rs/rs_core.c:374
↓ 1 callersFunctionrs_valgrind_client_request
See `valgrind.h`
cpp/rs/rs.cpp:18
↓ 1 callersMethodrun
the main function that does all the filtering and test running
cpp/tests/doctest.h:6730
↓ 1 callersFunctionrunCDC
cpp/cdc/CDC.cpp:1181
↓ 1 callersFunctionrunCheckpoint
(log *log.Logger, client *client.Client, prefix string, files *fileHistoryFiles)
go/terntests/filehistory.go:161
↓ 1 callersMethodrunFileAggregator
(wg *sync.WaitGroup)
go/cleanup/migrate.go:815
↓ 1 callersMethodrunFileFetchers
(wg *sync.WaitGroup)
go/cleanup/migrate.go:733
↓ 1 callersMethodrunFileMigrators
(wg *sync.WaitGroup)
go/cleanup/migrate.go:904
↓ 1 callersFunctionrunShard
cpp/shard/Shard.cpp:2507
↓ 1 callersFunctionrunStep
(log *log.Logger, client *client.Client, dirInfoCache *client.DirInfoCache, files *fileHistoryFiles, stepAny a
go/terntests/filehistory.go:171
↓ 1 callersFunctions
(n,u,i)
go/ternweb/preact-hooks-10.18.1.module.js:5
↓ 1 callersFunctionscrubScraper
( log *log.Logger, c *client.Client, stats *ScrubState, shid msgs.ShardId, terminateChan chan any, worke
go/cleanup/scrub.go:193
↓ 1 callersFunctionscrubWorker
( log *log.Logger, c *client.Client, opts *ScrubOptions, stats *ScrubState, rateLimit *timing.RateLimit,
go/cleanup/scrub.go:72
↓ 1 callersMethodsend
cpp/core/httplib.h:6755
↓ 1 callersMethodsendLogsDBMessages
cpp/registry/RegistryServer.cpp:114
↓ 1 callersFunctionsendMetrics
(l *log.Logger, env *env, influxDB *log.InfluxDB, blockServices map[msgs.BlockServiceId]*blockService, failure
go/ternblocks/ternblocks.go:1237
↓ 1 callersFunctionsendMetrics
Writes stats to influx db.
go/ternregistryproxy/ternregistryproxy.go:391
↓ 1 callersMethodsendShardRequests
cpp/registry/RegistryServer.cpp:127
↓ 1 callersMethodsendStop
cpp/core/Loop.cpp:39
↓ 1 callersFunctionsend_socket
cpp/core/httplib.h:2672
↓ 1 callersFunctionsetColFilter
(ix)
go/ternweb/scripts.js:188
↓ 1 callersMethodsetDirName
(inode msgs.InodeId, name string)
go/terncli/filesamples/filesamples.go:189
↓ 1 callersMethodsetLeadersAtOtherLocations
cpp/shard/Shard.cpp:191
↓ 1 callersMethodsetReplicas
cpp/cdc/CDC.cpp:64
↓ 1 callersMethodsetReplicas
cpp/shard/Shard.cpp:183
↓ 1 callersMethodsetStripeCrc
cpp/shard/ShardDBData.hpp:237
↓ 1 callersMethodset_boundary
cpp/core/httplib.h:4269
↓ 1 callersMethodset_ca_cert_store
cpp/core/httplib.h:7976
↓ 1 callersMethodset_connection_timeout
cpp/core/httplib.h:1918
↓ 1 callersMethodset_content_provider
cpp/core/httplib.h:5227
↓ 1 callersMethodset_read_timeout
cpp/core/httplib.h:1926
↓ 1 callersMethodset_write_timeout
cpp/core/httplib.h:1933
↓ 1 callersFunctionsetupRouting
(l *log.Logger, st *state, scriptsJsFile string)
go/ternweb/ternweb.go:1000
↓ 1 callersMethodshardAddrs
(shid msgs.ShardId)
go/client/client.go:1195
↓ 1 callersMethodshardReplicaId
cpp/core/Msgs.hpp:211
↓ 1 callersMethodshutdown
cpp/core/httplib.h:616
↓ 1 callersFunctionskip_content_with_length
cpp/core/httplib.h:3746
↓ 1 callersMethodsleep
cpp/core/Time.cpp:46
↓ 1 callersMethodsnapshot
cpp/shard/ShardDBData.hpp:609
← previousnext →1,401–1,500 of 4,832, ranked by callers