MCPcopy Create free account

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

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

↓ 13 callersMethodinvalidateLocalMD
src/core/nixl_agent.cpp:1661
↓ 13 callersFunctionmemTypeStr
src/core/nixl_enum_strings.cpp:24
↓ 13 callersFunctionnixlDocaEngineCheckCudaError
src/plugins/gpunetio/gpunetio_utils.cpp:31
↓ 13 callersFunctionstream_wait
examples/device/ep/csrc/event.hpp:56
↓ 13 callersFunctionthrowRuntimeError
src/utils/common/exception.h:28
↓ 12 callersFunctioncheckCudaError
test/unit/plugins/ucx/ucx_worker_test.cpp:35
↓ 12 callersMethodcheck_xfer_state
(self, handle: nixl_xfer_handle)
src/api/python/_api.py:647
↓ 12 callersMethodcovers
* @brief Check if current object address range covers the input object's * * @param query nixlBasicDesc object */
src/api/cpp/nixl_descriptors.h:113
↓ 12 callersMethodexportStr
Buffer management serialization
src/utils/serdes/serdes.cpp:152
↓ 12 callersMethodgetBlobDesc
test/gtest/metadata_exchange.cpp:57
↓ 12 callersMethodgetEp
src/plugins/ucx/ucx_utils.h:112
↓ 12 callersMethodincRailActive
src/utils/libfabric/libfabric_rail_manager.cpp:1222
↓ 12 callersMethodinitialize_xfer
( self, operation: str, local_descs: nixlBind.nixlXferDList, remote_descs: nix
src/api/python/_api.py:599
↓ 12 callersFunctionparsePathMeta
src/utils/file/file_path_mode.cpp:33
↓ 12 callersFunctionprintProgress
test/unit/plugins/posix/nixl_posix_test.cpp:146
↓ 12 callersMethodregister
(&mut self, agent: &Agent, opt_args: Option<&OptArgs>)
src/bindings/rust/src/lib.rs:557
↓ 12 callersMethodsetSimulateSuccess
test/gtest/unit/obj/obj_test_base.h:70
↓ 11 callersMethodcheckLocalMem
test/gtest/plugins/transfer_handler.h:94
↓ 11 callersMethodderegister_memory
( self, dereg_list: nixlBind.nixlRegDList, backends: list[str] = [] )
src/api/python/_api.py:425
↓ 11 callersMethodfetchRemoteMD
test/gtest/test_transfer.cpp:194
↓ 11 callersMethodget
Returns the memory type at the given index
src/bindings/rust/src/lib.rs:434
↓ 11 callersMethodget_local_md
Gets the local metadata for this agent as a byte array
src/bindings/rust/src/agent.rs:356
↓ 11 callersMethodisEmpty
* @brief Check if nixlDescList is empty or not */
src/api/cpp/nixl_descriptors.h:326
↓ 11 callersMethodmakeXferReq
src/core/nixl_agent.cpp:646
↓ 11 callersMethodresetLocalMem
test/gtest/plugins/transfer_handler.h:88
↓ 11 callersMethodsetSimulateSuccess
test/gtest/unit/azure_blob/azure_blob.cpp:47
↓ 11 callersFunctionucsToNixlStatus
src/plugins/ucx/ucx_enums.cpp:42
↓ 11 callersMethodupdate
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 callersMethodadd
benchmark/nixlbench/src/utils/utils.cpp:1610
↓ 10 callersFunctioncleanupSlots
Best-effort teardown for early-exit / error paths.
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:1515
↓ 10 callersMethodfetchRemoteMD
src/core/nixl_agent.cpp:1635
↓ 10 callersMethodfrom_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 callersMethodgetAvailPlugins
src/core/nixl_agent.cpp:202
↓ 10 callersMethodgetDesc
test/gtest/unit/agent/agent.cpp:61
↓ 10 callersMethodgetRank
benchmark/nixlbench/src/runtime/runtime.cpp:24
↓ 10 callersMethodget_available_plugins
Gets the list of available plugins
src/bindings/rust/src/agent.rs:127
↓ 10 callersMethodimportStr
src/utils/serdes/serdes.cpp:156
↓ 10 callersMethodrelease_xfer_handle
(self, handle: nixl_xfer_handle)
src/api/python/_api.py:696
↓ 10 callersMethodsendLocalMD
src/core/nixl_agent.cpp:1571
↓ 10 callersMethodset
Sets a key-value pair in the parameters (overwrites if exists)
src/bindings/rust/src/utils/params.rs:174
↓ 10 callersMethodsupportsLocal
src/core/agent_data.h:162
↓ 10 callersMethodtransfer
(self, handle: nixl_xfer_handle, notif_msg: bytes = b"")
src/api/python/_api.py:631
↓ 9 callersFunctionGetMockBackendName
test/gtest/common.h:54
↓ 9 callersMethodaddBuf
Byte buffers serialization
src/utils/serdes/serdes.cpp:82
↓ 9 callersFunctionexchange_metadata
(agent1: &Agent, agent2: &Agent)
src/bindings/rust/tests/tests.rs:134
↓ 9 callersMethodgetAndLoadRemoteMd
test/gtest/unit/agent/agent.cpp:102
↓ 9 callersMethodgetConnInfo
test/gtest/mocks/mock_backend_engine.h:84
↓ 9 callersMethodgetSize
benchmark/nixlbench/src/runtime/runtime.cpp:20
↓ 9 callersFunctiongetValueDefaulted
src/utils/common/configuration.h:136
↓ 9 callersMethodinitAndRegisterMemory
test/gtest/unit/agent/agent.cpp:109
↓ 9 callersFunctioniovListToNixlRegDlist
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 callersMethodload_remote_md
Loads remote metadata from a byte slice
src/bindings/rust/src/agent.rs:448
↓ 9 callersMethodmodify
src/plugins/ucx/config.cpp:25
↓ 9 callersFunctionprint_protected
test/unit/plugins/hf3fs/nixl_hf3fs_mt_test.cpp:66
↓ 9 callersMethodreserve
benchmark/nixlbench/src/utils/utils.cpp:1620
↓ 9 callersMethodset
Sets a variable for the lifetime of the guard.
src/bindings/rust/tests/env_guard/mod.rs:68
↓ 9 callersMethodstart
src/plugins/ucx/ucx_backend.cpp:209
↓ 9 callersMethodunlock
src/core/sync.h:64
↓ 8 callersMethodadd_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 callersMethodcheck_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 callersMethodcreate_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 callersMethodenqueueCommWork
src/core/nixl_listener.cpp:729
↓ 8 callersMethodfd
src/utils/file/file_path_mode.h:76
↓ 8 callersMethodflush
src/plugins/telemetry/doca/doca_exporter.cpp:331
↓ 8 callersMethodgetBuf
src/utils/serdes/serdes.cpp:113
↓ 8 callersMethodgetLoadedBackendPluginNames
src/core/nixl_plugin_manager.cpp:578
↓ 8 callersMethodgetLocalMD
src/core/nixl_agent.cpp:1337
↓ 8 callersMethodget_new_notifs
(self, backends: list[str] = [])
src/api/python/_api.py:716
↓ 8 callersFunctiongetenvOptional
src/utils/common/configuration.cpp:92
↓ 8 callersMethodloadRemoteMD
src/core/nixl_agent.cpp:1462
↓ 8 callersMethodlock
src/core/sync.h:56
↓ 8 callersFunctionmemTypeToStr
Helper function to convert memory type to string
src/plugins/infinia/infinia_backend.cpp:40
↓ 8 callersMethodmemset
Fill the storage with a specific byte value
src/bindings/rust/src/lib.rs:526
↓ 8 callersMethodname
Gets the name of the agent
src/bindings/rust/src/agent.rs:122
↓ 8 callersFunctionprintProgress
test/unit/plugins/hf3fs/nixl_hf3fs_test.cpp:105
↓ 8 callersFunctionprintProgress
test/unit/plugins/infinia/infinia_nixl_test.cpp:223
↓ 8 callersFunctionprintProgress
test/unit/plugins/gds_mt/nixl_gds_mt_test.cpp:105
↓ 8 callersFunctionprintProgress
test/unit/plugins/cuda_gds/nixl_gds_test.cpp:93
↓ 8 callersFunctionprintProgress
* @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 callersMethodremDesc
src/infra/nixl_descriptors.cpp:198
↓ 8 callersMethodsenders_ranks
Return the ranks that send messages
benchmark/kvbench/test/traffic_pattern.py:55
↓ 8 callersMethodserialize
src/infra/nixl_descriptors.cpp:73
↓ 7 callersMethodadd_desc_with_meta
Add a descriptor with metadata
src/bindings/rust/src/descriptors/reg.rs:120
↓ 7 callersMethodallgather_obj
All-gather operation for objects
benchmark/kvbench/runtime/rt_base.py:47
↓ 7 callersFunctioncheckCudaError
test/unit/plugins/mooncake/mooncake_backend_test.cpp:31
↓ 7 callersFunctioncheckCudaError
test/unit/plugins/ucx/ucx_backend_test.cpp:34
↓ 7 callersFunctioncreateAgent
Initialize an agent with etcd enabled
examples/cpp/nixl_etcd_example.cpp:41
↓ 7 callersMethodexecAsync
test/gtest/unit/obj/obj_test_base.h:210
↓ 7 callersMethodfull
Check if buffer is full
examples/python/telemetry_reader.py:180
↓ 7 callersMethodgetBackendParams
src/core/nixl_agent.cpp:246
↓ 7 callersMethodgetInitErr
src/api/cpp/backend/backend_engine.h:97
↓ 7 callersMethodgetNotifs
src/core/nixl_agent.cpp:1219
↓ 7 callersMethodinitDefault
test/gtest/metadata_exchange.cpp:114
↓ 7 callersMethodlen
Returns the number of memory types in the list
src/bindings/rust/src/lib.rs:420
↓ 7 callersMethodloadBackendPlugin
src/core/nixl_plugin_manager.cpp:370
↓ 7 callersMethodpostXferReq
src/core/nixl_agent.cpp:1011
↓ 7 callersMethodprogress
src/plugins/ucx/ucx_utils.cpp:664
↓ 7 callersFunctionrailIdsToString
src/utils/libfabric/libfabric_common.cpp:126
↓ 7 callersMethodreset
test/gtest/plugins/memory_handler.h:60
↓ 7 callersMethodsetKeyOutcome
test/gtest/unit/azure_blob/azure_blob.cpp:57
← previousnext →101–200 of 3,108, ranked by callers