MCPcopy Create free account

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

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

↓ 382 callersMethodsize
(&self)
src/bindings/rust/src/lib.rs:537
↓ 328 callersMethodaddDesc
src/infra/nixl_descriptors.cpp:193
↓ 283 callersMethodsize
Get the number of events in the buffer
examples/python/telemetry_reader.py:166
↓ 267 callersMethodend
src/api/cpp/nixl_descriptors.h:349
↓ 240 callersMethodempty
Check if buffer is empty
examples/python/telemetry_reader.py:176
↓ 226 callersFunctionnixl_exit_on_failure
src/infra/test_utils.cpp:22
↓ 164 callersMethodget
src/plugins/ucx/rkey.h:36
↓ 139 callersMethoddescCount
* @brief Get count of descriptors */
src/api/cpp/nixl_descriptors.h:318
↓ 128 callersMethodhas_value
Returns true if this response contains parameters
src/bindings/rust/src/descriptors/query.rs:90
↓ 124 callersMethodregisterMem
test/gtest/mocks/mock_backend_engine.cpp:27
↓ 122 callersMethoddata
Provides read-only access to the frontend data (no sync)
src/bindings/rust/src/descriptors/sync_manager.rs:39
↓ 115 callersMethodas_ptr
(&self)
src/bindings/rust/src/descriptors/xfer.rs:101
↓ 114 callersMethodgetType
TODO? engine->getType() returns a const nixl_backend_t&
src/core/agent_data.h:152
↓ 111 callersMethodbegin
* @brief Vector like iterators for const and non-const elements */
src/api/cpp/nixl_descriptors.h:344
↓ 109 callersMethodderegisterMem
test/gtest/mocks/mock_backend_engine.cpp:35
↓ 95 callersFunctionresolve
Resolve a symbol from the nixl C API shared library. Aborts if the library is not loaded or the symbol is not found.
src/bindings/rust/stubs.cpp:58
↓ 88 callersMethodappend
src/plugins/ucx/ucx_backend.cpp:89
↓ 67 callersMethodtrim
src/infra/nixl_descriptors.cpp:211
↓ 66 callersMethodclear
Clears all descriptors from the list
src/bindings/rust/src/descriptors/reg.rs:176
↓ 65 callersMethodreleaseXferReq
src/core/nixl_agent.cpp:1183
↓ 59 callersMethoderror
benchmark/nixlbench/src/runtime/etcd/etcd_rt.h:61
↓ 59 callersFunctiongetUs
src/utils/common/nixl_time.h:35
↓ 55 callersMethodsize
benchmark/nixlbench/src/worker/nixl/nixl_worker.cpp:393
↓ 54 callersMethodjoin
src/plugins/ucx/ucx_backend.cpp:218
↓ 50 callersFunctionstatusStr
src/core/nixl_enum_strings.cpp:52
↓ 44 callersMethodcreateBackend
src/core/nixl_agent.cpp:279
↓ 43 callersMethodgetXferStatus
src/core/nixl_agent.cpp:1121
↓ 40 callersMethodadd_desc
(&mut self, addr: usize, len: usize, dev_id: u64)
src/bindings/rust/tests/tests.rs:91
↓ 40 callersMethodload
src/utils/libfabric/libfabric_rail_manager.cpp:1308
↓ 40 callersMethodresize
src/infra/nixl_descriptors.cpp:205
↓ 38 callersMethodwrite
src/plugins/ucx/ucx_utils.cpp:284
↓ 37 callersMethodreserve
src/plugins/ucx/ucx_backend.cpp:83
↓ 36 callersMethodqueryMem
src/core/nixl_agent.cpp:390
↓ 35 callersMethodaddVar
test/gtest/common.cpp:45
↓ 35 callersFunctiongetBackendParamDefaulted
src/utils/common/backend.h:48
↓ 33 callersMethodpostXferReq
test/gtest/error_handling.cpp:215
↓ 31 callersMethodcheckRemoteMD
test/gtest/test_transfer.cpp:202
↓ 30 callersMethodgetIgnoredCount
test/gtest/common.cpp:159
↓ 30 callersFunctionthrow_nixl_exception
src/bindings/python/nixl_bindings.cpp:93
↓ 29 callersMethodprepXfer
test/gtest/mocks/mock_backend_engine.cpp:59
↓ 29 callersMethodreset
src/plugins/cuda_gds/gds_utils.cpp:192
↓ 29 callersFunctiontestSimpleSuccess
test/gtest/configuration.cpp:68
↓ 28 callersMethodcreateXferReq
test/gtest/error_handling.cpp:204
↓ 28 callersMethodprint
test/unit/plugins/gusli/nixl_gusli_test.cpp:81
↓ 27 callersMethodtestTransfer
test/gtest/plugins/transfer_handler.h:76
↓ 26 callersFunctioncreate_agent_with_backend
(name: &str)
src/bindings/rust/tests/tests.rs:65
↓ 26 callersMethodloadRemoteMD
test/gtest/error_handling.cpp:199
↓ 26 callersFunctionprint_segment_title
test/unit/plugins/hf3fs/nixl_hf3fs_test.cpp:129
↓ 25 callersMethodcheckXfer
test/gtest/mocks/mock_backend_engine.cpp:81
↓ 25 callersMethodcreate_backend
Creates a new backend for the given plugin using the provided parameters
src/bindings/rust/src/agent.rs:203
↓ 24 callersMethodpop
Pop an event from the buffer
examples/python/telemetry_reader.py:186
↓ 23 callersMethodgetNumRails
Get total number of rails */
src/utils/libfabric/libfabric_rail_manager.h:130
↓ 23 callersMethodget_xfer_descs
( self, descs, mem_type: Optional[str] = None, )
src/api/python/_api.py:954
↓ 23 callersFunctionphase_title
test/unit/plugins/hf3fs/nixl_hf3fs_test.cpp:124
↓ 23 callersMethodrelease
src/plugins/ucx/ucx_backend.cpp:117
↓ 22 callersMethodaddDescs
src/infra/nixl_descriptors.cpp:420
↓ 22 callersMethodclear
test/unit/plugins/gusli/nixl_gusli_test.cpp:71
↓ 22 callersFunctioncreate_storage_list
(agent: &Agent, opt_args: &OptArgs, size: usize)
src/bindings/rust/tests/tests.rs:114
↓ 22 callersMethodget_plugin_params
Gets the parameters for a plugin # Arguments `plugin_name` - The name of the plugin # Returns The plugin's memory list and parameters # Errors Retu
src/bindings/rust/src/agent.rs:169
↓ 22 callersMethoditer
Returns an iterator over the memory types
src/bindings/rust/src/lib.rs:448
↓ 21 callersMethodcreateBackendWithGMock
test/gtest/unit/agent/agent.cpp:96
↓ 21 callersMethodinvalidateRemoteMD
src/core/nixl_agent.cpp:1539
↓ 21 callersMethodpopVar
test/gtest/common.cpp:50
↓ 21 callersFunctionprint_segment_title
test/unit/plugins/posix/nixl_posix_test.cpp:169
↓ 21 callersMethodto_string
src/utils/common/uuid_v4.cpp:33
↓ 20 callersMethodclear
benchmark/nixlbench/src/utils/utils.cpp:1625
↓ 20 callersMethodclone
Creates a new Params object by copying from another Params # Example ```ignore let original_params = agent.get_plugin_params("OBJ")?.1; let mut modif
src/bindings/rust/src/utils/params.rs:169
↓ 19 callersMethodaddStr
Strings serialization
src/utils/serdes/serdes.cpp:36
↓ 19 callersMethodas_ptr
(&self)
src/bindings/rust/src/lib.rs:541
↓ 19 callersMethodderegisterMem
src/core/nixl_agent.cpp:469
↓ 19 callersMethodgetPluginParams
src/core/nixl_agent.cpp:209
↓ 19 callersMethodreleaseReqH
test/gtest/mocks/mock_backend_engine.cpp:87
↓ 19 callersMethodsendLocalPartialMD
src/core/nixl_agent.cpp:1601
↓ 18 callersMethodaddErrorTelemetry
src/core/agent_data.h:129
↓ 18 callersFunctioncreate_dlist
(storage_list: &'a mut Vec<SystemStorage>)
src/bindings/rust/tests/tests.rs:126
↓ 18 callersMethodgetIndex
src/infra/nixl_descriptors.cpp:230
↓ 18 callersMethodgetNotifs
test/gtest/mocks/mock_backend_engine.cpp:115
↓ 18 callersMethodprepXferDlist
src/core/nixl_agent.cpp:573
↓ 17 callersMethoddata_mut
Provides mutable access to the frontend data
src/bindings/rust/src/descriptors/sync_manager.rs:33
↓ 17 callersMethodgetActiveRailCount
src/utils/libfabric/libfabric_rail_manager.cpp:1265
↓ 17 callersFunctionget_logger
(name: str)
src/api/python/logging.py:115
↓ 17 callersMethodget_reg_descs
( self, descs, mem_type: Optional[str] = None, )
src/api/python/_api.py:1037
↓ 17 callersMethodhandle
(&self)
src/bindings/rust/src/xfer.rs:56
↓ 17 callersMethodregisterMem
src/core/nixl_agent.cpp:403
↓ 16 callersMethodbackend
Provides read-only access to the backend after ensuring synchronization
src/bindings/rust/src/descriptors/sync_manager.rs:44
↓ 16 callersFunctionphase_title
test/unit/plugins/posix/nixl_posix_test.cpp:165
↓ 16 callersMethodread
src/plugins/ucx/ucx_utils.cpp:258
↓ 16 callersMethodregister_memory
Registers a memory descriptor with the agent # Arguments `descriptor` - The memory descriptor to register `opt_args` - Optional arguments for the reg
src/bindings/rust/src/agent.rs:291
↓ 16 callersMethodreleasedDlistH
src/core/nixl_agent.cpp:1212
↓ 16 callersMethodsetLocalMem
test/gtest/plugins/transfer_handler.h:82
↓ 15 callersMethodexception
src/plugins/posix/posix_backend.h:69
↓ 15 callersFunctionformat_duration
Helper function to format duration
test/unit/plugins/infinia/infinia_nixl_test.cpp:360
↓ 15 callersFunctionnixl_strerror
* Get the error message for the given error number. Thread-safe. * @param err: The error number. * @return: The error message. */
src/utils/common/nixl_log.h:126
↓ 15 callersMethodpostXfer
test/gtest/plugins/uccl/uccl_test.cpp:365
↓ 14 callersMethodadd_backend
Add a backend to the optional arguments
src/bindings/rust/src/lib.rs:271
↓ 14 callersMethodgetLocalMD
test/gtest/error_handling.cpp:193
↓ 14 callersMethodremove
Removes a variable for the lifetime of the guard.
src/bindings/rust/tests/env_guard/mod.rs:74
↓ 13 callersFunctionformat_data_size
Helper function to format data size in MiB Always uses MiB for consistency (1 MiB = 1024 * 1024 bytes)
test/unit/plugins/infinia/infinia_nixl_test.cpp:374
↓ 13 callersMethodgetLocalPartialMD
src/core/nixl_agent.cpp:1382
↓ 13 callersMethodgetStr
src/utils/serdes/serdes.cpp:48
next →1–100 of 3,108, ranked by callers