Skip to content

Commit

Permalink
GH-1510 Add ship_streamer_if_test disabled requires GH-2172
Browse files Browse the repository at this point in the history
  • Loading branch information
heifner committed Jan 31, 2024
1 parent 6e9fff5 commit 8f016e6
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 3 deletions.
1 change: 1 addition & 0 deletions libraries/chain/controller.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3758,6 +3758,7 @@ struct controller_impl {
void set_if_irreversible_block_num(uint32_t block_num) {
if( block_num > if_irreversible_block_num ) {
if_irreversible_block_num = block_num;
dlog("irreversible block ${bn}", ("bn", block_num));
}
}

Expand Down
3 changes: 3 additions & 0 deletions tests/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -138,6 +138,9 @@ set_property(TEST ship_if_test PROPERTY LABELS nonparallelizable_tests)

add_test(NAME ship_streamer_test COMMAND tests/ship_streamer_test.py -v --num-clients 10 ${UNSHARE} WORKING_DIRECTORY ${CMAKE_BINARY_DIR})
set_property(TEST ship_streamer_test PROPERTY LABELS long_running_tests)
# TODO investigate failure: https://github.com/AntelopeIO/leap/issues/2172
#add_test(NAME ship_streamer_if_test COMMAND tests/ship_streamer_test.py -v --num-clients 10 --activate-if ${UNSHARE} WORKING_DIRECTORY ${CMAKE_BINARY_DIR})
#set_property(TEST ship_streamer_if_test PROPERTY LABELS long_running_tests)

add_test(NAME p2p_dawn515_test COMMAND tests/p2p_tests/dawn_515/test.sh WORKING_DIRECTORY ${CMAKE_BINARY_DIR})
set_property(TEST p2p_dawn515_test PROPERTY LABELS nonparallelizable_tests)
Expand Down
8 changes: 5 additions & 3 deletions tests/ship_streamer_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,10 +31,11 @@

appArgs = AppArgs()
extraArgs = appArgs.add(flag="--num-clients", type=int, help="How many ship_streamers should be started", default=1)
args = TestHelper.parse_args({"--dump-error-details","--keep-logs","-v","--leave-running","--unshared"}, applicationSpecificArgs=appArgs)
args = TestHelper.parse_args({"--activate-if","--dump-error-details","--keep-logs","-v","--leave-running","--unshared"}, applicationSpecificArgs=appArgs)

Utils.Debug=args.v
cluster=Cluster(unshared=args.unshared, keepRunning=args.leave_running, keepLogs=args.keep_logs)
activateIF=args.activate_if
dumpErrorDetails=args.dump_error_details
walletPort=TestHelper.DEFAULT_WALLET_PORT

Expand Down Expand Up @@ -75,7 +76,7 @@ def getLatestSnapshot(nodeId):
specificExtraNodeosArgs[totalProducerNodes]="--plugin eosio::test_control_api_plugin "

if cluster.launch(topo="bridge", pnodes=totalProducerNodes,
totalNodes=totalNodes, totalProducers=totalProducers,
totalNodes=totalNodes, totalProducers=totalProducers, activateIF=activateIF, biosFinalizer=False,
specificExtraNodeosArgs=specificExtraNodeosArgs) is False:
Utils.cmdError("launcher")
Utils.errorExit("Failed to stand up eos cluster.")
Expand Down Expand Up @@ -168,8 +169,9 @@ def getLatestSnapshot(nodeId):
assert status is not None and status is not False, "ERROR: Failed to spinup Transaction Generators"

prodNode0.waitForProducer("defproducerc")
prodNode0.waitForProducer("defproducera")

block_range = 350
block_range = 450
end_block_num = start_block_num + block_range

shipClient = "tests/ship_streamer"
Expand Down

0 comments on commit 8f016e6

Please sign in to comment.