Skip to content

Commit eaac618

Browse files
committedNov 14, 2024
Added g_ prefix to global variables
1 parent cde6c2e commit eaac618

File tree

7 files changed

+101
-101
lines changed

7 files changed

+101
-101
lines changed
 

Diff for: ‎Libs/lib.sh

+4-4
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
RUST_LOG_OFF=tonic=off,h2=off,tokio_util=off,tower=off,hyper=off
1+
g_RUST_LOG_OFF=tonic=off,h2=off,tokio_util=off,tower=off,hyper=off
22

33
. ./Libs/lib_run_simulator.sh
44
. ./Libs/lib_inputs.sh
@@ -15,9 +15,9 @@ build_digitiser_argument() {
1515
}
1616

1717
kill_persistant_components() {
18-
pkill $PROCESS_EVENT_FORMATION
19-
pkill $PROCESS_WRITER
20-
pkill $PROCESS_AGGREGATOR
18+
pkill $g_PROCESS_EVENT_FORMATION
19+
pkill $g_PROCESS_WRITER
20+
pkill $g_PROCESS_AGGREGATOR
2121
pkill trace-archiver-
2222
}
2323

Diff for: ‎Libs/lib_inputs.sh

+14-14
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,16 @@
11
run_trace_simulator() {
2-
$SIMULATOR \
3-
--broker $BROKER \
4-
$OTEL_ENDPOINT \
5-
$OTEL_LEVEL_SIM \
6-
defined "$SIMULATOR_CONFIG_SOURCE" \
7-
--digitiser-trace-topic $TRACE_TOPIC \
8-
--digitiser-event-topic $DAT_EVENT_TOPIC \
9-
--frame-event-topic $FRAME_EVENT_TOPIC \
10-
--control-topic $CONTROL_TOPIC \
11-
--runlog-topic $CONTROL_TOPIC \
12-
--selog-topic $CONTROL_TOPIC \
13-
--alarm-topic $CONTROL_TOPIC
2+
$g_SIMULATOR \
3+
--broker $g_BROKER \
4+
$g_OTEL_ENDPOINT \
5+
$g_OTEL_LEVEL_SIM \
6+
defined "$g_SIMULATOR_CONFIG_SOURCE" \
7+
--digitiser-trace-topic $g_TRACE_TOPIC \
8+
--digitiser-event-topic $g_DAT_EVENT_TOPIC \
9+
--frame-event-topic $g_FRAME_EVENT_TOPIC \
10+
--control-topic $g_CONTROL_TOPIC \
11+
--runlog-topic $g_CONTROL_TOPIC \
12+
--selog-topic $g_CONTROL_TOPIC \
13+
--alarm-topic $g_CONTROL_TOPIC
1414
}
1515

