MCPcopy Create free account

hub / github.com/ai-dynamo/nixl / functions

Functions3,108 in github.com/ai-dynamo/nixl

↓ 1 callersMethodadd
src/plugins/obj/obj_engine_registry.cpp:17
↓ 1 callersMethodaddDescList
Calls into backend engine to register the memories in the desc list
src/infra/nixl_memory_section.cpp:132
↓ 1 callersMethodaddOperation
src/plugins/infinia/infinia_backend.cpp:1050
↓ 1 callersMethodaddPostTime
src/core/telemetry/telemetry.cpp:304
↓ 1 callersMethodaddRdmaQp
src/plugins/gpunetio/gpunetio_backend.cpp:572
↓ 1 callersMethodaddRequest
src/plugins/ucx/ucx_backend.cpp:583
↓ 1 callersMethodaddToBatch
src/plugins/cuda_gds/gds_utils.cpp:120
↓ 1 callersMethodadd_failure
test/unit/plugins/hf3fs/nixl_hf3fs_mt_test.cpp:128
↓ 1 callersMethodagents
Returns an iterator over the agent names that have notifications
src/bindings/rust/src/notify.rs:63
↓ 1 callersFunctionallBytesAre
benchmark/nixlbench/src/utils/utils.cpp:880
↓ 1 callersFunctionallocateBuffer
test/unit/plugins/ucx/ucx_backend_test.cpp:182
↓ 1 callersMethodallocateControlRequest
src/utils/libfabric/libfabric_rail.cpp:1496
↓ 1 callersMethodallocateMemory
Allocate and register memory descriptors for each thread. */
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:933
↓ 1 callersFunctionallocateWrongGPUTest
test/unit/plugins/mooncake/mooncake_backend_test.cpp:290
↓ 1 callersMethodalltoall_obj
All-to-all operation for objects
benchmark/kvbench/runtime/rt_base.py:51
↓ 1 callersMethodappendNotif
src/plugins/ucx/ucx_backend.cpp:380
↓ 1 callersMethodareAllPeersAlive
benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:170
↓ 1 callersMethodarm
src/plugins/ucx/ucx_utils.cpp:694
↓ 1 callersMethodbroadcastInt
benchmark/nixlbench/src/worker/worker.cpp:45
↓ 1 callersMethodbroadcastInt
benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:515
↓ 1 callersMethodbuf_size
(self, src, dst)
benchmark/kvbench/test/traffic_pattern.py:81
↓ 1 callersFunctionbuild_nixl
(cc_builder: &mut cc::Build)
src/bindings/rust/build.rs:87
↓ 1 callersMethodbytes_per_token
(self)
benchmark/kvbench/test/inference_workload_matgen.py:79
↓ 1 callersFunctioncalc_cq_external_umem_size
src/plugins/gpunetio/verbs/verbs.cpp:55
↓ 1 callersFunctioncalc_qp_external_umem_size
src/plugins/gpunetio/verbs/verbs.cpp:44
↓ 1 callersMethodcheckBlobExistsAsync
src/plugins/azure_blob/azure_blob_client.cpp:202
↓ 1 callersMethodcheckIncreasing
test/gtest/plugins/memory_handler.h:47
↓ 1 callersMethodcheckKeepAlive
benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:155
↓ 1 callersFunctioncheckMissingFileRejected
A ro: registration of a missing `path` must fail gracefully, not crash.
test/unit/plugins/path_mode_common.h:132
↓ 1 callersMethodcheckObjectExistsAsync
src/plugins/obj/s3/client.cpp:124
↓ 1 callersFunctioncheckPathModeParser
Path-mode parser unit checks (POSIX-only since it owns parsePathMeta tests).
test/unit/plugins/posix/nixl_posix_test.cpp:774
↓ 1 callersMethodcheckStatus
src/plugins/cuda_gds/gds_utils.cpp:169
↓ 1 callersMethodcheckTransfer
src/plugins/infinia/infinia_backend.cpp:1166
↓ 1 callersMethodcheckTxState
src/plugins/ucx/ucx_utils.h:65
↓ 1 callersFunctioncheck_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 callersFunctionchooseIpAddress
src/plugins/mooncake/mooncake_backend.cpp:73
↓ 1 callersMethodcleanup
src/plugins/infinia/infinia_client.cpp:108
↓ 1 callersFunctioncleanupBasicDescDram
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:803
↓ 1 callersFunctioncleanupBasicDescObj
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:826
↓ 1 callersFunctioncleanupBasicDescVram
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:810
↓ 1 callersMethodcleanupForExit
benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:141
↓ 1 callersFunctioncleanupIov
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 callersFunctioncleanupVramCuda
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:599
↓ 1 callersFunctioncleanupVramNeuron
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:530
↓ 1 callersFunctioncleanupVramRocm
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:624
↓ 1 callersMethodclear
* @brief Empty the descriptors list */
src/api/cpp/nixl_descriptors.h:386
↓ 1 callersFunctionclear_buffer
test/unit/plugins/hf3fs/nixl_hf3fs_test.cpp:89
↓ 1 callersFunctionclear_buffer
test/unit/plugins/infinia/infinia_nixl_test.cpp:288
↓ 1 callersFunctionclear_buffer
test/unit/plugins/gds_mt/nixl_gds_mt_test.cpp:175
↓ 1 callersFunctionclear_buffer
test/unit/plugins/cuda_gds/nixl_gds_test.cpp:156
↓ 1 callersFunctionclear_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 callersFunctionclear_gpu_buffer
test/unit/plugins/infinia/infinia_nixl_test.cpp:308
↓ 1 callersFunctionclear_gpu_buffer
test/unit/plugins/gds_mt/nixl_gds_mt_test.cpp:180
↓ 1 callersFunctionclear_gpu_buffer
test/unit/plugins/cuda_gds/nixl_gds_test.cpp:160
↓ 1 callersFunctionclear_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 callersFunctioncli
KVBench - NIXL Performance Testing CLI
benchmark/kvbench/main.py:63
↓ 1 callersFunctioncli
Generate communication matrices for inference workloads
benchmark/kvbench/test/inference_workload_matgen.py:488
↓ 1 callersMethodcloseGdsDriver
src/plugins/cuda_gds/gds_utils.cpp:71
↓ 1 callersMethodcloseHf3fsDriver
src/plugins/hf3fs/hf3fs_utils.cpp:42
↓ 1 callersMethodconnect
src/plugins/ucx/ucx_backend.cpp:878
↓ 1 callersMethodconnectListener
src/utils/stream/metadata_stream.cpp:220
↓ 1 callersMethodconnectServerRdmaQp
src/plugins/gpunetio/gpunetio_backend.cpp:797
↓ 1 callersFunctionconnectToIP
src/core/nixl_listener.cpp:39
↓ 1 callersFunctionconnect_to_agents
(my_agent, agents_file)
examples/python/remote_storage_example/nixl_p2p_storage_example.py:74
↓ 1 callersMethodconnected
test/doca-telemetry/loopback_connection.h:68
↓ 1 callersFunctionconvert_mds
examples/device/ep/csrc/nixl_ep.cpp:1469
↓ 1 callersFunctioncopytree
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 callersMethodcreate
test/gtest/unit/obj/mock_client_registry.h:39
↓ 1 callersMethodcreate
src/plugins/obj/obj_engine_registry.cpp:49
↓ 1 callersFunctioncreateEngine
test/unit/plugins/mooncake/mooncake_backend_test.cpp:115
↓ 1 callersFunctioncreateEngine
test/unit/plugins/ucx/ucx_backend_test.cpp:110
↓ 1 callersMethodcreateEngine
src/core/nixl_plugin_manager.cpp:58
↓ 1 callersFunctioncreateFileFds
Create file descriptors from explicit filenames or auto-generate
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:698
↓ 1 callersMethodcreateIOR
src/plugins/hf3fs/hf3fs_utils.cpp:69
↓ 1 callersMethodcreateIOV
src/plugins/hf3fs/hf3fs_utils.cpp:81
↓ 1 callersFunctioncreateRT
benchmark/nixlbench/src/worker/worker.cpp:86
↓ 1 callersFunctioncreateTransferDescLists
benchmark/nixlbench/src/main.cpp:75
↓ 1 callersFunctioncreateUcclBackend
test/gtest/plugins/uccl/uccl_test.cpp:30
↓ 1 callersFunctioncreateUcxBackend
test/gtest/error_handling.cpp:29
↓ 1 callersFunctioncreateWorker
benchmark/nixlbench/src/main.cpp:160
↓ 1 callersMethodcreate_backend
(self, backend: str, initParams: dict[str, str] = {})
src/api/python/_api.py:382
↓ 1 callersFunctioncreate_event
examples/device/ep/csrc/event.hpp:50
↓ 1 callersFunctioncreate_grouped_scores
( scores: torch.Tensor, group_idx: torch.Tensor, num_groups: int )
examples/device/ep/tests/utils.py:106
↓ 1 callersFunctioncreate_test_agent
Helper function to create an agent with error handling
src/bindings/rust/tests/tests.rs:30
↓ 1 callersFunctioncreate_wheel
Create a wheel from a temporary directory.
contrib/wheel_add_ucx_plugins.py:84
↓ 1 callersFunctioncudaQueryAddr
test/unit/plugins/mooncake/mooncake_backend_test.cpp:162
↓ 1 callersFunctioncudaQueryAddr
test/unit/plugins/ucx/ucx_backend_test.cpp:152
↓ 1 callersMethodcudaSetCtx
src/plugins/libfabric/libfabric_backend.cpp:180
↓ 1 callersMethodcudaUpdateCtxPtr
src/plugins/libfabric/libfabric_backend.cpp:150
↓ 1 callersMethodcurrent_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 callersMethoddataCmp
test/gtest/error_handling.cpp:252
↓ 1 callersMethoddataCmp
test/gtest/plugins/uccl/uccl_test.cpp:246
↓ 1 callersMethoddeallocateMemory
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:1129
↓ 1 callersMethodderegister
(&mut self)
src/bindings/rust/src/lib.rs:152
↓ 1 callersMethodderegisterBufHandle
src/plugins/cuda_gds/gds_utils.cpp:81
↓ 1 callersMethodderegisterFileHandle
src/plugins/hf3fs/hf3fs_utils.cpp:47
↓ 1 callersMethodderegisterFileHandle
src/plugins/cuda_gds/gds_utils.cpp:76
↓ 1 callersMethodderive_remote_selected_endpoints
src/plugins/libfabric/libfabric_backend.cpp:893
↓ 1 callersMethoddesc_count
Returns the number of descriptors in the list
src/bindings/rust/src/descriptors/xfer.rs:119
↓ 1 callersMethoddesc_count
Returns the number of descriptors in the list
src/bindings/rust/src/descriptors/reg.rs:141
← previousnext →701–800 of 3,108, ranked by callers