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 callersMethodnotify

Notify kernel

src/async_fuse/fuse/fuse_reply.rs:749

↓ 1 callersMethodop

(&self)

src/distribute_kv_cache/rpc/client.rs:515

↓ 1 callersMethodopen

Open a file. Open flags (with the exception of `O_CREAT`, `O_EXCL`, `O_NOCTTY` and `O_TRUNC`) are available in flags. Filesystem may store an arbitrar

src/async_fuse/fuse/file_system.rs:419

↓ 1 callersMethodopen

( &self, context: ReqContext, ino: u64, flags: u32, )

src/fs/datenlordfs/s3_metadata.rs:166

↓ 1 callersMethodopen_pre_check

Check if given uid and gid can access this node

src/fs/datenlordfs/s3_node.rs:208

↓ 1 callersMethodopendir

Open a directory. Filesystem may store an arbitrary file handle (pointer, index, etc) in fh, and use self in other all other directory stream operatio

src/async_fuse/fuse/file_system.rs:932

↓ 1 callersFunctionparse_kv_cache_index_value

(value: &str)

src/distribute_kv_cache/manager.rs:72

↓ 1 callersMethodpolicy

Get the `policy`.

src/storage/memory_cache/cache.rs:86

↓ 1 callersMethodpredecessor_counts

(&self)

src/common/task_manager/manager.rs:128

↓ 1 callersMethodprobe

(&mut self, _ctx: RpcContext, req: ProbeRequest, sink: UnarySink<ProbeResponse>)

src/csi/identity.rs:70

↓ 1 callersFunctionprocess_fuse_request

Process one FUSE request

src/async_fuse/fuse/session.rs:190

↓ 1 callersMethodpurge_outdated_tasks

Purge the outdated tasks when connection is timeout

src/distribute_kv_cache/rpc/packet.rs:225

↓ 1 callersMethodput_blocks

(&self, addr: String, kv_blocks: Vec<KVBlock>)

src/distribute_kv_cache/kvclient.rs:846

↓ 1 callersMethodrange_raw_key

Get all key/value pairs with the given prefix.

src/fs/kv_engine/etcd_impl.rs:371

↓ 1 callersMethodread

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

src/distribute_kv_cache/server_cache/backend.rs:52

↓ 1 callersMethodreaddir

Read directory. Send a buffer filled using buffer.fill(), with size not exceeding the requested size. Send an empty buffer on end of stream. fh will c

src/async_fuse/fuse/file_system.rs:969

↓ 1 callersMethodreadlink

Read symbolic link.

src/async_fuse/fuse/file_system.rs:1121

↓ 1 callersMethodrecv_header

Recv request header from the stream

src/distribute_kv_cache/rpc/server.rs:114

↓ 1 callersMethodrecv_loop

(&self)

src/distribute_kv_cache/rpc/client.rs:253

↓ 1 callersMethodregister

src/distribute_kv_cache/cluster/cluster_manager.rs:341

↓ 1 callersMethodrelease

