Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/SJTU-IPADS/krcore-artifacts
/ functions
Functions
2,356 in github.com/SJTU-IPADS/krcore-artifacts
⨍
Functions
2,356
◇
Types & classes
482
↓ 1 callers
Method
resolve_inner
(&mut self, service_id: u64, ctx: &RContext, dst_gid: ib_gid,
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/ib_path_explorer.rs:59
↓ 1 callers
Method
rlock_f
(&self, f: impl FnOnce(&'a T) -> R)
rust-kernel-rdma/rust-kernel-linux-util/src/rwlock.rs:23
↓ 1 callers
Function
run
exp/LITE/lib/lite_rpc.c:385
↓ 1 callers
Function
safe_ib_create_dct
(pd: *mut ib_pd, attr: *mut ib_dct_init_attr)
rust-kernel-rdma/rust-kernel-rdma-base/src/ofed_4_9_3_1_5_0.rs:84
↓ 1 callers
Function
safe_ib_destroy_dct
(dct : *mut ib_dct)
KRdmaKit-syscall/two-sided-dc/rust-kernel-rdma-base/src/ofed_4_9_3_1_5_0.rs:100
↓ 1 callers
Function
safe_ib_destroy_dct
(dct : *mut ib_dct)
rust-kernel-rdma/rust-kernel-rdma-base/src/ofed_4_9_3_1_5_0.rs:101
↓ 1 callers
Method
second_segment
Returns the second 16-bit segment that makes up this address. # Examples ``` use no_std_net::Ipv6Addr; assert_eq!(Ipv6Addr::new(0x0011, 0x2233, 0,
KRdmaKit-syscall/two-sided-dc/deps/no-std-net/src/ip.rs:975
↓ 1 callers
Method
second_segment
Returns the second 16-bit segment that makes up this address. # Examples ``` use no_std_net::Ipv6Addr; assert_eq!(Ipv6Addr::new(0x0011, 0x2233, 0,
rust-kernel-rdma/deps/no-std-net/src/ip.rs:975
↓ 1 callers
Method
segments
(&self)
KRdmaKit-syscall/two-sided-dc/deps/no-std-net/src/lib.rs:105
↓ 1 callers
Method
segments
(&self)
rust-kernel-rdma/deps/no-std-net/src/lib.rs:105
↓ 1 callers
Function
send
exp/motiv-connect/ud_msg.hh:109
↓ 1 callers
Method
send
deps/r2/src/msg/ud_session.hh:72
↓ 1 callers
Method
send_reply
( &self, mut rep: ib_cm_rep_param, mut pri: T, )
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/cm/client.rs:101
↓ 1 callers
Method
send_req
( &mut self, mut req: ib_cm_req_param, mut pri: T, )
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/cm/client.rs:120
↓ 1 callers
Method
send_req
(&self, req: ib_cm_req_param, pri: S)
KRdmaKit/src/queue_pairs/rc_comm.rs:51
↓ 1 callers
Method
send_rtu
(&mut self, mut pri: T)
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/cm/client.rs:169
↓ 1 callers
Method
send_rtu
(&self, mut private_data: T)
KRdmaKit/src/comm_manager/client.rs:140
↓ 1 callers
Method
send_sidr
( &mut self, mut req: ib_cm_sidr_req_param, mut pri: T, )
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/cm/client.rs:192
↓ 1 callers
Method
send_sidr_reply
( &mut self, mut rep: ib_cm_sidr_rep_param, mut info: T, )
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/cm/client.rs:222
↓ 1 callers
Function
server_mw
( server: Arc<ConnectionManagerServer<UserDefinedHandler>>, running_addr: u64, )
KRdmaKit/examples/memory_window.rs:41
↓ 1 callers
Method
service_handler
(self: Arc<Self>, mut stream: TcpStream)
KRdmaKit/src/services_user/mod.rs:230
↓ 1 callers
Function
set_current_task_id
(task_id: TaskId)
KRdmaKit/src/runtime/task.rs:18
↓ 1 callers
Method
set_inner
(&mut self, inner: HashMap<String, MRInfo>)
KRdmaKit/src/services_user/cm.rs:238
↓ 1 callers
Method
set_max_cqe
(mut self, new_v: usize)
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/qp/mod.rs:89
↓ 1 callers
Method
set_max_recv_sge
Set the maximum number of scatter/gather elements in any Work Request that can be posted to the Receive Queue in that Queue Pair. Default value is 1
KRdmaKit/src/queue_pairs/builder.rs:133
↓ 1 callers
Method
set_max_send_sge
Set the maximum number of scatter/gather elements in any Work Request that can be posted to the Send Queue in that Queue Pair. Default value is 16
KRdmaKit/src/queue_pairs/builder.rs:124
↓ 1 callers
Method
set_max_send_wr
Set both `max_send_wr` for the new `QueuePair` Default value is 128
KRdmaKit/src/queue_pairs/builder.rs:98
↓ 1 callers
Method
set_rnr_retry
Set the number of times that the new `QueuePair` tries to resend the packets when an RNR NACK was sent by the remote QP before reporting an error. De
KRdmaKit/src/queue_pairs/builder.rs:226
↓ 1 callers
Method
sidr_callback
(&mut self, cm: *mut ib_cm_id, event: ib_cm_event)
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/ctrl.rs:277
↓ 1 callers
Method
sidr_callback
(&mut self, cm: *mut ib_cm_id, event: ib_cm_event)
KRdmaKit/src/ctrl.rs:305
↓ 1 callers
Method
spawn
Spawn a new task to a worker with its index. Return `JoinHandle` if success and error if the index if out of bound.
KRdmaKit/src/runtime/worker_group.rs:68
↓ 1 callers
Method
spawn_and_bind
(self, body: extern "C" fn(*mut c_void) -> i32, cpu: u32)
rust-kernel-rdma/rust-kernel-linux-util/src/kthread.rs:178
↓ 1 callers
Function
spawn_server_thread
(addr: SocketAddr)
user-benchs/bench_runtime/server/src/main.rs:10
↓ 1 callers
Function
spawn_server_thread
( addr: SocketAddr, )
KRdmaKit/examples/memory_window.rs:123
↓ 1 callers
Function
spawn_server_thread
( addr: SocketAddr, )
KRdmaKit/examples/user_rc_cm.rs:37
↓ 1 callers
Function
spawn_server_thread
( addr: SocketAddr, )
KRdmaKit/examples/rc_read_bench.rs:37
↓ 1 callers
Method
spawn_unchecked
# Description Spawn a new task to a worker with its index. Return the task's `JoinHandle` # Safety It is unsafe to `spawn_unchecked` # Panic Panic t
KRdmaKit/src/runtime/worker_group.rs:92
↓ 1 callers
Method
spawn_wo_bind
(self, body: extern "C" fn(*mut c_void) -> i32)
rust-kernel-rdma/rust-kernel-linux-util/src/kthread.rs:165
↓ 1 callers
Function
split
exp/race-hasing/trigger.cc:61
↓ 1 callers
Function
split
exp/motiv-connect/connect_simulation.cc:52
↓ 1 callers
Function
split
exp/one-sided/krc_client.cc:51
↓ 1 callers
Function
split
exp/one-sided/krc_client-docker.cc:51
↓ 1 callers
Method
start
(&'static mut self)
KRdmaKit/src/runtime/worker_group.rs:40
↓ 1 callers
Method
stop
deps/r2/src/sshed.hh:128
↓ 1 callers
Method
store_value
(&self, data: &[u8])
KRdmaKit-syscall/two-sided-dc/deps/rust-kernel-module/src/sysctl.rs:36
↓ 1 callers
Method
store_value
(&self, data: &[u8])
rust-kernel-rdma/deps/rust-kernel-module/src/sysctl.rs:36
↓ 1 callers
Function
sys_command_outstatuserr
(cmd, timeout=30)
exp_scripts/evaluation_runner.py:23
↓ 1 callers
Method
take_endpoint
(&mut self)
KRdmaKit/src/queue_pairs/endpoint.rs:270
↓ 1 callers
Function
test_async_rpc_recv
exp/LITE/lib/lite_rpc.c:304
↓ 1 callers
Function
test_async_rpc_send
* Can we reuse the send buffer? Depends on when the syscall returned. * If it is returned after send has completed, then we can. * If it is returned
exp/LITE/lib/lite_rpc.c:212
↓ 1 callers
Function
test_case_0
()
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/device/src/lib.rs:78
↓ 1 callers
Function
test_case_0
test whether we can acquire devices
KRdmaKit-syscall/two-sided-dc/rust-kernel-rdma-base/unitests/get_devices/src/lib.rs:52
↓ 1 callers
Function
test_case_1
()
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/device/src/lib.rs:83
↓ 1 callers
Function
test_case_1
test whether we can create pd using the dev
KRdmaKit-syscall/two-sided-dc/rust-kernel-rdma-base/unitests/get_devices/src/lib.rs:59
↓ 1 callers
Function
test_case_2
()
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/device/src/lib.rs:87
↓ 1 callers
Function
test_case_3
()
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/device/src/lib.rs:93
↓ 1 callers
Function
test_case_4
()
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/device/src/lib.rs:102
↓ 1 callers
Function
test_case_gid
()
KRdmaKit-syscall/two-sided-dc/rust-kernel-rdma-base/unitests/get_devices/src/lib.rs:63
↓ 1 callers
Function
test_case_rc_3
path resolve
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/qp/src/lib.rs:136
↓ 1 callers
Function
test_case_rc_overflow
QP state
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/qp_state/src/lib.rs:103
↓ 1 callers
Function
test_case_rc_reg
path resolve
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/reg_mr/src/lib.rs:101
↓ 1 callers
Function
test_case_rpc
UD sidr handshake
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/rpc/src/lib.rs:105
↓ 1 callers
Function
test_cq_construction
()
KRdmaKit/unitests-kernel/unreliable_datagram/src/lib.rs:29
↓ 1 callers
Function
test_create_cq
for each device in the "ALL_DEVS", create a CQ on it, if successful, then delete it
KRdmaKit-syscall/two-sided-dc/rust-kernel-rdma-base/unitests/create_dct/src/lib.rs:65
↓ 1 callers
Function
test_create_cq
for each device in the "ALL_DEVS", create a CQ on it, if successful, then delete it
KRdmaKit-syscall/two-sided-dc/rust-kernel-rdma-base/unitests/create_qps/src/lib.rs:66
↓ 1 callers
Function
test_create_cq
for each device in the "ALL_DEVS", create a CQ on it, if successful, then delete it
rust-kernel-rdma/rust-kernel-rdma-base/unitests/create_dct/src/lib.rs:65
↓ 1 callers
Function
test_create_cq
for each device in the "ALL_DEVS", create a CQ on it, if successful, then delete it
rust-kernel-rdma/rust-kernel-rdma-base/unitests/create_qps/src/lib.rs:66
↓ 1 callers
Function
test_create_qp
for each device in the "ALL_DEVS", create a QP on it, if successful, then delete it
KRdmaKit-syscall/two-sided-dc/rust-kernel-rdma-base/unitests/create_dct/src/lib.rs:154
↓ 1 callers
Function
test_create_qp
for each device in the "ALL_DEVS", create a QP on it, if successful, then delete it
KRdmaKit-syscall/two-sided-dc/rust-kernel-rdma-base/unitests/create_qps/src/lib.rs:98
↓ 1 callers
Function
test_create_qp
for each device in the "ALL_DEVS", create a QP on it, if successful, then delete it
rust-kernel-rdma/rust-kernel-rdma-base/unitests/create_dct/src/lib.rs:154
↓ 1 callers
Function
test_create_qp
for each device in the "ALL_DEVS", create a QP on it, if successful, then delete it
rust-kernel-rdma/rust-kernel-rdma-base/unitests/create_qps/src/lib.rs:98
↓ 1 callers
Function
test_dct_builder
()
KRdmaKit/unitests-kernel/dynamic_connected_transport/src/lib.rs:59
↓ 1 callers
Function
test_dct_query
()
KRdmaKit/unitests-kernel/dynamic_connected_transport/src/lib.rs:106
↓ 1 callers
Function
test_mr
()
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/device/src/lib.rs:115
↓ 1 callers
Function
test_rc_duplicate_handshake
()
KRdmaKit/unitests-kernel/reliable_connection/src/lib.rs:98
↓ 1 callers
Function
test_rc_handshake
()
KRdmaKit/unitests-kernel/reliable_connection/src/lib.rs:29
↓ 1 callers
Function
test_rc_read_write
()
KRdmaKit/unitests-kernel/reliable_connection/src/lib.rs:170
↓ 1 callers
Function
test_rc_with_wrong_key
()
KRdmaKit/unitests-kernel/reliable_connection/src/lib.rs:309
↓ 1 callers
Function
test_reset_device
()
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/device/src/lib.rs:123
↓ 1 callers
Function
test_srq_construction
()
KRdmaKit/unitests-kernel/dynamic_connected_transport/src/lib.rs:33
↓ 1 callers
Function
test_sync_rpc_recv
exp/LITE/lib/lite_rpc.c:189
↓ 1 callers
Function
test_sync_rpc_send
exp/LITE/lib/lite_rpc.c:151
↓ 1 callers
Function
test_two_sided_dct
()
KRdmaKit-syscall/two-sided-dc/KRdmaKit/unitests/dct/src/lib.rs:228
↓ 1 callers
Function
test_ud_builder
()
KRdmaKit/unitests-kernel/unreliable_datagram/src/lib.rs:55
↓ 1 callers
Function
test_ud_query
()
KRdmaKit/unitests-kernel/unreliable_datagram/src/lib.rs:87
↓ 1 callers
Function
test_wrapper
()
KRdmaKit/unitests-kernel/dynamic_connected_transport/src/lib.rs:249
↓ 1 callers
Function
test_wrapper
()
KRdmaKit/unitests-kernel/unreliable_datagram/src/lib.rs:257
↓ 1 callers
Function
test_wrapper
()
KRdmaKit/unitests-kernel/reliable_connection/src/lib.rs:418
↓ 1 callers
Function
then_send_async
(write: &mut WriteHalf<'_>, message: CMMessage)
KRdmaKit/src/services_user/mod.rs:280
↓ 1 callers
Method
timeout
(&self)
KRdmaKit/src/queue_pairs/mod.rs:192
↓ 1 callers
Method
to_mrinfos
(&self)
KRdmaKit/src/services_user/cm.rs:260
↓ 1 callers
Method
transfer
(&mut self)
KRdmaKit-syscall/two-sided-dc/KRdmaKit/src/cm/sidr.rs:65
↓ 1 callers
Function
trigger
(dictory)
exp_scripts/log_analyser.py:115
↓ 1 callers
Function
trigger_bootstrap
(dictory)
exp_scripts/evaluation_runner.py:41
↓ 1 callers
Function
trim_whitespace
(mut data: &[u8])
KRdmaKit-syscall/two-sided-dc/deps/rust-kernel-module/src/sysctl.rs:18
↓ 1 callers
Function
trim_whitespace
(mut data: &[u8])
rust-kernel-rdma/deps/rust-kernel-module/src/sysctl.rs:18
↓ 1 callers
Method
ud_push_impl
(&mut self, req_list: &[core_req_t])
KRdmaKit-syscall/two-sided-dc/KRdmaKit-syscall/src/virtual_queue.rs:538
↓ 1 callers
Method
unlock
(&self)
rust-kernel-rdma/deps/rust-kernel-module/src/mutex.rs:29
↓ 1 callers
Method
update_client_endpoint_cache
(&mut self, k: &usize, ctx: &RContext, point: *mut EndPoint)
KRdmaKit-syscall/src/virtual_queue.rs:961
↓ 1 callers
Method
update_client_endpoint_cache
(&mut self, k: &usize, pd: *mut ib_pd, point: *mut EndPoint)
KRdmaKit-syscall/two-sided-dc/KRdmaKit-syscall/src/virtual_queue.rs:788
← previous
next →
901–1,000 of 2,356, ranked by callers