1616
run_trace_reader() {
@@ -21,13 +21,13 @@ run_trace_reader() {
2121
NUM_TRACE_EVENTS=$5
2222
TRACE_TOPIC=$6
2323

24-
$TRACE_READER \
24+
$g_TRACE_READER \
2525
--broker $BROKER \
2626
--trace-topic $TRACE_TOPIC \
2727
--consumer-group trace-reader \
2828
--frame-number=$FRAME_NUMBER \
2929
--digitizer-id=$DID \
30-
$OTEL_ENDPOINT \
30+
$g_OTEL_ENDPOINT \
3131
--number-of-trace-events=$NUM_TRACE_EVENTS \
3232
--trace-offset=$OFFSET \
3333
--file-name "../Data/Traces/MuSR_A41_B42_C43_D44_Apr2021_Ag_ZF_IntDeg_Slit60_short.traces"

Diff for: ‎Libs/lib_persistant.sh

+26-26
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,17 @@
11
run_trace_to_events() {
2-
echo "Using detector settings '$TTE_INPUT_MODE'"
2+
echo "Using detector settings '$g_TTE_INPUT_MODE'"
33

44
echo "--" "--" "Executing Event Formation"
5-
$TRACE_TO_EVENTS \
6-
--broker $BROKER --consumer-group $GROUP_EVENT_FORMATION \
5+
$g_TRACE_TO_EVENTS \
6+
--broker $g_BROKER --consumer-group $g_GROUP_EVENT_FORMATION \
77
--observability-address "127.0.0.1:29094" \
8-
--trace-topic $TRACE_TOPIC \
9-
--event-topic $DAT_EVENT_TOPIC \
10-
--polarity $TTE_POLARITY \
11-
--baseline $TTE_BASELINE \
12-
$OTEL_ENDPOINT \
13-
$OTEL_LEVEL_EVENT_FORMATION \
14-
$TTE_INPUT_MODE &
8+
--trace-topic $g_TRACE_TOPIC \
9+
--event-topic $g_DAT_EVENT_TOPIC \
10+
--polarity $g_TTE_POLARITY \
11+
--baseline $g_TTE_BASELINE \
12+
$g_OTEL_ENDPOINT \
13+
$g_OTEL_LEVEL_EVENT_FORMATION \
14+
$g_TTE_INPUT_MODE &
1515
# --save-file Output/HiFi/output_ \
1616
}
1717

@@ -28,30 +28,30 @@ build_digitiser_argument() {
2828
run_aggregator() {
2929
echo "--" "--" "Executing aggregator"
3030

31-
$EVENT_AGGREGATOR \
32-
--broker $BROKER --group $GROUP_AGGREGATOR \
33-
--input-topic $DAT_EVENT_TOPIC --output-topic $FRAME_EVENT_TOPIC \
31+
$g_EVENT_AGGREGATOR \
32+
--broker $g_BROKER --group $g_GROUP_AGGREGATOR \
33+
--input-topic $g_DAT_EVENT_TOPIC --output-topic $g_FRAME_EVENT_TOPIC \
3434
--observability-address "127.0.0.1:29091" \
3535
--frame-ttl-ms 2000 \
36-
$OTEL_ENDPOINT \
37-
$OTEL_LEVEL_AGGREGATOR \
38-
$DIGITIZERS &
36+
$g_OTEL_ENDPOINT \
37+
$g_OTEL_LEVEL_AGGREGATOR \
38+
$g_DIGITIZERS &
3939
}
4040

4141
run_nexus_writer() {
4242
echo "--" "--" "Executing nexus-writer"
4343

44-
$NEXUS_WRITER \
45-
--broker $BROKER --consumer-group "$GROUP_WRITER" \
44+
$g_NEXUS_WRITER \
45+
--broker $g_BROKER --consumer-group "$g_GROUP_WRITER" \
4646
--observability-address "127.0.0.1:29090" \
47-
--control-topic $CONTROL_TOPIC \
48-
--frame-event-topic $FRAME_EVENT_TOPIC \
49-
--log-topic $CONTROL_TOPIC \
50-
--sample-env-topic $CONTROL_TOPIC \
51-
--alarm-topic $CONTROL_TOPIC \
47+
--control-topic $g_CONTROL_TOPIC \
48+
--frame-event-topic $g_FRAME_EVENT_TOPIC \
49+
--log-topic $g_CONTROL_TOPIC \
50+
--sample-env-topic $g_CONTROL_TOPIC \
51+
--alarm-topic $g_CONTROL_TOPIC \
5252
--cache-run-ttl-ms 5000 \
53-
$OTEL_ENDPOINT \
54-
$OTEL_LEVEL_WRITER \
55-
--file-name "$NEXUS_OUTPUT_PATH" &
53+
$g_OTEL_ENDPOINT \
54+
$g_OTEL_LEVEL_WRITER \
55+
--file-name "g_$NEXUS_OUTPUT_PATH" &
5656
}
5757

Diff for: ‎Libs/lib_run_simulator.sh

+25-25
Original file line numberDiff line numberDiff line change
@@ -4,16 +4,16 @@ send_run_start() {
44
INSTRUMENT_NAME=$2
55
TIME="$3"
66

7-
$SIMULATOR --broker $BROKER \
8-
--trace-topic $TRACE_TOPIC \
9-
--event-topic $DAT_EVENT_TOPIC \
10-
--frame-event-topic $FRAME_EVENT_TOPIC \
11-
--control-topic $CONTROL_TOPIC \
12-
$OTEL_ENDPOINT \
13-
$OTEL_LEVEL_SIM \
7+
$g_SIMULATOR --broker $g_BROKER \
8+
--trace-topic $g_TRACE_TOPIC \
9+
--event-topic $g_DAT_EVENT_TOPIC \
10+
--frame-event-topic $g_FRAME_EVENT_TOPIC \
11+
--control-topic $g_CONTROL_TOPIC \
12+
$g_OTEL_ENDPOINT \
13+
$g_OTEL_LEVEL_SIM \
1414
start $TIME \
1515
--run-name $RUN_NAME \
16-
--topic $CONTROL_TOPIC \
16+
--topic $g_CONTROL_TOPIC \
1717
--instrument-name $INSTRUMENT_NAME
1818
}
1919

@@ -22,10 +22,10 @@ send_logdata() {
2222
VALUE_TYPE="$2"
2323
VALUE="$3"
2424

25-
$RUN_SIMULATOR --broker $BROKER --topic $CONTROL_TOPIC \
25+
$g_RUN_SIMULATOR --broker $g_BROKER --topic $g_CONTROL_TOPIC \
2626
--run-name $RUN_NAME \
27-
$OTEL_ENDPOINT \
28-
$OTEL_LEVEL \
27+
$g_OTEL_ENDPOINT \
28+
$g_OTEL_LEVEL \
2929
$TIME \
3030
log \
3131
--source-name "$SOURCE_NAME" \
@@ -38,10 +38,10 @@ send_selog() {
3838
VALUE_TYPE="$2"
3939
VALUE="$3"
4040

41-
$RUN_SIMULATOR --broker $BROKER --topic $CONTROL_TOPIC \
41+
$g_RUN_SIMULATOR --broker $g_BROKER --topic $g_CONTROL_TOPIC \
4242
--run-name $RUN_NAME \
43-
$OTEL_ENDPOINT \
44-
$OTEL_LEVEL \
43+
$g_OTEL_ENDPOINT \
44+
$g_OTEL_LEVEL \
4545
$TIME \
4646
sample-env \
4747
--name "$SOURCE_NAME" \
@@ -55,10 +55,10 @@ send_alarm() {
5555
SEVERITY="$2"
5656
MESSAGE="$3"
5757

58-
$RUN_SIMULATOR --broker $BROKER --topic $CONTROL_TOPIC \
58+
$g_RUN_SIMULATOR --broker $g_BROKER --topic $g_CONTROL_TOPIC \
5959
--run-name $RUN_NAME \
60-
$OTEL_ENDPOINT \
61-
$OTEL_LEVEL \
60+
$g_OTEL_ENDPOINT \
61+
$g_OTEL_LEVEL \
6262
$TIME \
6363
alarm \
6464
--source-name "$SOURCE_NAME" \
@@ -70,14 +70,14 @@ send_run_stop() {
7070
RUN_NAME=$1
7171
TIME="$3"
7272

73-
$SIMULATOR --broker $BROKER \
74-
--trace-topic $TRACE_TOPIC \
75-
--event-topic $DAT_EVENT_TOPIC \
76-
--frame-event-topic $FRAME_EVENT_TOPIC \
77-
--control-topic $CONTROL_TOPIC \
78-
$OTEL_ENDPOINT \
79-
$OTEL_LEVEL_SIM \
73+
$g_SIMULATOR --broker $g_BROKER \
74+
--trace-topic $g_TRACE_TOPIC \
75+
--event-topic $g_DAT_EVENT_TOPIC \
76+
--frame-event-topic $g_FRAME_EVENT_TOPIC \
77+
--control-topic $g_CONTROL_TOPIC \
78+
$g_OTEL_ENDPOINT \
79+
$g_OTEL_LEVEL_SIM \
8080
stop $TIME \
8181
--run-name $RUN_NAME \
82-
--topic $CONTROL_TOPIC
82+
--topic $g_CONTROL_TOPIC
8383
}

Diff for: ‎Settings/EventFormationConfig.sh

+4-4
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
#TTE_INPUT_MODE="advanced-muon-detector --muon-onset=0.1 --muon-fall=-0.1 --muon-termination=0.01 --duration=10 --smoothing-window-size=10"
2-
TTE_POLARITY=positive
3-
TTE_BASELINE=0
4-
TTE_INPUT_MODE="fixed-threshold-discriminator --threshold=10 --duration=1 --cool-off=0"
1+
#g_TTE_INPUT_MODE="advanced-muon-detector --muon-onset=0.1 --muon-fall=-0.1 --muon-termination=0.01 --duration=10 --smoothing-window-size=10"
2+
g_TTE_POLARITY=positive
3+
g_TTE_BASELINE=0
4+
g_TTE_INPUT_MODE="fixed-threshold-discriminator --threshold=10 --duration=1 --cool-off=0"

Diff for: ‎Settings/Local/PipelineConfig.sh

+10-10
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,17 @@
11
# Use This Broker
2-
BROKER="localhost:9092"
2+
g_BROKER="localhost:9092"
33

44
# Broker Topics
5-
TRACE_TOPIC=daq-traces-in
6-
DAT_EVENT_TOPIC=daq-events-in
7-
FRAME_EVENT_TOPIC=ics-_events
8-
CONTROL_TOPIC=ics-control-change
9-
LOGS_TOPIC=ics-metadata
10-
SELOGS_TOPIC=ics-metadata
11-
ALARMS_TOPIC=ics-alarms
5+
g_TRACE_TOPIC=daq-traces-in
6+
g_DAT_EVENT_TOPIC=daq-events-in
7+
g_FRAME_EVENT_TOPIC=ics-_events
8+
g_CONTROL_TOPIC=ics-control-change
9+
g_LOGS_TOPIC=ics-metadata
10+
g_SELOGS_TOPIC=ics-metadata
11+
g_ALARMS_TOPIC=ics-alarms
1212

1313
# Digitisers Expected from Broker
14-
DIGITIZERS=$(build_digitiser_argument 7)
14+
g_DIGITIZERS=$(build_digitiser_argument 7)
1515

1616
# Output Path
17-
NEXUS_OUTPUT_PATH="Output/Local"
17+
g_NEXUS_OUTPUT_PATH="Output/Local"

Diff for: ‎Settings/PipelineSetup.sh

+18-18
Original file line numberDiff line numberDiff line change
@@ -1,23 +1,23 @@
1-
APPLICATION_PREFIX="../supermusr-data-pipeline/target/release/"
2-
#APPLICATION_PREFIX="cargo run --manifest-path "../supermusr-data-pipeline" --release --bin "
1+
g_APPLICATION_PREFIX="../supermusr-data-pipeline/target/release/"
2+
#g_APPLICATION_PREFIX="cargo run --manifest-path "../supermusr-data-pipeline" --release --bin "
33

4-
RUN_SIMULATOR="${APPLICATION_PREFIX}run-simulator"
5-
SIMULATOR="${APPLICATION_PREFIX}simulator"
6-
TRACE_READER="${APPLICATION_PREFIX}trace-reader"
7-
TRACE_TO_EVENTS="${APPLICATION_PREFIX}trace-to-events"
8-
EVENT_AGGREGATOR="${APPLICATION_PREFIX}digitiser-aggregator"
9-
NEXUS_WRITER="${APPLICATION_PREFIX}/nexus-writer"
4+
g_RUN_SIMULATOR="${g_APPLICATION_PREFIX}run-simulator"
5+
g_SIMULATOR="${g_APPLICATION_PREFIX}simulator"
6+
g_TRACE_READER="${g_APPLICATION_PREFIX}trace-reader"
7+
g_TRACE_TO_EVENTS="${g_APPLICATION_PREFIX}trace-to-events"
8+
g_EVENT_AGGREGATOR="${g_APPLICATION_PREFIX}digitiser-aggregator"
9+
g_NEXUS_WRITER="${g_APPLICATION_PREFIX}/nexus-writer"
1010

1111

12-
GROUP_WRITER=nexus-writer
13-
GROUP_AGGREGATOR=digitiser-aggregator
14-
GROUP_EVENT_FORMATION=trace-to-events
12+
g_GROUP_WRITER=nexus-writer
13+
g_GROUP_AGGREGATOR=digitiser-aggregator
14+
g_GROUP_EVENT_FORMATION=trace-to-events
1515

16-
PROCESS_WRITER=nexus-writer
17-
PROCESS_AGGREGATOR=digitiser-aggre
18-
PROCESS_EVENT_FORMATION=trace-to-events
16+
g_PROCESS_WRITER=nexus-writer
17+
g_PROCESS_AGGREGATOR=digitiser-aggre
18+
g_PROCESS_EVENT_FORMATION=trace-to-events
1919

20-
OTEL_ENDPOINT="--otel-endpoint http://localhost:4317/v1/traces"
21-
#OTEL_ENDPOINT="--otel-endpoint http://172.16.113.245:4317/v1/traces" # HiFi
22-
#OTEL_ENDPOINT="--otel-endpoint http://146.199.207.182:4317/v1/traces" # MyPC
23-
#OTEL_ENDPOINT=""
20+
g_OTEL_ENDPOINT="--otel-endpoint http://localhost:4317/v1/traces"
21+
#g_OTEL_ENDPOINT="--otel-endpoint http://172.16.113.245:4317/v1/traces" # HiFi
22+
#g_OTEL_ENDPOINT="--otel-endpoint http://146.199.207.182:4317/v1/traces" # MyPC
23+
#g_OTEL_ENDPOINT=""

0 commit comments

Comments
 (0)
Please sign in to comment.