Functions — github.com/ai-dynamo/nixl

CodeHub MCPcopy Create free account

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

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

⨍ Functions 3,108◇ Types & classes 683↳ Endpoints 1

↓ 2 callersFunctioncreate_verbs_ah_attr

src/plugins/gpunetio/gpunetio_utils.cpp:137

↓ 2 callersFunctioncudaQueryAddr

src/plugins/libfabric/libfabric_backend.cpp:108

↓ 2 callersFunctionderegisterIterationMem

Deregister local and remote memory from the agent.

benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:1365

↓ 2 callersMethodderegisterMemory

src/utils/libfabric/libfabric_rail_manager.cpp:840

↓ 2 callersMethoddisconnect

src/plugins/ucx/ucx_backend.cpp:887

↓ 2 callersMethoddisconnect_ranks

examples/device/ep/csrc/nixl_ep.cpp:521

↓ 2 callersMethoddispatch

examples/device/ep/csrc/nixl_ep.cpp:1030

↓ 2 callersFunctiondoRoundtrip

One register/WRITE/READ/verify/deregister cycle; baseline non-null asserts net-zero fd delta.

test/unit/plugins/path_mode_common.h:53

↓ 2 callersFunctiondocaTimestamp

src/plugins/telemetry/doca/doca_exporter.cpp:59

↓ 2 callersFunctionendsWith

src/core/nixl_plugin_manager.cpp:463

↓ 2 callersMethodepAddr

src/plugins/ucx/ucx_utils.cpp:515

↓ 2 callersMethodestimateXferCost

src/core/nixl_agent.cpp:969

↓ 2 callersMethodexchangeIOV

benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:1205

↓ 2 callersFunctionexchange_target_metadata

Exchange metadata from target to initiator

examples/python/partial_md_example.py:30

↓ 2 callersFunctionexecTransfer

No thread support for NVSHMEM yet

benchmark/nixlbench/src/worker/nvshmem/nvshmem_worker.cpp:128

↓ 2 callersFunctionexecTransfer

benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:1668

↓ 2 callersFunctionexecute_transfer

( my_agent, local_descs, remote_descs, remote_name, operation, use_backends=[] )

examples/python/remote_storage_example/nixl_p2p_storage_example.py:31

↓ 2 callersFunctionexecute_transfer_iterations

test/unit/plugins/hf3fs/nixl_hf3fs_mt_test.cpp:152

↓ 2 callersFunctionextractPluginName

src/core/nixl_plugin_manager.cpp:468

↓ 2 callersFunctionextractTransferParams

src/plugins/gds_mt/gds_mt_backend.cpp:146

↓ 2 callersFunctionfillRegList

test/gtest/error_handling.cpp:57

↓ 2 callersFunctionfillRegList

test/gtest/plugins/uccl/uccl_test.cpp:51

↓ 2 callersMethodfillRegList

test/gtest/error_handling.cpp:188

↓ 2 callersMethodfillRegList

test/gtest/plugins/uccl/uccl_test.cpp:179

↓ 2 callersFunctionfill_test_pattern

Helper function to fill buffer with repeating pattern * @brief Fill buffer with a repeating test pattern * @param buffer Pointer to the buffer to fil

test/unit/plugins/object/nixl_object_test.cpp:165

↓ 2 callersMethodfindByContext

src/utils/libfabric/libfabric_rail.cpp:92

↓ 2 callersFunctionformat_throughput

Helper function to format throughput in MiB/s

test/unit/plugins/infinia/infinia_nixl_test.cpp:383

↓ 2 callersMethodgenNotif

Generates a standalone notification, not bound to a transfer.

src/api/cpp/backend/backend_engine.h:222

↓ 2 callersFunctiongenerate_timestamped_filename

Helper function to generate timestamped filename

test/unit/plugins/posix/nixl_posix_test.cpp:138

↓ 2 callersMethodgetBackendMems

src/core/nixl_plugin_manager.cpp:569

↓ 2 callersMethodgetBackendPlugin

src/core/nixl_plugin_manager.cpp:539

↓ 2 callersMethodgetBackends

src/core/nixl_agent.cpp:1710

↓ 2 callersMethodgetBufLen

src/utils/serdes/serdes.cpp:92

↓ 2 callersMethodgetConfig

Get red_config_t for accessing resources

