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 callersMethodvalidate_request_capability

Validate request with controller capabilities

src/csi/node.rs:65

↓ 2 callersFunctionverify_volume_file_content

( vol_id: &str, vol_file_name: &str, expected_content: &str, )

src/csi/mod.rs:642

↓ 2 callersFunctionwait_for_shutdown

( manager: &TaskManager, )

src/common/task_manager/manager.rs:227

↓ 2 callersFunctionwarm_up

Open a read file handle ,read to end, but don't close the handle

src/new_storage/storage_manager/tests.rs:94

↓ 2 callersMethodwrite

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

src/new_storage/backend/memory_backend.rs:53

↓ 2 callersMethodwrite

(&self, ino: u64, offset: i64, data: &[u8], _flags: u32)

src/fs/datenlordfs/mod.rs:535

↓ 2 callersFunctionwrite_back_one_block

Write a block back to the backend.

src/storage/memory_cache/write_back_task.rs:46

↓ 2 callersFunctionwrite_file_in_volume

( vol_id: &str, vol_file_name: &str, vol_file_content: &str, )

src/csi/mod.rs:630

↓ 2 callersMethodwrite_key

Appends the unique part of the key to a mutable string buffer.

src/fs/kv_engine/key_type.rs:117

↓ 2 callersMethodwrite_or_update_kv

( &self, key: K, value: &T, )

src/common/etcd_delegate.rs:478

↓ 2 callersMethodwrite_to_etcd_if_none

