Functions — github.com/datenlord/datenlord

hub / github.com/datenlord/datenlord / functions

Functions1,395 in github.com/datenlord/datenlord

⨍ Functions 1,395◇ Types & classes 335

↓ 2 callersMethodclean_sessions

Clean up the tasks

src/distribute_kv_cache/cluster/cluster_manager.rs:436

↓ 2 callersFunctioncleanup_dir

(directory: &Path)

src/async_fuse/test/integration_tests.rs:634

↓ 2 callersFunctionclear_test_data

(etcd_delegate: &EtcdDelegate)

src/csi/mod.rs:259

↓ 2 callersFunctionconv_u64_sec_2_i64

Convert u64 seceond to i64

src/fs/kv_engine/mod.rs:257

↓ 2 callersFunctioncreate_file_attr

Helper function to create a FileAttr instance for testing

src/fs/datenlordfs/serial.rs:203

↓ 2 callersMethodcreate_or_open_handle

Create or open a new filehandle, if current filehandle is new, return true otherwise return false. If true, we need to update the file handle attr lat

src/new_storage/storage_manager/handle.rs:713

↓ 2 callersFunctioncreate_storage_for_concurrent_test

()

src/storage/storage_manager/test/concurrency.rs:74

↓ 2 callersFunctioncreate_writer

