Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ai-dynamo/nixl
/ functions
Functions
3,108 in github.com/ai-dynamo/nixl
⨍
Functions
3,108
◇
Types & classes
683
↳
Endpoints
1
↓ 1 callers
Method
add
src/plugins/obj/obj_engine_registry.cpp:17
↓ 1 callers
Method
addDescList
Calls into backend engine to register the memories in the desc list
src/infra/nixl_memory_section.cpp:132
↓ 1 callers
Method
addOperation
src/plugins/infinia/infinia_backend.cpp:1050
↓ 1 callers
Method
addPostTime
src/core/telemetry/telemetry.cpp:304
↓ 1 callers
Method
addRdmaQp
src/plugins/gpunetio/gpunetio_backend.cpp:572
↓ 1 callers
Method
addRequest
src/plugins/ucx/ucx_backend.cpp:583
↓ 1 callers
Method
addToBatch
src/plugins/cuda_gds/gds_utils.cpp:120
↓ 1 callers
Method
add_failure
test/unit/plugins/hf3fs/nixl_hf3fs_mt_test.cpp:128
↓ 1 callers
Method
agents
Returns an iterator over the agent names that have notifications
src/bindings/rust/src/notify.rs:63
↓ 1 callers
Function
allBytesAre
benchmark/nixlbench/src/utils/utils.cpp:880
↓ 1 callers
Function
allocateBuffer
test/unit/plugins/ucx/ucx_backend_test.cpp:182
↓ 1 callers
Method
allocateControlRequest
src/utils/libfabric/libfabric_rail.cpp:1496
↓ 1 callers
Method
allocateMemory
Allocate and register memory descriptors for each thread. */
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:933
↓ 1 callers
Function
allocateWrongGPUTest
test/unit/plugins/mooncake/mooncake_backend_test.cpp:290
↓ 1 callers
Method
alltoall_obj
All-to-all operation for objects
benchmark/kvbench/runtime/rt_base.py:51
↓ 1 callers
Method
appendNotif
src/plugins/ucx/ucx_backend.cpp:380
↓ 1 callers
Method
areAllPeersAlive
benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:170
↓ 1 callers
Method
arm
src/plugins/ucx/ucx_utils.cpp:694
↓ 1 callers
Method
broadcastInt
benchmark/nixlbench/src/worker/worker.cpp:45
↓ 1 callers
Method
broadcastInt
benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:515
↓ 1 callers
Method
buf_size
(self, src, dst)
benchmark/kvbench/test/traffic_pattern.py:81
↓ 1 callers
Function
build_nixl
(cc_builder: &mut cc::Build)
src/bindings/rust/build.rs:87
↓ 1 callers
Method
bytes_per_token
(self)
benchmark/kvbench/test/inference_workload_matgen.py:79
↓ 1 callers
Function
calc_cq_external_umem_size
src/plugins/gpunetio/verbs/verbs.cpp:55
↓ 1 callers
Function
calc_qp_external_umem_size
src/plugins/gpunetio/verbs/verbs.cpp:44
↓ 1 callers
Method
checkBlobExistsAsync
src/plugins/azure_blob/azure_blob_client.cpp:202
↓ 1 callers
Method
checkIncreasing
test/gtest/plugins/memory_handler.h:47
↓ 1 callers
Method
checkKeepAlive
benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:155
↓ 1 callers
Function
checkMissingFileRejected
A ro: registration of a missing `path` must fail gracefully, not crash.
test/unit/plugins/path_mode_common.h:132
↓ 1 callers
Method
checkObjectExistsAsync
src/plugins/obj/s3/client.cpp:124
↓ 1 callers
Function
checkPathModeParser
Path-mode parser unit checks (POSIX-only since it owns parsePathMeta tests).
test/unit/plugins/posix/nixl_posix_test.cpp:774
↓ 1 callers
Method
checkStatus
src/plugins/cuda_gds/gds_utils.cpp:169
↓ 1 callers
Method
checkTransfer
src/plugins/infinia/infinia_backend.cpp:1166
↓ 1 callers
Method
checkTxState
src/plugins/ucx/ucx_utils.h:65
↓ 1 callers
Function
check_memory_requirements
Check if there's enough memory available for the test Returns true if sufficient memory, false otherwise
test/unit/plugins/infinia/infinia_nixl_test.cpp:123
↓ 1 callers
Function
chooseIpAddress
src/plugins/mooncake/mooncake_backend.cpp:73
↓ 1 callers
Method
cleanup
src/plugins/infinia/infinia_client.cpp:108
↓ 1 callers
Function
cleanupBasicDescDram
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:803
↓ 1 callers
Function
cleanupBasicDescObj
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:826
↓ 1 callers
Function
cleanupBasicDescVram
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:810
↓ 1 callers
Method
cleanupForExit
benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:141
↓ 1 callers
Function
cleanupIov
FILE fds are owned by xferFileState and BLK descriptors own nothing, so both fall through to the no-op default.
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:836
↓ 1 callers
Function
cleanupVramCuda
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:599
↓ 1 callers
Function
cleanupVramNeuron
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:530
↓ 1 callers
Function
cleanupVramRocm
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:624
↓ 1 callers
Method
clear
* @brief Empty the descriptors list */
src/api/cpp/nixl_descriptors.h:386
↓ 1 callers
Function
clear_buffer
test/unit/plugins/hf3fs/nixl_hf3fs_test.cpp:89
↓ 1 callers
Function
clear_buffer
test/unit/plugins/infinia/infinia_nixl_test.cpp:288
↓ 1 callers
Function
clear_buffer
test/unit/plugins/gds_mt/nixl_gds_mt_test.cpp:175
↓ 1 callers
Function
clear_buffer
test/unit/plugins/cuda_gds/nixl_gds_test.cpp:156
↓ 1 callers
Function
clear_buffer
* @brief Clear a buffer by setting all bytes to zero * @param buffer Pointer to the buffer to clear * @param size Size of the buffer in bytes */
test/unit/plugins/object/nixl_object_test.cpp:184
↓ 1 callers
Function
clear_gpu_buffer
test/unit/plugins/infinia/infinia_nixl_test.cpp:308
↓ 1 callers
Function
clear_gpu_buffer
test/unit/plugins/gds_mt/nixl_gds_mt_test.cpp:180
↓ 1 callers
Function
clear_gpu_buffer
test/unit/plugins/cuda_gds/nixl_gds_test.cpp:160
↓ 1 callers
Function
clear_gpu_buffer
* @brief Clear a GPU buffer by setting all bytes to zero * @param gpu_buffer Pointer to the GPU buffer to clear * @param size Size of the buffer in
test/unit/plugins/object/nixl_object_test.cpp:208
↓ 1 callers
Function
cli
KVBench - NIXL Performance Testing CLI
benchmark/kvbench/main.py:63
↓ 1 callers
Function
cli
Generate communication matrices for inference workloads
benchmark/kvbench/test/inference_workload_matgen.py:488
↓ 1 callers
Method
closeGdsDriver
src/plugins/cuda_gds/gds_utils.cpp:71
↓ 1 callers
Method
closeHf3fsDriver
src/plugins/hf3fs/hf3fs_utils.cpp:42
↓ 1 callers
Method
connect
src/plugins/ucx/ucx_backend.cpp:878
↓ 1 callers
Method
connectListener
src/utils/stream/metadata_stream.cpp:220
↓ 1 callers
Method
connectServerRdmaQp
src/plugins/gpunetio/gpunetio_backend.cpp:797
↓ 1 callers
Function
connectToIP
src/core/nixl_listener.cpp:39
↓ 1 callers
Function
connect_to_agents
(my_agent, agents_file)
examples/python/remote_storage_example/nixl_p2p_storage_example.py:74
↓ 1 callers
Method
connected
test/doca-telemetry/loopback_connection.h:68
↓ 1 callers
Function
convert_mds
examples/device/ep/csrc/nixl_ep.cpp:1469
↓ 1 callers
Function
copytree
Copy a tree of files from @src directory to @dst directory. Similar to shutil.copytree, but returns a list of all files copied. Returns:
contrib/wheel_add_ucx_plugins.py:163
↓ 1 callers
Method
create
test/gtest/unit/obj/mock_client_registry.h:39
↓ 1 callers
Method
create
src/plugins/obj/obj_engine_registry.cpp:49
↓ 1 callers
Function
createEngine
test/unit/plugins/mooncake/mooncake_backend_test.cpp:115
↓ 1 callers
Function
createEngine
test/unit/plugins/ucx/ucx_backend_test.cpp:110
↓ 1 callers
Method
createEngine
src/core/nixl_plugin_manager.cpp:58
↓ 1 callers
Function
createFileFds
Create file descriptors from explicit filenames or auto-generate
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:698
↓ 1 callers
Method
createIOR
src/plugins/hf3fs/hf3fs_utils.cpp:69
↓ 1 callers
Method
createIOV
src/plugins/hf3fs/hf3fs_utils.cpp:81
↓ 1 callers
Function
createRT
benchmark/nixlbench/src/worker/worker.cpp:86
↓ 1 callers
Function
createTransferDescLists
benchmark/nixlbench/src/main.cpp:75
↓ 1 callers
Function
createUcclBackend
test/gtest/plugins/uccl/uccl_test.cpp:30
↓ 1 callers
Function
createUcxBackend
test/gtest/error_handling.cpp:29
↓ 1 callers
Function
createWorker
benchmark/nixlbench/src/main.cpp:160
↓ 1 callers
Method
create_backend
(self, backend: str, initParams: dict[str, str] = {})
src/api/python/_api.py:382
↓ 1 callers
Function
create_event
examples/device/ep/csrc/event.hpp:50
↓ 1 callers
Function
create_grouped_scores
( scores: torch.Tensor, group_idx: torch.Tensor, num_groups: int )
examples/device/ep/tests/utils.py:106
↓ 1 callers
Function
create_test_agent
Helper function to create an agent with error handling
src/bindings/rust/tests/tests.rs:30
↓ 1 callers
Function
create_wheel
Create a wheel from a temporary directory.
contrib/wheel_add_ucx_plugins.py:84
↓ 1 callers
Function
cudaQueryAddr
test/unit/plugins/mooncake/mooncake_backend_test.cpp:162
↓ 1 callers
Function
cudaQueryAddr
test/unit/plugins/ucx/ucx_backend_test.cpp:152
↓ 1 callers
Method
cudaSetCtx
src/plugins/libfabric/libfabric_backend.cpp:180
↓ 1 callers
Method
cudaUpdateCtxPtr
src/plugins/libfabric/libfabric_backend.cpp:150
↓ 1 callers
Method
current_stream_wait
The current stream `torch.cuda.current_stream()` waits for the event to be finished.
examples/device/ep/nixl_ep/utils.py:56
↓ 1 callers
Method
dataCmp
test/gtest/error_handling.cpp:252
↓ 1 callers
Method
dataCmp
test/gtest/plugins/uccl/uccl_test.cpp:246
↓ 1 callers
Method
deallocateMemory
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:1129
↓ 1 callers
Method
deregister
(&mut self)
src/bindings/rust/src/lib.rs:152
↓ 1 callers
Method
deregisterBufHandle
src/plugins/cuda_gds/gds_utils.cpp:81
↓ 1 callers
Method
deregisterFileHandle
src/plugins/hf3fs/hf3fs_utils.cpp:47
↓ 1 callers
Method
deregisterFileHandle
src/plugins/cuda_gds/gds_utils.cpp:76
↓ 1 callers
Method
derive_remote_selected_endpoints
src/plugins/libfabric/libfabric_backend.cpp:893
↓ 1 callers
Method
desc_count
Returns the number of descriptors in the list
src/bindings/rust/src/descriptors/xfer.rs:119
↓ 1 callers
Method
desc_count
Returns the number of descriptors in the list
src/bindings/rust/src/descriptors/reg.rs:141
← previous
next →
701–800 of 3,108, ranked by callers