Functions — github.com/datenlord/datenlord

hub / github.com/datenlord/datenlord / functions

Functions1,395 in github.com/datenlord/datenlord

⨍ Functions 1,395◇ Types & classes 335

↓ 1 callersMethodfind_volume_by_id

Find volume by ID

src/csi/meta_data.rs:603

↓ 1 callersFunctionflags2str

tests/fstest_dir/fstest.c:250

↓ 1 callersMethodflush

(&self, ino: INum)

src/storage/mock.rs:103

↓ 1 callersMethodflush

(&self, _: INum)

src/storage/backend/backend_impl.rs:288

↓ 1 callersMethodflush

( &self, req: &Request<'_>, fh: u64, lock_owner: u64, reply: ReplyEmpt

src/async_fuse/fuse/file_system.rs:807

↓ 1 callersMethodflush

( &self, req: &Request<'_>, fh: u64, lock_owner: u64, reply: ReplyEmpt

src/async_fuse/memfs/mod.rs:650

↓ 1 callersMethodflush

(&self, ino: u64, lock_owner: u64)

src/fs/datenlordfs/mod.rs:598

↓ 1 callersMethodflush_all

(&self)

src/storage/mock.rs:108

↓ 1 callersMethodflush_all

(&self)

src/storage/backend/backend_impl.rs:294

↓ 1 callersMethodflush_all

Flush all file in the cache to persistent layer.

src/storage/storage_manager/manager.rs:281

↓ 1 callersMethodflush_file

Flush a file, write blocks of it to backend immediately.

src/storage/memory_cache/write_back_task.rs:182

↓ 1 callersMethodforget

(&self, req: &Request<'_>, nlookup: u64)

src/async_fuse/fuse/file_system.rs:457

↓ 1 callersFunctionfsync

()

src/async_fuse/fuse/fuse_request.rs:1479

↓ 1 callersMethodfsync

( &self, req: &Request<'_>, fh: u64, datasync: bool, reply: ReplyEmpty

src/async_fuse/fuse/file_system.rs:894

↓ 1 callersMethodfsyncdir

( &self, req: &Request<'_>, fh: u64, datasync: bool, reply: ReplyEmpty

src/async_fuse/fuse/file_system.rs:1059

↓ 1 callersFunctionfuse_device_reader

( buffer_tx: Sender<(File, AlignedBytes)>, buffer_rx: Receiver<(File, AlignedBytes)>, fuse_request

src/async_fuse/fuse/session.rs:110

↓ 1 callersFunctionfuse_dir_ent_in_raw

Get the underlying raw part of a `FuseDirEnt`, represented in `&[u8]`. # Safety Behavior is undefined if any of the following conditions are violated

src/async_fuse/fuse/fuse_reply.rs:682

↓ 1 callersFunctionfuse_fd_clone

(session_fd: RawFd)

src/async_fuse/fuse/session.rs:88

↓ 1 callersFunctionfuser_mount

(mount_point: &Path)

src/async_fuse/fuse/mount.rs:73

↓ 1 callersFunctiongenerate_bytes_impl

The implementation of `generate_bytes!`.

macro-utils/src/generator.rs:230

↓ 1 callersFunctiongenerate_kv_cache_index_value

Helper function to generate kv cache index value

src/distribute_kv_cache/manager.rs:66

↓ 1 callersMethodget_all_dir_entry

Helper function to get all dir etnry in a directory from `KVEngine`

src/fs/datenlordfs/s3_metadata.rs:846

↓ 1 callersMethodget_block

(&self, addr: String, kv_cache_id: u64)

src/distribute_kv_cache/kvclient.rs:800

↓ 1 callersMethodget_block_id

Get the block id

src/distribute_kv_cache/kvclient.rs:155

↓ 1 callersMethodget_dispatch_handler

Get dispatch handler for the connection.

src/distribute_kv_cache/rpc/server.rs:373

↓ 1 callersMethodget_free_block

Get a free block from the cache manager's free list.

src/new_storage/memory_cache.rs:80

↓ 1 callersMethodget_handle

(&self, ino: u64)

src/new_storage/storage_manager/handle.rs:703

↓ 1 callersFunctionget_hash

Get the hash index of a key

src/distribute_kv_cache/cluster/ring.rs:541

↓ 1 callersMethodget_inode_from_txn

Helper function to get inode that must exist from `MetaTxn`

src/fs/datenlordfs/s3_metadata.rs:808

↓ 1 callersMethodget_kv_block

Get `KVBlock`

src/distribute_kv_cache/kvclient.rs:208

↓ 1 callersMethodget_kv_cache_metas

Get `KVCacheMeta`

src/distribute_kv_cache/kvclient.rs:219

↓ 1 callersMethodget_longest_kv

Get longest prefix match value by key from the index and value

src/distribute_kv_cache/server_cache/manager.rs:406

↓ 1 callersMethodget_max_volumes_per_node

Get max volumes per node

src/csi/meta_data.rs:354

↓ 1 callersMethodget_node

Get the node of a given key

src/distribute_kv_cache/cluster/ring.rs:498

↓ 1 callersMethodget_node

Get node

src/csi/meta_data.rs:335

↓ 1 callersMethodget_node_remote

Get node by hashring index

src/distribute_kv_cache/cluster/cluster_manager.rs:60

↓ 1 callersMethodget_nodes

Get all nodes

src/distribute_kv_cache/cluster/cluster_manager.rs:55

↓ 1 callersMethodget_open_count

(&self)

src/new_storage/storage_manager/handle.rs:363

↓ 1 callersMethodget_plugin_capabilities

( &mut self, _ctx: RpcContext, req: GetPluginCapabilitiesRequest, sink: UnaryS

src/csi/identity.rs:50

↓ 1 callersMethodget_plugin_info

( &mut self, _ctx: RpcContext, req: GetPluginInfoRequest, sink: UnarySink<GetP

src/csi/identity.rs:36

↓ 1 callersFunctionget_position

(_arg: &FuseSetXAttrIn)

src/async_fuse/fuse/session.rs:731

↓ 1 callersMethodget_req_len

(&self)

src/distribute_kv_cache/rpc/client.rs:537

↓ 1 callersMethodget_req_len

Get request size to construct request header

src/distribute_kv_cache/rpc/message.rs:312

↓ 1 callersMethodget_ring_force

If current hashring version is not matched, we need to update the hashring manaually in client

src/distribute_kv_cache/cluster/cluster_manager.rs:79

↓ 1 callersMethodget_symlink_target

Get symlink target path

src/fs/datenlordfs/s3_node.rs:435

↓ 1 callersMethodget_timestamp

(&self)

src/distribute_kv_cache/rpc/packet.rs:418

↓ 1 callersMethodget_version

(&self)

src/distribute_kv_cache/server_cache/block.rs:59

↓ 1 callersFunctionget_worker

(storage: Arc<StorageManager<S3MetaData>>, ino: u64, time: u64)

src/new_storage/storage_manager/tests.rs:291

↓ 1 callersMethodgetattr

Get file attributes.

src/async_fuse/fuse/file_system.rs:387

↓ 1 callersMethodgetlk

Test for a POSIX file lock.

src/async_fuse/fuse/file_system.rs:1516

↓ 1 callersMethodgetxattr

Get an extended attribute. If `size` is 0, the size of the value should be sent with `reply.size()`. If `size` is not 0, and the value fits, send it w

src/async_fuse/fuse/file_system.rs:1294

↓ 1 callersMethodhandle_block_batch_put_request

Handle the block batch put request.

src/distribute_kv_cache/manager.rs:393

↓ 1 callersMethodhandle_block_get_request

Handle the block get request.

src/distribute_kv_cache/manager.rs:340

↓ 1 callersMethodhandle_command

Handle commands

src/storage/memory_cache/write_back_task.rs:281

↓ 1 callersMethodhandle_id_allocate

Handle id allocate request

src/distribute_kv_cache/manager.rs:581

↓ 1 callersMethodhandle_index_batch_insert

(&self, buf: &mut BytesMut)

src/distribute_kv_cache/manager.rs:602

↓ 1 callersMethodhandle_index_match

Match index from index manager.

src/distribute_kv_cache/manager.rs:675

↓ 1 callersMethodhandle_index_remove

Remove index from index manager.

src/distribute_kv_cache/manager.rs:655

↓ 1 callersMethodinc_predecessor_count

Increase the `predecessor_count`.

src/common/task_manager/task.rs:137

↓ 1 callersMethodinc_version

Increments the version of the block.

src/new_storage/block.rs:94

↓ 1 callersMethodinit

false positive

src/async_fuse/fuse/session.rs:412

↓ 1 callersMethodinsert_indexes

( &self, kv_cache_meta_list: Vec<&KVCacheMeta<K>>, node_address: String, )

src/distribute_kv_cache/kvclient.rs:689

↓ 1 callersMethodinterrupt

Interrupt another FUSE request

src/async_fuse/fuse/file_system.rs:1191

↓ 1 callersMethodinterval

(mut self, interval: Duration)

src/storage/memory_cache/builder.rs:81

↓ 1 callersMethodinto_next_id_allocate_range_begin

(self)

src/fs/kv_engine/value_type.rs:47

↓ 1 callersMethodinto_s3_nodedata

(self)

src/fs/datenlordfs/serial.rs:77

↓ 1 callersMethodinto_token_stream

(self)

macro-utils/src/generator.rs:221

↓ 1 callersMethodinvalidate

(&self, _: INum)

src/storage/mock.rs:99

↓ 1 callersMethodinvalidate

(&self, _: INum)

src/storage/backend/backend_impl.rs:282

↓ 1 callersMethodis_dirty

Check current file handle is dirty or not. If the file handle is dirty, return true, otherwise return false.

src/new_storage/storage_manager/handle.rs:370

↓ 1 callersMethodis_shutdown

(&self)

src/common/task_manager/manager.rs:171

↓ 1 callersMethodjoin_all

Await all tasks in this node.

src/common/task_manager/task.rs:157

↓ 1 callersMethodkeepalive

Raised by `tokio::select`

src/fs/kv_engine/etcd_impl.rs:165

↓ 1 callersMethodlease_id

(&self)

src/fs/kv_engine/etcd_impl.rs:88

↓ 1 callersFunctionlink

()

src/async_fuse/fuse/fuse_request.rs:1260

↓ 1 callersMethodlink

Create a hard link.

src/async_fuse/fuse/file_system.rs:1203

↓ 1 callersMethodlist_snapshots

List snapshots except those creation time failed to convert to proto timestamp

src/csi/meta_data.rs:573

↓ 1 callersMethodlist_volumes

List volumes

src/csi/meta_data.rs:548

↓ 1 callersMethodlistxattr

List extended attribute names. If `size` is 0, the size of the value should be sent with `reply.size()`. If `size` is not 0, and the value fits, send

src/async_fuse/fuse/file_system.rs:1340

↓ 1 callersMethodload_blocks

Load blocks from the storage concurrently.

src/storage/storage_manager/manager.rs:47

↓ 1 callersMethodload_from_backend

(&self, ino: INum, block_id: usize)

src/storage/storage_trait.rs:90

↓ 1 callersMethodload_from_backend

(&self, ino: INum, block_id: usize)

src/storage/memory_cache/cache.rs:271

↓ 1 callersMethodload_from_self

(&self, ino: INum, block_id: usize)

src/storage/storage_trait.rs:86

↓ 1 callersMethodload_nodes

Get node list from etcd

src/distribute_kv_cache/cluster/cluster_manager.rs:886

↓ 1 callersMethodlookup

Look up a directory entry by name and get its attributes.

src/async_fuse/fuse/file_system.rs:356

↓ 1 callersFunctionlseek

()

src/async_fuse/fuse/fuse_request.rs:2369

↓ 1 callersMethodmake_blocks_from_slice

Convert slice to `Block`s.

src/storage/storage_manager/manager.rs:109

↓ 1 callersFunctionmake_partial_u8_slice

Make a partial slice of `u8` slice for debugging.

src/new_storage/block.rs:12

↓ 1 callersFunctionmake_partial_u8_slice

Make a partial slice of `u8` slice for debugging.

src/storage/block.rs:24

↓ 1 callersMethodmark_deleted

Mark deferred delete flag to postpone backend file removal on close

src/new_storage/storage_manager/handle.rs:375

↓ 1 callersFunctionmemory_backend

Creates a new `BackendImpl` instance with a memory backend.

src/new_storage/backend/backend_impl.rs:167

↓ 1 callersFunctionmkdir

()

src/async_fuse/fuse/fuse_request.rs:1152

↓ 1 callersMethodmkdir

Create a directory.

src/async_fuse/fuse/file_system.rs:537

↓ 1 callersMethodmknod

Create file node. Create a regular file, character device, block device, fifo or socket node.

src/async_fuse/fuse/file_system.rs:500

↓ 1 callersFunctionmodify_data

(data: &mut Vec<u8>, user_index: u64)

src/new_storage/storage_manager/tests.rs:61

↓ 1 callersFunctionmount_volume_bind_path

Mount target path, if fail try force un-mount again

src/csi/util.rs:220

↓ 1 callersMethodname

(&self)

src/fs/datenlordfs/direntry.rs:108

↓ 1 callersMethodnode_expand_volume

node_expand_volume is only implemented so the driver can be used for e2e testing no actual volume expansion operation

src/csi/node.rs:480

↓ 1 callersMethodnode_get_capabilities

( &mut self, _ctx: RpcContext, req: NodeGetCapabilitiesRequest, sink: UnarySin

src/csi/node.rs:541

↓ 1 callersMethodnode_get_info

( &mut self, _ctx: RpcContext, req: NodeGetInfoRequest, sink: UnarySink<NodeGe

src/csi/node.rs:554

← previous next →501–600 of 1,395, ranked by callers