Write a key value pair to etcd when there's no key - if key exist, don't insert, return the old value - if key not exist, insert, return None - `expir

src/common/etcd_delegate.rs:229

↓ 2 callersMethodwritten

Reply to a request with the given open result

src/async_fuse/fuse/fuse_reply.rs:490

↓ 1 callersMethodaccess

Check file access permissions. This will be called for the `access()` system call. If the `default_permissions` mount option is given, self method is

src/async_fuse/fuse/file_system.rs:1418

↓ 1 callersMethodadd_dependency

Add a dependency of this node.

src/common/task_manager/task.rs:132

↓ 1 callersMethodalloc_id

just get a unique id

src/fs/datenlordfs/id_alloc.rs:80

↓ 1 callersMethodalloc_inum_for_fnode

get a unique inum for a new file return inum

src/fs/datenlordfs/id_alloc_used.rs:27

↓ 1 callersMethodallocate_id

Allocate a new block id

src/distribute_kv_cache/server_cache/manager.rs:365

↓ 1 callersFunctionas_abi_bytes

(raw: &T)

src/async_fuse/fuse/abi_marker.rs:28

↓ 1 callersFunctionas_bytes_unchecked

(raw: &T)

src/async_fuse/fuse/abi_marker.rs:19

↓ 1 callersMethodas_io_slice_list

(&self)

src/async_fuse/fuse/fuse_reply.rs:46

↓ 1 callersFunctionasync_fail

Send async failure `gRPC` response

src/csi/util.rs:178

↓ 1 callersFunctionasync_success

Send async success `gRPC` response

src/csi/util.rs:169

↓ 1 callersMethodbatch_replace

Batch replace Try to modify current ring and try the best to keep the old ring distribution It will return removed nodes here

src/distribute_kv_cache/cluster/ring.rs:317

↓ 1 callersMethodbind_mount

Bind mount volume directory to target path if root

src/csi/meta_data.rs:1234

↓ 1 callersMethodbmap

(self, block: u64)

src/async_fuse/fuse/fuse_reply.rs:598

↓ 1 callersFunctionbuild_controller_client

()

src/csi/mod.rs:567

↓ 1 callersFunctionbuild_identity_client

()

src/csi/mod.rs:512

↓ 1 callersFunctionbuild_node_client

()

src/csi/mod.rs:1209

↓ 1 callersMethodbuild_snapshot_from_volume

Build snapshot from source volume

src/csi/meta_data.rs:1373

↓ 1 callersFunctionbuild_test_meta_data

()

src/csi/mod.rs:278

↓ 1 callersMethodbuild_volume_from_source

Build volume from either snapshot or another volume

src/csi/worker.rs:48

↓ 1 callersMethodcache_block_from_backend

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

src/storage/storage_trait.rs:94

↓ 1 callersMethodcalculate_period

Calculate a new period for write back task's interval.

src/storage/memory_cache/write_back_task.rs:118

↓ 1 callersFunctioncalculate_size_impl

The implementation of `calculate_size!`.

macro-utils/src/generator.rs:236

↓ 1 callersMethodcapacity

(&self)

src/distribute_kv_cache/server_cache/policy.rs:121

↓ 1 callersMethodcheck_exist_in_accessible_nodes

Check if volume can be accessible on node id

src/csi/meta_data.rs:1700

↓ 1 callersMethodcheck_exist_on_node_id

Check if volume is stored on node id

src/csi/meta_data.rs:1695

↓ 1 callersMethodcheck_perm_inner

(&self, uid: u32, gid: u32, access_mode: u8)

src/fs/fs_util.rs:336

↓ 1 callersMethodcheck_session_valid

Try to check current session is valid

src/distribute_kv_cache/cluster/cluster_manager.rs:442

↓ 1 callersFunctioncheck_ttl

Fix ttl, ttl should be > 0

src/fs/kv_engine/mod.rs:263

↓ 1 callersFunctioncheck_type_supported

Check if `file_type` is supported. We only support 1. Regular file 2. Directory 3. Symbolic link

src/fs/datenlordfs/mod.rs:65

↓ 1 callersMethodcheck_valid

(&self)

src/config/config.rs:213

↓ 1 callersMethodclean_timeout_tasks

Clean pending tasks as timeout In first step, we will try to mark the task as timeout if it is pending and timeout In 10 * timeout time, we will force

src/distribute_kv_cache/rpc/packet.rs:199

↓ 1 callersFunctionclean_up_etcd

()

src/distribute_kv_cache/tests/kvcache.rs:52

↓ 1 callersMethodclose_handle

Close and remove current filehandle.

src/new_storage/storage_manager/handle.rs:745

↓ 1 callersMethodcommand_queue_limit

(mut self, limit: usize)

src/storage/memory_cache/builder.rs:88

↓ 1 callersFunctionconcurrency_read

()

src/new_storage/storage_manager/tests.rs:159

↓ 1 callersFunctionconcurrency_read_with_write

()

src/new_storage/storage_manager/tests.rs:211

↓ 1 callersFunctioncontroller_expand_volume

( client: &ControllerClient, req: &ControllerExpandVolumeRequest, )

src/csi/mod.rs:622

↓ 1 callersMethodcontroller_expand_volume

( &mut self, _ctx: RpcContext, req: ControllerExpandVolumeRequest, sink: Unary

src/csi/controller.rs:842

↓ 1 callersFunctionconvert_nix_errno_to_cint

(error_no: Errno)

src/async_fuse/util.rs:24

↓ 1 callersMethodconvert_to_gc_task

Convert this task into GC task. # Panic This method will panic, if: - This method is not called in the context of a tokio runtime. - This task node

src/common/task_manager/task.rs:100

↓ 1 callersFunctioncopy_directory_recursively

Copy a directory recursively

src/csi/util.rs:87

↓ 1 callersMethodcopy_volume_from_snapshot

Populate the given destPath with data from the snapshot ID

src/csi/meta_data.rs:919

↓ 1 callersMethodcopy_volume_from_volume

Populate the given destPath with data from the `src_volume_id`

src/csi/meta_data.rs:977

↓ 1 callersMethodcreate

Create and open a file. If the file does not exist, first create it with the specified mode, and then open it. Open flags (with the exception of `O_NO

src/async_fuse/fuse/file_system.rs:1468

↓ 1 callersMethodcreate

