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

↓ 3 callersFunctionget_lib_deps

Get the dependencies of a library, as a map from library name to path. Example: ldd nixl.libs/ucx/libuct_cma.so linux-vdso.so.1

contrib/wheel_add_ucx_plugins.py:120

↓ 3 callersMethodget_mut

Safe mutable access to descriptor by index

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

↓ 3 callersMethodget_rdma_buffer_size_hint

examples/device/ep/csrc/config.hpp:89

↓ 3 callersMethodinit

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

↓ 3 callersFunctioninit_agent

test/python/prep_xfer_perf.py:29

↓ 3 callersFunctioninplace_unique

(x: torch.Tensor, num_slots: int)

examples/device/ep/tests/utils.py:91

↓ 3 callersMethodinvalidateRemoteData

src/core/nixl_listener.cpp:794

↓ 3 callersFunctioniovListToNixlXferDlist

Convert vector of xferBenchIOV to nixl_xfer_dlist_t

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

↓ 3 callersMethodisTarget

benchmark/nixlbench/src/worker/worker.cpp:191

↓ 3 callersMethodlap

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

↓ 3 callersMethodlen

Returns the number of agents that have notifications

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

↓ 3 callersMethodlen

Returns the number of responses in the list

src/bindings/rust/src/descriptors/query.rs:48

↓ 3 callersMethodlen

src/bindings/rust/tests/tests.rs:95

↓ 3 callersMethodloadLocalMD

test/gtest/mocks/mock_backend_engine.cpp:109

↓ 3 callersMethodloadTelemetryPlugin

src/core/nixl_plugin_manager.cpp:422

↓ 3 callersMethodmake_prepped_xfer