src/plugins/infinia/infinia_client.h:62

↓ 2 callersMethodgetDeviceNumaNode

src/utils/libfabric/libfabric_topology.cpp:204

↓ 2 callersMethodgetEfaDevicesForPci

src/utils/libfabric/libfabric_topology.cpp:156

↓ 2 callersFunctiongetMaxNumaNode

src/utils/libfabric/libfabric_common.cpp:140

↓ 2 callersFunctiongetNextSeqId

src/utils/libfabric/libfabric_common.cpp:199

↓ 2 callersMethodgetNumAwsAccel

System information

src/utils/libfabric/libfabric_topology.h:204

↓ 2 callersFunctiongetNumThreads

src/plugins/azure_blob/azure_blob_backend.cpp:35

↓ 2 callersMethodgetRailInfo

src/utils/libfabric/libfabric_rail.cpp:1542

↓ 2 callersFunctiongetRemoteSegType

benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:1326

↓ 2 callersMethodgetSupportedMems

src/plugins/ucx/ucx_backend.cpp:847

↓ 2 callersFunctiongetTensorFromVA

benchmark/nixlbench/src/utils/neuron.cpp:129

↓ 2 callersMethodgetTopology

src/utils/libfabric/libfabric_rail_manager.h:329

↓ 2 callersFunctiongetUseVirtualAddressing

src/utils/object/s3/utils.cpp:48

↓ 2 callersFunctiongetValidationPtr

test/unit/plugins/mooncake/mooncake_backend_test.cpp:254

↓ 2 callersFunctiongetValidationPtr

test/unit/plugins/ucx/ucx_backend_test.cpp:242

↓ 2 callersMethodget_backend

Gets a backend by name

src/bindings/rust/src/agent.rs:246

↓ 2 callersMethodget_backend_params

Gets the parameters and memory types for a backend after initialization

src/bindings/rust/src/agent.rs:255

↓ 2 callersMethodget_dispatch_layout

examples/device/ep/csrc/nixl_ep.cpp:551

↓ 2 callersFunctionget_gusli_backend_options

src/plugins/gusli/gusli_plugin.cpp:24

↓ 2 callersMethodget_local_metadata

examples/device/ep/csrc/nixl_ep.cpp:1303

↓ 2 callersMethodget_local_partial_md

Gets the local partial metadata as a byte array # Arguments `descs` - Registration descriptor list to get metadata for `opt_args` - Optional argument

src/bindings/rust/src/agent.rs:410

↓ 2 callersFunctionget_mooncake_options

src/plugins/mooncake/mooncake_plugin.cpp:22

↓ 2 callersMethodget_notifications_size

Returns the number of notifications for a given agent

src/bindings/rust/src/notify.rs:72

↓ 2 callersMethodget_plugin_mem_types

(self, backend: str)

src/api/python/_api.py:311

↓ 2 callersMethodget_rank

examples/device/ep/tests/elastic/rank_server.py:125

↓ 2 callersMethodget_rkey

src/plugins/gpunetio/verbs/verbs.h:156

↓ 2 callersMethodget_submitted_requests_count

src/plugins/libfabric/libfabric_backend.cpp:270

↓ 2 callersMethodget_type

Returns the memory type of the transfer descriptor list

src/bindings/rust/src/descriptors/xfer.rs:106

↓ 2 callersMethodget_type

src/bindings/rust/src/descriptors/reg.rs:112

↓ 2 callersFunctionget_uccl_options

src/plugins/uccl/uccl_plugin.cpp:23

↓ 2 callersFunctionget_ucx_backend_common_options

src/plugins/ucx/ucx_utils.cpp:34

↓ 2 callersMethodget_xfer_telemetry

( self, handle: nixl_xfer_handle )

src/api/python/_api.py:667

↓ 2 callersFunctiongetenvDefaulted

src/utils/common/configuration.cpp:102

↓ 2 callersFunctionhexdump

src/utils/libfabric/libfabric_common.cpp:115

↓ 2 callersMethodht_combine

examples/device/ep/csrc/nixl_ep.cpp:900

↓ 2 callersFunctionhttpGet

Minimal HTTP/1.1 GET over 127.0.0.1:<port>. Returns response body (empty string on any failure). Keeps the test free of a curl dependency.

test/gtest/telemetry_prometheus_test.cpp:47

