You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
198 lines
8.8 KiB
198 lines
8.8 KiB
#include "../gossip_rcvd_filter.c"
|
|
#include "../pseudorand.c"
|
|
#include "../../wire/fromwire.c"
|
|
#include <common/setup.h>
|
|
#include <common/utils.h>
|
|
#include <stdio.h>
|
|
|
|
/* AUTOGENERATED MOCKS START */
|
|
/* Generated stub for amount_asset_is_main */
|
|
bool amount_asset_is_main(struct amount_asset *asset UNNEEDED)
|
|
{ fprintf(stderr, "amount_asset_is_main called!\n"); abort(); }
|
|
/* Generated stub for amount_asset_to_sat */
|
|
struct amount_sat amount_asset_to_sat(struct amount_asset *asset UNNEEDED)
|
|
{ fprintf(stderr, "amount_asset_to_sat called!\n"); abort(); }
|
|
/* Generated stub for amount_sat */
|
|
struct amount_sat amount_sat(u64 satoshis UNNEEDED)
|
|
{ fprintf(stderr, "amount_sat called!\n"); abort(); }
|
|
/* Generated stub for amount_sat_add */
|
|
bool amount_sat_add(struct amount_sat *val UNNEEDED,
|
|
struct amount_sat a UNNEEDED,
|
|
struct amount_sat b UNNEEDED)
|
|
{ fprintf(stderr, "amount_sat_add called!\n"); abort(); }
|
|
/* Generated stub for amount_sat_eq */
|
|
bool amount_sat_eq(struct amount_sat a UNNEEDED, struct amount_sat b UNNEEDED)
|
|
{ fprintf(stderr, "amount_sat_eq called!\n"); abort(); }
|
|
/* Generated stub for amount_sat_greater_eq */
|
|
bool amount_sat_greater_eq(struct amount_sat a UNNEEDED, struct amount_sat b UNNEEDED)
|
|
{ fprintf(stderr, "amount_sat_greater_eq called!\n"); abort(); }
|
|
/* Generated stub for amount_sat_sub */
|
|
bool amount_sat_sub(struct amount_sat *val UNNEEDED,
|
|
struct amount_sat a UNNEEDED,
|
|
struct amount_sat b UNNEEDED)
|
|
{ fprintf(stderr, "amount_sat_sub called!\n"); abort(); }
|
|
/* Generated stub for amount_sat_to_asset */
|
|
struct amount_asset amount_sat_to_asset(struct amount_sat *sat UNNEEDED, const u8 *asset UNNEEDED)
|
|
{ fprintf(stderr, "amount_sat_to_asset called!\n"); abort(); }
|
|
/* Generated stub for amount_tx_fee */
|
|
struct amount_sat amount_tx_fee(u32 fee_per_kw UNNEEDED, size_t weight UNNEEDED)
|
|
{ fprintf(stderr, "amount_tx_fee called!\n"); abort(); }
|
|
/* Generated stub for fromwire_amount_sat */
|
|
struct amount_sat fromwire_amount_sat(const u8 **cursor UNNEEDED, size_t *max UNNEEDED)
|
|
{ fprintf(stderr, "fromwire_amount_sat called!\n"); abort(); }
|
|
/* Generated stub for memleak_remove_htable */
|
|
void memleak_remove_htable(struct htable *memtable UNNEEDED, const struct htable *ht UNNEEDED)
|
|
{ fprintf(stderr, "memleak_remove_htable called!\n"); abort(); }
|
|
/* Generated stub for towire */
|
|
void towire(u8 **pptr UNNEEDED, const void *data UNNEEDED, size_t len UNNEEDED)
|
|
{ fprintf(stderr, "towire called!\n"); abort(); }
|
|
/* Generated stub for towire_amount_sat */
|
|
void towire_amount_sat(u8 **pptr UNNEEDED, const struct amount_sat sat UNNEEDED)
|
|
{ fprintf(stderr, "towire_amount_sat called!\n"); abort(); }
|
|
/* Generated stub for towire_bool */
|
|
void towire_bool(u8 **pptr UNNEEDED, bool v UNNEEDED)
|
|
{ fprintf(stderr, "towire_bool called!\n"); abort(); }
|
|
/* Generated stub for towire_secp256k1_ecdsa_signature */
|
|
void towire_secp256k1_ecdsa_signature(u8 **pptr UNNEEDED,
|
|
const secp256k1_ecdsa_signature *signature UNNEEDED)
|
|
{ fprintf(stderr, "towire_secp256k1_ecdsa_signature called!\n"); abort(); }
|
|
/* Generated stub for towire_sha256 */
|
|
void towire_sha256(u8 **pptr UNNEEDED, const struct sha256 *sha256 UNNEEDED)
|
|
{ fprintf(stderr, "towire_sha256 called!\n"); abort(); }
|
|
/* Generated stub for towire_u16 */
|
|
void towire_u16(u8 **pptr UNNEEDED, u16 v UNNEEDED)
|
|
{ fprintf(stderr, "towire_u16 called!\n"); abort(); }
|
|
/* Generated stub for towire_u32 */
|
|
void towire_u32(u8 **pptr UNNEEDED, u32 v UNNEEDED)
|
|
{ fprintf(stderr, "towire_u32 called!\n"); abort(); }
|
|
/* Generated stub for towire_u64 */
|
|
void towire_u64(u8 **pptr UNNEEDED, u64 v UNNEEDED)
|
|
{ fprintf(stderr, "towire_u64 called!\n"); abort(); }
|
|
/* Generated stub for towire_u8 */
|
|
void towire_u8(u8 **pptr UNNEEDED, u8 v UNNEEDED)
|
|
{ fprintf(stderr, "towire_u8 called!\n"); abort(); }
|
|
/* Generated stub for towire_u8_array */
|
|
void towire_u8_array(u8 **pptr UNNEEDED, const u8 *arr UNNEEDED, size_t num UNNEEDED)
|
|
{ fprintf(stderr, "towire_u8_array called!\n"); abort(); }
|
|
/* AUTOGENERATED MOCKS END */
|
|
|
|
void memleak_add_helper_(const tal_t *p UNNEEDED,
|
|
void (*cb)(struct htable *memtable,
|
|
const tal_t *) UNNEEDED)
|
|
{
|
|
}
|
|
|
|
static u8 *mkgossip(const tal_t *ctx, const char *str)
|
|
{
|
|
return tal_hexdata(ctx, str, strlen(str));
|
|
}
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
const tal_t *ctx = tal(NULL, char);
|
|
struct gossip_rcvd_filter *f = new_gossip_rcvd_filter(ctx);
|
|
const u8 *msg[3], *badmsg;
|
|
|
|
common_setup(argv[0]);
|
|
|
|
msg[0] = mkgossip(ctx, "0100231024fcd59aa58ca8e2ed8f71e07843fc576dd6b2872681960ce64f5f3cd3b5386211a103736bf1de2c03a74f5885d50ea30d21a82e4389339ad13149ac7f52942e6ff0778952b7cb001350d1e2edd25cee80c4c64d624a0273be5436923f5524f1f7e4586007203b2f2c47d6863052529321ebb8e0a171ed013c889bbeaa7a462e9826861c608428509804eb4dd5f75dc5e6baa03205933759fd7abcb2e0304b1a895abb7de3d24e92ade99a6a14f51ac9852ef3daf68b8ad40459d8a6124f23e1271537347b6a1bc9bff1f3e6f60e93177b3bf1d53e76771be9c974ba6b1c6d4916762c0867c13f3617e4893f6272c64fa360aaf6c2a94af7739c498bab3600006fe28c0ab6f1b372c1a6a246ae63f74f931e8365e15a089c68d619000000000008a8090000510000020cf679b34b5819dfbaf68663bdd636c92117b6c04981940e878818b736c0cdb702809e936f0e82dfce13bcc47c77112db068f569e1db29e7bf98bcdd68b838ee8402590349bcd37d04b81022e52bd65d5119a43e0d7b78f526971ede38d2cd1c0d9e02eec6ac38e4acad847cd42b0946977896527b9e1f7dd59525a1a1344a3cea7fa3");
|
|
msg[1] = mkgossip(ctx, "0102ccc0a84e4ce09f522f7765db7c30b822ebb346eb17dda92612d03cc8e53ee1454b6c9a918a60ac971e623fd056687f17a01d3c7e805723f7b68be0e8544013546fe28c0ab6f1b372c1a6a246ae63f74f931e8365e15a089c68d619000000000008a80900005100005d06bacc0102009000000000000003e8000003e8000000010000000005e69ec0");
|
|
msg[2] = mkgossip(ctx, "01017914e70e3ef662e8d75166ea64465f8679d042bdc26b91c7de6d2c5bdd1f73654f4df7c010ea4c41538bbc5f0f6528dfd48097c7c18f3febae4dc36819550c5900005c8d5bac020cf679b34b5819dfbaf68663bdd636c92117b6c04981940e878818b736c0cdb73399ff5468655f4c656176696e677300000000000000000000000000000000000000000007018e3b64fd2607");
|
|
|
|
/* Not a gossip msg. */
|
|
badmsg = tal_hexdata(ctx, "00100000", strlen("00100000"));
|
|
|
|
gossip_rcvd_filter_add(f, msg[0]);
|
|
assert(htable_count(f->cur) == 1);
|
|
assert(htable_count(f->old) == 0);
|
|
|
|
gossip_rcvd_filter_add(f, msg[1]);
|
|
assert(htable_count(f->cur) == 2);
|
|
assert(htable_count(f->old) == 0);
|
|
|
|
gossip_rcvd_filter_add(f, msg[2]);
|
|
assert(htable_count(f->cur) == 3);
|
|
assert(htable_count(f->old) == 0);
|
|
|
|
gossip_rcvd_filter_add(f, badmsg);
|
|
assert(htable_count(f->cur) == 3);
|
|
assert(htable_count(f->old) == 0);
|
|
|
|
assert(gossip_rcvd_filter_del(f, msg[0]));
|
|
assert(htable_count(f->cur) == 2);
|
|
assert(htable_count(f->old) == 0);
|
|
assert(!gossip_rcvd_filter_del(f, msg[0]));
|
|
assert(htable_count(f->cur) == 2);
|
|
assert(htable_count(f->old) == 0);
|
|
assert(gossip_rcvd_filter_del(f, msg[1]));
|
|
assert(htable_count(f->cur) == 1);
|
|
assert(htable_count(f->old) == 0);
|
|
assert(!gossip_rcvd_filter_del(f, msg[1]));
|
|
assert(htable_count(f->cur) == 1);
|
|
assert(htable_count(f->old) == 0);
|
|
assert(gossip_rcvd_filter_del(f, msg[2]));
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 0);
|
|
assert(!gossip_rcvd_filter_del(f, msg[2]));
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 0);
|
|
assert(!gossip_rcvd_filter_del(f, badmsg));
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 0);
|
|
|
|
/* Re-add them, and age. */
|
|
gossip_rcvd_filter_add(f, msg[0]);
|
|
gossip_rcvd_filter_add(f, msg[1]);
|
|
gossip_rcvd_filter_add(f, msg[2]);
|
|
assert(htable_count(f->cur) == 3);
|
|
assert(htable_count(f->old) == 0);
|
|
|
|
gossip_rcvd_filter_age(f);
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 3);
|
|
|
|
/* Delete 1 and 2. */
|
|
assert(gossip_rcvd_filter_del(f, msg[2]));
|
|
assert(gossip_rcvd_filter_del(f, msg[1]));
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 1);
|
|
assert(!gossip_rcvd_filter_del(f, msg[2]));
|
|
assert(!gossip_rcvd_filter_del(f, msg[1]));
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 1);
|
|
assert(!gossip_rcvd_filter_del(f, badmsg));
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 1);
|
|
|
|
/* Re-add 2, and age. */
|
|
gossip_rcvd_filter_add(f, msg[2]);
|
|
assert(htable_count(f->cur) == 1);
|
|
assert(htable_count(f->old) == 1);
|
|
|
|
gossip_rcvd_filter_age(f);
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 1);
|
|
|
|
/* Now, only 2 remains. */
|
|
assert(!gossip_rcvd_filter_del(f, msg[0]));
|
|
assert(!gossip_rcvd_filter_del(f, msg[1]));
|
|
assert(gossip_rcvd_filter_del(f, msg[2]));
|
|
assert(!gossip_rcvd_filter_del(f, msg[2]));
|
|
assert(htable_count(f->cur) == 0);
|
|
assert(htable_count(f->old) == 0);
|
|
|
|
/* They should have no children, and f should only have 2. */
|
|
assert(!tal_first(f->cur));
|
|
assert(!tal_first(f->old));
|
|
|
|
assert((tal_first(f) == f->cur
|
|
&& tal_next(f->cur) == f->old
|
|
&& tal_next(f->old) == NULL)
|
|
|| (tal_first(f) == f->old
|
|
&& tal_next(f->old) == f->cur
|
|
&& tal_next(f->cur) == NULL));
|
|
|
|
tal_free(ctx);
|
|
common_shutdown();
|
|
return 0;
|
|
}
|
|
|