@@ -53,7 +53,7 @@ handle_options "$@"
5353
5454FUNC_IDS=" 20 30 40 60 70"
5555FPROCESS=$BASE_DIR /../sharedlog-stream/bin/nexmark_handler_debug
56- REMOTE_TXN_PROCESS=$BASE_DIR /../sharedlog-stream/bin/remote_txn_mngr_debug
56+ REMOTE_TXN_PROCESS=$BASE_DIR /../sharedlog-stream/bin/remote_txn_mngr_boki_debug
5757
5858docker-compose -f $SCRIPT_DIR /docker-compose.yml up -d
5959
@@ -110,11 +110,12 @@ rm -rf $BASE_DIR/tmp/output/*
110110GATEWAY_HTTP_PORT=8081
111111
112112FUNC_CONFIG_FILE=$BASE_DIR /../sharedlog-stream-experiments/nexmark_sharedlog/specs/4_ins/${QUERY} .json
113+ GATEWAY_FUNC_CONFIG_FILE=$BASE_DIR /../sharedlog-stream-experiments/nexmark_sharedlog/specs/4_ins/${QUERY} _gateway.json
113114RTX_MNGR_CONFIG_FILE=$BASE_DIR /../sharedlog-stream-experiments/nexmark_sharedlog/specs/remote_txn_mngr.json
114115$BASE_DIR /bin/$BUILD_TYPE /gateway \
115116 --listen_addr=127.0.0.1 --http_port=$GATEWAY_HTTP_PORT \
116117 --message_conn_per_worker=2 --tcp_enable_reuseport \
117- --func_config_file=${FUNC_CONFIG_FILE } \
118+ --func_config_file=${GATEWAY_FUNC_CONFIG_FILE } \
118119 --async_call_result_path=$BASE_DIR /tmp/output/async_results \
119120 --v=0 2> $BASE_DIR /tmp/output/gateway.log &
120121PIDS+=($! )
@@ -128,8 +129,8 @@ sleep 1
128129
129130SEQUENCERS=" 1 2 3"
130131ENGINES=" 1 2 3 4 5 6 7 8"
131- STORAGES=" 1 2 3"
132- ENGINES_ON_STORAGES=" 9 10 11"
132+ STORAGES=" 1 2 3 4 "
133+ ENGINES_ON_STORAGES=" 9 10 11 12 "
133134
134135rm -rf /mnt/inmem/faas
135136rm -rf /tmp/faas
@@ -182,12 +183,12 @@ sleep 1
182183cnt=1
183184for i in $ENGINES_ON_STORAGES ; do
184185 func=110
185- port=$(( 50051 + ${cnt} ))
186- echo " assign remote_txn_manager port " , $port
186+ # port=$(( 50051 + ${cnt} ))
187+ # echo "assign remote_txn_manager port ", $port
187188 mkdir -p $BASE_DIR /tmp/output/node$i
188189 GRPC_GO_LOG_VERBOSITY_LEVEL=99 GRPC_GO_LOG_SEVERITY_LEVEL=info GOGC=200 FAAS_GO_MAX_PROC_FACTOR=1 FAAS_BUILD_TYPE=release \
189190 MEASURE_SINK=1 MEASURE_SRC=1 BUFPUSH=1 REDIS_ADDR=127.0.0.1:6666 CREATE_SNAPSHOT=1 \
190- PARALLEL_RESTORE=1 ASYNC_SECOND_PHASE=1 RTX_PORT= $port \
191+ PARALLEL_RESTORE=1 ASYNC_SECOND_PHASE=1 \
191192 $BASE_DIR /bin/$BUILD_TYPE /launcher \
192193 --root_path_for_ipc=/mnt/inmem/faas/engine_node$i \
193194 --func_id=$func --fprocess_mode=go \
@@ -202,7 +203,8 @@ for i in $ENGINES; do
202203 mkdir -p $BASE_DIR /tmp/output/node$i
203204 for func in $FUNC_IDS ; do
204205 GRPC_GO_LOG_VERBOSITY_LEVEL=99 GRPC_GO_LOG_SEVERITY_LEVEL=info GOGC=200 FAAS_GO_MAX_PROC_FACTOR=1 FAAS_BUILD_TYPE=release \
205- RTXN_MNGR_ADDR=127.0.0.1:50052,127.0.0.1:50053,127.0.0.1:50054 \
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" \
206208 MEASURE_SINK=1 MEASURE_SRC=1 BUFPUSH=1 REDIS_ADDR=127.0.0.1:6666 \
207209 CREATE_SNAPSHOT=1 PARALLEL_RESTORE=1 ASYNC_SECOND_PHASE=1 \
208210 $BASE_DIR /bin/$BUILD_TYPE /launcher \
0 commit comments