↓ 2 callersMethodindex

(&self, index: usize)

src/bindings/rust/src/descriptors/reg.rs:290

↓ 2 callersMethodinit

src/utils/libfabric/libfabric_rail_manager.cpp:239

↓ 2 callersFunctioninitAWSSDK

* Initialize the AWS SDK in a thread-safe manner. * This function uses std::call_once to ensure that Aws::InitAPI is called * exactly once, even in

src/utils/object/s3/aws_sdk_init.h:35

↓ 2 callersFunctioninitMem

test/nixl/nixl_test.cpp:51

↓ 2 callersMethodinitialize

src/utils/libfabric/libfabric_rail.cpp:217

↓ 2 callersFunctionisAcceleratedRequested

src/utils/object/engine_utils.h:26

↓ 2 callersFunctionisEfaDevice

src/utils/common/hw_info.cpp:47

↓ 2 callersMethodis_completed

src/plugins/libfabric/libfabric_backend.cpp:281

↓ 2 callersMethodis_success

src/bindings/rust/src/agent.rs:46

↓ 2 callersMethodkv_cache_size

KV cache size in bytes

benchmark/kvbench/test/inference_workload_matgen.py:146

↓ 2 callersFunctionlarge_gemm_with_hook

examples/device/ep/tests/elastic/elastic.py:381

↓ 2 callersMethodlen

Returns the number of strings in the list

src/bindings/rust/src/utils/string_list.rs:29

↓ 2 callersFunctionload_matrix

Load traffic pattern matrix from file

benchmark/kvbench/main.py:50

↓ 2 callersMethodmake_connection

(&self, remote_agent: &str, opt_args: Option<&OptArgs>)

src/bindings/rust/src/agent.rs:484

↓ 2 callersMethodmake_xfer_req

(&self, operation: XferOp, local_descs: &XferDlistHandle, local_indices: &[i32],

src/bindings/rust/src/agent.rs:529

↓ 2 callersMethodmax

benchmark/nixlbench/src/utils/utils.cpp:1574

↓ 2 callersMethodmemDereg

src/plugins/ucx/ucx_utils.cpp:602

↓ 2 callersMethodmemReg

src/plugins/ucx/ucx_utils.cpp:547

↓ 2 callersFunctionmetricValue

Value on the first non-comment exposition line that starts with `metric`. Exposition format is: name{labels} VALUE [TIMESTAMP] (or name VALUE [TS]).

test/doca-telemetry/scrape_util.h:48

↓ 2 callersFunctionmock_fabric_create

Helper: build a mock fid_fabric using the stubs above

test/unit/utils/libfabric/libfabric_mock_stubs.h:265

↓ 2 callersFunctionnixl_capi_notif_map_get_agent_at

src/bindings/rust/stubs.cpp:839

↓ 2 callersFunctionnixl_capi_notif_map_get_notif

src/bindings/rust/stubs.cpp:855

↓ 2 callersFunctionnixl_capi_notif_map_get_notifs_size

src/bindings/rust/stubs.cpp:846

↓ 2 callersFunctionnormalizeSecDesc

* @brief Normalize a section descriptor for file-like segments. * * For BLK_SEG, OBJ_SEG, and FILE_SEG, a zero-length registration is stored * inte

src/infra/mem_section.h:131

↓ 2 callersFunctionnrt_tensor_write

benchmark/nixlbench/src/utils/neuron.cpp:96

↓ 2 callersFunctionoob_connection_client_setup

src/plugins/gpunetio/gpunetio_utils.cpp:50

↓ 2 callersFunctionopenFileWithFlags

Helper to open a single file with appropriate flags

benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:674

↓ 2 callersMethodpackRkey

src/plugins/ucx/ucx_utils.cpp:587

↓ 2 callersFunctionparseConnectionString

Parse connection string in format: ip_addr:port?gpu_index

src/plugins/uccl/uccl_backend.cpp:31

↓ 2 callersFunctionparseGusliDeviceList

Implement GUSLI device parser (declared in utils.h) so it can be reused by both utils and worker

benchmark/nixlbench/src/utils/utils.cpp:894

↓ 2 callersFunctionparsePrometheusSampleLine

test/gtest/telemetry_prometheus_test.cpp:96

← previous next →501–600 of 3,108, ranked by callers