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 callersFunctionwriteRegistryResponseError
(log *log.Logger, w io.Writer, err msgs.TernError)
go/ternregistryproxy/ternregistryproxy.go:215
↓ 2 callersMethodwriteSpan
Writes out current span. Does _not_ replenish f.span. Must be a locked transient file.
go/ternfuse/ternfuse.go:346
↓ 2 callersMethodwriteSpanBlocks
( log *log.Logger, id msgs.InodeId, initiateReqWrapper msgs.ShardRequest, initiateRespWrapper msgs.ShardRe
go/client/span.go:398
↓ 2 callersFunctionwrite_block_finalize
kmod/file.c:279
↓ 2 callersFunctionwrite_content_chunked
cpp/core/httplib.h:4016
↓ 2 callersFunctionwrite_headers
cpp/core/httplib.h:3914
↓ 2 callersMethodwritersToPageCache
()
go/client/span.go:892
↓ 1 callersFunction$
(n,l,u)
go/ternweb/preact-10.18.1.module.js:5
↓ 1 callersFunctionA
(n,l,u,t)
go/ternweb/preact-10.18.1.module.js:5
↓ 1 callersMethodActive
()
go/msgs/msgs.go:1625
↓ 1 callersFunctionActiveDeleteAfterTime
(duration time.Duration)
go/msgs/msgs.go:1615
↓ 1 callersFunctionActiveDeleteAfterVersions
(versions int16)
go/msgs/msgs.go:1645
↓ 1 callersMethodAdvance
This lets you assert that you've written already checked pages for a total of `count` bytes (_excluding_ CRCs).
go/client/client.go:1559
↓ 1 callersFunctionAppend
(crc1 uint32, crc2 uint32, len2 int)
go/core/crc32c/crc32c.go:29
↓ 1 callersFunctionB
(u,t,i)
go/ternweb/preact-10.18.1.module.js:5
↓ 1 callersFunctionB
(n,t)
go/ternweb/preact-hooks-10.18.1.module.js:5
↓ 1 callersFunctionBlockEraseCertificate
(blockServiceId msgs.BlockServiceId, blockId msgs.BlockId, key cipher.Block)
go/core/certificate/blockscert.go:30
↓ 1 callersFunctionBlockEraseProof
(blockServiceId msgs.BlockServiceId, blockId msgs.BlockId, key cipher.Block)
go/core/certificate/blockscert.go:45
↓ 1 callersFunctionBlockServiceFlagFromName
(n string)
go/msgs/msgs.go:112
↓ 1 callersFunctionBlockWriteCertificate
(cipher cipher.Block, blockServiceId msgs.BlockServiceId, req *msgs.WriteBlockReq)
go/core/certificate/blockscert.go:15
↓ 1 callersFunctionBlockWriteProof
(blockServiceId msgs.BlockServiceId, blockId msgs.BlockId, key cipher.Block)
go/ternblocks/ternblocks.go:145
↓ 1 callersFunctionCBCMAC
Intended to be used with AES-128
go/core/cbcmac/cbcmac.go:13
↓ 1 callersMethodCDCResponseKind
()
go/msgs/msgs_bincode.go:37
↓ 1 callersMethodCanWrite
()
go/msgs/msgs.go:189
↓ 1 callersMethodClear
(log *Logger, xmon *Xmon)
go/core/log/xmon.go:635
↓ 1 callersMethodClose
()
go/core/timing/ratelimit.go:65
↓ 1 callersMethodClose
()
go/core/managedprocess/managedprocess.go:234
↓ 1 callersFunctionCollectDirectories
( log *log.Logger, c *client.Client, dirInfoCache *client.DirInfoCache, rateLimit *timing.RateLimit, opts
go/cleanup/collectdirectories.go:249
↓ 1 callersFunctionCollectDirectory
(log *log.Logger, c *client.Client, dirInfoCache *client.DirInfoCache, stats *CollectDirectoriesStats, dirId m
go/cleanup/collectdirectories.go:110
↓ 1 callersMethodConsume
Does something with the crc for the page starting at this offset.
go/client/client.go:1494
↓ 1 callersMethodContext
cpp/tests/doctest.h:6526
↓ 1 callersMethodCrcs
()
go/client/client.go:1526
↓ 1 callersFunctionCreateInt64AddOperator
cpp/core/RocksDBUtils.cpp:41
↓ 1 callersMethodCreateSpanWithParams
( log *log.Logger, blacklist []msgs.BlacklistEntry, spanParams *SpanParameters, id msgs.InodeId, referenc
go/client/span.go:309
↓ 1 callersFunctionD
(n,l,u,t,i)
go/ternweb/preact-10.18.1.module.js:5
↓ 1 callersFunctionDestructFile
( log *log.Logger, c *client.Client, stats *DestructFilesStats, id msgs.InodeId, deadline msgs.TernTime,
go/cleanup/destructfiles.go:40
↓ 1 callersFunctionDestructFiles
( log *log.Logger, c *client.Client, opts *DestructFilesOptions, stats *DestructFilesState, shid msgs.Sha
go/cleanup/destructfiles.go:229
↓ 1 callersMethodDiv
(quotient uint32)
go/divide32/divide32.go:23
↓ 1 callersMethodEraseBlock
(log *log.Logger, block *msgs.RemoveSpanInitiateBlockInfo)
go/client/client.go:1632
↓ 1 callersMethodEraseDecommissionedBlock
(block *msgs.RemoveSpanInitiateBlockInfo)
go/client/client.go:1644
↓ 1 callersMethodFetchFile
( log *log.Logger, bufPool *bufpool.BufPool, id msgs.InodeId, )
go/client/span.go:1507
↓ 1 callersFunctionHardUnlinkFile
( log *log.Logger, c *client.Client, dirId msgs.InodeId, fileId msgs.InodeId, name string, creationTime
go/cleanup/collectdirectories.go:33
↓ 1 callersMethodHits
()
go/client/dirinfocache.go:283
↓ 1 callersFunctionInactiveDeleteAfterTime
()
go/msgs/msgs.go:1611
↓ 1 callersFunctionInactiveDeleteAfterVersions
()
go/msgs/msgs.go:1641
↓ 1 callersMethodIncreaseNumRegistryHandlersTo
(numHandlers uint)
go/client/client.go:1117
↓ 1 callersMethodInfoStack
(calldepth int, format string, v ...any)
go/core/log/log.go:243
↓ 1 callersMethodIsReady
()
go/client/client.go:1236
↓ 1 callersMethodLevel
()
go/core/log/log.go:183
↓ 1 callersMethodLog
(log *log.Logger)
go/client/client.go:82
↓ 1 callersMethodLookupCachedDirInfoEntry
If it couldn't be found, will return NULL_INODE_ID. Otherwise that's where it was inherited from.
go/client/dirinfocache.go:156
↓ 1 callersMethodLookups
()
go/client/dirinfocache.go:287
↓ 1 callersFunctionM
(l,u,t,i,o,r,f,e,s)
go/ternweb/preact-10.18.1.module.js:5
↓ 1 callersFunctionMakeContextScope
cpp/tests/doctest.h:1874
↓ 1 callersFunctionMakeInodeIdExtra
(id InodeId, owned bool)
go/msgs/msgs.go:474
↓ 1 callersFunctionMakeShardReplicaId
(shard ShardId, replica ReplicaId)
go/msgs/msgs.go:257
↓ 1 callersFunctionMakeTernTime
(t time.Time)
go/msgs/msgs.go:488
↓ 1 callersMethodMerge
cpp/core/RocksDBUtils.cpp:17
↓ 1 callersMethodMerge
(t2 *Timings)
go/core/timing/timings.go:21
↓ 1 callersFunctionMergeReqCounters
(cs []ReqCounters)
go/client/client.go:46
↓ 1 callersMethodMigrationFinishedStats
()
go/cleanup/migrate.go:718
↓ 1 callersFunctionMkFailureDomain
(str string)
go/msgs/msgs.go:755
↓ 1 callersFunctionMkParity
(dataBlocks uint8, parityBlocks uint8)
go/core/parity/parity.go:14
↓ 1 callersFunctionNewClient
Create a new client by acquiring the CDC and Shard connection details from Registry. It also refreshes the shard/cdc infos every minute.
go/client/client.go:1050
↓ 1 callersFunctionNewClientDirectNoAddrs
( log *log.Logger, localAddresses msgs.AddrsInfo, )
go/client/client.go:1135
↓ 1 callersFunctionNewHardwareEventClient
(serverURL string)
go/core/log/hardwareevent.go:50
↓ 1 callersFunctionNewHistogram
(bins int, firstUpperBound uint64, growth float64)
go/core/timing/histogram.go:20
↓ 1 callersFunctionNewTimings
(bins int, firstUpperBound time.Duration, growth float64)
go/core/timing/timings.go:47
↓ 1 callersFunctionNewXmon
(log *Logger, config *XmonConfig)
go/core/log/xmon.go:479
↓ 1 callersMethodP
(target float64)
go/core/timing/timings.go:105
↓ 1 callersMethodPagesWithCrcBuffer
()
go/client/client.go:1553
↓ 1 callersMethodPop
()
go/client/client.go:212
↓ 1 callersMethodPop
()
go/cleanup/migrate.go:806
↓ 1 callersMethodPush
(x any)
go/client/client.go:205
↓ 1 callersFunctionREGISTER_EXCEPTION_TRANSLATOR
cpp/tests/tests.cpp:28
↓ 1 callersMethodRaiseAlertAppType
(appType XmonAppType, format string, v ...any)
go/core/log/log.go:260
↓ 1 callersMethodRaiseHardwareEvent
Asynchronously sends a hardware event to the server or simply logs if hardware event logging is not enabled.
go/core/log/log.go:289
↓ 1 callersMethodRaiseNCStack
(alert *XmonNCAlert, calldepth int, format string, v ...any)
go/core/log/log.go:268
↓ 1 callersMethodRecover
( haveBlocks uint32, blocks [][]byte, wantBlock uint8, )
go/core/rs/rs.go:87
↓ 1 callersMethodRegistryResponseKind
()
go/msgs/msgs.go:2045
↓ 1 callersMethodRemoveDirectoryInfoEntry
Not atomic between the read/write
go/client/client.go:1281
↓ 1 callersMethodResolve
(ownerInode msgs.InodeId, filename string)
go/terncli/filesamples/filesamples.go:47
↓ 1 callersMethodResolveFilePaths
Given an input of `sample-files` output, resolves the full path for every sample, and writes enriched samples to output.
go/terncli/filesamples/filesamples.go:25
↓ 1 callersFunctionScrubFiles
( log *log.Logger, c *client.Client, opts *ScrubOptions, rateLimit *timing.RateLimit, stats *ScrubState,
go/cleanup/scrub.go:273
↓ 1 callersMethodSendHardwareEvent
(he HardwareEvent)
go/core/log/hardwareevent.go:56
↓ 1 callersMethodSetAddrs
Modify the CDC and Shard IP addresses and ports dynamically. The update is atomic, this can be done at any time from any context.
go/client/client.go:1204
↓ 1 callersMethodSetattr
(ctx context.Context, in *fuse.SetAttrIn, out *fuse.AttrOut)
go/ternfuse/ternfuse.go:484
↓ 1 callersMethodShard
()
go/msgs/msgs.go:261
↓ 1 callersMethodShardRequestDontWait
( logger *log.Logger, shid msgs.ShardId, reqBody msgs.ShardRequest, )
go/client/shardreq.go:175
↓ 1 callersMethodShardResponseKind
()
go/msgs/msgs_bincode.go:25
↓ 1 callersMethodStartGc
(ll *log.Logger, opts *GcOptions)
go/core/managedprocess/managedprocess.go:533
↓ 1 callersMethodStartRegistryProxy
(ll *log.Logger, opts *RegistryProxyOpts)
go/core/managedprocess/managedprocess.go:489
↓ 1 callersMethodStartWeb
(ll *log.Logger, opts *WebOptions)
go/core/managedprocess/managedprocess.go:585
↓ 1 callersMethodStartWriteBlock
An asynchronous version of [StartBlock] that is currently unused.
go/client/client.go:1393
↓ 1 callersFunctionStorageClassFromString
(s string)
go/msgs/msgs.go:577
↓ 1 callersMethodString
()
go/msgs/msgs.go:269
↓ 1 callersMethodString
()
go/msgs/msgs.go:500
↓ 1 callersMethodString
()
go/msgs/msgs.go:526
↓ 1 callersMethodString
()
go/msgs/msgs.go:745
↓ 1 callersMethodString
()
go/msgs/msgs_bincode.go:261
← previousnext →1,001–1,100 of 4,832, ranked by callers