aljaz/lightning
1
0
Fork 0
mirror of https://github.com/aljazceru/lightning.git synced 2025-12-23 00:54:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

pytest: cleanup test_forward_stats.

Browse Source 
Use dev_ignore_htlcs to make sure HTLC gets stuck.

Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
This commit is contained in:
Rusty Russell
2018-10-19 14:56:30 +10:30
parent 604638712b
commit 31d8a5a9a4
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
tests/test_pay.py
View File

@@ -976,6 +976,7 @@ def test_forward_pad_fees_and_cltv(node_factory, bitcoind):
assert only_one(l3.rpc.listinvoices('test_forward_pad_fees_and_cltv')['invoices'])['status'] == 'paid' assert only_one(l3.rpc.listinvoices('test_forward_pad_fees_and_cltv')['invoices'])['status'] == 'paid'
@unittest.skipIf(not DEVELOPER, "needs DEVELOPER=1 for dev_ignore_htlcs")
def test_forward_stats(node_factory, bitcoind): def test_forward_stats(node_factory, bitcoind):
"""Check that we track forwarded payments correctly. """Check that we track forwarded payments correctly.
@@ -1009,18 +1010,13 @@ def test_forward_stats(node_factory, bitcoind):
l1.rpc.sendpay(route, payment_hash) l1.rpc.sendpay(route, payment_hash)
l1.rpc.waitsendpay(payment_hash) l1.rpc.waitsendpay(payment_hash)
# l5 will hold the HTLC hostage and walk away # l5 will hold the HTLC hostage.
l5.rpc.dev_ignore_htlcs(id=l2.info['id'], ignore=True)
route = l1.rpc.getroute(l5.info['id'], amount, 1)['route'] route = l1.rpc.getroute(l5.info['id'], amount, 1)['route']
payment_hash = l5.rpc.invoice(amount, "first", "desc")['payment_hash'] payment_hash = l5.rpc.invoice(amount, "first", "desc")['payment_hash']
l1.rpc.sendpay(route, payment_hash) l1.rpc.sendpay(route, payment_hash)
# Wait for the HTLC to be added, then try to kill it to keep the l5.daemon.wait_for_log(r'their htlc .* dev_ignore_htlcs')
# HTLC pending. This is racy but there seems to be no good
# alternative
l5.daemon.wait_for_log(r'RCVD_ADD_HTLC/SENT_ADD_HTLC')
l5.daemon.wait_for_log(r'peer_out WIRE_COMMITMENT_SIGNED')
l5.daemon.kill()
print("Killed!")
# Select all forwardings, ordered by htlc_id to ensure the order # Select all forwardings, ordered by htlc_id to ensure the order
# matches below # matches below