MCPcopy Create free account

hub / github.com/Rivendile/Muri / functions

Functions770 in github.com/Rivendile/Muri

↓ 1 callersMethodRegisterTrainer
(self, request: RegisterTrainerRequest, context)
cluster_exp/runtime/rpc/scheduler_server.py:22
↓ 1 callersMethodRegisterWorker
(self, request: RegisterWorkerRequest, context)
cluster_exp/runtime/rpc/master_server.py:22
↓ 1 callersMethodReportIterTime
(self, request: ReportIterTimeRequest, context)
cluster_exp/runtime/rpc/scheduler_server.py:32
↓ 1 callersMethod__init__
(self)
cluster_exp/workloads/models/deep_rl/network/network_utils.py:16
↓ 1 callersMethod__init__
(self, config)
cluster_exp/workloads/models/deep_rl/agent/DQN_agent.py:15
↓ 1 callersMethod__init__
(self, config)
cluster_exp/workloads/models/deep_rl/agent/QuantileRegressionDQN_agent.py:15
↓ 1 callersMethod__init__
(self, config)
cluster_exp/workloads/models/deep_rl/agent/BaseAgent.py:17
↓ 1 callersMethod__init__
(self, config)
cluster_exp/workloads/models/deep_rl/agent/CategoricalDQN_agent.py:16
↓ 1 callersMethod_propagate
(self, idx, change)
cluster_exp/workloads/models/deep_rl/utils/sum_tree.py:16
↓ 1 callersMethod_retrieve
(self, idx, s)
cluster_exp/workloads/models/deep_rl/utils/sum_tree.py:23
↓ 1 callersMethod_rolling_window
(self, a, window)
cluster_exp/workloads/models/deep_rl/utils/plot.py:23
↓ 1 callersMethod_transition
(self)
cluster_exp/workloads/models/deep_rl/agent/BaseAgent.py:165
↓ 1 callersMethod_window_func
(self, x, y, window, func)
cluster_exp/workloads/models/deep_rl/utils/plot.py:28
↓ 1 callersMethodadd
(self, p, data)
cluster_exp/workloads/models/deep_rl/utils/sum_tree.py:39
↓ 1 callersMethodadd_blossom
(self, u, lca, v)
cluster_exp/matching.py:312
↓ 1 callersMethodadd_blossom
(self, u, lca, v)
simulator/matching.py:370
↓ 1 callersMethodadd_cpus
(self, num_cpu=0)
cluster_exp/node.py:110
↓ 1 callersMethodadd_cpus
(self, num_cpu=0)
simulator/node.py:108
↓ 1 callersMethodadd_gpu_job
only used in sim-gpu-demands
cluster_exp/jobs.py:636
↓ 1 callersMethodadd_gpu_job
only used in sim-gpu-demands
simulator/jobs.py:644
↓ 1 callersMethodadd_gpus
(self, num_gpu=0)
cluster_exp/node.py:51
↓ 1 callersMethodadd_gpus
(self, num_gpu=0)
simulator/node.py:49
↓ 1 callersMethodadd_job
(self, rjob)
cluster_exp/matching.py:44
↓ 1 callersMethodadd_job
(self, rpacking)
simulator/matching.py:51
↓ 1 callersMethodadd_nodes
(self, num_node=0, num_gpu_p_node=0, num_cpu_p_node=0, mem_p_node=0)
cluster_exp/switch.py:28
↓ 1 callersMethodadd_nodes
(self, num_node=0, num_gpu_p_node=0, num_cpu_p_node=0, mem_p_node=0)
simulator/switch.py:28
↓ 1 callersMethodalloc_gpus
If enough free gpus, allocate gpus Return: True, for success; False, for failure
cluster_exp/node.py:71
↓ 1 callersMethodalloc_gpus
If enough free gpus, allocate gpus Return: True, for success; False, for failure
simulator/node.py:69
↓ 1 callersMethodantman_alloc_res
antman allocates res from a single switch for resource-guarantee job: for opportunistic job: if no enough gpus, give
cluster_exp/switch.py:522
↓ 1 callersMethodantman_alloc_res
antman allocates res from a single switch for resource-guarantee job: for opportunistic job: if no enough gpus, give
simulator/switch.py:504
↓ 1 callersFunctionantman_calc_iter_time
calculate 1 iter time of job, whose priority is 1 ignore synchronization among different gpu and return the maximum time of each gpu
simulator/run_sim.py:1602
↓ 1 callersFunctionantman_find_collocate_job
return the collocate job with job job is an opportunistic job
simulator/run_sim.py:1572
↓ 1 callersMethodantman_placement
(self, job)
cluster_exp/cluster.py:444
↓ 1 callersMethodantman_placement
(self, job)
simulator/cluster.py:442
↓ 1 callersFunctionantman_sim_jobs
simulate antman with the following assumptions: 1. at most two jobs are packed 2. the memory is enough 3. resource guarantee job will
simulator/run_sim.py:1637
↓ 1 callersMethodblossom_one_round
(self, gpu_packing, ordering=1)
cluster_exp/matching.py:514
↓ 1 callersMethodblossom_one_round
(self, gpu_packing, ordering=1)
simulator/matching.py:572
↓ 1 callersFunctioncal_r_gittins_index
a means attained-service to that job gittins_index = P/E r_gi = E/P
cluster_exp/run.py:1641
↓ 1 callersFunctioncal_r_gittins_index
a means attained-service to that job gittins_index = P/E r_gi = E/P
simulator/run_sim.py:2151
↓ 1 callersMethodcalc_packing_finished_info
(self, rjob, tmp_time, last_check_time)
cluster_exp/jobs.py:844
↓ 1 callersMethodcalc_used_ratio
(self, packing, ordering=1)
cluster_exp/matching.py:161
↓ 1 callersMethodcalc_used_ratio
(self, packing, ordering=1)
simulator/matching.py:177
↓ 1 callersMethodcheck_tasks
(self)
cluster_exp/worker.py:53
↓ 1 callersMethodcheckpoint_gpu_demands
1-GPU, 2-GPU, 4-GPU, 8-GPU, 12-GPU, 16-GPU, 24-GPU, 32-GPU
cluster_exp/log.py:285
↓ 1 callersMethodcheckpoint_gpu_demands
1-GPU, 2-GPU, 4-GPU, 8-GPU, 12-GPU, 16-GPU, 24-GPU, 32-GPU
simulator/log.py:359
↓ 1 callersMethodclose
(self)
cluster_exp/workloads/models/deep_rl/component/replay.py:277
↓ 1 callersMethodcompute_q
(self, prediction)
cluster_exp/workloads/models/deep_rl/agent/DQN_agent.py:20
↓ 1 callersMethodconsolidate_random_placement
consolidate first, but randomly pick machines; if cross machines, still try to consolidate. if can't consolidate, consider sp
cluster_exp/cluster.py:599
↓ 1 callersMethodconsolidate_random_placement
consolidate first, but randomly pick machines; if cross machines, still try to consolidate. if can't consolidate, consider sp
simulator/cluster.py:597
↓ 1 callersMethodcreate_multi_nodes_placement_same_switch
(self, job, switch_id, node_list)
cluster_exp/jobs.py:417
↓ 1 callersMethodcreate_multi_nodes_placement_same_switch
(self, job, switch_id, node_list)
simulator/jobs.py:425
↓ 1 callersMethoddelete_gpu_job
(self, job)
cluster_exp/jobs.py:645
↓ 1 callersMethoddelete_gpu_job
(self, job)
simulator/jobs.py:653
↓ 1 callersFunctiondlas_sim_jobs
Job's executed time -- priority queue Q0:[0, 30min) Q1:[30min,1h) Q2:[1h, 2h) Q3:[2h, 00) in each queue, jobs are scheduled
cluster_exp/run.py:547
↓ 1 callersFunctiondlas_sim_jobs
Job's executed time -- priority queue Q0:[0, 30min) Q1:[30min,1h) Q2:[1h, 2h) Q3:[2h, 00) in each queue, jobs are scheduled
simulator/run_sim.py:369
↓ 1 callersFunctiondraw_all
(x:list)
cluster_exp/draw.py:75
↓ 1 callersMethodeval_episode
(self)
cluster_exp/workloads/models/deep_rl/agent/BaseAgent.py:39
↓ 1 callersMethodeval_episodes
(self)
cluster_exp/workloads/models/deep_rl/agent/BaseAgent.py:50
↓ 1 callersMethodeval_step
(self, state)
cluster_exp/workloads/models/deep_rl/agent/BaseAgent.py:36
↓ 1 callersMethodexit_command
(self)
cluster_exp/runtime/rpc/master_client.py:60
↓ 1 callersMethodexpand_blossom
(self, b)
cluster_exp/matching.py:389
↓ 1 callersMethodexpand_blossom
(self, b)
simulator/matching.py:447
↓ 1 callersMethodfind_gpu_util
find gpus whose gpu util < gpu_util_upper
cluster_exp/switch.py:501
↓ 1 callersMethodfind_gpu_util
find gpus whose gpu util < gpu_util_upper
simulator/switch.py:483
↓ 1 callersMethodgandiva_checkpoint
(self, event_time, idle_node, busy_gpu, frag_gpu, pending_job, running_job, len_g1, len_g2, len_g4, len_g8, le
cluster_exp/log.py:156
↓ 1 callersMethodgandiva_checkpoint
(self, event_time, idle_node, busy_gpu, frag_gpu, pending_job, running_job, len_g1, len_g2, len_g4, len_g8, le
simulator/log.py:149
↓ 1 callersMethodgandiva_node_set_expand
ns_num_gpu: num_gpu of job in this node_set node_list: node_set list to expend to num_ns: # of node_set to expend
cluster_exp/cluster.py:259
↓ 1 callersMethodgandiva_node_set_expand
ns_num_gpu: num_gpu of job in this node_set node_list: node_set list to expend to num_ns: # of node_set to expend
simulator/cluster.py:258
↓ 1 callersMethodgandiva_node_set_shrink
ns_num_gpu: num_gpu of job in this node_set node_list: node_set list to expend to num_ns: # of node_set to expend wh
cluster_exp/cluster.py:224
↓ 1 callersMethodgandiva_node_set_shrink
ns_num_gpu: num_gpu of job in this node_set node_list: node_set list to expend to num_ns: # of node_set to expend wh
simulator/cluster.py:223
↓ 1 callersMethodgandiva_placement
gandiva: nodes are put into class(1-GPU, 2-GPU, 4-GPU)
cluster_exp/cluster.py:156
↓ 1 callersMethodgandiva_placement
gandiva: nodes are put into class(1-GPU, 2-GPU, 4-GPU)
simulator/cluster.py:155
↓ 1 callersFunctionget_base_constraints
(x, scale_factors_array)
simulator/run_sim.py:1816
↓ 1 callersFunctionget_data
(id)
cluster_exp/workloads/main_real_util.py:66
↓ 1 callersFunctionget_data
(id)
cluster_exp/workloads/main_real_preenv.py:64
↓ 1 callersMethodget_gpu_demands
(self)
cluster_exp/jobs.py:85
↓ 1 callersMethodget_gpu_demands
(self)
simulator/jobs.py:83
↓ 1 callersFunctionget_host_ip
get the host ip elegantly https://www.chenyudong.com/archives/python-get-local-ip-graceful.html
cluster_exp/utils.py:28
↓ 1 callersMethodget_idle_port
(self)
cluster_exp/task.py:26
↓ 1 callersFunctionget_isolated_throughputs
(jobs)
simulator/run_sim.py:1805
↓ 1 callersMethodget_job_model
(self, job_dict)
cluster_exp/jobs.py:128
↓ 1 callersMethodget_job_model
(self, job_dict)
simulator/jobs.py:128
↓ 1 callersMethodget_lca
(self, u, v)
cluster_exp/matching.py:298
↓ 1 callersMethodget_lca
(self, u, v)
simulator/matching.py:356
↓ 1 callersFunctionget_logger
(tag='default', log_level=0)
cluster_exp/workloads/models/deep_rl/utils/logger.py:17
↓ 1 callersFunctionget_model
get model tensor information by model_name return a dict{name, tensors(list)}
cluster_exp/models.py:29
↓ 1 callersFunctionget_model
get model tensor information by model_name return a dict{name, tensors(list)}
simulator/models.py:29
↓ 1 callersMethodget_network_load
(self, job_dict)
cluster_exp/jobs.py:136
↓ 1 callersMethodget_network_load
(self, job_dict)
simulator/jobs.py:136
↓ 1 callersFunctionget_sargs
()
cluster_exp/workloads/main_real_util.py:27
↓ 1 callersFunctionget_sargs
()
cluster_exp/workloads/main_real_preenv.py:25
↓ 1 callersMethodget_time
(self)
cluster_exp/controller.py:31
↓ 1 callersMethodget_util
(self, secs=20)
cluster_exp/controller.py:58
↓ 1 callersMethodgreedy_placement
greedy placement:
cluster_exp/cluster.py:853
↓ 1 callersMethodgreedy_placement
greedy placement:
simulator/cluster.py:851
↓ 1 callersFunctionhuber
(x, k=1.0)
cluster_exp/workloads/models/deep_rl/utils/torch_utils.py:47
↓ 1 callersMethodinit_dlas_pack_gpu
(self)
cluster_exp/cluster.py:107
↓ 1 callersMethodinit_dlas_pack_gpu
(self)
simulator/cluster.py:106
↓ 1 callersMethodinit_infra
Init and create cluster infration entities (switches, nodes) by using class _Switch, _Node
cluster_exp/cluster.py:75
↓ 1 callersMethodinit_infra
Init and create cluster infration entities (switches, nodes) by using class _Switch, _Node
simulator/cluster.py:75
← previousnext →201–300 of 770, ranked by callers