MCPcopy Create free account

hub / github.com/XTXMarkets/ternfs / functions

Functions4,832 in github.com/XTXMarkets/ternfs

⨍ Functions 4,832◇ Types & classes 1,957
↓ 2 callersFunctionfetch_span_pages_state_request_full_fetch
kmod/span.c:139
↓ 2 callersMethodfieldRaw
(name string, value string)
go/core/log/metrics.go:75
↓ 2 callersFunctionfill
NOLINTEND(*-avoid-c-arrays)
cpp/tests/doctest.h:1153
↓ 2 callersFunctionfind_policy
kmod/policy.c:47
↓ 2 callersMethodfirstSeen
cpp/shard/BlockServicesCacheDB.cpp:222
↓ 2 callersMethodformatLog
(level LogLevel, time time.Time, file string, line int, format string, v ...any)
go/core/log/log.go:85
↓ 2 callersMethodfreeBlocks
(bufPool *bufpool.BufPool)
go/client/span.go:983
↓ 2 callersFunctionfrom_hex_to_i
cpp/core/httplib.h:2197
↓ 2 callersFunctionfrom_i_to_hex
cpp/core/httplib.h:2214
↓ 2 callersFunctionfulltext_log_assert_to_stream
cpp/tests/doctest.h:5603
↓ 2 callersMethodgenInSlice
lack of pointer is intentional: we don't want to destructively update the tabs.
go/bincodegen/bincodegen.go:68
↓ 2 callersFunctiongenRenameFile
(filePrefix string, rand *wyhash.Rand, files *fileHistoryFiles)
go/terntests/filehistory.go:121
↓ 2 callersMethodgenerateDouble
cpp/core/Random.cpp:61
↓ 2 callersFunctiongenerateErrString
cpp/core/Xmon.cpp:52
↓ 2 callersFunctiongenerateKmodStructOpaque
(w io.Writer, typ reflect.Type, suffix string)
go/bincodegen/bincodegen.go:404
↓ 2 callersFunctiongetFileLine
(calldepth int)
go/core/log/log.go:195
↓ 2 callersMethodgetNextBlockServiceIdx
cpp/registry/RegistryDB.cpp:700
↓ 2 callersMethodgetReplicaId
cpp/core/LogsDB.cpp:456
↓ 2 callersMethodgetReplicas
cpp/cdc/CDC.cpp:61
↓ 2 callersMethodgetRequest
cpp/core/LogsDB.cpp:560
↓ 2 callersFunctionget_local_ip_and_port
cpp/core/httplib.h:3256
↓ 2 callersFunctionget_metadata_request
kmod/net.c:29
↓ 2 callersFunctionget_remote_ip_and_port
cpp/core/httplib.h:3265
↓ 2 callersMethodgetattr
(f fs.FileHandle, out *fuse.Attr)
go/ternfuse/ternfuse.go:158
↓ 2 callersFunctionhandleRequest
( log *log.Logger, env *env, terminateChan chan any, blockServices map[msgs.BlockServiceId]*blockService,
go/ternblocks/ternblocks.go:1083
↓ 2 callersMethodhasFiles
cpp/shard/BlockServicesCacheDB.cpp:252
↓ 2 callersFunctionhas_header
cpp/core/httplib.h:3629
↓ 2 callersFunctioninc_latency_bucket
jiffies only have millisecond precision, but we still use nanoseconds as the format is nicer and makes the buckets a bit more precise. |1 below drops
kmod/net.c:248
↓ 2 callersMethodincrementDirs
(log *log.Logger, opts *fsTestOpts)
go/terntests/fstest.go:638
↓ 2 callersMethodincrementFiles
(log *log.Logger, opts *fsTestOpts)
go/terntests/fstest.go:696
↓ 2 callersMethodinit
(slots int32)
go/client/dirinfocache.go:46
↓ 2 callersFunctioninitOut
(filename string)
go/core/managedprocess/managedprocess.go:87
↓ 2 callersFunctioninitializeCdcForLocation
cpp/registry/RegistryDBData.hpp:242
↓ 2 callersFunctioninitializeShardsForLocation
cpp/registry/RegistryDBData.hpp:176
↓ 2 callersFunctioninode_set_mtime_to_ts
kmod/inode_compat.h:108
↓ 2 callersFunctioninsertPageCrcs
(data []byte)
go/client/span_test.go:124
↓ 2 callersMethodisInitialStart
cpp/core/LogsDB.cpp:413
↓ 2 callersFunctionis_multipart_boundary_chars_valid
cpp/core/httplib.h:4534
↓ 2 callersMethodis_multipart_form_data
cpp/core/httplib.h:5155
↓ 2 callersMethodis_valid
cpp/core/httplib.h:3497
↓ 2 callersFunctionkmodFieldName
(s string)
go/bincodegen/bincodegen.go:381
↓ 2 callersFunctionkmodMaxSizeName
(typ reflect.Type)
go/bincodegen/bincodegen.go:398
↓ 2 callersFunctionkmodStaticSizeName
(typ reflect.Type)
go/bincodegen/bincodegen.go:392
↓ 2 callersFunctionkmodType
(t reflect.Type)
go/bincodegen/bincodegen.go:474
↓ 2 callersMethodlastAppliedLogEntry
cpp/shard/ShardDB.cpp:4127
↓ 2 callersMethodlastInfoChange
cpp/shard/BlockServicesCacheDB.cpp:242
↓ 2 callersMethodlocationId
cpp/shard/BlockServicesCacheDB.cpp:182
↓ 2 callersMethodlocked
cpp/shard/ShardDBData.hpp:648
↓ 2 callersMethodlookupDir
lookupDir traverses a path to find the final directory's InodeId.
go/s3/s3.go:414
↓ 2 callersFunctionm
(n)
go/ternweb/preact-10.18.1.module.js:5
↓ 2 callersMethodmakeDirFromTemp
(log *log.Logger, harness fsTestHarness[Id], opts *fsTestOpts, parent []int, name int, tmpParent []int)
go/terntests/fstest.go:669
↓ 2 callersFunctionmake_basic_authentication_header
cpp/core/httplib.h:5099
↓ 2 callersFunctionmake_bearer_token_authentication_header
cpp/core/httplib.h:5107
↓ 2 callersFunctionmake_digest_authentication_header
cpp/core/httplib.h:4914
↓ 2 callersMethodmetadataRequest
( log *log.Logger, shid int16, // -1 for cdc reqBody bincode.Packable, respBody bincode.Unpackable, count
go/client/metadatareq.go:20
↓ 2 callersFunctionmigrateBlocksInternal
Tries to migrate as many blocks as possible from that block service in a certain shard.
go/cleanup/migrate.go:481
↓ 2 callersFunctionmix
cpp/core/Random.cpp:22
↓ 2 callersMethodopen
cpp/core/httplib.h:2566
↓ 2 callersMethodpack
cpp/core/MsgsGen.cpp:675
↓ 2 callersMethodpack
cpp/core/Msgs.hpp:422
↓ 2 callersMethodpackScalar
cpp/core/Bincode.hpp:299
↓ 2 callersMethodpackedSize
cpp/core/MsgsGen.cpp:6467
↓ 2 callersMethodparse
cpp/core/httplib.h:4277
↓ 2 callersFunctionparseKernelLatencies
(serviceType string, nInstances int, metricsHeader kernelMetricsHeader)
go/terncli/kernelmetrics.go:134
↓ 2 callersFunctionparseKernelMetricsCounters
(serviceType string, nInstances int, metricsHeader kernelMetricsHeader)
go/terncli/kernelmetrics.go:94
↓ 2 callersFunctionparseOptionImpl
the implementation of parseOption()
cpp/tests/doctest.h:6386
↓ 2 callersMethodparseResponse
(log *log.Logger, req *metadataProcessorRequest, rawResp *rawMetadataResponse, dischargeBuf bool)
go/client/client.go:371
↓ 2 callersFunctionparseTag
(tag reflect.StructTag)
go/bincodegen/bincodegen.go:140
↓ 2 callersFunctionparseUint32
cpp/core/CommonOptions.hpp:441
↓ 2 callersFunctionparse_header
cpp/core/httplib.h:3652
↓ 2 callersFunctionparse_query_text
cpp/core/httplib.h:4165
↓ 2 callersFunctionparse_www_authenticate
cpp/core/httplib.h:4975
↓ 2 callersMethodpath
cpp/shard/BlockServicesCacheDB.cpp:262
↓ 2 callersFunctionpolicy_key
kmod/policy.c:43
↓ 2 callersFunctionprepare_resp_ctx
kmod/metadata.c:71
↓ 2 callersFunctionprintCrc32
(name string, r io.Reader)
go/crc32csum/crc32csum.go:17
↓ 2 callersFunctionprintDelta
cpp/ktools/ternktools.cpp:295
↓ 2 callersFunctionprintOut
(what string, out io.Writer, w io.Writer)
go/core/managedprocess/managedprocess.go:99
↓ 2 callersFunctionprintStatsLastReport
(log *log.Logger, what string, c *client.Client, stats *MigrateStats, timeStats *timeStats, progressReportAler
go/cleanup/migrate.go:249
↓ 2 callersMethodprocessRawResponse
(log *log.Logger, rawResp *rawMetadataResponse)
go/client/client.go:463
↓ 2 callersMethodprocessRequests
terminates when cm.incoming gets nil
go/client/client.go:292
↓ 2 callersMethodprocessResponses
terminates when `cm.quitResponseProcessor` gets a message
go/client/client.go:516
↓ 2 callersFunctionprocess_server_socket_core
cpp/core/httplib.h:2883
↓ 2 callersFunctionrandom_string
https://stackoverflow.com/questions/440133/how-do-i-create-a-random-alpha-numeric-string-in-c/440240#answer-440240
cpp/core/httplib.h:5009
↓ 2 callersFunctionreadDir
(log *log.Logger, client *client.Client, dir msgs.InodeId)
go/terntests/req.go:132
↓ 2 callersMethodreadDirectory
files, directories
go/terntests/fstest.go:64
↓ 2 callersFunctionreadFileSetattr
(id msgs.InodeId, in *fuse.SetAttrIn, out *fuse.AttrOut)
go/ternfuse/ternfuse.go:458
↓ 2 callersMethodreadLogEntry
cpp/core/LogsDB.cpp:245
↓ 2 callersFunctionreadRs
The goal here is to read as little as possible (i.e. only the pages involved), which is a common use case for flash storage. We also assume that while
go/client/span.go:1316
↓ 2 callersFunctionread_content_with_length
cpp/core/httplib.h:3724
↓ 2 callersMethodreceiveMessages
cpp/registry/RegistryServer.cpp:63
↓ 2 callersMethodrefreshAddrs
()
go/client/client.go:971
↓ 2 callersFunctionregisterReporterImpl
cpp/tests/doctest.h:7003
↓ 2 callersFunctionregistryToLastHeartBeat
cpp/registry/RegistryDBData.hpp:381
↓ 2 callersMethodrelease
cpp/core/Connect.hpp:35
↓ 2 callersMethodremoveWork
cpp/core/SPSC.hpp:65
↓ 2 callersMethodrename
(log *log.Logger, isDirectory bool, targetId Id, oldOwner Id, oldCreationTime msgs.TernTime, oldName string, n
go/terntests/fstest.go:60
↓ 2 callersMethodreplicas
cpp/registry/Registerer.hpp:36
↓ 2 callersMethodrocksDBMetrics
cpp/core/SharedRocksDB.cpp:187
↓ 2 callersFunctionrs_cpuidex
out must be at leas size 4
cpp/rs/rs_core.c:177
← previousnext →801–900 of 4,832, ranked by callers