MCPcopy Create free account

hub / github.com/XTXMarkets/ternfs / functions

Functions4,832 in github.com/XTXMarkets/ternfs

⨍ Functions 4,832◇ Types & classes 1,957
↓ 3 callersFunctionwriteRegistryInfo
cpp/registry/RegistryDBData.hpp:96
↓ 3 callersFunctionz
(n,u,t,i,o,r,f,e,c,s)
go/ternweb/preact-10.18.1.module.js:5
↓ 3 callersFunctionz
(n,t)
go/ternweb/preact-hooks-10.18.1.module.js:5
↓ 2 callersMethodAddSize
(size uint64)
go/cleanup/scratch/scratch.go:116
↓ 2 callersMethodClose
()
go/client/client.go:1240
↓ 2 callersFunctionComputeSpanParameters
( spanPolicies *msgs.SpanPolicy, blockPolicies *msgs.BlockPolicy, stripePolicy *msgs.StripePolicy, spanSiz
go/client/span.go:109
↓ 2 callersMethodDebugStack
(calldepth int, format string, v ...any)
go/core/log/log.go:235
↓ 2 callersFunctionF
(n,r)
go/ternweb/preact-hooks-10.18.1.module.js:5
↓ 2 callersMethodFetchSpan
The buf we get out must be returned to the bufPool.
go/client/span.go:736
↓ 2 callersMethodFetchSpans
( log *log.Logger, fileId msgs.InodeId, )
go/client/span.go:761
↓ 2 callersMethodFlush
(ctx context.Context)
go/ternfuse/ternfuse.go:525
↓ 2 callersMethodIncreaseNumHandlersTo
(numHandlers uint)
go/client/registryreq.go:207
↓ 2 callersFunctionL
(n,u,t)
go/ternweb/preact-10.18.1.module.js:5
↓ 2 callersFunctionMakeRegistryConn
( log *log.Logger, timeout *RegistryTimeouts, registryAddress string, numHandlers uint, )
go/client/registryreq.go:193
↓ 2 callersMethodMean
()
go/core/timing/timings.go:92
↓ 2 callersMethodMedian
()
go/core/timing/timings.go:121
↓ 2 callersFunctionMessageBuilder
cpp/tests/doctest.h:1841
↓ 2 callersMethodNextNow
If 0, time's up.
go/core/timing/timeouts.go:49
↓ 2 callersFunctionO
(n,u,t)
go/ternweb/preact-10.18.1.module.js:5
↓ 2 callersFunctionP
(n,l,u,t,i,o,r,f,e,a,h)
go/ternweb/preact-10.18.1.module.js:5
↓ 2 callersMethodPick
(size uint32)
go/msgs/msgs.go:1733
↓ 2 callersMethodPush
(x any)
go/cleanup/migrate.go:799
↓ 2 callersMethodRaiseStack
(log *Logger, xmon *Xmon, appType XmonAppType, calldepth int, format string, v ...any)
go/core/log/xmon.go:617
↓ 2 callersMethodReadCache
Return 0 if things could not be found in the cache. Must read multiples of TERN_PAGE_SIZE, or not at all.
go/client/span.go:1014
↓ 2 callersMethodRegistryAddress
()
go/client/client.go:1640
↓ 2 callersMethodReplica
()
go/msgs/msgs.go:265
↓ 2 callersMethodScheduleBlockService
(bs msgs.BlockServiceId)
go/cleanup/migrate.go:696
↓ 2 callersMethodStartBlockService
(ll *log.Logger, opts *BlockServiceOpts)
go/core/managedprocess/managedprocess.go:292
↓ 2 callersMethodStartCDC
(ll *log.Logger, repoDir string, opts *CDCOpts)
go/core/managedprocess/managedprocess.go:758
↓ 2 callersMethodStartFuse
(ll *log.Logger, opts *FuseOpts)
go/core/managedprocess/managedprocess.go:351
↓ 2 callersMethodStartRegistry
(ll *log.Logger, opts *RegistryOpts)
go/core/managedprocess/managedprocess.go:438
↓ 2 callersMethodStartShard
(ll *log.Logger, repoDir string, opts *ShardOpts)
go/core/managedprocess/managedprocess.go:661
↓ 2 callersFunctionT
(n)
go/ternweb/preact-10.18.1.module.js:5
↓ 2 callersFunctionZeroExtend
(crc uint32, zeros int)
go/core/crc32c/crc32c.go:36
↓ 2 callersFunction_freshShardReqId
cpp/cdc/CDC.cpp:758
↓ 2 callersMethod_getPartitionIterators
cpp/core/LogsDB.cpp:322
↓ 2 callersFunction_packCDCResponse
cpp/cdc/CDC.cpp:829
↓ 2 callersFunction_packLogsDBRequest
cpp/cdc/CDC.cpp:506
↓ 2 callersFunction_packLogsDBResponse
cpp/cdc/CDC.cpp:487
↓ 2 callersFunction_prepareCDCShardResp
To be called when we have a shard response with given `reqId`. Searches it in the in flight map, removes it from it, and adds a CDCShardResp to `_shar
cpp/cdc/CDC.cpp:555
↓ 2 callersFunction_recordCDCShardResp
cpp/cdc/CDC.cpp:575
↓ 2 callersMethodadd
cpp/tests/doctest.h:5711
↓ 2 callersMethodaddTime
cpp/tests/doctest.h:5721
↓ 2 callersFunctionadd_certs_to_x509_store
cpp/core/httplib.h:4846
↓ 2 callersFunctionadd_span_initiate
kmod/file.c:361
↓ 2 callersMethodappendSubcaseNamesToLastTestcase
cpp/tests/doctest.h:5715
↓ 2 callersFunctionappend_query_params
cpp/core/httplib.h:5076
↓ 2 callersFunctionassertNoTag
(e *subexpr)
go/bincodegen/bincodegen.go:32
↓ 2 callersMethodassignLogIdx
cpp/core/LogsDB.cpp:460
↓ 2 callersMethodavailableBytes
cpp/shard/BlockServicesCacheDB.cpp:202
↓ 2 callersFunctionbadBlockError
(err error)
go/cleanup/scrub.go:37
↓ 2 callersFunctionbigResponse
cpp/shard/Shard.cpp:208
↓ 2 callersFunctionblock_ops_exit
kmod/block.c:336
↓ 2 callersFunctionblock_ops_init
kmod/block.c:134
↓ 2 callersFunctionblock_socket_receive_req_locked
kmod/block.c:765
↓ 2 callersFunctionblock_socket_sk_data_ready
kmod/block.c:834
↓ 2 callersFunctionblock_socket_start_req
kmod/block.c:882
↓ 2 callersFunctionblock_socket_state_check_locked
kmod/block.c:357
↓ 2 callersFunctionblock_socket_write_work
kmod/block.c:504
↓ 2 callersMethodbucket
(l int)
go/core/bufpool/bufpool.go:70
↓ 2 callersMethodcalcFileSize
(log *log.Logger, opts *fsTestOpts, rand *wyhash.Rand)
go/terntests/fstest.go:706
↓ 2 callersFunctioncalculateBlockServicesForLocation
cpp/registry/RegistryDB.cpp:758
↓ 2 callersMethodcapacityBytes
cpp/shard/BlockServicesCacheDB.cpp:192
↓ 2 callersFunctioncdcToLastHeartBeat
cpp/registry/RegistryDBData.hpp:402
↓ 2 callersMethodcell
Block start: where to download from in the block. blockFrom/blockTo: where to copy from this block. These offsets are relative to the block start. out
go/client/span.go:917
↓ 2 callersFunctioncheckBlockSendArgs
(blockService *msgs.BlockService, blockId msgs.BlockId, size uint32, crc msgs.Crc, extra any)
go/client/client.go:1652
↓ 2 callersMethodcheckBlockSize
Returns block size
go/core/rs/rs.go:49
↓ 2 callersFunctioncheckCheckpoint
(prefix string, files *fileHistoryFiles, allEdges []edge)
go/terntests/filehistory.go:142
↓ 2 callersFunctioncleanupCloseMap
()
go/ternfuse/ternfuse.go:1139
↓ 2 callersMethodclear
cpp/core/Msgs.hpp:36
↓ 2 callersFunctioncloseOut
(out io.Writer)
go/core/managedprocess/managedprocess.go:118
↓ 2 callersFunctioncomputePages
(sortByIx, colFilters, elementsPerPage)
go/ternweb/scripts.js:85
↓ 2 callersFunctionconnectToHost
cpp/core/Connect.cpp:25
↓ 2 callersMethodcopy_settings
cpp/core/httplib.h:6614
↓ 2 callersFunctioncount_format_placeholders
cpp/core/FormatTuple.hpp:28
↓ 2 callersMethodcreateDirectory
(log *log.Logger, owner Id, name string)
go/terntests/fstest.go:59
↓ 2 callersMethodcreateFile
(log *log.Logger, owner Id, spanSize uint32, name string, size uint64, dataSeed uint64)
go/terntests/fstest.go:61
↓ 2 callersMethodcreateInlineSpan
( log *log.Logger, id msgs.InodeId, cookie [8]byte, offset uint64, sizeWithZeros uint32, data []byte, )
go/client/span.go:63
↓ 2 callersMethodcreateInternal
(name string, flags uint32, mode uint32)
go/ternfuse/ternfuse.go:276
↓ 2 callersFunctioncreate_socket
cpp/core/httplib.h:2936
↓ 2 callersFunctiondefaultDirectoryInfo
cpp/shard/ShardDB.cpp:3988
↓ 2 callersFunctiondefragFileInternal
( log *log.Logger, c *client.Client, bufPool *bufpool.BufPool, dirInfoCache *client.DirInfoCache, stats *
go/cleanup/defrag.go:51
↓ 2 callersMethoddeleteObjectLogic
deleteObjectLogic contains the core logic for deleting a single object.
go/s3/s3.go:773
↓ 2 callersMethoddir
()
go/s3/s3.go:132
↓ 2 callersFunctiondirInfoCachePickBucket
(id msgs.InodeId)
go/client/dirinfocache.go:134
↓ 2 callersFunctiondirName
(mountPoint string, i int)
go/terntests/rsynctest.go:22
↓ 2 callersMethoddropEntriesAfterIdx
cpp/core/LogsDB.cpp:302
↓ 2 callersFunctiondrop_sockets
kmod/block.c:948
↓ 2 callersMethodeline
(s string)
go/bincodegen/bincodegen.go:850
↓ 2 callersFunctionencoding_type
cpp/core/httplib.h:3401
↓ 2 callersFunctionensureLen
(buf *[]byte, l int)
go/client/span.go:91
↓ 2 callersMethodensureTagClosed
cpp/tests/doctest.h:5342
↓ 2 callersFunctioneraseBlockSendArgs
(block *msgs.RemoveSpanInitiateBlockInfo, extra any)
go/client/client.go:1612
↓ 2 callersFunctionexplicitGenerateErrString
cpp/core/Connect.cpp:15
↓ 2 callersFunctionfailureString
cpp/tests/doctest.h:3822
↓ 2 callersFunctionfetchBlock
( log *log.Logger, c *client.Client, bufPool *bufpool.BufPool, fileId msgs.InodeId, blockServices []msgs.
go/cleanup/migrate.go:49
↓ 2 callersFunctionfetchBlockSendArgs
(blockService *msgs.BlockService, blockId msgs.BlockId, offset uint32, count uint32, w io.ReaderFrom, extra an
go/client/client.go:1449
↓ 2 callersFunctionfetchRsSpan
( log *log.Logger, startFetch startFetch, bufPool *bufpool.BufPool, span *SpanWithBlockServices, )
go/client/span.go:620
↓ 2 callersFunctionfetch_span_blocks
Starts loading up D blocks as necessary.
kmod/span.c:277
↓ 2 callersFunctionfetch_span_pages_state_need_blocks
kmod/span.c:117
← previousnext →701–800 of 4,832, ranked by callers