MCPcopy Create free account

hub / github.com/MilenMT/torus / functions

Functions1,324 in github.com/MilenMT/torus

⨍ Functions 1,324◇ Types & classes 158
↓ 3 callersFunctionnewDeviceBlockTester
(deviceSize uint64)
storage/block_device_test.go:43
↓ 3 callersFunctionnewDistributor
(srv *torus.Server, addr *url.URL)
distributor/distributor.go:37
↓ 3 callersFunctionnewServer
(md *temp.Server)
block/volume_test.go:19
↓ 3 callersMethodoffset
()
internal/nbd/nbd.go:388
↓ 3 callersMethodopenWrite
()
file.go:102
↓ 3 callersFunctionpstring
poke a string into p at off and pad with space
block/aoe/device.go:68
↓ 3 callersMethodresetConn
resetConn resets connection for the uuid.
distributor/client.go:101
↓ 3 callersFunctionrun
(cmd string, args ...string)
storage/block_device_test.go:35
↓ 3 callersFunctionstderr
(msg string, args ...interface{})
cmd/fsck.torus/fsck.torus.go:19
↓ 3 callersFunctiontestRequest
testRequest performs a single AoE request using the input request header and returns a single AoE response.
block/aoe/aoe_test.go:232
↓ 3 callersMethodtracef
(format string, stuff ...interface{})
internal/nbd/nbdserver.go:110
↓ 3 callersMethodwriteData
(offset uint64, data []byte)
storage/block_device.go:269
↓ 2 callersMethodAtomicModifyKey
TODO(barakmich): Perhaps make this an etcd client library function.
metadata/etcd/etcd.go:243
↓ 2 callersMethodBlock
(ctx context.Context, ref torus.BlockRef)
distributor/protocols/protocols.go:17
↓ 2 callersMethodChangeReplication
(r int)
ring.go:23
↓ 2 callersMethodClear
()
gc/gc.go:22
↓ 2 callersMethodDelete
(br torus.BlockRef)
storage/block_device/blockHeader.go:118
↓ 2 callersMethodDeleteVolume
()
block/metadata.go:30
↓ 2 callersMethodDisconnect
()
internal/nbd/nbd.go:260
↓ 2 callersMethodExtendContext
(ctx context.Context)
server.go:109
↓ 2 callersMethodGetBlocks
()
models/torus.pb.go:61
↓ 2 callersMethodGetLiveINodes
GetLiveInodes returns the current INode representation of the Blockset. The returned INode might not be synced.
blockset.go:23
↓ 2 callersMethodGetPeerMap
()
server.go:115
↓ 2 callersMethodHasBlock
(ctx context.Context, b BlockRef)
storage.go:251
↓ 2 callersMethodHasBlock
(_ context.Context, s torus.BlockRef)
storage/temp.go:63
↓ 2 callersMethodHasBlock
(_ context.Context, s torus.BlockRef)
storage/mfile.go:187
↓ 2 callersMethodHasUUID
(uuid string)
ring.go:102
↓ 2 callersMethodIsDead
(torus.BlockRef)
gc/gc.go:21
↓ 2 callersMethodIsUsed
()
storage/block_device/blockHeader.go:97
↓ 2 callersMethodKind
()
storage/temp.go:38
↓ 2 callersMethodLease
()
server.go:65
↓ 2 callersFunctionListenReplication
ListenReplication opens the internal networking port and connects to the cluster
distributor/replication.go:15
↓ 2 callersMethodMarshal
()
storage/block_device/metadata.go:16
↓ 2 callersFunctionMustParseBlockLayerSpec
(s string)
blockset/blockset_main.go:154
↓ 2 callersMethodNumBlocks
()
storage/temp.go:51
↓ 2 callersMethodNumBlocks
NumBlocks returns the total capacity of the file in blocks.
storage/mmap_file.go:82
↓ 2 callersMethodPrepVolume
(*models.Volume)
distributor/rebalance/rebalancer.go:24
↓ 2 callersMethodReadFrom
(b []byte)
block/aoe/aoe_test.go:385
↓ 2 callersMethodRestoreSnapshot
(name string)
block/blockfile.go:88
↓ 2 callersMethodRing
()
distributor/rebalance/rebalancer.go:17
↓ 2 callersMethodSend
(hdr *aoe.Header)
block/aoe/frame.go:44
↓ 2 callersMethodServe
()
internal/nbd/nbd.go:175
↓ 2 callersMethodSetBlockSize
(blocksize int64)
internal/nbd/nbd.go:126
↓ 2 callersMethodString
()
storage/block_device/blockHeader.go:39
↓ 2 callersMethodSyncAllWrites
()
file.go:351
↓ 2 callersMethodSyncBlocks
()
file.go:378
↓ 2 callersFunctionUint64ToBytes
(x uint64)
metadata/etcd/helpers.go:15
↓ 2 callersFunctionUnmarshal
(b []byte)
ring/ring_main.go:22
↓ 2 callersMethodUnmarshal
(buf []byte)
storage/block_device/blockHeader.go:57
↓ 2 callersMethodUpdatePeerMap
()
heartbeat.go:155
↓ 2 callersMethodUsedBlocks
()
storage.go:257
↓ 2 callersMethodUsedBlocks
()
storage/temp.go:57
↓ 2 callersMethodVersionStart
()
distributor/rebalance/rebalancer.go:23
↓ 2 callersFunctionbenchmarkWrites
(b *testing.B, flush bool)
storage/mmap_file_test.go:21
↓ 2 callersFunctionbitsetFromBool
(in []bool)
distributor/protocols/tdp/bitset.go:31
↓ 2 callersFunctioncompareBytes
(t *testing.T, mds *temp.Server, data []byte, volume string)
integration/integration_test.go:173
↓ 2 callersMethodcreateOrRenewLease
(ctx context.Context)
server.go:50
↓ 2 callersFunctioncreateVol
(t *testing.T, server *torus.Server, volname string, size uint64)
integration/integration_test.go:123
↓ 2 callersFunctiondefaultConfig
defaultConfig is the default AoE server configuration.
block/aoe/aoe.go:265
↓ 2 callersFunctiondie
(why string, args ...interface{})
cmd/fsck.torus/fsck.torus.go:29
↓ 2 callersMethodfindDefaultBlockOffset
(b torus.BlockRef)
storage/block_device.go:428
↓ 2 callersMethodfindEmpty
()
storage/mfile.go:175
↓ 2 callersFunctionflush
(d string)
cmd/torusblk/aoe.go:125
↓ 2 callersMethodflush
()
storage/mfile.go:128
↓ 2 callersMethodget
(key string)
distributor/lru.go:65
↓ 2 callersMethodgetOrCreateBlockINode
(ref torus.INodeRef)
block/volume.go:129
↓ 2 callersMethodgetRing
()
metadata/etcd/etcd.go:385
↓ 2 callersMethodgetWriteFromServer
()
distributor/storage.go:175
↓ 2 callersMethodhandleFrame
(from net.Addr, iface *Interface, f *Frame)
block/aoe/aoe.go:194
↓ 2 callersMethodincrementUsedBlocks
()
storage/block_device.go:468
↓ 2 callersMethodlength
()
internal/nbd/nbd.go:380
↓ 2 callersFunctionloadIndex
(m *MFile)
storage/mfile.go:37
↓ 2 callersMethodmakeID
(torus.INodeRef)
blockset/blockset_main.go:38
↓ 2 callersFunctionmarshalTest
(t *testing.T, s torus.BlockStore, spec torus.BlockLayerSpec)
blockset/base_test.go:49
↓ 2 callersMethodmustAssembleBPF
mustAssembleBPF assembles a BPF program to filter out packets not bound for this server.
block/aoe/aoe.go:281
↓ 2 callersFunctionnewReplicationBlockset
(sub blockset, bs torus.BlockStore, r int)
blockset/replication.go:40
↓ 2 callersFunctionnewServer
(md *temp.Server)
distributor/distributor_test.go:15
↓ 2 callersMethodnextHelper
(firstRun bool)
storage/block_device.go:352
↓ 2 callersFunctionopenReplication
(s *torus.Server, addr *url.URL)
distributor/replication.go:23
↓ 2 callersFunctionopenVol
(t *testing.T, server *torus.Server, volname string)
integration/integration_test.go:131
↓ 2 callersFunctionparseJSONArg
(s string)
cmd/torusblk/flex.go:129
↓ 2 callersMethodprintBalance
()
cmd/ringtool/ringtool.go:164
↓ 2 callersMethodreadFromPeer
(ctx context.Context, i torus.BlockRef, peer string)
distributor/storage.go:163
↓ 2 callersMethodreadSequential
(ctx context.Context, i torus.BlockRef, peers torus.PeerPermutation, timeout time.Duration)
distributor/storage.go:87
↓ 2 callersFunctionreadWriteTest
(t *testing.T, b blockset)
blockset/base_test.go:22
↓ 2 callersMethodresize
(buf []byte)
internal/nbd/nbd.go:395
↓ 2 callersFunctionringN
(t testing.TB, n int)
distributor/rpc_test.go:94
↓ 2 callersMethodserveLoop
(dev Device, wg *sync.WaitGroup)
internal/nbd/nbd.go:298
↓ 2 callersMethodset
(i int)
distributor/protocols/tdp/bitset.go:5
↓ 2 callersMethodsetStore
(store torus.BlockStore)
blockset/blockset_main.go:39
↓ 2 callersMethodupdatePeerMap
()
heartbeat.go:122
↓ 2 callersFunctionvolumeCreateBlockFromSnapshotAction
(cmd *cobra.Command, args []string)
cmd/torusctl/volume.go:133
↓ 2 callersFunctionwriteFull
(w io.Writer, buf []byte)
internal/nbd/nbdserver.go:239
↓ 2 callersMethodwriteMetadata
()
storage/block_device.go:478
↓ 2 callersMethodwriteToBlock
(i, from, to int, data []byte)
file.go:124
↓ 1 callersMethodAddTimeoutCallback
(f func(uuid string))
heartbeat.go:95
↓ 1 callersMethodBeginHeartbeat
BeginHeartbeat spawns a goroutine for heartbeats. Non-blocking.
heartbeat.go:40
↓ 1 callersMethodCheck
(ctx context.Context, peer string, refs []torus.BlockRef)
distributor/rebalance/rebalancer.go:29
↓ 1 callersMethodClear
()
block/gc_block_vol.go:134
↓ 1 callersMethodClose
()
server.go:71
← previousnext →201–300 of 1,324, ranked by callers