Skip to content

Commit

Permalink
plugins/libplugin-pay.c: Round-robin routehints when splitting.
Browse files Browse the repository at this point in the history
This improves the success rate of `test_mpp_interference_2`, though
still not quite up to the level that we can remove `@flaky` from it.
  • Loading branch information
ZmnSCPxj committed Aug 13, 2020
1 parent fb6b7eb commit 4a9e570
Show file tree
Hide file tree
Showing 2 changed files with 48 additions and 6 deletions.
38 changes: 35 additions & 3 deletions plugins/libplugin-pay.c
Original file line number Diff line number Diff line change
Expand Up @@ -1883,8 +1883,8 @@ static struct route_info *next_routehint(struct routehints_data *d,
* - MUST specify the most-preferred field first, followed
* by less-preferred fields, in order.
*/
for (; d->offset <numhints; d->offset++) {
curr = d->routehints[d->offset];
for (; d->offset < numhints; d->offset++) {
curr = d->routehints[(d->base + d->offset) % numhints];
if (curr == NULL || !routehint_excluded(p, curr))
return curr;
}
Expand Down Expand Up @@ -2131,18 +2131,50 @@ static struct routehints_data *routehint_data_init(struct payment *p)
d->routehints = pd->routehints;
pd = payment_mod_routehints_get_data(p->parent);
if (p->parent->step == PAYMENT_STEP_RETRY) {
d->base = pd->base;
d->offset = pd->offset;
/* If the previous try failed to route, advance
* to the next routehint. */
if (!p->parent->route)
++d->offset;
} else
} else {
size_t num_routehints = tal_count(d->routehints);
d->offset = 0;
/* This used to be pseudorand.
*
* However, it turns out that using the partid for
* this payment has some nice properties.
* The partid is in general quite random, due to
* getting entropy from the network on the timing
* of when payments complete/fail, and the routehint
* randomization is not a privacy or security feature,
* only a reliability one, thus does not need a lot
* of entropy.
*
* But the most important bit is that *splits get
* contiguous partids*, e.g. a presplit into 4 will
* usually be numbered 2,3,4,5, and an adaptive split
* will get two consecutive partid.
* Because of the contiguity, using the partid for
* the base will cause the split-up payments to
* have fairly diverse initial routehints.
*
* The special-casing for <= 2 and the - 2 is due
* to the presplitter skipping over partid 1, we want
* the starting splits to have partid 2 start at
* base 0.
*/
if (p->partid <= 2 || num_routehints <= 1)
d->base = 0;
else
d->base = (p->partid - 2) % num_routehints;
}
return d;
} else {
/* We defer the actual initialization of the routehints array to
* the step callback when we have the invoice attached. */
d->routehints = NULL;
d->base = 0;
d->offset = 0;
return d;
}
Expand Down
16 changes: 13 additions & 3 deletions plugins/libplugin-pay.h
Original file line number Diff line number Diff line change
Expand Up @@ -300,16 +300,26 @@ struct routehints_data {
/* What we did about routehints (if anything) */
const char *routehint_modifications;

/* Any remaining routehints to try. */
/* Array of routehints to try. */
struct route_info **routehints;

/* Current routehint, if any. */
struct route_info *current_routehint;

/* Position of the current routehint in the routehints
* array. Inherited and incremented on child payments and reset on
* split. */
* array. Inherited on retry (and possibly incremented),
* reset to 0 on split. */
int offset;
/* Base of the current routehint.
* This is randomized to start routehints at a random point
* on each split, to reduce the chances of multiple splits
* going to the same routehint.
* The sum of base + offset is used as the index into the
* routehints array (wraps around).
* offset is used to determine if we have run out of
* routehints, base is used for randomization.
*/
int base;

/* We modify the CLTV in the getroute call, so we need to remember
* what the final cltv delta was so we re-apply it correctly. */
Expand Down

0 comments on commit 4a9e570

Please sign in to comment.