( self, operation: str, local_xfer_side: nixl_prepped_dlist_handle, local_indi

src/api/python/_api.py:552

↓ 3 callersFunctionmemType2Str

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

↓ 3 callersFunctionmemType2Str

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

↓ 3 callersMethodnixlAgent

nixlAgent implementation ***/

src/core/nixl_agent.cpp:158

↓ 3 callersMethodnixlAgentConfig

* @brief Default constructor. */

src/api/cpp/nixl_params.h:74

↓ 3 callersFunctionnixl_capi_invalidate_remote_md

src/bindings/rust/stubs.cpp:174

↓ 3 callersFunctionop2string

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

↓ 3 callersFunctionop2string

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

↓ 3 callersFunctionoverride_yaml_args

(model_config: ModelConfig, args: argparse.Namespace)

benchmark/kvbench/models/utils.py:43

↓ 3 callersMethodp99

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

↓ 3 callersFunctionperformTransfer

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

↓ 3 callersMethodpopulateBlobDesc

test/gtest/plugins/memory_handler.h:103

↓ 3 callersMethodpostXferReq

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

↓ 3 callersMethodprogressLoop

src/plugins/ucx/ucx_backend.cpp:1356

↓ 3 callersMethodquery_mask_buffer

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

↓ 3 callersFunctionreadSysfsUlong

src/utils/common/hw_info.cpp:53

↓ 3 callersMethodrelease

src/api/python/_api.py:94

↓ 3 callersMethodreleaseRequest

src/utils/libfabric/libfabric_rail.cpp:1506

↓ 3 callersMethodrelease_rank

Release a rank (decrement the global counter by 1)

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

↓ 3 callersMethodreqRelease

src/plugins/ucx/ucx_utils.cpp:684

↓ 3 callersMethodrun

Execute the performance test. Args: verify_buffers: Whether to verify buffer contents after transfer print_recv_buffe

benchmark/kvbench/test/custom_traffic_perftest.py:348

↓ 3 callersMethodsend_local_metadata

(self, ip_addr: str = "", port: int = DEFAULT_COMM_PORT)

src/api/python/_api.py:855

↓ 3 callersFunctionserializeSections

src/infra/nixl_memory_section.cpp:255

↓ 3 callersMethodsetHeader

@brief Set header fields */

src/utils/libfabric/libfabric_common.h:156

↓ 3 callersFunctionsetup_agent_with_backend

(agent: &Agent)

src/bindings/rust/tests/tests.rs:34

↓ 3 callersMethodsignaled

benchmark/nixlbench/src/worker/worker.h:44

↓ 3 callersMethodsupportsRemote

test/gtest/mocks/mock_backend_engine.h:34

↓ 3 callersFunctiontoStream

src/plugins/ucx/ucx_enums.h:94

↓ 3 callersMethodto_dict

Convert the Qwen3 model configuration to a dictionary. Returns: Dict[str, Any]: A dictionary containing all model config

benchmark/kvbench/models/qwen3.py:110

↓ 3 callersMethodtotal_src_size

Return the sum of the sizes received by <rank>

benchmark/kvbench/test/traffic_pattern.py:84

↓ 3 callersFunctionucx_err_mode_to_string

src/plugins/ucx/ucx_utils.cpp:43

↓ 3 callersMethodupdateErrorCount

src/core/telemetry/telemetry.cpp:269

↓ 3 callersMethodupdateRequestStats

src/core/nixl_agent.cpp:66

↓ 3 callersMethodupdateRxBytes

src/core/telemetry/telemetry.cpp:254

↓ 3 callersMethodverify

test/unit/plugins/gusli/nixl_gusli_test.cpp:88

↓ 3 callersFunctionwarnIgnoreToml

src/utils/common/configuration.cpp:129

↓ 2 callersMethodSetToParams

test/gtest/mocks/gmock_engine.cpp:62

↓ 2 callersFunction__wrap_numa_distance

test/unit/utils/libfabric/libfabric_topology_test.cpp:528

↓ 2 callersMethod_check_tp_config

(self, tp: TrafficPattern)

benchmark/kvbench/test/custom_traffic_perftest.py:308

↓ 2 callersMethod_destroy

(self, handles: list[NixlHandle])

benchmark/kvbench/test/custom_traffic_perftest.py:290

↓ 2 callersMethod_fetch_remote_metadata_from_tcp_store

(self, remote_ranks: List[int])

examples/device/ep/nixl_ep/buffer.py:797

↓ 2 callersMethod_get_tp_total_size

Return total size of matrix in bytes

benchmark/kvbench/test/custom_traffic_perftest.py:344

↓ 2 callersMethod_load_plugin_params

(self, plugin: str)

src/api/python/_api.py:291

↓ 2 callersMethod_params

Collect all benchmark parameters into a dictionary. Returns: dict: Dictionary containing all benchmark parameters.

benchmark/kvbench/commands/nixlbench.py:305

↓ 2 callersMethod_share_md

Share agent metadata between all ranks. (Need to be run after registering buffers)

benchmark/kvbench/test/custom_traffic_perftest.py:154

↓ 2 callersMethod_verify_tp

( self, tp: TrafficPattern, recv_bufs: list[Optional[NixlBuffer]], print_recv_

benchmark/kvbench/test/custom_traffic_perftest.py:315

↓ 2 callersMethodaddElement

src/infra/nixl_memory_section.cpp:108

↓ 2 callersMethodaddXferTime

src/core/telemetry/telemetry.cpp:287

↓ 2 callersMethodadd_desc

Adds a descriptor to the list

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

↓ 2 callersFunctionadd_plugins

Adds the plugins from @sys_dir to the wheel. The plugins are copied to a subdirectory @install_dir relative to the wheel's nixl.libs. The

contrib/wheel_add_ucx_plugins.py:183

↓ 2 callersMethodadd_transfer

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

↓ 2 callersMethodadjust_total_submitted_requests

src/plugins/libfabric/libfabric_backend.cpp:275

↓ 2 callersFunctionalign_up_uint32

src/plugins/gpunetio/verbs/verbs.cpp:29

↓ 2 callersFunctionallocDram

test/unit/plugins/path_mode_common.h:35

↓ 2 callersMethodallocate

src/utils/libfabric/libfabric_rail.cpp:302

↓ 2 callersFunctionallocateBuffer

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

↓ 2 callersMethodallocateDataRequest

src/utils/libfabric/libfabric_rail.cpp:1501

↓ 2 callersFunctionappendAll

src/infra/nixl_descriptors.cpp:368

↓ 2 callersMethodbarrier

benchmark/nixlbench/src/worker/worker.cpp:66

↓ 2 callersMethodbarrier

benchmark/nixlbench/src/runtime/etcd/etcd_rt.cpp:471

↓ 2 callersFunctionbench

(fn, num_warmups: int = 50, num_tests: int = 50, post_fn=None)

examples/device/ep/tests/utils.py:116

↓ 2 callersFunctionbuild_stubs

(cc_builder: &mut cc::Build)

src/bindings/rust/build.rs:208

↓ 2 callersMethodcancelBatch

src/plugins/cuda_gds/gds_utils.cpp:144

↓ 2 callersFunctioncenter_str

test/unit/plugins/hf3fs/nixl_hf3fs_test.cpp:58

↓ 2 callersFunctioncenter_str

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

↓ 2 callersMethodclean_meta

examples/device/ep/csrc/config.hpp:130

↓ 2 callersFunctionclearTesting

test/unit/utils/libfabric/libfabric_topology_test.cpp:476

↓ 2 callersFunctionclear_buffer

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

↓ 2 callersFunctionconErrConv

src/plugins/gusli/gusli_backend.cpp:42

↓ 2 callersFunctionconfigureClientCommon

src/utils/object/s3/utils.h:72

↓ 2 callersMethodconfigure_buffer_size

benchmark/kvbench/commands/nixlbench.py:292

↓ 2 callersMethodconfigure_scheme

Configure the scheme based on the model configuration. For ISL (input)

benchmark/kvbench/commands/nixlbench.py:271

↓ 2 callersMethodconfigure_segment_type

(self, backend: str, source: str, destination: str)

benchmark/kvbench/commands/nixlbench.py:257

↓ 2 callersMethodconnect

test/gtest/mocks/mock_backend_engine.cpp:41

↓ 2 callersMethodconnect

src/plugins/ucx/ucx_utils.cpp:531

↓ 2 callersMethodconnect_ranks

Add connections to remote ranks. Arguments: remote_ranks: List of remote rank IDs to establish connections with.

examples/device/ep/nixl_ep/buffer.py:840

↓ 2 callersFunctioncopyVramToHost

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

↓ 2 callersFunctioncountOpenFds

test/unit/plugins/path_mode_common.h:26

↓ 2 callersFunctioncreateAWSCredentials

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

↓ 2 callersFunctioncreateAccelEngine

src/plugins/obj/obj_backend.cpp:42

↓ 2 callersFunctioncreateElements

src/plugins/ucx/mem_list.cpp:139

↓ 2 callersFunctioncreateMemList

src/plugins/ucx/mem_list.cpp:149

↓ 2 callersFunctioncreateObjEngineImpl

src/plugins/obj/obj_backend.cpp:56

↓ 2 callersFunctioncreate_builder

src/bindings/rust/build.rs:239

↓ 2 callersFunctioncreate_posix_backend

Helper function to create and initialize a POSIX backend with optional arguments Returns (backend, opt_args) if POSIX is available, or None if not ava

src/bindings/rust/tests/tests.rs:155

← previous next →401–500 of 3,108, ranked by callers