mirror of
https://github.com/ElementsProject/lightning.git
synced 2025-01-18 05:12:45 +01:00
79443d6f94
This addresses a performance regression introduced by
6ceb375650. We were storing it in an
otherwise empty DB transaction, which means that DB transaction was no
longer a no-op. Now we defer storing until we need to store the
corresponding HTLC anyway, so we can just piggyback on top of that
transaction.
This is also more consistent since we'd be forgetting the payment
anyway if we restart between adding the HTLC and committing to it.
Signed-off-by: Christian Decker <decker.christian@gmail.com>
143 lines
3.8 KiB
C
143 lines
3.8 KiB
C
#ifndef LIGHTNING_LIGHTNINGD_HTLC_END_H
|
|
#define LIGHTNING_LIGHTNINGD_HTLC_END_H
|
|
#include "config.h"
|
|
#include <ccan/htable/htable_type.h>
|
|
#include <ccan/short_types/short_types.h>
|
|
#include <common/htlc_state.h>
|
|
#include <common/sphinx.h>
|
|
#include <wire/gen_onion_wire.h>
|
|
|
|
/* We look up HTLCs by peer & id */
|
|
struct htlc_key {
|
|
struct peer *peer;
|
|
u64 id;
|
|
};
|
|
|
|
/* Incoming HTLC */
|
|
struct htlc_in {
|
|
/* The database primary key for this htlc. Must be 0 until it
|
|
* is saved to the database, must be >0 after saving to the
|
|
* database. */
|
|
u64 dbid;
|
|
struct htlc_key key;
|
|
u64 msatoshi;
|
|
u32 cltv_expiry;
|
|
struct sha256 payment_hash;
|
|
|
|
enum htlc_state hstate;
|
|
|
|
/* Onion information */
|
|
u8 onion_routing_packet[TOTAL_PACKET_SIZE];
|
|
|
|
/* Shared secret for us to send any failure message. */
|
|
struct secret shared_secret;
|
|
|
|
/* If we failed HTLC, here's the message. */
|
|
const u8 *failuremsg;
|
|
|
|
/* If it was malformed, here's the error. */
|
|
enum onion_type malformed;
|
|
|
|
/* If they fulfilled, here's the preimage. */
|
|
struct preimage *preimage;
|
|
};
|
|
|
|
struct htlc_out {
|
|
/* The database primary key for this htlc. Must be 0 until it
|
|
* is saved to the database, must be >0 after saving to the
|
|
* database. */
|
|
u64 dbid;
|
|
u64 origin_htlc_id;
|
|
struct htlc_key key;
|
|
u64 msatoshi;
|
|
u32 cltv_expiry;
|
|
struct sha256 payment_hash;
|
|
|
|
enum htlc_state hstate;
|
|
|
|
/* Onion information */
|
|
u8 onion_routing_packet[TOTAL_PACKET_SIZE];
|
|
|
|
/* If we failed HTLC, here's the message. */
|
|
const u8 *failuremsg;
|
|
|
|
/* If it was malformed, here's the error. */
|
|
enum onion_type malformed;
|
|
|
|
/* If we fulfilled, here's the preimage. */
|
|
struct preimage *preimage;
|
|
|
|
/* Where it's from, if not going to us. */
|
|
struct htlc_in *in;
|
|
|
|
/* Otherwise, payment command which created it. */
|
|
struct pay_command *pay_command;
|
|
|
|
/* Temporary payment store, so we can save everything in one go */
|
|
struct wallet_payment *payment;
|
|
};
|
|
|
|
static inline const struct htlc_key *keyof_htlc_in(const struct htlc_in *in)
|
|
{
|
|
return &in->key;
|
|
}
|
|
|
|
static inline const struct htlc_key *keyof_htlc_out(const struct htlc_out *out)
|
|
{
|
|
return &out->key;
|
|
}
|
|
|
|
size_t hash_htlc_key(const struct htlc_key *htlc_key);
|
|
|
|
static inline bool htlc_in_eq(const struct htlc_in *in, const struct htlc_key *k)
|
|
{
|
|
return in->key.peer == k->peer && in->key.id == k->id;
|
|
}
|
|
|
|
static inline bool htlc_out_eq(const struct htlc_out *out,
|
|
const struct htlc_key *k)
|
|
{
|
|
return out->key.peer == k->peer && out->key.id == k->id;
|
|
}
|
|
|
|
|
|
HTABLE_DEFINE_TYPE(struct htlc_in, keyof_htlc_in, hash_htlc_key, htlc_in_eq,
|
|
htlc_in_map);
|
|
|
|
HTABLE_DEFINE_TYPE(struct htlc_out, keyof_htlc_out, hash_htlc_key, htlc_out_eq,
|
|
htlc_out_map);
|
|
|
|
struct htlc_in *find_htlc_in(const struct htlc_in_map *map,
|
|
const struct peer *peer,
|
|
u64 htlc_id);
|
|
|
|
struct htlc_out *find_htlc_out(const struct htlc_out_map *map,
|
|
const struct peer *peer,
|
|
u64 htlc_id);
|
|
|
|
/* You still need to connect_htlc_in this! */
|
|
struct htlc_in *new_htlc_in(const tal_t *ctx,
|
|
struct peer *peer, u64 id,
|
|
u64 msatoshi, u32 cltv_expiry,
|
|
const struct sha256 *payment_hash,
|
|
const struct secret *shared_secret,
|
|
const u8 *onion_routing_packet);
|
|
|
|
/* You need to set the ID, then connect_htlc_out this! */
|
|
struct htlc_out *new_htlc_out(const tal_t *ctx,
|
|
struct peer *peer,
|
|
u64 msatoshi, u32 cltv_expiry,
|
|
const struct sha256 *payment_hash,
|
|
const u8 *onion_routing_packet,
|
|
struct htlc_in *in,
|
|
struct pay_command *pc,
|
|
struct wallet_payment *payment);
|
|
|
|
void connect_htlc_in(struct htlc_in_map *map, struct htlc_in *hin);
|
|
void connect_htlc_out(struct htlc_out_map *map, struct htlc_out *hout);
|
|
|
|
struct htlc_out *htlc_out_check(const struct htlc_out *hout,
|
|
const char *abortstr);
|
|
struct htlc_in *htlc_in_check(const struct htlc_in *hin, const char *abortstr);
|
|
#endif /* LIGHTNING_LIGHTNINGD_HTLC_END_H */
|