Code Review
/
sim
/
a1-interface.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Consumer algorithm improvment via autoblock during message iteration
[sim/a1-interface.git]
/
near-rt-ric-simulator
/
test
/
KAFKA_DISPATCHER_TEST
/
timeout_test.sh
diff --git
a/near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/basic_test_with_cust_header.sh
b/near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/timeout_test.sh
similarity index 94%
rename from
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/basic_test_with_cust_header.sh
rename to
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/timeout_test.sh
index
4fa8ac0
..
f4e080c
100755
(executable)
--- a/
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/basic_test_with_cust_header.sh
+++ b/
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/timeout_test.sh
@@
-78,7
+78,7
@@
do_curl PUT /policytypes/ANR/kafkadispatcher/alpha 408 jsonfiles/alpha_policy.j
proc_id=$!
sleep $timeout
# after time out duration, publish the event
proc_id=$!
sleep $timeout
# after time out duration, publish the event
-publish_response_event $req_id
+publish_response_event $req_id
kafkatopicres
# wait until the main process to be completed
wait $proc_id
# wait until the main process to be completed
wait $proc_id
@@
-91,7
+91,7
@@
do_curl PUT /policytypes/STD_1/kafkadispatcher/alpha 200 jsonfiles/alpha_policy
proc_id=$!
sleep 10
# after 10s, publish the event
proc_id=$!
sleep 10
# after 10s, publish the event
-publish_response_event $req_id
+publish_response_event $req_id
kafkatopicres2
# wait until the main process to be completed
wait $proc_id
# wait until the main process to be completed
wait $proc_id
@@
-105,7
+105,7
@@
do_curl GET /policytypes/STD_2/kafkadispatcher/alpha/status 408 jsonfiles/alpha
proc_id=$!
sleep $timeout
# after time out duration, publish the event
proc_id=$!
sleep $timeout
# after time out duration, publish the event
-publish_response_event $req_id
+publish_response_event $req_id
kafkatopicres3
# wait until the main process to be completed
wait $proc_id
# wait until the main process to be completed
wait $proc_id
@@
-118,7
+118,7
@@
do_curl GET /policytypes/ANR/kafkadispatcher/alpha/status 200 jsonfiles/alpha_p
proc_id=$!
sleep 15
# after 15s, publish the event
proc_id=$!
sleep 15
# after 15s, publish the event
-publish_response_event $req_id
+publish_response_event $req_id
kafkatopicres
# wait until the main process to be completed
wait $proc_id
# wait until the main process to be completed
wait $proc_id
@@
-129,7
+129,7
@@
RESULT=""
# asynch callout
do_curl DELETE /policytypes/STD_1/kafkadispatcher/alpha 200 jsonfiles/alpha_policy.json $req_id &
proc_id=$!
# asynch callout
do_curl DELETE /policytypes/STD_1/kafkadispatcher/alpha 200 jsonfiles/alpha_policy.json $req_id &
proc_id=$!
-publish_response_event $req_id
+publish_response_event $req_id
kafkatopicres2
# wait until the main process to be completed
wait $proc_id
# wait until the main process to be completed
wait $proc_id