MCPcopy Create free account

hub / github.com/XTXMarkets/ternfs / functions

Functions4,832 in github.com/XTXMarkets/ternfs

⨍ Functions 4,832◇ Types & classes 1,957
↓ 5 callersFunctionnewFsTestDir
(id Id)
go/terntests/fstest.go:606
↓ 5 callersMethodpack
cpp/registry/RegistryDBLogEntry.cpp:19
↓ 5 callersFunctionparseTemplates
(ts ...namedTemplate)
go/ternweb/ternweb.go:45
↓ 5 callersMethodpline
(s string)
go/bincodegen/bincodegen.go:834
↓ 5 callersFunctionprocess_status
(p, fmt, *args, **kwargs)
common.py:20
↓ 5 callersFunctionreadBlocksResponse
( log *log.Logger, r io.Reader, resp msgs.BlocksResponse, )
go/client/blocksreq.go:71
↓ 5 callersFunctionreadCdcInfo
cpp/registry/RegistryDBData.hpp:211
↓ 5 callersFunctionreadShardInfo
cpp/registry/RegistryDBData.hpp:144
↓ 5 callersMethodremove
(slot int32)
go/client/dirinfocache.go:62
↓ 5 callersFunctionrs_data_blocks
cpp/rs/rs.h:38
↓ 5 callersFunctionrun_docker_unbuffered
(docker_args, args)
ci.py:28
↓ 5 callersMethodsend
This currently never fails (everything network related happens in the processor loops), keeping error since it might fail in the future
go/client/client.go:885
↓ 5 callersFunctionserialize_multipart_formdata
cpp/core/httplib.h:4576
↓ 5 callersMethodsetLastReleased
cpp/core/LogsDB.cpp:513
↓ 5 callersFunctionset_nonblocking
cpp/core/httplib.h:3068
↓ 5 callersMethodshards
cpp/registry/RegistryDB.cpp:1088
↓ 5 callersMethodtargetId
cpp/shard/ShardDBData.hpp:652
↓ 5 callersFunctionternfs_dir_entry_size
kmod/dir.c:19
↓ 5 callersFunctionternfs_get_inode_normal
kmod/inode.h:156
↓ 5 callersFunctionternfs_get_policy_body
kmod/policy.c:139
↓ 5 callersFunctionternfs_send_cdc_req
kmod/metadata.c:178
↓ 5 callersMethodtimespec
cpp/core/Time.hpp:51
↓ 5 callersMethodtoSockAddrIn
cpp/core/Msgs.cpp:11
↓ 5 callersMethoduline
(s string)
go/bincodegen/bincodegen.go:838
↓ 5 callersMethodunlock
(locked *bool)
go/ternfuse/ternfuse.go:413
↓ 5 callersMethodunpack
cpp/registry/RegistryDBLogEntry.cpp:24
↓ 5 callersFunctionwait_cmd
(p, timeout=None)
common.py:42
↓ 5 callersFunctionwriteBlocksRequest
(log *log.Logger, w io.Writer, blockServiceId msgs.BlockServiceId, req msgs.BlocksRequest)
go/client/blocksreq.go:54
↓ 5 callersFunctionwriteCdcInfo
cpp/registry/RegistryDBData.hpp:224
↓ 5 callersFunctionwriteIfChanged
Useful to not have spurious rebuilds that depend on mtime
go/bincodegen/bincodegen.go:1497
↓ 5 callersMethodwriteLogEntries
cpp/core/LogsDB.cpp:278
↓ 5 callersFunctionwriteShardInfo
cpp/registry/RegistryDBData.hpp:157
↓ 4 callersMethodBlocksRequestKind
()
go/msgs/msgs.go:2385
↓ 4 callersMethodBlocksResponseKind
()
go/msgs/msgs.go:2391
↓ 4 callersMethodComputeParityInto
(data [][]byte, parity [][]byte)
go/core/rs/rs.go:72
↓ 4 callersMethodCreateSpan
Appends a new span to a given file. Note: the buffer underlying data might be modified by adding padding zeros for the purpose of splitting things int
go/client/span.go:279
↓ 4 callersMethodError
()
go/s3/s3.go:39
↓ 4 callersMethodFetchBlock
Retrieve a single block from the block server. The block is identified by the BlockService (which holds the id, status flags and ips/ports) and the B
go/client/client.go:1483
↓ 4 callersFunctionFileEtag
FileEtag generates a consistent ETag for a given file ID.
go/s3/s3.go:212
↓ 4 callersMethodGetFailureDomainForBlockService
(blockServiceId msgs.BlockServiceId)
go/client/client.go:1691
↓ 4 callersFunctionI
(n,l,u,t,i)
go/ternweb/preact-10.18.1.module.js:5
↓ 4 callersMethodInodeIdExtra
cpp/core/Msgs.hpp:328
↓ 4 callersMethodLen
()
go/cleanup/migrate.go:784
↓ 4 callersMethodPayload
()
go/core/log/metrics.go:35
↓ 4 callersMethodRaiseAlertStack
(appType XmonAppType, calldepth int, format string, v ...any)
go/core/log/log.go:256
↓ 4 callersMethodRecoverInto
( haveBlocks uint32, // bitmap blocks [][]byte, wantBlock uint8, block []byte, )
go/core/rs/rs.go:97
↓ 4 callersMethodRename
(ctx context.Context, oldName string, newParent0 fs.InodeEmbedder, newName string, flags uint32)
go/ternfuse/ternfuse.go:583
↓ 4 callersMethodReset
()
go/core/timing/timings.go:59
↓ 4 callersFunctionS
(n,l,u)
go/ternweb/preact-10.18.1.module.js:5
↓ 4 callersMethodSendMetrics
(payload io.Reader)
go/core/log/metrics.go:112
↓ 4 callersMethodSetBlockTimeouts
Override the block timeout parameters. This is only safe to use during initialization.
go/client/client.go:1113
↓ 4 callersMethodShardRequestKind
()
go/msgs/msgs_bincode.go:19
↓ 4 callersMethodSink
(level LogLevel)
go/core/log/log.go:350
↓ 4 callersMethodStartFetchBlock
(log *log.Logger, blockService *msgs.BlockService, blockId msgs.BlockId, offset uint32, count uint32, w io.Rea
go/client/span.go:1305
↓ 4 callersMethodString
()
go/msgs/msgs.go:319
↓ 4 callersMethodTotalTime
In these aggregates we're conservative (pick the upper bound)
go/core/timing/timings.go:76
↓ 4 callersMethodWriteCache
(offset uint64, data []byte)
go/client/span.go:1015
↓ 4 callersMethod_setVersion
cpp/cdc/CDCDB.cpp:1485
↓ 4 callersMethodaddFile
(name string, id msgs.InodeId, creationTime msgs.TernTime)
go/terntests/filehistory.go:62
↓ 4 callersFunctionaddressFromReplicaId
cpp/cdc/CDC.cpp:596
↓ 4 callersMethodafterAlloc
cpp/shard/ShardDBData.hpp:557
↓ 4 callersFunctionappTypeString
cpp/core/Xmon.cpp:27
↓ 4 callersMethodbasename
()
go/s3/s3.go:125
↓ 4 callersFunctionblock_socket_key
kmod/block.c:48
↓ 4 callersFunctioncdcRequest
(req msgs.CDCRequest, resp msgs.CDCResponse)
go/ternfuse/ternfuse.go:141
↓ 4 callersMethodcdcs
cpp/registry/RegistryDB.cpp:1100
↓ 4 callersFunctioncheck
cpp/tests/doctest.h:838
↓ 4 callersFunctioncreateFile
( log *log.Logger, client *client.Client, dirInfoCache *client.DirInfoCache, dirId msgs.InodeId, spanSize
go/terntests/req.go:49
↓ 4 callersMethoddeleteCF
cpp/core/SharedRocksDB.cpp:149
↓ 4 callersMethoddone
cpp/core/CommonOptions.hpp:50
↓ 4 callersMethodend
cpp/cdc/CDCDB.cpp:158
↓ 4 callersFunctionenumName
(t reflect.Type)
go/bincodegen/bincodegen.go:200
↓ 4 callersMethodfile
* func (files *files) id(name string) msgs.InodeId { ix, present := files.byName[name] if !present { panic(fmt.Errorf("name not found %v", name))
go/terntests/filehistory.go:80
↓ 4 callersMethodflags
cpp/shard/BlockServicesCacheDB.cpp:172
↓ 4 callersFunctionformatSize
(bytes uint64)
go/ternweb/ternweb.go:268
↓ 4 callersFunctiongenDeleteFile
(filePrefix string, rand *wyhash.Rand, files *fileHistoryFiles)
go/terntests/filehistory.go:116
↓ 4 callersMethodgenerateBytes
cpp/core/Random.cpp:74
↓ 4 callersFunctiongenerateCppReqResp
(hpp io.Writer, cpp io.Writer, what string, reqResps []reqRespType)
go/bincodegen/bincodegen.go:1349
↓ 4 callersFunctiongenerateKmodMsgKind
(hOut io.Writer, cOut io.Writer, what string, reqResps []reqRespType)
go/bincodegen/bincodegen.go:343
↓ 4 callersMethodgetStats
cpp/shard/BlockServicePicker.cpp:342
↓ 4 callersFunctionget_range_offset_and_length
cpp/core/httplib.h:4591
↓ 4 callersFunctiongf_inv
cpp/rs/rs_core.c:17
↓ 4 callersFunctionhandleRecover
( ch chan *errorWithStack, err any, info string, )
go/client/span_test.go:31
↓ 4 callersMethodid
cpp/registry/RegistryDB.cpp:708
↓ 4 callersFunctioninodeTypeToMode
(typ msgs.InodeType)
go/ternfuse/ternfuse.go:115
↓ 4 callersFunctioninode_get_atime_sec
kmod/inode_compat.h:63
↓ 4 callersFunctioninode_set_ctime
kmod/inode_compat.h:50
↓ 4 callersFunctioninode_set_mtime
kmod/inode_compat.h:115
↓ 4 callersFunctionis_space_or_tab
cpp/core/httplib.h:2443
↓ 4 callersFunctionloadState
(db *sql.DB, what string, state any)
go/terngc/terngc.go:58
↓ 4 callersMethodlocations
cpp/registry/RegistryDB.cpp:1077
↓ 4 callersMethodlock
cpp/core/AssertiveLock.hpp:40
↓ 4 callersFunctionlookup
(log *log.Logger, client *client.Client, path string)
go/ternweb/ternweb.go:464
↓ 4 callersFunctionmarshalJSONId
(id uint64)
go/msgs/msgs.go:228
↓ 4 callersFunctionmigrateBlocksInFileGeneric
We reuse this functionality for scrubbing, they're basically doing the same thing.
go/cleanup/migrate.go:267
↓ 4 callersMethodparityBlocks
cpp/core/Msgs.hpp:383
↓ 4 callersFunctionparseKernelMetricsHeader
(serviceType string)
go/terncli/kernelmetrics.go:59
↓ 4 callersFunctionparseObjectPath
(str string)
go/s3/s3.go:143
↓ 4 callersFunctionparseUint8
cpp/core/CommonOptions.hpp:233
↓ 4 callersFunctionprocess_file_pages
kmod/file.c:1176
← previousnext →401–500 of 4,832, ranked by callers