MCPcopy Create free account

hub / github.com/QDelta/Phantora / functions

Functions1,051 in github.com/QDelta/Phantora

⨍ Functions 1,051◇ Types & classes 193
↓ 1 callersMethodnccl_comm_init_rank
( &mut self, host: ResponseId, curr_time: i64, device: i32, rank: i32,
phantora/phantora/src/simulator.rs:858
↓ 1 callersFunctionnccl_comm_split
( rank: i32, comm_id: *const ffi::c_char, color: i32, key: i32, rank_out: *mut i32, nr
phantora/cuda_call/src/capi.rs:878
↓ 1 callersMethodnccl_comm_split
( &mut self, host: ResponseId, curr_time: i64, rank: i32, id: [u8; 128
phantora/phantora/src/simulator.rs:921
↓ 1 callersMethodnccl_get_unique_id
(&mut self, host: &ResponseId)
phantora/phantora/src/simulator.rs:852
↓ 1 callersMethodnccl_grouped_p2p
(&mut self, host: HostId, curr_time: i64, calls: Vec<CudaCall>)
phantora/phantora/src/simulator.rs:1135
↓ 1 callersFunctionnccl_recv
( count: usize, dtype: i32, peer: i32, comm_id: *const ffi::c_char, rank: i32, device:
phantora/cuda_call/src/capi.rs:1009
↓ 1 callersFunctionnccl_reduce_scatter
( count: usize, dtype: i32, op: i32, comm_id: *const ffi::c_char, rank: i32, device: i
phantora/cuda_call/src/capi.rs:965
↓ 1 callersFunctionnccl_send
( count: usize, dtype: i32, peer: i32, comm_id: *const ffi::c_char, rank: i32, device:
phantora/cuda_call/src/capi.rs:987
↓ 1 callersMethodnccl_ungrouped_recv
( &mut self, host: HostId, curr_time: i64, count: usize, dtype: NcclDa
phantora/phantora/src/simulator.rs:1085
↓ 1 callersMethodnccl_ungrouped_send
( &mut self, host: HostId, curr_time: i64, count: usize, dtype: NcclDa
phantora/phantora/src/simulator.rs:1063
↓ 1 callersMethodnext_record
(&mut self)
phantora/visualizer/src/main.rs:76
↓ 1 callersFunctionnode_socket_path
(pid: u32, tid: i32)
phantora/cuda_call/src/capi.rs:154
↓ 1 callersMethodon_event_alltoall
(&mut self, event: AppEvent)
phantora/netsim/src/background_flow.rs:50
↓ 1 callersMethodon_event_plink_probe
(&mut self, event: AppEvent)
phantora/netsim/src/background_flow.rs:151
↓ 1 callersMethodpeek_next_time
(&mut self)
phantora/phantora/src/event_queue.rs:242
↓ 1 callersFunctionphantora_cupti_clear
phantora/phantora/src/cupti_shim.c:103
↓ 1 callersFunctionphantora_cupti_flush
phantora/phantora/src/cupti_shim.c:108
↓ 1 callersFunctionphantora_cupti_init
phantora/phantora/src/cupti_shim.c:85
↓ 1 callersFunctionphantora_cupti_sum_activity_ns
phantora/phantora/src/cupti_shim.c:113
↓ 1 callersMethodpop_event
(&mut self)
phantora/phantora/src/event_queue.rs:235
↓ 1 callersMethodpop_matching_peer_endpoint
( &mut self, kind: P2PCallKind, key: &P2PKey, )
phantora/phantora/src/simulator.rs:1329
↓ 1 callersMethodproceed
(&mut self, ts_inc: Duration)
phantora/netsim/src/simulator.rs:308
↓ 1 callersFunctionread_config
(path: P)
phantora/netsim/src/config.rs:30
↓ 1 callersMethodread_timer
(&mut self, host: ResponseId, curr_time: i64, _stream: CudaStream)
phantora/phantora/src/simulator.rs:1578
↓ 1 callersFunctionreplay_memcpy
(kind: CudaMemcpyKind, size: usize)
phantora/phantora/src/cuda_estimate.rs:78
↓ 1 callersMethodrollback_to
(&mut self, sim_ts: Timestamp, past_ts: Timestamp)
phantora/netsim/src/simulator.rs:799
↓ 1 callersFunctionrun_module
Generic (non-pipeline) DeepSpeed train loop for a full HF causal LM. Used for real-model presets like gpt-oss: forward(input_ids, labels) -> loss
tests/test_deepspeed.py:168
↓ 1 callersMethodrun_one_step
(&mut self, until: Option<Timestamp>)
phantora/netsim/src/simulator.rs:495
↓ 1 callersMethodrun_with_application
(&mut self, mut app: Box<dyn Application<Output = T> + 'a>)
phantora/netsim/src/simulator.rs:543
↓ 1 callersMethodschedule_matched_p2p_flow
( &mut self, kind: P2PCallKind, endpoint: P2PFlowEndpoint, peer_endpoint: P2PF
phantora/phantora/src/simulator.rs:1364
↓ 1 callersMethodserialize
(&self, serializer: S)
phantora/cuda_call/src/lib.rs:82
↓ 1 callersMethodto_dura
(self)
phantora/netsim/src/lib.rs:68
↓ 1 callersMethodupdate_flow_start_ts
(&mut self, flow: &Flow, new_ts_ns: Timestamp)
phantora/netsim/src/simulator.rs:243
↓ 1 callersMethodwith_setting
(&mut self, setting: SimulatorSetting)
phantora/netsim/src/simulator.rs:110
Method__getitem__
(self, index)
tests/phantora_utils.py:663
Method__getitem__
(self, index)
tests/phantora_utils.py:677
Method__getitem__
(self, index)
tests/phantora_utils.py:691
Method__init__
(self, vocab_size, seq_len, size)
tests/phantora_utils.py:658
Method__init__
(self, num_labels, shape, size)
tests/phantora_utils.py:672
Method__init__
(self, seq_len, shape, size)
tests/phantora_utils.py:686
Method__init__
(self, layer: nn.Module, rotary_emb: nn.Module)
tests/test_deepspeed.py:36
Method__init__
(self, vocab_size)
tests/test_megatron.py:37
Method__len__
(self)
tests/phantora_utils.py:668
Method__len__
(self)
tests/phantora_utils.py:682
Method__len__
(self)
tests/phantora_utils.py:696
Function_balanced_token_dispatch
(self, mod, inputs, device_mesh)
tests/phantora_utils.py:320
Function_build_fatree
(nports: usize, bw: Bandwidth)
phantora/netsim/tests/alltoall.rs:32
Function_cpu_device_state
(self)
tests/phantora_utils.py:82
Function_dense_experts_forward
(self, hidden_states, router_indices=None, routing_weights=None)
tests/phantora_utils.py:628
Function_dummy
stub/cudart.c:577
Function_ge_init
(self, *a, **kw)
tests/phantora_utils.py:265
Function_init_distributed_with_cpu_group
(*args, **kwargs)
tests/phantora_utils.py:380
Function_no_sync_rng_tracker_init
(self, device_mesh, run_state_sync=True, *args, **kwargs)
tests/phantora_utils.py:79
Function_phantora_norm_new
(cls, config, *args, **kwargs)
tests/phantora_utils.py:590
Function_phantora_permute
( tokens, routing_map, probs=None, num_out_tokens=None, fused=False, drop_and_pad=Fals
tests/phantora_utils.py:498
Function_phantora_preprocess
(self, routing_map)
tests/phantora_utils.py:528
Function_recv_tensor_meta
(self, send_stage)
tests/phantora_utils.py:182
Function_send_tensor_meta
(self, buffer, recv_stage)
tests/phantora_utils.py:171
Method_shape_inference
(self, args, kwargs=None)
tests/phantora_utils.py:394
Methodadd
(self, rhs: Self)
phantora/netsim/src/bandwidth.rs:148
Methodadd
(&mut self, app: Box<dyn Application<Output = T> + 'a>)
phantora/netsim/src/app.rs:101
Methodadd
(&mut self, e: Event)
phantora/netsim/src/simulator.rs:1177
Methodadd_event
Stream add event
phantora/phantora/src/simulator.rs:333
Methodadditional_special_tokens_ids
(self)
tests/test_megatron.py:85
Methodallgather
(&mut self, ranks: &[(HostId, i32)], count: usize, dtype: NcclDatatype)
phantora/phantora/src/nccl_ops.rs:81
Methodallreduce
(&mut self, ranks: &[(HostId, i32)], count: usize, dtype: NcclDatatype)
phantora/phantora/src/nccl_ops.rs:69
Functionalltoall
()
phantora/netsim/tests/alltoall.rs:158
Methodanswer
(&mut self)
phantora/netsim/src/background_flow.rs:203
Functionbuf_completed
phantora/phantora/src/cupti_shim.c:52
Functionbuf_requested
phantora/phantora/src/cupti_shim.c:44
Functionbuild_gpt_oss
Build a (real-architecture) gpt-oss MoE causal LM from a config. gpt-oss is a real HF MoE model: its experts run *locally* per rank (no expert
tests/test_deepspeed.py:124
Methodcalc_delta
(fairness: FairnessModel, l: &Link, fs: &mut FlowSet)
phantora/netsim/src/simulator.rs:300
Methodcalc_delta_groupped
(total_bw: Bandwidth, fs: &mut FlowSet)
phantora/netsim/src/simulator.rs:288
Methodcalc_delta_per_flow
(total_bw: Bandwidth, fs: &mut FlowSet)
phantora/netsim/src/simulator.rs:257
Functioncausal_lm_loss
(logits: torch.Tensor, labels: torch.Tensor)
tests/test_deepspeed.py:57
Functionclear
()
phantora/phantora/src/cupti.rs:50
Methodclear_compute_buffer_on
( torch_estimator: &mut TorchEstimator, sinfo: &mut StreamInfo, queue: &mut EventQueue
phantora/phantora/src/simulator.rs:358
Methodcls
(self)
tests/test_megatron.py:69
Methodcmp
(&self, other: &Self)
phantora/netsim/src/bandwidth.rs:106
Methodcmp
(&self, other: &Self)
phantora/netsim/src/simulator.rs:1114
Methodcmp
(&self, other: &Self)
phantora/netsim/src/timer.rs:148
FunctioncuCtxGetCurrent
stub/cuda.c:36
FunctioncuDeviceGetAttribute
stub/cuda.c:143
FunctioncuDevicePrimaryCtxGetState
stub/cuda.c:28
FunctioncuGetErrorString
stub/cuda.c:200
FunctioncuLaunchKernel
stub/cuda.c:126
FunctioncuMemAddressFree
stub/cuda.c:94
FunctioncuMemAddressReserve
stub/cuda.c:44
FunctioncuMemCreate
stub/cuda.c:56
FunctioncuMemExportToShareableHandle
stub/cuda.c:161
FunctioncuMemGetAllocationGranularity
stub/cuda.c:151
FunctioncuMemImportFromShareableHandle
stub/cuda.c:171
FunctioncuMemMap
stub/cuda.c:66
FunctioncuMemRelease
stub/cuda.c:87
FunctioncuMemSetAccess
stub/cuda.c:77
FunctioncuMemUnmap
stub/cuda.c:101
FunctioncuMemsetD32Async
stub/cuda.c:180
FunctioncuModuleGetFunction
stub/cuda.c:117
FunctioncuModuleLoadData
stub/cuda.c:108
FunctioncuStreamWriteValue32
stub/cuda.c:190
← previousnext →201–300 of 1,051, ranked by callers