|
@ -404,25 +404,25 @@ class LightningDTests(BaseLightningDTests): |
|
|
|
|
|
|
|
|
# Test expiration waiting. |
|
|
# Test expiration waiting. |
|
|
# The second invoice created expires first. |
|
|
# The second invoice created expires first. |
|
|
l2.rpc.invoice('any', 'inv1', 'description', 5) |
|
|
l2.rpc.invoice('any', 'inv1', 'description', 10) |
|
|
l2.rpc.invoice('any', 'inv2', 'description', 2) |
|
|
l2.rpc.invoice('any', 'inv2', 'description', 4) |
|
|
l2.rpc.invoice('any', 'inv3', 'description', 8) |
|
|
l2.rpc.invoice('any', 'inv3', 'description', 16) |
|
|
# Check waitinvoice correctly waits |
|
|
# Check waitinvoice correctly waits |
|
|
w1 = self.executor.submit(l2.rpc.waitinvoice, 'inv1') |
|
|
w1 = self.executor.submit(l2.rpc.waitinvoice, 'inv1') |
|
|
w2 = self.executor.submit(l2.rpc.waitinvoice, 'inv2') |
|
|
w2 = self.executor.submit(l2.rpc.waitinvoice, 'inv2') |
|
|
w3 = self.executor.submit(l2.rpc.waitinvoice, 'inv3') |
|
|
w3 = self.executor.submit(l2.rpc.waitinvoice, 'inv3') |
|
|
time.sleep(1) # total 1 |
|
|
time.sleep(2) # total 2 |
|
|
assert not w1.done() |
|
|
assert not w1.done() |
|
|
assert not w2.done() |
|
|
assert not w2.done() |
|
|
assert not w3.done() |
|
|
assert not w3.done() |
|
|
time.sleep(2) # total 3 |
|
|
time.sleep(4) # total 6 |
|
|
assert not w1.done() |
|
|
assert not w1.done() |
|
|
self.assertRaises(ValueError, w2.result) |
|
|
self.assertRaises(ValueError, w2.result) |
|
|
assert not w3.done() |
|
|
assert not w3.done() |
|
|
time.sleep(3) # total 6 |
|
|
time.sleep(6) # total 12 |
|
|
self.assertRaises(ValueError, w1.result) |
|
|
self.assertRaises(ValueError, w1.result) |
|
|
assert not w3.done() |
|
|
assert not w3.done() |
|
|
time.sleep(4) # total 10 |
|
|
time.sleep(8) # total 20 |
|
|
self.assertRaises(ValueError, w3.result) |
|
|
self.assertRaises(ValueError, w3.result) |
|
|
|
|
|
|
|
|
def test_connect(self): |
|
|
def test_connect(self): |
|
|