( &self, req: &Request<'_>, fh: u64, flags: u32, // same as the open flags

src/async_fuse/fuse/file_system.rs:855

↓ 1 callersMethodreleasedir

Release an open directory. For every opendir call there will be exactly one releasedir call. fh will contain the value set by the opendir method, or w

src/async_fuse/fuse/file_system.rs:1019

↓ 1 callersMethodremaining_len

Get the length of the remaining bytes

src/async_fuse/fuse/de.rs:111

↓ 1 callersMethodremove

(&self, path: &str)

src/new_storage/backend/backend_impl.rs:152

↓ 1 callersMethodremove

(&self, path: &str)

src/distribute_kv_cache/server_cache/backend.rs:89

↓ 1 callersMethodremove_all

(&self, prefix: &str)

src/new_storage/backend/memory_backend.rs:69

↓ 1 callersMethodremove_index

(&self, prefix: Vec<K>)

src/distribute_kv_cache/kvclient.rs:756

↓ 1 callersMethodremove_task

Get a task from the packets and remove it

src/distribute_kv_cache/rpc/packet.rs:191

↓ 1 callersMethodremovexattr

Remove an extended attribute.

src/async_fuse/fuse/file_system.rs:1378

↓ 1 callersFunctionresultify

Converts `cqe.raw_result()` to [`io::Result<u32>`]

src/async_fuse/proactor/global.rs:253

↓ 1 callersFunctionrmdir

()

src/async_fuse/fuse/fuse_request.rs:1203

↓ 1 callersMethodrmdir

( &self, req: &Request<'_>, parent: INum, dir_name: &str, reply: Reply

src/async_fuse/fuse/file_system.rs:623

↓ 1 callersFunctionround_up

(len: usize, align: usize)

src/async_fuse/util.rs:179

↓ 1 callersMethodrun

(&self)

src/distribute_kv_cache/tests/rpc.rs:80

↓ 1 callersMethodrun

(&self)

src/distribute_kv_cache/rpc/workerpool.rs:170

↓ 1 callersMethodrun

Raised by `tokio::select!`

src/storage/memory_cache/write_back_task.rs:311

↓ 1 callersFunctionrun_fs

(mount_point: &Path, is_s3: bool, token: CancellationToken)

src/async_fuse/test/test_util.rs:62

↓ 1 callersFunctionrun_single_server_helper

Helper function to run server

src/csi/mod.rs:145

↓ 1 callersMethodsave_ring

Save current master node info and hashring to etcd with one txn

src/distribute_kv_cache/cluster/cluster_manager.rs:765

↓ 1 callersMethodsave_volume_bind_mount_path

Write volume bind mount path to etcd, if volume has multiple bind mount path, then append to the value in etcd TODO: make it fault tolerant when etcd

src/csi/meta_data.rs:1156

↓ 1 callersFunctionscan_worker

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

src/new_storage/storage_manager/tests.rs:269

↓ 1 callersMethodscheduler

Scheduler pod

src/csi/scheduler_extender.rs:265

↓ 1 callersMethodseek

(&mut self, pos: std::io::SeekFrom)

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

↓ 1 callersMethodselect_random_node

Select a random node

src/csi/meta_data.rs:174

↓ 1 callersMethodsend_error_code

Send error code response to FUSE kernel

src/async_fuse/fuse/fuse_reply.rs:216

↓ 1 callersMethodsend_packet

Send packet by the client.

src/distribute_kv_cache/rpc/client.rs:222

↓ 1 callersMethodseq

(&self)

src/distribute_kv_cache/rpc/client.rs:507

↓ 1 callersMethodserial

(&self)

src/fs/datenlordfs/s3_node.rs:42

↓ 1 callersFunctionserial_to_entry_type

(entry_type: &SerialSFlag)

src/fs/datenlordfs/serial.rs:112

↓ 1 callersMethodset_dirty_filesize_and_version

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

src/new_storage/storage_manager/handle.rs:189

↓ 1 callersMethodset_ip

Set the ip of the node

src/distribute_kv_cache/cluster/node.rs:141

↓ 1 callersMethodset_resp_data

(&mut self, _data: BytesMut)

src/distribute_kv_cache/rpc/packet.rs:426

↓ 1 callersMethodset_seq

(&mut self, seq: u64)

src/distribute_kv_cache/rpc/client.rs:511

↓ 1 callersMethodset_timestamp

(&mut self, timestamp: u64)

src/distribute_kv_cache/rpc/packet.rs:414

↓ 1 callersMethodsetattr

Set file attributes.

src/async_fuse/fuse/file_system.rs:464

↓ 1 callersMethodsetattr

Set file attributes.

src/async_fuse/memfs/mod.rs:326

↓ 1 callersMethodsetattr_precheck

Precheck before set attr

src/fs/fs_util.rs:193

↓ 1 callersFunctionsetup

Set up once for tracing

src/distribute_kv_cache/tests/kvcache.rs:38

↓ 1 callersMethodsetup_buffer_pool

Setup buffer pool

src/async_fuse/fuse/session.rs:356

↓ 1 callersMethodsetxattr

Set an extended attribute.

src/async_fuse/fuse/file_system.rs:1245

↓ 1 callersMethodsize

Get the size of this item (in bytes).

macro-utils/src/generator.rs:101

↓ 1 callersMethodsize

Return the current number of items in the LRU policy.

src/storage/policy/lru.rs:66

↓ 1 callersMethodsize_with_name

(&self)

src/async_fuse/fuse/protocol.rs:1307

↓ 1 callersMethodslots_clear

Clear the ring

src/distribute_kv_cache/cluster/ring.rs:218

↓ 1 callersMethodspawn

Spawn an async task in this task node.

src/common/task_manager/task.rs:173

↓ 1 callersMethodstart

(&self)

src/distribute_kv_cache/rpc/workerpool.rs:110

↓ 1 callersMethodstart

Raised by `tokio::select!`

src/csi/scheduler_extender.rs:116

↓ 1 callersMethodstart_kv_lock_timer

Starts a timer to measure KV lock acquiring latency.

src/metrics/kv.rs:63

↓ 1 callersMethodstart_watch

Start the distribute cache client watch task

src/distribute_kv_cache/kvclient.rs:252

↓ 1 callersMethodstatefs

Fake data for statefs TODO: handle some important data from S3 storage

src/fs/datenlordfs/s3_node.rs:446

↓ 1 callersMethodstatfs

(self, param: StatFsParam)

src/async_fuse/fuse/fuse_reply.rs:505

↓ 1 callersMethodstore_blocks

Store blocks into the storage concurrently.

src/storage/storage_manager/manager.rs:84

↓ 1 callersMethodsymlink

Create a symbolic link.

src/async_fuse/fuse/file_system.rs:1146

↓ 1 callersFunctiontest_bind_mount

(fuse_mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:631

↓ 1 callersFunctiontest_controller_create_and_list_snapshot

(client: &ControllerClient)

src/csi/mod.rs:1095

↓ 1 callersFunctiontest_controller_create_delete_idempotency

(client: &ControllerClient)

src/csi/mod.rs:962

↓ 1 callersFunctiontest_controller_create_volume_from_snapshot

( client: &ControllerClient, )

src/csi/mod.rs:862

↓ 1 callersFunctiontest_controller_create_volume_from_volume

(client: &ControllerClient)

src/csi/mod.rs:756

↓ 1 callersFunctiontest_controller_expand_volume

(client: &ControllerClient)

src/csi/mod.rs:1052

↓ 1 callersFunctiontest_controller_server

()

src/csi/mod.rs:662

↓ 1 callersFunctiontest_deferred_deletion

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:138

↓ 1 callersFunctiontest_delete_file

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:687

↓ 1 callersFunctiontest_directory_manipulation_rust_way

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:103

↓ 1 callersFunctiontest_file_manipulation_rust_way

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:86

↓ 1 callersFunctiontest_identity_server

()

src/csi/mod.rs:519

↓ 1 callersFunctiontest_list_volumes

(client: &ControllerClient)

src/csi/mod.rs:674

↓ 1 callersFunctiontest_meta_data

()

src/csi/mod.rs:314

↓ 1 callersFunctiontest_name_too_long

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:48

↓ 1 callersFunctiontest_node_server

()

src/csi/mod.rs:1216

↓ 1 callersFunctiontest_node_server_multiple_publish

(client: &NodeClient)

src/csi/mod.rs:1379

↓ 1 callersFunctiontest_node_server_publish_unpublish

(client: &NodeClient)

src/csi/mod.rs:1231

↓ 1 callersFunctiontest_node_server_remount_publish

(client: &NodeClient)

src/csi/mod.rs:1329

↓ 1 callersFunctiontest_open_file_permission

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:707

↓ 1 callersFunctiontest_rename_dir

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:493

↓ 1 callersFunctiontest_rename_exchange

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:364

↓ 1 callersFunctiontest_rename_file

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:196

↓ 1 callersFunctiontest_rename_file_replace

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:236

↓ 1 callersFunctiontest_rename_no_replace_flag

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:289

↓ 1 callersFunctiontest_rename_non_existent_source

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:263

↓ 1 callersFunctiontest_rename_to_non_existent_destination_directory

(mount_dir: &Path)

src/async_fuse/test/integration_tests.rs:334

← previous next →601–700 of 1,395, ranked by callers