reduce ram use
This commit is contained in:
parent
a99f206e7a
commit
5dd45b6b53
@ -2,9 +2,9 @@ import csv
|
|||||||
import os
|
import os
|
||||||
envvars:
|
envvars:
|
||||||
"BENCHDIR"
|
"BENCHDIR"
|
||||||
def_flags="--release --no-default-features --features std,snapshot_fast,restarting,do_hash_notify_state,do_hash_notify_value,fuzz_int,trace_job_response_times,observe_systemstate_unordered"
|
def_flags="--release --no-default-features --features std,snapshot_fast,restarting,do_hash_notify_state,fuzz_int,trace_job_response_times,observe_systemstate_unordered"
|
||||||
benchdir=os.environ["BENCHDIR"]
|
benchdir=os.environ["BENCHDIR"]
|
||||||
RUNTIME=int(os.environ["RUNTIME"]) if "RUNTIME" in os.environ else (3600*24)
|
RUNTIME=int(os.environ["RUNTIME"]) if "RUNTIME" in os.environ else (3600*8)
|
||||||
TARGET_SET=['feedgeneration100', 'stgwoet', 'frafl']
|
TARGET_SET=['feedgeneration100', 'stgwoet', 'frafl']
|
||||||
TARGET_REPLICA_NUMBER=int(os.environ["TARGET_REPLICA_NUMBER"]) if "TARGET_REPLICA_NUMBER" in os.environ else 10
|
TARGET_REPLICA_NUMBER=int(os.environ["TARGET_REPLICA_NUMBER"]) if "TARGET_REPLICA_NUMBER" in os.environ else 10
|
||||||
RANDOM_REPLICA_NUMBER=int(os.environ["RANDOM_REPLICA_NUMBER"]) if "RANDOM_REPLICA_NUMBER" in os.environ else 1
|
RANDOM_REPLICA_NUMBER=int(os.environ["RANDOM_REPLICA_NUMBER"]) if "RANDOM_REPLICA_NUMBER" in os.environ else 1
|
||||||
@ -95,7 +95,7 @@ rule build_stg_abbpath:
|
|||||||
output:
|
output:
|
||||||
directory("{benchdir}/bins/target_stg_abbpath")
|
directory("{benchdir}/bins/target_stg_abbpath")
|
||||||
shell:
|
shell:
|
||||||
"cp -r -a --reflink=auto {input} {output} && cargo build --target-dir {output} {def_flags},config_stg_abbpath"
|
"cp -r -a --reflink=auto {input} {output} && cargo build --target-dir {output} {def_flags},config_stg_abbpath,feed_job_wort,feed_job_woet,feed_stg_abb_woet"
|
||||||
|
|
||||||
rule build_stg_edge:
|
rule build_stg_edge:
|
||||||
input:
|
input:
|
||||||
@ -263,7 +263,8 @@ rule quicktest:
|
|||||||
params:
|
params:
|
||||||
benchdir=benchdir
|
benchdir=benchdir
|
||||||
input:
|
input:
|
||||||
expand("{benchdir}/timedump/{fuzzer}/{target}{variant}#{num}.time", benchdir=benchdir, fuzzer=['feedgeneration100', 'stg', 'random'], target=['polycopter'], variant=['_seq_dataflow_full'], num=range(0,int( 1 ))),
|
expand("{benchdir}/timedump/{fuzzer}/{target}{variant}#{num}.time", benchdir=benchdir, fuzzer=['feedgeneration100', 'stgwoet'], target=['watersgen1'], variant=['_par_bytes'], num=range(1,int( 9 ))),
|
||||||
|
expand("{benchdir}/timedump/{fuzzer}/{target}{variant}#{num}.time", benchdir=benchdir, fuzzer=['random'], target=['watersgen1'], variant=['_par_bytes'], num=range(0,int( 0 ))),
|
||||||
|
|
||||||
rule eval_bytes:
|
rule eval_bytes:
|
||||||
params:
|
params:
|
||||||
@ -325,4 +326,4 @@ rule plot_benchmarks:
|
|||||||
|
|
||||||
rule plot_traces:
|
rule plot_traces:
|
||||||
shell:
|
shell:
|
||||||
"bash scripts/plot_all_traces.sh {benchdir}"
|
"bash scripts/plot_all_traces.sh {benchdir}"
|
||||||
|
@ -176,7 +176,7 @@ pub(super) fn refine_system_states(
|
|||||||
#[cfg(feature = "observe_systemstate_unordered")]
|
#[cfg(feature = "observe_systemstate_unordered")]
|
||||||
{
|
{
|
||||||
// respect the order of the first ``lookahead`` tasks and sort the rest by hash value
|
// respect the order of the first ``lookahead`` tasks and sort the rest by hash value
|
||||||
const LOOKAHEAD : usize = 2;
|
const LOOKAHEAD : usize = 1;
|
||||||
collector.get_mut(LOOKAHEAD..).map(|slice| slice.sort_by(|a, b| { a.cmp(&*b) }));
|
collector.get_mut(LOOKAHEAD..).map(|slice| slice.sort_by(|a, b| { a.cmp(&*b) }));
|
||||||
}
|
}
|
||||||
// collect delay list
|
// collect delay list
|
||||||
|
Loading…
x
Reference in New Issue
Block a user