MCPcopy Create free account

hub / github.com/XTXMarkets/ternfs / functions

Functions4,832 in github.com/XTXMarkets/ternfs

↓ 1 callersFunctionStringContains
cpp/tests/doctest.h:836
↓ 1 callersMethodStripes
(size uint32)
go/msgs/msgs.go:1759
↓ 1 callersMethodSwap
(i, j int)
go/cleanup/migrate.go:793
↓ 1 callersMethodSymlink
(ctx context.Context, target, name string, out *fuse.EntryOut)
go/ternfuse/ternfuse.go:787
↓ 1 callersFunctionTableInner
(props)
go/ternweb/scripts.js:79
↓ 1 callersMethodTime
()
go/msgs/msgs.go:1607
↓ 1 callersMethodUnmarshalJSON
(b []byte)
go/msgs/msgs.go:327
↓ 1 callersFunctionUnpackBytes
This function will discard what's in `data`, and just set the pointer to a slice of the backing `buf`.
go/core/bincode/bincode.go:72
↓ 1 callersMethodUpdateInheritedFrom
(dirId msgs.InodeId, tag msgs.DirectoryInfoTag, inheritedFrom msgs.InodeId)
go/client/dirinfocache.go:253
↓ 1 callersMethodUpdatePolicy
This must be called before UpdateInheritedFrom.
go/client/dirinfocache.go:221
↓ 1 callersMethodWriteBlock
(log *log.Logger, timeouts *timing.ReqTimeouts, block *msgs.AddSpanInitiateBlockInfo, r io.ReadSeeker, size ui
go/client/client.go:1441
↓ 1 callersFunctionXor
(crc1 uint32, crc2 uint32, len int)
go/core/crc32c/crc32c.go:22
↓ 1 callersFunction_advanceLogIndex
cpp/cdc/CDC.cpp:846
↓ 1 callersMethod_lastAppliedLogEntry
cpp/shard/ShardDB.cpp:3870
↓ 1 callersMethod_lastAppliedLogEntryDB
cpp/cdc/CDCDB.cpp:1614
↓ 1 callersMethod_lock
()
go/cleanup/scratch/scratch.go:169
↓ 1 callersFunction_processCDCMessages
cpp/cdc/CDC.cpp:668
↓ 1 callersFunction_processCDCSnapshotMessage
cpp/cdc/CDC.cpp:745
↓ 1 callersFunction_processLogMessages
cpp/cdc/CDC.cpp:622
↓ 1 callersFunction_processShardMessages
cpp/cdc/CDC.cpp:714
↓ 1 callersFunction_processStep
cpp/cdc/CDC.cpp:765
↓ 1 callersFunction_waitForShards
cpp/cdc/CDC.cpp:528
↓ 1 callersMethodaddBlockService
cpp/registry/RegistryDB.cpp:696
↓ 1 callersMethodaddError
cpp/tests/doctest.h:5733
↓ 1 callersMethodaddFailure
cpp/tests/doctest.h:5728
↓ 1 callersMethodaddWork
cpp/core/SPSC.hpp:56
↓ 1 callersFunctionapplyPolicy
returns whether all the edges were removed
go/cleanup/collectdirectories.go:67
↓ 1 callersFunctionapplyScaling
Apply power scaling to ensure max FD weight <= 1/N of total
cpp/shard/BlockServicePicker.cpp:26
↓ 1 callersFunctionassertExpectedTag
(e *subexpr, expected string)
go/bincodegen/bincodegen.go:26
↓ 1 callersFunctionbase64_encode
NOTE: This code came up with the following stackoverflow post: https://stackoverflow.com/questions/180947/base64-decode-snippet-in-c
cpp/core/httplib.h:2258
↓ 1 callersFunctionbigRequest
cpp/shard/Shard.cpp:201
↓ 1 callersFunctionbincodeToRocksValue
cpp/core/RocksDBUtils.hpp:364
↓ 1 callersFunctionbind_ip_address
cpp/core/httplib.h:3087
↓ 1 callersMethodblockIdAt
cpp/shard/BlockServicesCacheDB.cpp:104
↓ 1 callersFunctionblockServiceFlagsReadable
cpp/core/Msgs.hpp:498
↓ 1 callersFunctionblockServiceIdFromKey
(secretKey [16]byte)
go/ternblocks/ternblocks.go:158
↓ 1 callersMethodblockServiceInfoAt
cpp/shard/BlockServicesCacheDB.cpp:112
↓ 1 callersFunctionblockServiceIsWritable
cpp/shard/BlockServicePicker.cpp:21
↓ 1 callersFunctionblock_socket_check_timeout
kmod/block.c:405
↓ 1 callersFunctionblock_socket_cleanup
check if socket needs cleanup due to error or timeout returns true if socket was cleaned up or partly cleaned up
kmod/block.c:440
↓ 1 callersMethodblocksBody
we only allow modifications of new format so non const version does not need compatibility wrapper
cpp/shard/ShardDBData.hpp:410
↓ 1 callersMethodblocksPageCacheWriteCh
()
go/client/span.go:906
↓ 1 callersMethodbootstrap
cpp/cdc/CDCDB.cpp:1931
↓ 1 callersMethodbootstrapEntry
cpp/cdc/CDCDB.hpp:94
↓ 1 callersFunctionbuildCpp
Returns build dir
go/core/managedprocess/managedprocess.go:839
↓ 1 callersFunctionbuild_and_upload
Builds and uploads binaries to the vm.
kmod/vm_deploy.py:17
↓ 1 callersFunctioncanDeleteFileImmediately
(dirId msgs.InodeId)
go/ternfuse/ternfuse.go:732
↓ 1 callersFunctioncan_compress_content_type
cpp/core/httplib.h:3383
↓ 1 callersMethodcdcAddrs
()
go/client/client.go:1188
↓ 1 callersFunctioncheckBlock
(log *log.Logger, env *env, blockServiceId msgs.BlockServiceId, basePath string, blockId msgs.BlockId, expecte
go/ternblocks/ternblocks.go:593
↓ 1 callersFunctioncheckEraseCertificate
(log *log.Logger, blockServiceId msgs.BlockServiceId, cipher cipher.Block, req *msgs.EraseBlockReq, stats *blo
go/ternblocks/ternblocks.go:345
↓ 1 callersFunctioncheckFile
(path string)
go/badblocks/badblocks.go:32
↓ 1 callersMethodcheckFileData
(log *log.Logger, id Id, size uint64, dataSeed uint64)
go/terntests/fstest.go:62
↓ 1 callersMethodcheckRepeatedCDCRequestError
( logger *log.Logger, // these are already filled in by now reqBody msgs.CDCRequest, resp msgs.CDCResponse
go/client/cdcreq.go:14
↓ 1 callersMethodcheckRepeatedShardRequestError
( logger *log.Logger, // these are already filled in by now reqBody msgs.ShardRequest, resp msgs.ShardResp
go/client/shardreq.go:98
↓ 1 callersMethodcheckSize
cpp/cdc/CDCDBData.hpp:266
↓ 1 callersFunctioncheckWriteCertificate
(log *log.Logger, cipher cipher.Block, blockServiceId msgs.BlockServiceId, req *msgs.WriteBlockReq, stats *blo
go/ternblocks/ternblocks.go:656
↓ 1 callersMethodclean
(log *log.Logger, harness fsTestHarness[Id])
go/terntests/fstest.go:810
↓ 1 callersMethodcleanVisitedBlockService
()
go/cleanup/migrate.go:722
↓ 1 callersFunctioncleanupAfterTest
( log *log.Logger, registryAddress string, counters *client.ClientCounters, pauseBlockServiceKiller *sync.
go/terntests/cleanup.go:53
↓ 1 callersMethodclear
cpp/core/Bincode.hpp:153
↓ 1 callersMethodclear
cpp/core/MsgsGen.hpp:942
↓ 1 callersMethodcloseMigrators
()
go/cleanup/migrate.go:899
↓ 1 callersFunctioncollectDirectoriesScraper
( log *log.Logger, c *client.Client, state *CollectDirectoriesState, shid msgs.ShardId, workerChan chan m
go/cleanup/collectdirectories.go:210
↓ 1 callersFunctioncollectDirectoriesWorker
( log *log.Logger, c *client.Client, dirInfoCache *client.DirInfoCache, rateLimit *timing.RateLimit, stat
go/cleanup/collectdirectories.go:177
↓ 1 callersFunctioncompare_case_ignore
cpp/core/httplib.h:3643
↓ 1 callersFunctioncompute_span_parameters
kmod/file.c:467
↓ 1 callersFunctionconnCheck
From <https://stackoverflow.com/a/58664631>, checks if a connection is still alive.
go/client/client.go:709
↓ 1 callersMethodconnect
()
go/client/registryreq.go:279
↓ 1 callersMethodconnect
(log *log.Logger)
go/client/client.go:669
↓ 1 callersMethodconnect_with_proxy
Assumes that socket_mutex_ is locked and that there are no requests in flight
cpp/core/httplib.h:8423
↓ 1 callersFunctionconstexpr_strlen
cpp/core/FormatTuple.hpp:20
↓ 1 callersMethodcontainsFd
cpp/core/UDPSocketPair.hpp:30
↓ 1 callersFunctioncopyBlock
the bool is whether we found an error that we can retry
go/cleanup/migrate.go:148
↓ 1 callersFunctioncorruptFiles
returns how many blocks were corrupted
go/terntests/fstest.go:858
↓ 1 callersFunctioncountBlocks
Do this in one go in C to minimize syscall overhead in golang, also I think the busy loop with syscalls in them was starving the goroutines waiting on
go/ternblocks/ternblocks.go:176
↓ 1 callersFunctioncrc32c_4k_fusion
cpp/crc32c/crc32c_body.c:15
↓ 1 callersFunctioncrc32c_mod_p
cpp/crc32c/crc32c_body.c:243
↓ 1 callersFunctioncrc32c_mul
cpp/crc32c/crc32c_body.c:212
↓ 1 callersFunctioncrc32c_x_pow_neg_n
cpp/crc32c/crc32c_body.c:288
↓ 1 callersFunctioncrc_append
(crc1, crc2, l2)
cpp/crc32c/crc32c.py:49
↓ 1 callersFunctioncrc_precond_append
(crc1, crc2, l2)
cpp/crc32c/crc32c.py:63
↓ 1 callersFunctioncrc_precond_xor
(crc1, crc2, l)
cpp/crc32c/crc32c.py:83
↓ 1 callersFunctioncrc_prepostcond_append
(crc1, crc2, l2)
cpp/crc32c/crc32c.py:75
↓ 1 callersFunctioncrc_prepostcond_xor
(crc1, crc2, l)
cpp/crc32c/crc32c.py:92
↓ 1 callersMethodcreate_ca_cert_store
cpp/core/httplib.h:7982
↓ 1 callersMethoddecompress
cpp/core/httplib.h:3499
↓ 1 callersFunctiondefragFileReplace
Replaces a file with another, identical one.
go/cleanup/defrag.go:241
↓ 1 callersFunctiondefragPrintStatsLastReport
(log *log.Logger, c *client.Client, stats *DefragStats, timeStats *timeStats, progressReportAlert *log.XmonNCA
go/cleanup/defrag.go:35
↓ 1 callersFunctiondeleteDir
(log *log.Logger, client *client.Client, ownerId msgs.InodeId, name string, creationTime msgs.TernTime, dirId
go/terntests/cleanup.go:17
↓ 1 callersFunctiondestructFilesScraper
( log *log.Logger, c *client.Client, state *DestructFilesState, terminateChan chan<- any, shid msgs.Shard
go/cleanup/destructfiles.go:177
↓ 1 callersFunctiondestructFilesWorker
( log *log.Logger, c *client.Client, stats *DestructFilesState, shid msgs.ShardId, workersChan chan *dest
go/cleanup/destructfiles.go:145
↓ 1 callersMethoddir
(path []int)
go/terntests/fstest.go:623
↓ 1 callersFunctiondirSeekTest
(log *log.Logger, registryAddress string, mountPoint string, numPaths int)
go/terntests/dirseek.go:165
↓ 1 callersMethoddrainSocket
terminates when the socket is closed
go/client/client.go:556
↓ 1 callersMethoddropEntry
cpp/core/LogsDB.cpp:134
↓ 1 callersMethoddumpRocksDBStatistics
cpp/core/SharedRocksDB.cpp:193
↓ 1 callersFunctionedgesAsOf
(allEdges []fullEdge, t msgs.TernTime)
go/terntests/filehistory.go:211
↓ 1 callersFunctionencode_query_param
cpp/core/httplib.h:2337
↓ 1 callersFunctionencode_url
cpp/core/httplib.h:2358
← previousnext →1,101–1,200 of 4,832, ranked by callers