MCPcopy Create free account

hub / github.com/QDelta/Phantora / functions

Functions1,051 in github.com/QDelta/Phantora

⨍ Functions 1,051◇ Types & classes 193
↓ 75 callersMethodallocate
(&mut self, info: &TensorInfo)
phantora/phantora/src/torch_estimate.rs:70
↓ 63 callersMethodpush
(&mut self, fs: FlowStateRef)
phantora/netsim/src/simulator.rs:624
↓ 40 callersMethodcache
(&mut self, t: Tensor)
phantora/phantora/src/torch_estimate.rs:92
↓ 35 callersMethodwrite
(&mut self, rec: &Record)
phantora/phantora/src/timeline.rs:38
↓ 30 callersMethodlen
(&self)
phantora/netsim/src/simulator.rs:1165
↓ 27 callersMethoditer
(&self)
phantora/netsim/src/simulator.rs:669
↓ 24 callersMethodis_empty
(&self)
phantora/netsim/src/simulator.rs:644
↓ 21 callersMethodinto_iter
(self)
phantora/netsim/src/simulator.rs:1198
↓ 16 callersMethodgbps
(self)
phantora/netsim/src/bandwidth.rs:62
↓ 16 callersMethodval
(&self)
phantora/netsim/src/bandwidth.rs:44
↓ 15 callersMethodappend
(&mut self, mut e: Events)
phantora/netsim/src/simulator.rs:1181
↓ 13 callersMethodadd_action_or_point
( &mut self, depends_on: Vec<Option<EventId>>, action: Option<Action>, mut cur
phantora/phantora/src/event_queue.rs:382
↓ 13 callersMethodsize
(&self)
phantora/cuda_call/src/lib.rs:43
↓ 12 callersFunctionsend_cuda_call
(call: CudaCall)
phantora/cuda_call/src/capi.rs:213
↓ 11 callersMethodadd_node
(&mut self, node: Node)
phantora/netsim/src/cluster.rs:153
↓ 10 callersMethodlast
(&self)
phantora/netsim/src/simulator.rs:1173
↓ 9 callersMethodadd_link_by_name
(&mut self, parent: &str, child: &str, bw: Bandwidth)
phantora/netsim/src/cluster.rs:168
↓ 9 callersMethodalloc_torch_tensor
(&mut self, py: Python, shape: &[i32], dtype: &PyObject)
phantora/phantora/src/cuda_estimate.rs:272
↓ 9 callersMethodallocate_list
(&mut self, info: &[TensorInfo])
phantora/phantora/src/torch_estimate.rs:88
↓ 9 callersFunctionmaybe_tensor_list
(value: &[TorchValue])
phantora/phantora/src/torch_call.rs:163
↓ 9 callersMethodpop
(&mut self)
phantora/netsim/src/simulator.rs:1189
↓ 8 callersMethodcall
(&mut self, call: CudaCall)
phantora/cuda_call/src/capi.rs:805
↓ 8 callersFunctioncurrent_cpu_time_us
()
phantora/cuda_call/src/capi.rs:48
↓ 8 callersFunctionget_comm_id
(comm_id: *const ffi::c_char)
phantora/cuda_call/src/capi.rs:731
↓ 8 callersMethodpush_event
(&mut self, event: PushEvent, time: i64)
phantora/phantora/src/event_queue.rs:139
↓ 8 callersMethodretain
(&mut self, f: F)
phantora/netsim/src/simulator.rs:652
↓ 8 callersFunctionsend_cuda_call_get_response
(call: CudaCall)
phantora/cuda_call/src/capi.rs:221
↓ 8 callersFunctiontime_pair
()
tests/phantora_utils.py:34
↓ 7 callersFunction_get_current_device
stub/cudart.c:41
↓ 7 callersMethodby_arbitrary_topo
(&self)
phantora/netsim/src/architecture.rs:51
↓ 7 callersMethodindex
(&self, index: NodeIx)
phantora/netsim/src/cluster.rs:189
↓ 7 callersMethoditer_mut
(&mut self)
phantora/netsim/src/simulator.rs:685
↓ 6 callersFunctionenum_to_nccl_datatype
(dtype: i32)
phantora/cuda_call/src/capi.rs:70
↓ 6 callersFunctionget_current_sim_time
()
phantora/cuda_call/src/capi.rs:104
↓ 6 callersFunctionget_phantora_metadata_process_group
Return the cached Gloo process group for Phantora metadata messages.
tests/phantora_utils.py:15
↓ 6 callersFunctionsend_response_to
(host: &ResponseId, resp: Vec<u8>)
phantora/phantora/src/simulator.rs:37
↓ 5 callersMethodadd_record
(&mut self, rec: TraceRecord)
phantora/netsim/src/lib.rs:91
↓ 5 callersFunctionget_args
()
phantora/phantora/src/args.rs:45
↓ 5 callersMethodget_node_index
(&self, name: &str)
phantora/netsim/src/cluster.rs:334
↓ 5 callersMethodget_reverse_link
(&self, ix: LinkIx)
phantora/netsim/src/cluster.rs:361
↓ 5 callersMethodget_uplink
(&self, ix: NodeIx)
phantora/netsim/src/cluster.rs:350
↓ 5 callersFunctionhandle_sync_response
(resp: Vec<u8>)
phantora/cuda_call/src/capi.rs:233
↓ 5 callersFunctionsend_query_response_to
Reply to a non-blocking poll. The wire payload is `Option<i64>`: `Some(completion_time)` when the event has completed (recorded as a sync point), or `
phantora/phantora/src/simulator.rs:111
↓ 4 callersFunctionadd_activity_duration
phantora/phantora/src/cupti_shim.c:37
↓ 4 callersMethodadd_dependency
(&mut self, id: EventId, dep: Option<EventId>)
phantora/phantora/src/event_queue.rs:438
↓ 4 callersMethodadd_layer
(&mut self, layer: Layer)
phantora/netsim/tests/alltoall.rs:17
↓ 4 callersMethodcompleted
(&self)
phantora/netsim/src/simulator.rs:1088
↓ 4 callersFunctiondisable_function_tracer
()
tests/phantora_utils.py:645
↓ 4 callersFunctionenable_function_tracer
()
tests/phantora_utils.py:640
↓ 4 callersMethodhash
(&self, state: &mut H)
phantora/netsim/src/lib.rs:146
↓ 4 callersFunctionignore_cpu_time
()
phantora/cuda_call/src/capi.rs:97
↓ 4 callersFunctionround_multiple
(x: i32, m: i32)
phantora/phantora/src/cuda_estimate.rs:66
↓ 4 callersFunctionsend_sync_response_to
( host_times: &mut HashMap<HostId, HostTime>, host: ResponseId, end_time: i64, event: Option<E
phantora/phantora/src/simulator.rs:95
↓ 4 callersFunctionupdate_host_curr
(host_times: &mut HashMap<HostId, HostTime>, host: HostId, curr: i64)
phantora/phantora/src/simulator.rs:85
↓ 3 callersFunction_get_device_memory
stub/cudart.c:47
↓ 3 callersMethodall_links
(&self)
phantora/netsim/src/cluster.rs:365
↓ 3 callersMethodanswer
(&mut self)
phantora/netsim/src/app.rs:64
↓ 3 callersMethoddecode
(&self)
phantora/netsim/src/app.rs:195
↓ 3 callersMethodemit_flow
(&mut self, fs: FlowStateRef)
phantora/netsim/src/simulator.rs:898
↓ 3 callersFunctionenabled
Read the env var once and cache. Default is **on** — CUPTI gives GPU activity time. Set `PHANTORA_USE_CUPTI=0` (or `false`) to fall back to `cudaEvent
phantora/phantora/src/cupti.rs:25
↓ 3 callersMethodend_event
(&mut self, id: EventId, start_time: i64, end_time: i64)
phantora/phantora/src/event_queue.rs:265
↓ 3 callersMethodexecute_to_event
(&mut self, until: EventId)
phantora/phantora/src/simulator.rs:406
↓ 3 callersMethodforward
(&mut self, app_id: usize, ts: Timestamp, app_event_kind: AppEventKind)
phantora/netsim/src/app.rs:323
↓ 3 callersFunctioninit
Initialise CUPTI activity tracking. No-ops when CUPTI is disabled. Call once at simulator startup after the first CUDA call.
phantora/phantora/src/cupti.rs:35
↓ 3 callersMethodis_host
(&self)
phantora/netsim/src/cluster.rs:526
↓ 3 callersMethodlog
(&mut self, prefix: &str, val: T, suffix: &str)
phantora/visualizer/src/main.rs:50
↓ 3 callersFunctionnccl_comm_init_rank
( nranks: i32, comm_id: *const ffi::c_char, rank: i32, device: i32, )
phantora/cuda_call/src/capi.rs:860
↓ 3 callersMethodon_event
(&mut self, event: Event)
phantora/netsim/src/simulator.rs:501
↓ 3 callersMethodquery
(&self, id: &EventId)
phantora/phantora/src/event_queue.rs:561
↓ 3 callersMethodrecord_timeline_span
(&mut self, id: EventId, start_time: i64, end_time: i64)
phantora/phantora/src/event_queue.rs:126
↓ 3 callersFunctionrecv_from_simulator
()
phantora/cuda_call/src/capi.rs:201
↓ 3 callersMethodremove_none_dependency
(&mut self, id: EventId)
phantora/phantora/src/event_queue.rs:455
↓ 3 callersMethodresolve_route
Tenants' are segregated, so there must be no flow between two different tenants. There two some special cases that should be noted. When psrc == pdst
phantora/netsim/src/cluster.rs:378
↓ 3 callersFunctionsubtract_cpu_time
(us: ffi::c_long)
phantora/cuda_call/src/capi.rs:128
↓ 3 callersFunctionupdate_host_sync
( host_times: &mut HashMap<HostId, HostTime>, host: HostId, curr: i64, event: Option<EventId>,
phantora/phantora/src/simulator.rs:66
↓ 2 callersFunction_get_device_count
stub/cudart.c:26
↓ 2 callersFunction_positive_norm
(norm)
tests/phantora_utils.py:118
↓ 2 callersFunction_round_up
(x, m)
tests/phantora_utils.py:276
↓ 2 callersMethodbuild
(&mut self)
phantora/netsim/src/simulator.rs:141
↓ 2 callersFunctionbuild_arbitrary_cluster
( nracks: usize, rack_size: usize, host_bw: Bandwidth, rack_bw: Bandwidth, )
phantora/netsim/src/architecture.rs:199
↓ 2 callersFunctioncuda_event_record
(device: i32, stream: i32, id: i32)
phantora/cuda_call/src/capi.rs:393
↓ 2 callersFunctionenum_to_nccl_reduce_op
(op: i32)
phantora/cuda_call/src/capi.rs:86
↓ 2 callersMethodexecute
(&mut self)
phantora/phantora/src/event_queue.rs:319
↓ 2 callersMethodextract_call
( &self, stream: CudaStream, // kernel_name: String, // grid_dim: Dim3,
phantora/cuda_call/src/capi.rs:690
↓ 2 callersMethodfully_connect
(&mut self, layer1: Layer, layer2: Layer, bw: Bandwidth)
phantora/netsim/tests/alltoall.rs:23
↓ 2 callersFunctionget_args
()
phantora/visualizer/src/main.rs:30
↓ 2 callersFunctionget_model
( tensor_parallel_size, pipeline_model_parallel_size, virtual_pipeline_model_parallel_size, vp
tests/test_megatron.py:89
↓ 2 callersMethodget_target
(&self, ix: LinkIx)
phantora/netsim/src/cluster.rs:342
↓ 2 callersFunctionget_train_data_iterator
(vocab_size, micro_batch_size, sequence_length)
tests/test_megatron.py:218
↓ 2 callersFunctionincr_nccl_id
(id: &mut [u8; 128])
phantora/phantora/src/simulator.rs:240
↓ 2 callersMethodis_loopback
(&self)
phantora/netsim/src/simulator.rs:1094
↓ 2 callersMethodis_tor
(&self)
phantora/netsim/src/cluster.rs:531
↓ 2 callersFunctioniter_model_chunks
(model)
tests/test_megatron.py:214
↓ 2 callersFunctionmask_new_host
(host: &HostId)
phantora/phantora/src/simulator.rs:31
↓ 2 callersMethodmatch_or_enqueue_p2p_endpoint
( &mut self, kind: P2PCallKind, key: P2PKey, endpoint: P2PFlowEndpoint, )
phantora/phantora/src/simulator.rs:1316
↓ 2 callersMethodmax_min_fairness
(&mut self, until: Option<Timestamp>)
phantora/netsim/src/simulator.rs:377
↓ 2 callersMethodmin_ts
(&self)
phantora/visualizer/src/main.rs:159
↓ 2 callersFunctionncclCommInitRank
stub/nccl.c:34
↓ 2 callersFunctionnccl_get_unique_id
(id: *mut ffi::c_char)
phantora/cuda_call/src/capi.rs:723
↓ 2 callersFunctionnccl_group_end
()
phantora/cuda_call/src/capi.rs:855
next →1–100 of 1,051, ranked by callers