Skip to content

Devnet 3 #70

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
uink45 merged 4 commits into from
Mar 10, 2026
Merged

Devnet 3 #70

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
a4de158
Refactor attestation collection, prune gossip
uink45 Mar 9, 2026
fe61508
Use cached fork-choice head state & refine gossip cache
uink45 Mar 9, 2026
c0644f3
Cache block proofs and proposer attestations
uink45 Mar 9, 2026
6f2574a
Buffer and replay pending gossip votes
uink45 Mar 10, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions include/lantern/consensus/store.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -110,6 +110,9 @@ int lantern_store_get_gossip_signature(
const LanternStore *store,
const LanternSignatureKey *key,
LanternSignature *out_signature);
int lantern_store_remove_gossip_signature(
LanternStore *store,
const LanternSignatureKey *key);
int lantern_store_add_new_aggregated_payload(
LanternStore *store,
const LanternRoot *data_root,
Expand Down
14 changes: 14 additions & 0 deletions include/lantern/core/client.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@ extern "C" {
#define LANTERN_DEFAULT_METRICS_PORT 8080
#define LANTERN_DEFAULT_DEVNET "devnet0"
#define LANTERN_PENDING_BLOCK_LIMIT 1024u
#define LANTERN_PENDING_GOSSIP_VOTE_LIMIT 1024u

typedef enum
{
Expand Down Expand Up @@ -119,6 +120,17 @@ struct lantern_pending_block_list {
struct lantern_pending_parent_index parent_index;
};

struct lantern_pending_vote {
LanternSignedVote vote;
char peer_text[128];
};

struct lantern_pending_vote_list {
struct lantern_pending_vote *items;
size_t length;
size_t capacity;
};

struct lantern_active_blocks_request {
uint64_t request_id;
char peer_id[128];
Expand Down Expand Up @@ -220,6 +232,7 @@ struct lantern_client {
struct lantern_string_list inbound_peer_ids;
struct lantern_string_list status_failure_peer_ids;
struct lantern_pending_block_list pending_blocks;
struct lantern_pending_vote_list pending_gossip_votes;
pthread_mutex_t pending_lock;
bool pending_lock_initialized;
LanternRoot sync_last_requested_root;
Expand Down Expand Up @@ -342,6 +355,7 @@ int lantern_client_debug_import_block(
const LanternRoot *block_root,
const char *peer_id_text);
size_t lantern_client_pending_block_count(const struct lantern_client *client);
size_t lantern_client_pending_vote_count(const struct lantern_client *client);

#define LANTERN_TEST_BLOCKS_REQUEST_SUCCESS 0
#define LANTERN_TEST_BLOCKS_REQUEST_FAILED 1
Expand Down
Loading