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

↓ 7 callersMethodsetKeyOutcome

test/gtest/unit/obj/obj_test_base.h:80

↓ 7 callersMethodsupportsRemote

src/core/agent_data.h:157

↓ 7 callersFunctiontest_inter_agent_transfer

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

↓ 7 callersMethodunloadBackendPlugin

src/core/nixl_plugin_manager.cpp:511

↓ 6 callersMethod_run_tp

(self, handles: list[NixlHandle], blocking=False)

benchmark/kvbench/test/custom_traffic_perftest.py:262

↓ 6 callersMethodbarrier

Synchronization barrier for processes

benchmark/kvbench/runtime/rt_base.py:43

↓ 6 callersMethodbarrier

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

↓ 6 callersMethodcreateXferReq

src/core/nixl_agent.cpp:831

↓ 6 callersMethoddisconnect

test/gtest/mocks/mock_backend_engine.cpp:47

↓ 6 callersFunctionfill_test_pattern

Helper function to fill buffer with repeating pattern

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

↓ 6 callersMethodgenNotif

test/gtest/mocks/mock_backend_engine.cpp:121

↓ 6 callersMethodgetTotalNicCount

* @brief Retrieves the total number of NICs, as correlated from hwloc. This differs from * all_devices array which gathers info from fi_getinfo.

src/utils/libfabric/libfabric_topology.h:309

↓ 6 callersFunctiongetValueWithStatus

src/utils/common/configuration.h:76

↓ 6 callersMethodgetWorkerId

src/plugins/ucx/ucx_backend.cpp:1034

↓ 6 callersMethodgetXferTelemetry

src/core/nixl_agent.cpp:1158

↓ 6 callersFunctionget_page_size

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

↓ 6 callersMethodget_qp

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

↓ 6 callersFunctionisTesting

we need to differentiate normal execution from test scenario this is done via env var

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

↓ 6 callersMethodlen

Returns the number of descriptors in the list

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

↓ 6 callersMethodloadRemoteConnInfo

test/gtest/mocks/mock_backend_engine.cpp:93

↓ 6 callersMethodprepare_xfer_dlist