Create and open a file. If the file does not exist, first create it with the specified mode, and then open it. Open flags (with the exception of `O_NO

src/async_fuse/memfs/mod.rs:1040

↓ 1 callersMethodcreate_child_dir

Create sub-directory in a directory

src/fs/datenlordfs/s3_node.rs:332

↓ 1 callersMethodcreate_child_file

Create file in a directory

src/fs/datenlordfs/s3_node.rs:390

↓ 1 callersMethodcreate_child_symlink

Create symlink in a directory

src/fs/datenlordfs/s3_node.rs:292

↓ 1 callersMethodcreate_ephemeral_volume

Create ephemeral volume

src/csi/node.rs:74

↓ 1 callersMethodcreate_shared_state

Creates a shared state from the inner object pool

src/async_fuse/proactor/global.rs:272

↓ 1 callersMethodcreate_snapshot

( &mut self, _ctx: RpcContext, req: CreateSnapshotRequest, sink: UnarySink<Cre

src/csi/controller.rs:600

↓ 1 callersMethodcreate_vol_dir

Create volume directory

src/csi/meta_data.rs:1660

↓ 1 callersMethodcreate_volume

( &mut self, _ctx: RpcContext, req: CreateVolumeRequest, sink: UnarySink<Creat

src/csi/controller.rs:324

↓ 1 callersMethodcreate_volume_pre_check

The pre-check helper function for `create_volume`

src/csi/controller.rs:268

↓ 1 callersMethoddec_predecessor_count

Decrease the `predecessor_count`.

src/common/task_manager/task.rs:142

↓ 1 callersMethoddelete_all

(&self)

src/common/etcd_delegate.rs:639

↓ 1 callersMethoddelete_ephemeral_volume

Delete ephemeral volume `tolerant_error` means whether to ignore umount error or not

src/csi/node.rs:99

↓ 1 callersMethoddelete_exact_one_value_return_with_version

( &self, key: &str, )

src/common/etcd_delegate.rs:555

↓ 1 callersMethoddelete_file

Delete snapshot file

src/csi/meta_data.rs:1762

↓ 1 callersMethoddelete_one_value

( &self, key: &str, )

src/common/etcd_delegate.rs:624

↓ 1 callersMethoddelete_one_value_return_with_version

( &self, key: &str, )

src/common/etcd_delegate.rs:601

↓ 1 callersMethoddelete_snapshot

( &mut self, _ctx: RpcContext, req: DeleteSnapshotRequest, sink: UnarySink<Del

src/csi/controller.rs:676

↓ 1 callersMethoddelete_volume

( &mut self, _ctx: RpcContext, req: DeleteVolumeRequest, sink: UnarySink<Delet

src/csi/controller.rs:368

↓ 1 callersMethoddelete_volume_one_bind_mount_path

Delete one bind path of a volume from etcd, return all bind paths before deletion

src/csi/meta_data.rs:1045

↓ 1 callersMethoddestroy

Clean up filesystem. Called on filesystem exit.

src/async_fuse/fuse/file_system.rs:351

↓ 1 callersFunctiondirect_mount

(mount_point: &Path)

src/async_fuse/fuse/mount.rs:152

↓ 1 callersMethoddirty

(&self)

src/new_storage/block.rs:106

↓ 1 callersMethoddirty

(&self)

src/storage/block.rs:234

↓ 1 callersMethoddisable_close

(&self)

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

↓ 1 callersFunctiondispatch

( req: &'a Request<'a>, file: &mut File, fs: Arc<dyn FileSystem + Send + Sync + 'static>, )

src/async_fuse/fuse/session.rs:505

↓ 1 callersMethoddispatch

Dispatch the handler for the connection.

src/distribute_kv_cache/rpc/server.rs:225

↓ 1 callersMethoddo_campaign

Do campaign Try to campaign master, will return status and master value

src/distribute_kv_cache/cluster/cluster_manager.rs:382

↓ 1 callersMethoddo_master_tasks

Do master tasks 1. Master node will watch the node list update, and update the ring 2. Master will check self

src/distribute_kv_cache/cluster/cluster_manager.rs:189

↓ 1 callersMethoddo_slave_tasks

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

src/distribute_kv_cache/cluster/cluster_manager.rs:237

↓ 1 callersMethodedges

(&self)

src/common/task_manager/manager.rs:112

↓ 1 callersMethodenable_close

(&self)

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

↓ 1 callersMethodenable_remove

(&self)

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

↓ 1 callersMethodenable_write

(&self)

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

↓ 1 callersMethodencode

Encode the file block packet into a byte buffer.

src/distribute_kv_cache/rpc/message.rs:235

↓ 1 callersFunctionentry_type_to_serial

(entry_type: SFlag)

src/fs/datenlordfs/serial.rs:101

↓ 1 callersFunctionerr2str

tests/fstest_dir/fstest.c:624

↓ 1 callersMethodexpand_size

Expand volume size

src/csi/meta_data.rs:1685

↓ 1 callersMethodfetch_add_id_next_range

increase the inode number range begin in global cluster

src/fs/datenlordfs/id_alloc.rs:106

↓ 1 callersMethodfetch_all_as_slice

( &mut self, )

src/async_fuse/fuse/de.rs:148

↓ 1 callersMethodfile_type

(&self)

src/fs/datenlordfs/direntry.rs:114

↓ 1 callersMethodfind_existing_snapshot

Check for already existing snapshot name, and if found check for the requested source volume ID matches snapshot that has been created

src/csi/controller.rs:186

↓ 1 callersMethodfind_existing_volume

Check for already existing volume name, and if found check for the requested capacity and already allocated capacity

src/csi/controller.rs:94

↓ 1 callersFunctionfind_syscall

tests/fstest_dir/fstest.c:270

← previous next →401–500 of 1,395, ranked by callers