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
↓ 13 callers
Method
invalidateLocalMD
src/core/nixl_agent.cpp:1661
↓ 13 callers
Function
memTypeStr
src/core/nixl_enum_strings.cpp:24
↓ 13 callers
Function
nixlDocaEngineCheckCudaError
src/plugins/gpunetio/gpunetio_utils.cpp:31
↓ 13 callers
Function
stream_wait
examples/device/ep/csrc/event.hpp:56
↓ 13 callers
Function
throwRuntimeError
src/utils/common/exception.h:28
↓ 12 callers
Function
checkCudaError
test/unit/plugins/ucx/ucx_worker_test.cpp:35
↓ 12 callers
Method
check_xfer_state
(self, handle: nixl_xfer_handle)
src/api/python/_api.py:647
↓ 12 callers
Method
covers
* @brief Check if current object address range covers the input object's * * @param query nixlBasicDesc object */
src/api/cpp/nixl_descriptors.h:113
↓ 12 callers
Method
exportStr
Buffer management serialization
src/utils/serdes/serdes.cpp:152
↓ 12 callers
Method
getBlobDesc
test/gtest/metadata_exchange.cpp:57
↓ 12 callers
Method
getEp
src/plugins/ucx/ucx_utils.h:112
↓ 12 callers
Method
incRailActive
src/utils/libfabric/libfabric_rail_manager.cpp:1222
↓ 12 callers
Method
initialize_xfer
( self, operation: str, local_descs: nixlBind.nixlXferDList, remote_descs: nix
src/api/python/_api.py:599
↓ 12 callers
Function
parsePathMeta
src/utils/file/file_path_mode.cpp:33
↓ 12 callers
Function
printProgress
test/unit/plugins/posix/nixl_posix_test.cpp:146
↓ 12 callers
Method
register
(&mut self, agent: &Agent, opt_args: Option<&OptArgs>)
src/bindings/rust/src/lib.rs:557
↓ 12 callers
Method
setSimulateSuccess
test/gtest/unit/obj/obj_test_base.h:70
↓ 11 callers
Method
checkLocalMem
test/gtest/plugins/transfer_handler.h:94
↓ 11 callers
Method
deregister_memory
( self, dereg_list: nixlBind.nixlRegDList, backends: list[str] = [] )
src/api/python/_api.py:425
↓ 11 callers
Method
fetchRemoteMD
test/gtest/test_transfer.cpp:194
↓ 11 callers
Method
get
Returns the memory type at the given index
src/bindings/rust/src/lib.rs:434
↓ 11 callers
Method
get_local_md
Gets the local metadata for this agent as a byte array
src/bindings/rust/src/agent.rs:356
↓ 11 callers
Method
isEmpty
* @brief Check if nixlDescList is empty or not */
src/api/cpp/nixl_descriptors.h:326
↓ 11 callers
Method
makeXferReq
src/core/nixl_agent.cpp:646
↓ 11 callers
Method
resetLocalMem
test/gtest/plugins/transfer_handler.h:88
↓ 11 callers
Method
setSimulateSuccess
test/gtest/unit/azure_blob/azure_blob.cpp:47
↓ 11 callers
Function
ucsToNixlStatus
src/plugins/ucx/ucx_enums.cpp:42
↓ 11 callers
Method
update
Update config with values from a dictionary. Creates a new ModelConfig instance with updated values rather than modifying th
benchmark/kvbench/models/model_config.py:146
↓ 10 callers
Method
add
benchmark/nixlbench/src/utils/utils.cpp:1610
↓ 10 callers
Function
cleanupSlots
Best-effort teardown for early-exit / error paths.
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:1515
↓ 10 callers
Method
fetchRemoteMD
src/core/nixl_agent.cpp:1635
↓ 10 callers
Method
from_yaml
Create a model architecture instance from a YAML configuration file. Args: yaml_path (str): Path to the YAML configurati
benchmark/kvbench/models/models.py:91
↓ 10 callers
Method
getAvailPlugins
src/core/nixl_agent.cpp:202
↓ 10 callers
Method
getDesc
test/gtest/unit/agent/agent.cpp:61
↓ 10 callers
Method
getRank
benchmark/nixlbench/src/runtime/runtime.cpp:24
↓ 10 callers
Method
get_available_plugins
Gets the list of available plugins
src/bindings/rust/src/agent.rs:127
↓ 10 callers
Method
importStr
src/utils/serdes/serdes.cpp:156
↓ 10 callers
Method
release_xfer_handle
(self, handle: nixl_xfer_handle)
src/api/python/_api.py:696
↓ 10 callers
Method
sendLocalMD
src/core/nixl_agent.cpp:1571
↓ 10 callers
Method
set
Sets a key-value pair in the parameters (overwrites if exists)
src/bindings/rust/src/utils/params.rs:174
↓ 10 callers
Method
supportsLocal
src/core/agent_data.h:162
↓ 10 callers
Method
transfer
(self, handle: nixl_xfer_handle, notif_msg: bytes = b"")
src/api/python/_api.py:631
↓ 9 callers
Function
GetMockBackendName
test/gtest/common.h:54
↓ 9 callers
Method
addBuf
Byte buffers serialization
src/utils/serdes/serdes.cpp:82
↓ 9 callers
Function
exchange_metadata
(agent1: &Agent, agent2: &Agent)
src/bindings/rust/tests/tests.rs:134
↓ 9 callers
Method
getAndLoadRemoteMd
test/gtest/unit/agent/agent.cpp:102
↓ 9 callers
Method
getConnInfo
test/gtest/mocks/mock_backend_engine.h:84
↓ 9 callers
Method
getSize
benchmark/nixlbench/src/runtime/runtime.cpp:20
↓ 9 callers
Function
getValueDefaulted
src/utils/common/configuration.h:136
↓ 9 callers
Method
initAndRegisterMemory
test/gtest/unit/agent/agent.cpp:109
↓ 9 callers
Function
iovListToNixlRegDlist
Convert a vector of xferBenchIOV into a nixl_reg_dlist_t of the given segment type.
benchmark/nixlbench/src/worker/nixl/nixl_mem_region.h:40
↓ 9 callers
Method
load_remote_md
Loads remote metadata from a byte slice
src/bindings/rust/src/agent.rs:448
↓ 9 callers
Method
modify
src/plugins/ucx/config.cpp:25
↓ 9 callers
Function
print_protected
test/unit/plugins/hf3fs/nixl_hf3fs_mt_test.cpp:66
↓ 9 callers
Method
reserve
benchmark/nixlbench/src/utils/utils.cpp:1620
↓ 9 callers
Method
set
Sets a variable for the lifetime of the guard.
src/bindings/rust/tests/env_guard/mod.rs:68
↓ 9 callers
Method
start
src/plugins/ucx/ucx_backend.cpp:209
↓ 9 callers
Method
unlock
src/core/sync.h:64
↓ 8 callers
Method
add_storage_desc
Add a descriptor from a type implementing NixlDescriptor # Safety The caller must ensure that: - The descriptor remains valid for the lifetime of the
src/bindings/rust/src/descriptors/reg.rs:210
↓ 8 callers
Method
check_remote_metadata
Check if remote metadata for a specific agent is available This function checks if the metadata for the specified remote agent has been loaded and if
src/bindings/rust/src/agent.rs:574
↓ 8 callers
Method
create_xfer_req
Creates a transfer request between local and remote descriptors # Arguments `operation` - The transfer operation (read or write) `local_descs` - The
src/bindings/rust/src/agent.rs:844
↓ 8 callers
Method
enqueueCommWork
src/core/nixl_listener.cpp:729
↓ 8 callers
Method
fd
src/utils/file/file_path_mode.h:76
↓ 8 callers
Method
flush
src/plugins/telemetry/doca/doca_exporter.cpp:331
↓ 8 callers
Method
getBuf
src/utils/serdes/serdes.cpp:113
↓ 8 callers
Method
getLoadedBackendPluginNames
src/core/nixl_plugin_manager.cpp:578
↓ 8 callers
Method
getLocalMD
src/core/nixl_agent.cpp:1337
↓ 8 callers
Method
get_new_notifs
(self, backends: list[str] = [])
src/api/python/_api.py:716
↓ 8 callers
Function
getenvOptional
src/utils/common/configuration.cpp:92
↓ 8 callers
Method
loadRemoteMD
src/core/nixl_agent.cpp:1462
↓ 8 callers
Method
lock
src/core/sync.h:56
↓ 8 callers
Function
memTypeToStr
Helper function to convert memory type to string
src/plugins/infinia/infinia_backend.cpp:40
↓ 8 callers
Method
memset
Fill the storage with a specific byte value
src/bindings/rust/src/lib.rs:526
↓ 8 callers
Method
name
Gets the name of the agent
src/bindings/rust/src/agent.rs:122
↓ 8 callers
Function
printProgress
test/unit/plugins/hf3fs/nixl_hf3fs_test.cpp:105
↓ 8 callers
Function
printProgress
test/unit/plugins/infinia/infinia_nixl_test.cpp:223
↓ 8 callers
Function
printProgress
test/unit/plugins/gds_mt/nixl_gds_mt_test.cpp:105
↓ 8 callers
Function
printProgress
test/unit/plugins/cuda_gds/nixl_gds_test.cpp:93
↓ 8 callers
Function
printProgress
* @brief Print a progress bar to the console * @param progress Progress value between 0.0 and 1.0 */
test/unit/plugins/object/nixl_object_test.cpp:121
↓ 8 callers
Method
remDesc
src/infra/nixl_descriptors.cpp:198
↓ 8 callers
Method
senders_ranks
Return the ranks that send messages
benchmark/kvbench/test/traffic_pattern.py:55
↓ 8 callers
Method
serialize
src/infra/nixl_descriptors.cpp:73
↓ 7 callers
Method
add_desc_with_meta
Add a descriptor with metadata
src/bindings/rust/src/descriptors/reg.rs:120
↓ 7 callers
Method
allgather_obj
All-gather operation for objects
benchmark/kvbench/runtime/rt_base.py:47
↓ 7 callers
Function
checkCudaError
test/unit/plugins/mooncake/mooncake_backend_test.cpp:31
↓ 7 callers
Function
checkCudaError
test/unit/plugins/ucx/ucx_backend_test.cpp:34
↓ 7 callers
Function
createAgent
Initialize an agent with etcd enabled
examples/cpp/nixl_etcd_example.cpp:41
↓ 7 callers
Method
execAsync
test/gtest/unit/obj/obj_test_base.h:210
↓ 7 callers
Method
full
Check if buffer is full
examples/python/telemetry_reader.py:180
↓ 7 callers
Method
getBackendParams
src/core/nixl_agent.cpp:246
↓ 7 callers
Method
getInitErr
src/api/cpp/backend/backend_engine.h:97
↓ 7 callers
Method
getNotifs
src/core/nixl_agent.cpp:1219
↓ 7 callers
Method
initDefault
test/gtest/metadata_exchange.cpp:114
↓ 7 callers
Method
len
Returns the number of memory types in the list
src/bindings/rust/src/lib.rs:420
↓ 7 callers
Method
loadBackendPlugin
src/core/nixl_plugin_manager.cpp:370
↓ 7 callers
Method
postXferReq
src/core/nixl_agent.cpp:1011
↓ 7 callers
Method
progress
src/plugins/ucx/ucx_utils.cpp:664
↓ 7 callers
Function
railIdsToString
src/utils/libfabric/libfabric_common.cpp:126
↓ 7 callers
Method
reset
test/gtest/plugins/memory_handler.h:60
↓ 7 callers
Method
setKeyOutcome
test/gtest/unit/azure_blob/azure_blob.cpp:57
← previous
next →
101–200 of 3,108, ranked by callers