( &self, agent_name: &str, descs: &XferDescList, opt_args: Option<&OptArgs>,

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

↓ 6 callersMethodremove_remote_agent

(self, agent: str)

src/api/python/_api.py:843

↓ 6 callersMethodset_model_config

Set the model configuration for this architecture. Args: model_config (ModelConfig): The configuration to apply to this

benchmark/kvbench/models/models.py:47

↓ 6 callersMethodsupportsNotif

src/core/agent_data.h:167

↓ 6 callersFunctiontest_inter_agent_transfer

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

↓ 6 callersMethodtrim

Trims the list to the given size

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

↓ 6 callersMethodupdateTxBytes

The next 4 methods might be removed, as addXferTime covers them.

src/core/telemetry/telemetry.cpp:249

↓ 5 callersMethodadd_remote_agent

(self, metadata: bytes)

src/api/python/_api.py:831

↓ 5 callersMethodcheckRemoteMD

src/core/nixl_agent.cpp:1683

↓ 5 callersMethodcheck_remote_xfer_done

( self, remote_agent_name: str, lookup_tag: bytes, backends: list[str] = [],

src/api/python/_api.py:749

↓ 5 callersMethodcreateExporter

src/core/nixl_plugin_manager.cpp:142

↓ 5 callersMethodcurrent_stream_wait

examples/device/ep/csrc/event.hpp:45

↓ 5 callersMethoddecRailActive

src/utils/libfabric/libfabric_rail_manager.cpp:1235

↓ 5 callersMethodderegisterMemory

src/utils/libfabric/libfabric_rail.cpp:1416

↓ 5 callersMethoddestroy

test/gtest/error_handling.cpp:180

↓ 5 callersMethoddestroy

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

↓ 5 callersMethodexecAsync

test/gtest/unit/azure_blob/azure_blob.cpp:131

↓ 5 callersMethodfill

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

↓ 5 callersFunctionformat_duration

Helper function to format duration * @brief Format duration in microseconds to a human-readable string * @param us Duration in microseconds * @retur

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

↓ 5 callersFunctiongetCrtMinLimit

src/utils/object/engine_utils.h:21

↓ 5 callersFunctiongetPcieAddressFromHwlocObj

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

↓ 5 callersMethodgetPendingCount

test/gtest/unit/azure_blob/azure_blob.cpp:140

↓ 5 callersMethodgetPendingCount

test/gtest/unit/obj/obj_test_base.h:226

↓ 5 callersMethodget_agent_metadata

src/api/python/_api.py:798

↓ 5 callersMethodget_notifications

Gets notifications from other agents # Arguments `notifs` - Notification map to populate with notifications `opt_args` - Optional arguments to filter

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

↓ 5 callersMethodget_qp_gpu_dev

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

↓ 5 callersMethodget_rank

Get the rank of the current process

benchmark/kvbench/runtime/rt_base.py:35

↓ 5 callersMethodget_world_size

Get the total number of processes

benchmark/kvbench/runtime/rt_base.py:39

↓ 5 callersMethodget_xfer_status

Checks the status of a transfer request Returns `Ok(true)` if the transfer is still in progress, `Ok(false)` if it completed successfully. # Argumen

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

↓ 5 callersFunctionhasAnyAgentMetricSample

test/gtest/telemetry_prometheus_test.cpp:179

↓ 5 callersFunctionint_to_bytes

benchmark/kvbench/runtime/etcd_rt.py:32

↓ 5 callersMethodis_empty

Returns true if the memory list is empty

src/bindings/rust/src/lib.rs:406

↓ 5 callersMethodlen

Returns the number of descriptors in the list

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

↓ 5 callersMethodmakeConnection

src/core/nixl_agent.cpp:520

↓ 5 callersFunctionneuronCoreCount

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

↓ 5 callersMethodoverlaps

src/infra/nixl_descriptors.cpp:65

↓ 5 callersMethodpopulate

src/infra/nixl_memory_section.cpp:55

↓ 5 callersMethodpost_xfer_req

Posts a transfer request to initiate a transfer After this, the transfer state can be checked asynchronously until completion. For small transfers th

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

↓ 5 callersMethodprint

Prints the list contents

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

↓ 5 callersMethodptr

examples/device/ep/csrc/vmm.hpp:39

↓ 5 callersMethodqueryBackends

src/infra/nixl_memory_section.cpp:39

↓ 5 callersFunctionqueryFileInfoList

src/utils/file/file_utils.cpp:48

↓ 5 callersMethodqueryXferBackend

src/core/nixl_agent.cpp:1175

↓ 5 callersMethodreleaseMemView

src/core/nixl_agent.cpp:1835

↓ 5 callersMethodsend_notif

( self, remote_agent_name: str, notif_msg: bytes, backend: Optional[str] = None )

src/api/python/_api.py:784

↓ 5 callersMethodsetKeyDelay

test/gtest/unit/azure_blob/azure_blob.cpp:62

↓ 5 callersMethodsetKeyDelay

test/gtest/unit/obj/obj_test_base.h:85

↓ 5 callersMethodstatus

src/plugins/ucx/ucx_backend.cpp:470

↓ 5 callersMethodsupportsLocal

test/gtest/mocks/mock_backend_engine.h:39

↓ 5 callersFunctiontelemetryEventTypeStr

src/core/telemetry/telemetry_event.h:61

↓ 5 callersMethodtest

src/plugins/ucx/ucx_utils.cpp:675

↓ 5 callersFunctiontrim

Helper function to trim whitespace from string_view (C++20)

src/plugins/infinia/infinia_backend.cpp:59

↓ 5 callersMethodunloadMD

test/gtest/mocks/mock_backend_engine.cpp:53

↓ 5 callersFunctionwaitForMetricsBody

test/gtest/telemetry_prometheus_test.cpp:82

↓ 4 callersMethodConfig

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

↓ 4 callersFunctionSplitWithDelimiter

test/gtest/main.cpp:28

↓ 4 callersMethod_tensor_mem_type

(tensor: torch.Tensor)

src/api/python/_api.py:937

↓ 4 callersMethod_wait

(self, handles: list[NixlHandle])

benchmark/kvbench/test/custom_traffic_perftest.py:276

↓ 4 callersMethodaddPluginDirectory

src/core/nixl_plugin_manager.cpp:324

↓ 4 callersMethodadd_desc

Adds a descriptor to the list

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

↓ 4 callersFunctionallocateAndRegister

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

↓ 4 callersFunctionallocateAndRegister

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

↓ 4 callersMethodavg

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

↓ 4 callersMethodbarrier

Barrier for a group of ranks using etcd barrier

benchmark/kvbench/runtime/etcd_rt.py:99

↓ 4 callersFunctioncalc_diff

(x: torch.Tensor, y: torch.Tensor)

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

↓ 4 callersFunctioncheck_buf

test/nixl/agent_example.cpp:28

↓ 4 callersFunctioncompleteRequest

test/unit/plugins/ucx/ucx_worker_test.cpp:48

↓ 4 callersFunctionconnect_verbs_qp

src/plugins/gpunetio/gpunetio_utils.cpp:183

↓ 4 callersFunctiondeallocateAndDeregister

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

↓ 4 callersFunctiondeallocateAndDeregister

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

↓ 4 callersMethoddefaults

Get the default benchmark parameters. This static method provides the default values for all benchmark parameters when not e

benchmark/kvbench/commands/nixlbench.py:363

↓ 4 callersMethoddeserialize_descs

(self, serialized_descs: bytes)

src/api/python/_api.py:1123

↓ 4 callersMethoddevice_id

src/bindings/rust/src/lib.rs:551

↓ 4 callersFunctiondoMemset

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

↓ 4 callersFunctiondoMemset

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

↓ 4 callersMethodeq

(&self, other: &Self)

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

↓ 4 callersMethodfetch_remote_metadata

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

src/api/python/_api.py:896

↓ 4 callersFunctionfill_test_pattern

Helper function to fill buffer with repeating pattern

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

↓ 4 callersFunctionfill_test_pattern

Helper function to fill buffer with repeating pattern

test/unit/plugins/gds_mt/nixl_gds_mt_test.cpp:147

↓ 4 callersFunctionfill_test_pattern

Helper function to fill buffer with repeating pattern

test/unit/plugins/cuda_gds/nixl_gds_test.cpp:130

← previous next →201–300 of 3,108, ranked by callers