@@ -51,9 +51,9 @@ handle_options() {
5151
5252handle_options " $@ "
5353
54- FUNC_IDS=" 20 30 40 60 70"
54+ FUNC_IDS=" 20 30 40 50 60 70 90 "
5555FPROCESS=$BASE_DIR /../sharedlog-stream/bin/nexmark_handler_debug
56- REMOTE_TXN_PROCESS=$BASE_DIR /../sharedlog-stream/bin/remote_txn_mngr_boki_debug
56+ REMOTE_TXN_PROCESS=$BASE_DIR /../sharedlog-stream/bin/remote_txn_mngr_grpc_debug
5757
5858docker-compose -f $SCRIPT_DIR /docker-compose.yml up -d
5959
@@ -183,11 +183,11 @@ sleep 1
183183cnt=1
184184for i in $ENGINES_ON_STORAGES ; do
185185 func=110
186- # port=$(( 50051 + ${cnt} ))
187- # echo "assign remote_txn_manager port ", $port
186+ port=$(( 50051 + ${cnt} ))
187+ echo " assign remote_txn_manager port " , $port
188188 mkdir -p $BASE_DIR /tmp/output/node$i
189189 GRPC_GO_LOG_VERBOSITY_LEVEL=99 GRPC_GO_LOG_SEVERITY_LEVEL=info GOGC=200 FAAS_GO_MAX_PROC_FACTOR=1 FAAS_BUILD_TYPE=release \
190- MEASURE_SINK=1 MEASURE_SRC=1 BUFPUSH=1 REDIS_ADDR=127.0.0.1:6666 CREATE_SNAPSHOT=1 \
190+ MEASURE_SINK=1 MEASURE_SRC=1 BUFPUSH=1 REDIS_ADDR=127.0.0.1:6666 CREATE_SNAPSHOT=1 RTX_PORT= $port \
191191 PARALLEL_RESTORE=1 ASYNC_SECOND_PHASE=1 \
192192 $BASE_DIR /bin/$BUILD_TYPE /launcher \
193193 --root_path_for_ipc=/mnt/inmem/faas/engine_node$i \
@@ -203,8 +203,7 @@ for i in $ENGINES; do
203203 mkdir -p $BASE_DIR /tmp/output/node$i
204204 for func in $FUNC_IDS ; do
205205 GRPC_GO_LOG_VERBOSITY_LEVEL=99 GRPC_GO_LOG_SEVERITY_LEVEL=info GOGC=200 FAAS_GO_MAX_PROC_FACTOR=1 FAAS_BUILD_TYPE=release \
206- RTXN_MNGR_ADDR=" 127.0.0.1:50052,127.0.0.1:50053,127.0.0.1:50054" \
207- RTXN_MNGR_NODES=" 9,10,11,12" \
206+ RTXN_MNGR_ADDR=" 127.0.0.1:50052,127.0.0.1:50053,127.0.0.1:50054,127.0.0.1:50055" RTXN_MNGR_NODES=" 9,10,11,12" \
208207 MEASURE_SINK=1 MEASURE_SRC=1 BUFPUSH=1 REDIS_ADDR=127.0.0.1:6666 \
209208 CREATE_SNAPSHOT=1 PARALLEL_RESTORE=1 ASYNC_SECOND_PHASE=1 \
210209 $BASE_DIR /bin/$BUILD_TYPE /launcher \
0 commit comments