commit_tx: keep permutation map.

This lets us map the HTLCs back to outputs when txs occur onchain.

Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
This commit is contained in:
Rusty Russell
2016-05-02 16:05:56 +09:30
parent 76cb195ea1
commit 7614e513bd
7 changed files with 26 additions and 17 deletions

View File

@@ -42,7 +42,8 @@ struct bitcoin_tx *create_commit_tx(const tal_t *ctx,
unsigned int anchor_index, unsigned int anchor_index,
u64 anchor_satoshis, u64 anchor_satoshis,
const struct sha256 *rhash, const struct sha256 *rhash,
const struct channel_state *cstate) const struct channel_state *cstate,
int **map)
{ {
struct bitcoin_tx *tx; struct bitcoin_tx *tx;
const u8 *redeemscript; const u8 *redeemscript;
@@ -95,6 +96,7 @@ struct bitcoin_tx *create_commit_tx(const tal_t *ctx,
assert(num == tx->output_count); assert(num == tx->output_count);
assert(total <= anchor_satoshis); assert(total <= anchor_satoshis);
permute_outputs(tx->output, tx->output_count, NULL); *map = tal_arr(ctx, int, tx->output_count);
permute_outputs(tx->output, tx->output_count, *map);
return tx; return tx;
} }

View File

@@ -20,5 +20,6 @@ struct bitcoin_tx *create_commit_tx(const tal_t *ctx,
unsigned int anchor_index, unsigned int anchor_index,
u64 anchor_satoshis, u64 anchor_satoshis,
const struct sha256 *rhash, const struct sha256 *rhash,
const struct channel_state *cstate); const struct channel_state *cstate,
int **map);
#endif #endif

View File

@@ -304,7 +304,8 @@ void queue_pkt_commit(struct peer *peer)
peer->anchor.index, peer->anchor.index,
peer->anchor.satoshis, peer->anchor.satoshis,
&ci->revocation_hash, &ci->revocation_hash,
ci->cstate); ci->cstate,
&ci->map);
log_debug(peer->log, "Signing tx for %u/%u msatoshis, %zu/%zu htlcs", log_debug(peer->log, "Signing tx for %u/%u msatoshis, %zu/%zu htlcs",
ci->cstate->a.pay_msat, ci->cstate->a.pay_msat,
@@ -693,7 +694,8 @@ Pkt *accept_pkt_commit(struct peer *peer, const Pkt *pkt)
peer->anchor.index, peer->anchor.index,
peer->anchor.satoshis, peer->anchor.satoshis,
&ci->revocation_hash, &ci->revocation_hash,
ci->cstate); ci->cstate,
&ci->map);
/* BOLT #2: /* BOLT #2:
* *

View File

@@ -1330,7 +1330,8 @@ bool setup_first_commit(struct peer *peer)
peer->anchor.index, peer->anchor.index,
peer->anchor.satoshis, peer->anchor.satoshis,
&peer->us.commit->revocation_hash, &peer->us.commit->revocation_hash,
peer->us.commit->cstate); peer->us.commit->cstate,
&peer->us.commit->map);
peer->them.commit->tx = create_commit_tx(peer->them.commit, peer->them.commit->tx = create_commit_tx(peer->them.commit,
&peer->them.finalkey, &peer->them.finalkey,
@@ -1340,7 +1341,8 @@ bool setup_first_commit(struct peer *peer)
peer->anchor.index, peer->anchor.index,
peer->anchor.satoshis, peer->anchor.satoshis,
&peer->them.commit->revocation_hash, &peer->them.commit->revocation_hash,
peer->them.commit->cstate); peer->them.commit->cstate,
&peer->them.commit->map);
peer->us.staging_cstate = copy_funding(peer, peer->us.commit->cstate); peer->us.staging_cstate = copy_funding(peer, peer->us.commit->cstate);
peer->them.staging_cstate = copy_funding(peer, peer->them.commit->cstate); peer->them.staging_cstate = copy_funding(peer, peer->them.commit->cstate);

View File

@@ -63,6 +63,8 @@ struct commit_info {
struct channel_state *cstate; struct channel_state *cstate;
/* Other side's signature for this commit tx. */ /* Other side's signature for this commit tx. */
struct bitcoin_signature sig; struct bitcoin_signature sig;
/* Map for permutation: see commit_tx.c */
int *map;
/* Revocation preimage (if known). */ /* Revocation preimage (if known). */
struct sha256 *revocation_preimage; struct sha256 *revocation_preimage;
}; };

View File

@@ -2,7 +2,7 @@
#include <stdbool.h> #include <stdbool.h>
#include <string.h> #include <string.h>
static void init_map(size_t *map, size_t len) static void init_map(int *map, size_t len)
{ {
size_t i; size_t i;
@@ -15,10 +15,10 @@ static void init_map(size_t *map, size_t len)
/* This map says where things ended up, eg. 0 might be in slot 3. we /* This map says where things ended up, eg. 0 might be in slot 3. we
* want to change it so map[0] = 3. */ * want to change it so map[0] = 3. */
static void invert_map(size_t *map, size_t len) static void invert_map(int *map, size_t len)
{ {
if (map) { if (map) {
size_t i, newmap[len]; int i, newmap[len];
memset(newmap, 0, sizeof(newmap)); memset(newmap, 0, sizeof(newmap));
for (i = 0; i < len; i++) { for (i = 0; i < len; i++) {
@@ -59,7 +59,7 @@ static size_t find_best_in(struct bitcoin_tx_input *inputs, size_t num)
return best; return best;
} }
static void swap_inputs(struct bitcoin_tx_input *inputs, size_t *map, static void swap_inputs(struct bitcoin_tx_input *inputs, int *map,
size_t i1, size_t i2) size_t i1, size_t i2)
{ {
struct bitcoin_tx_input tmpinput; struct bitcoin_tx_input tmpinput;
@@ -78,7 +78,7 @@ static void swap_inputs(struct bitcoin_tx_input *inputs, size_t *map,
void permute_inputs(struct bitcoin_tx_input *inputs, void permute_inputs(struct bitcoin_tx_input *inputs,
size_t num_inputs, size_t num_inputs,
size_t *map) int *map)
{ {
size_t i; size_t i;
@@ -94,7 +94,7 @@ void permute_inputs(struct bitcoin_tx_input *inputs,
invert_map(map, num_inputs); invert_map(map, num_inputs);
} }
static void swap_outputs(struct bitcoin_tx_output *outputs, size_t *map, static void swap_outputs(struct bitcoin_tx_output *outputs, int *map,
size_t i1, size_t i2) size_t i1, size_t i2)
{ {
struct bitcoin_tx_output tmpoutput; struct bitcoin_tx_output tmpoutput;
@@ -146,7 +146,7 @@ static size_t find_best_out(struct bitcoin_tx_output *outputs, size_t num)
void permute_outputs(struct bitcoin_tx_output *outputs, void permute_outputs(struct bitcoin_tx_output *outputs,
size_t num_outputs, size_t num_outputs,
size_t *map) int *map)
{ {
size_t i; size_t i;

View File

@@ -8,9 +8,9 @@
*/ */
void permute_inputs(struct bitcoin_tx_input *inputs, void permute_inputs(struct bitcoin_tx_input *inputs,
size_t num_inputs, size_t num_inputs,
size_t *map); int *map);
void permute_outputs(struct bitcoin_tx_output *outputs, void permute_outputs(struct bitcoin_tx_output *outputs,
size_t num_outputs, size_t num_outputs,
size_t *map); int *map);
#endif /* LIGHTNING_PERMUTE_TX_H */ #endif /* LIGHTNING_PERMUTE_TX_H */