mirror of
https://github.com/ElementsProject/lightning.git
synced 2025-02-23 15:00:34 +01:00
638fff8526
Keep a double-entry record of pending routes so that we can flag them as not memory leaks. Signed-off-by: Lagrang3 <lagrang3@protonmail.com>
58 lines
2.2 KiB
C
58 lines
2.2 KiB
C
#ifndef LIGHTNING_PLUGINS_RENEPAY_ROUTETRACKER_H
|
|
#define LIGHTNING_PLUGINS_RENEPAY_ROUTETRACKER_H
|
|
|
|
/* This module provides entry points for the management of a route thread. */
|
|
|
|
#include "config.h"
|
|
#include <plugins/renepay/route.h>
|
|
|
|
struct routetracker{
|
|
struct payment *payment;
|
|
struct route_map *sent_routes;
|
|
struct route_map *pending_routes;
|
|
struct route **finalized_routes;
|
|
};
|
|
|
|
struct routetracker *new_routetracker(const tal_t *ctx, struct payment *payment);
|
|
// bool routetracker_is_ready(const struct routetracker *routetracker);
|
|
void routetracker_cleanup(struct routetracker *routetracker);
|
|
size_t routetracker_count_sent(struct routetracker *routetracker);
|
|
|
|
/* The payment has a list of route that have "returned". Calling this function
|
|
* payment will look through that list and process those routes' results:
|
|
* - update the commited amounts,
|
|
* - update the uncertainty network,
|
|
* - and free the allocated memory. */
|
|
void payment_collect_results(struct payment *payment,
|
|
struct preimage **payment_preimage,
|
|
enum jsonrpc_errcode *final_error,
|
|
const char **final_msg);
|
|
|
|
/* Announce that this route is pending and needs to be kept in the waiting list
|
|
* for notifications. */
|
|
void route_pending_register(struct routetracker *routetracker,
|
|
struct route *route);
|
|
|
|
/* Sends a sendpay request for this route. */
|
|
struct command_result *route_sendpay_request(struct command *cmd,
|
|
struct route *route,
|
|
struct payment *payment);
|
|
|
|
struct command_result *notification_sendpay_failure(struct command *cmd,
|
|
const char *buf,
|
|
const jsmntok_t *params);
|
|
|
|
struct command_result *notification_sendpay_success(struct command *cmd,
|
|
const char *buf,
|
|
const jsmntok_t *params);
|
|
|
|
/* Notify the tracker that this route has failed. */
|
|
void route_failure_register(struct routetracker *routetracker,
|
|
struct route *route);
|
|
|
|
// FIXME: double-check that we actually get one notification for each sendpay,
|
|
// ie. that after some time we don't have yet pending sendpays for old failed or
|
|
// successful payments that we havent processed because we haven't received the
|
|
// notification
|
|
|
|
#endif /* LIGHTNING_PLUGINS_RENEPAY_ROUTETRACKER_H */
|