( storage: Arc<StorageManager<S>>, write_pointer: Arc<AtomicUsize>, mtime: Arc<AtomicCell<SystemTi

src/storage/storage_manager/test/concurrency.rs:23

↓ 2 callersMethoddelete_directory

Delete volume directory

src/csi/meta_data.rs:1671

↓ 2 callersMethoddelete_from_etcd

Delete a key value pair or nothing from etcd

src/common/etcd_delegate.rs:290

↓ 2 callersMethoddelete_snapshot_meta_data

Delete the snapshot meta data

src/csi/meta_data.rs:706

↓ 2 callersMethoddelete_volume_all_bind_mount_path

Delete all bind path of a volume from etcd

src/csi/meta_data.rs:1108

↓ 2 callersMethoddependencies

Returns the dependencies of this node.

src/common/task_manager/task.rs:168

↓ 2 callersMethoddev_fd

(&self)

src/async_fuse/fuse/session.rs:321

↓ 2 callersMethoddisable_get

(&self)

src/storage/backend/test/mock.rs:90

↓ 2 callersMethoddisable_remove

(&self)

src/storage/backend/test/mock.rs:41

↓ 2 callersMethodenable_read

(&self)

src/storage/backend/test/mock.rs:163

↓ 2 callersFunctionensure_buffer_len

Ensure buffer length

src/distribute_kv_cache/rpc/utils.rs:120

↓ 2 callersMethodevict

(&mut self)

src/new_storage/memory_cache.rs:183

↓ 2 callersMethodevict

(&self)

src/new_storage/policy/lru.rs:54

↓ 2 callersMethodevict

Try to evict a block from the cache to backend, if needed.

src/storage/memory_cache/cache.rs:166

↓ 2 callersMethodexit

Exit the worker.

src/distribute_kv_cache/rpc/workerpool.rs:137

↓ 2 callersMethodexpand

Expand volume size, return previous size

src/csi/meta_data.rs:1412

↓ 2 callersMethodfetch_block

( &self, block_id: u64, version: u64, )

src/new_storage/storage_manager/handle.rs:196

↓ 2 callersMethodfetch_bytes

(&mut self, amt: usize)

src/async_fuse/fuse/de.rs:126

↓ 2 callersMethodfetch_c_str

Fetch some nul-terminated bytes. [`std::ffi::CStr::to_bytes`](https://doc.rust-lang.org/stable/std/ffi/struct.CStr.html#method.to_bytes) will take O(

src/async_fuse/fuse/de.rs:180

↓ 2 callersMethodfilter

(&self, args: ExtenderArgs)

src/csi/scheduler_extender.rs:164

↓ 2 callersMethodflush

Flush the cache to the persistent layer.

src/storage/storage_manager/manager.rs:272

↓ 2 callersMethodflush_all

(&self)

src/storage/memory_cache/cache.rs:437

↓ 2 callersMethodflush_all

Flush all files, write blocks of them to backend immediately. The flush tasks here are resolved in place, because the caller needs to know when the o

src/storage/memory_cache/write_back_task.rs:236

↓ 2 callersFunctionformat_file_path

(ino: u64)

src/new_storage/utils.rs:15

↓ 2 callersFunctionget_bind_mount_helper_cmd

Get the bind mount helper command path

src/csi/util.rs:205

↓ 2 callersMethodget_data

Get the block inner data of the Block

src/distribute_kv_cache/server_cache/block.rs:122

↓ 2 callersFunctionget_etcd_address_vec

()

src/csi/mod.rs:249

↓ 2 callersFunctionget_file_path

Get file path by `ino`

src/storage/backend/backend_impl.rs:27

↓ 2 callersMethodget_matched_metadata

Get the matched metadata, return with the metadata and the prefix metadata is from local or remote

src/distribute_kv_cache/kvclient.rs:258

↓ 2 callersMethodget_next_offset

Get next offset

src/distribute_kv_cache/kvclient.rs:160

↓ 2 callersMethodget_nodes

Get all nodes in cluster

src/csi/meta_data.rs:340

↓ 2 callersMethodget_one_kv_async

Get one key-value pair from etcd

src/common/etcd_delegate.rs:101

↓ 2 callersMethodget_primary_node_id

Get primary node id on which the volume is accessed first.

src/csi/meta_data.rs:1705

↓ 2 callersMethodget_remote_attr

(&self, ino: u64)

src/fs/datenlordfs/s3_metadata.rs:200

↓ 2 callersMethodget_snapshot_by_name

Find snapshot by name

src/csi/meta_data.rs:395

↓ 2 callersMethodget_snapshot_by_src_volume_id

Find snapshot by source volume ID, each source volume ID has one snapshot at most

src/csi/meta_data.rs:432

↓ 2 callersMethodget_snapshot_path

Get snapshot path by ID

src/csi/meta_data.rs:323

↓ 2 callersMethodget_stream_mut

(&self)

src/distribute_kv_cache/rpc/client.rs:365

↓ 2 callersFunctionget_volume_path

(vol_id: &str)

src/csi/mod.rs:414

↓ 2 callersMethodgetattr

(&self, req: &Request<'_>, reply: ReplyAttr<'_>)

src/async_fuse/memfs/mod.rs:230

↓ 2 callersMethodino

(&self)

src/fs/datenlordfs/direntry.rs:102

↓ 2 callersMethodip

(&self)

src/distribute_kv_cache/cluster/node.rs:35

↓ 2 callersMethodis_deferred_deleted

Whether the file is marked for deferred deletion

src/new_storage/storage_manager/handle.rs:381

↓ 2 callersMethodis_shutdown

(&self)

src/common/task_manager/gc.rs:56

↓ 2 callersMethodlimit

(mut self, limit: SoftLimit)

src/storage/memory_cache/builder.rs:74

↓ 2 callersMethodload_ring

Load ring from etcd

src/distribute_kv_cache/cluster/cluster_manager.rs:860

↓ 2 callersMethodlookup_helper

( &self, context: ReqContext, parent: INum, child_name: &str, )

src/fs/datenlordfs/s3_metadata.rs:481

↓ 2 callersMethodmatch_prefix

Used by pyo3.

src/distribute_kv_cache/kvclient.rs:166

↓ 2 callersFunctionmerge_two_blocks

Merge the content from `src` to `dst`. This will set `dst` to be dirty.

src/storage/memory_cache/cache.rs:21

↓ 2 callersMethodmknod

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

src/async_fuse/memfs/mod.rs:360

↓ 2 callersMethodmknod

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

src/fs/datenlordfs/mod.rs:242

↓ 2 callersFunctionmode_from_kind_and_perm

(kind: SFlag, perm: u16)

src/async_fuse/util.rs:32

↓ 2 callersFunctionmodify_file_node_list

Modify node list of a file

src/fs/kv_engine/kv_utils.rs:13

↓ 2 callersFunctionmount

(mount_point: &Path)

src/async_fuse/fuse/mount.rs:59

↓ 2 callersFunctionnew_fuse_session

allow this clone to transform trait to sub-trait

src/async_fuse/fuse/session.rs:285

↓ 2 callersFunctionparse_mode

Parse file mode

src/fs/fs_util.rs:407

↓ 2 callersFunctionparse_mode_bits

(mode: u32)

src/fs/fs_util.rs:421

↓ 2 callersMethodpin_count

(&self)

src/new_storage/block.rs:100

↓ 2 callersMethodport

(&self)

src/distribute_kv_cache/cluster/node.rs:41

↓ 2 callersMethodpredecessor_count

Returns the `predecessor_count`.

src/common/task_manager/task.rs:147

↓ 2 callersMethodprefix

(&self)

src/fs/kv_engine/key_type.rs:101

↓ 2 callersMethodread

(&self, path: &str, buf: &mut [u8], _version: u64)

src/new_storage/backend/memory_backend.rs:34

↓ 2 callersFunctionreal_workload

()

src/new_storage/storage_manager/tests.rs:318

↓ 2 callersMethodrecv_header

Recv request header from the stream

src/distribute_kv_cache/rpc/client.rs:101

↓ 2 callersMethodrecv_len

Recv request body from the stream

src/distribute_kv_cache/rpc/server.rs:132

↓ 2 callersMethodrecv_len_pass_in

Recv huge request body from the stream

src/distribute_kv_cache/rpc/server.rs:139

↓ 2 callersMethodrecv_len_pass_in

Receive request body from the server, try to read huge len data with given buffer.

src/distribute_kv_cache/rpc/client.rs:126

↓ 2 callersMethodrefresh_id_and_clear

Refresh the block id and clear the block cache with metadata

src/distribute_kv_cache/kvclient.rs:199

↓ 2 callersMethodremove

(&self, key: &K)

src/new_storage/policy/lru.rs:81

↓ 2 callersMethodremove

(&self, key: &K)

src/distribute_kv_cache/server_cache/policy.rs:102

↓ 2 callersMethodremove_by_index

Remove a slot by index

src/distribute_kv_cache/cluster/ring.rs:397

↓ 2 callersMethodrename

Rename a file If the target exists it should be atomically replaced. If the target's inode's lookup count is non-zero, the file system is expected to

src/async_fuse/fuse/file_system.rs:667

↓ 2 callersMethodrun

Keep the connection and get the handler for the connection.

src/distribute_kv_cache/rpc/server.rs:296

↓ 2 callersMethodrun

The `select!` macro will generate code that goes against these rules.

src/async_fuse/fuse/session.rs:327

↓ 2 callersMethodselect_node

Select a node to create volume or snapshot

src/csi/meta_data.rs:224

↓ 2 callersMethodsend_response

Send response to the stream The response is a byte array, contains the response header and body.

src/distribute_kv_cache/rpc/server.rs:161

↓ 2 callersFunctionseq_read

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

src/new_storage/storage_manager/tests.rs:109

↓ 2 callersFunctionserial_to_file_attr

(attr: &SerialFileAttr)

src/fs/datenlordfs/serial.rs:150

↓ 2 callersMethodserve

Serve the connection.

src/distribute_kv_cache/rpc/server.rs:378

↓ 2 callersMethodset_version

Set the version of the block.

src/new_storage/block.rs:89

↓ 2 callersMethodsetlk

Acquire, modify or release a POSIX file lock. For POSIX threads (NPTL) there's a 1-1 relation between pid and owner, but otherwise self is not always

src/async_fuse/fuse/file_system.rs:1565

↓ 2 callersFunctionsetup

(mount_dir: &Path, is_s3: bool)

src/async_fuse/test/test_util.rs:98

↓ 2 callersFunctionspawn_tasks

(task_manager: &TaskManager, tx: mpsc::Sender<i32>)

src/common/task_manager/tests.rs:48

↓ 2 callersFunctionstart_async_fuse

Raised by `tokio::select`

src/async_fuse/mod.rs:38

↓ 2 callersMethodstop

Stop the cluster manager

src/distribute_kv_cache/cluster/cluster_manager.rs:84

↓ 2 callersFunctionsymlink

()

src/async_fuse/fuse/fuse_request.rs:1080

↓ 2 callersFunctionteardown

(mount_dir: &Path)

src/async_fuse/test/test_util.rs:144

↓ 2 callersFunctiontest_create_file

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:23

↓ 2 callersMethodto_serial_node

(&self)

src/fs/datenlordfs/s3_node.rs:109

↓ 2 callersMethodtoken

Get the notifier of this node.

src/common/task_manager/task.rs:152

↓ 2 callersMethodunpin

(&mut self)

src/new_storage/block.rs:126

↓ 2 callersMethodupdate_volume_meta_data

Update the existing volume meta data

src/csi/meta_data.rs:752

↓ 2 callersFunctionusage

tests/fstest_dir/fstest.c:217

← previous next →301–400 of 1,395, ranked by callers