Commit 8fb1f6c0 authored by Willem Thiart's avatar Willem Thiart
Browse files

Remove num_nodes from raft_entry_t

parent 14d65292
...@@ -138,9 +138,6 @@ typedef struct ...@@ -138,9 +138,6 @@ typedef struct
/** the entry's unique ID */ /** the entry's unique ID */
unsigned int id; unsigned int id;
/** number of nodes that have this entry */
unsigned int num_nodes;
raft_entry_data_t data; raft_entry_data_t data;
} raft_entry_t; } raft_entry_t;
......
...@@ -39,8 +39,6 @@ raft_entry_t* log_get_from_idx(log_t* me_, int idx); ...@@ -39,8 +39,6 @@ raft_entry_t* log_get_from_idx(log_t* me_, int idx);
* @return youngest entry */ * @return youngest entry */
raft_entry_t *log_peektail(log_t * me_); raft_entry_t *log_peektail(log_t * me_);
void log_mark_node_has_committed(log_t* me_, int idx);
void log_delete(log_t* me_, int idx); void log_delete(log_t* me_, int idx);
int log_get_current_idx(log_t* me_); int log_get_current_idx(log_t* me_);
......
...@@ -96,7 +96,6 @@ int log_append_entry(log_t* me_, raft_entry_t* c) ...@@ -96,7 +96,6 @@ int log_append_entry(log_t* me_, raft_entry_t* c)
__ensurecapacity(me); __ensurecapacity(me);
memcpy(&me->entries[me->back], c, sizeof(raft_entry_t)); memcpy(&me->entries[me->back], c, sizeof(raft_entry_t));
me->entries[me->back].num_nodes = 0;
if (me->cb && me->cb->log_offer) if (me->cb && me->cb->log_offer)
me->cb->log_offer(me->raft, raft_get_udata(me->raft), c, me->back); me->cb->log_offer(me->raft, raft_get_udata(me->raft), c, me->back);
me->count++; me->count++;
...@@ -192,13 +191,6 @@ void log_free(log_t * me_) ...@@ -192,13 +191,6 @@ void log_free(log_t * me_)
free(me); free(me);
} }
void log_mark_node_has_committed(log_t* me_, int idx)
{
raft_entry_t* e = log_get_from_idx(me_, idx);
if (e)
e->num_nodes += 1;
}
int log_get_current_idx(log_t* me_) int log_get_current_idx(log_t* me_)
{ {
log_private_t* me = (log_private_t*)me_; log_private_t* me = (log_private_t*)me_;
......
#include <stdbool.h> #include <stdbool.h>
#include <assert.h> #include <assert.h>
#include <stdlib.h> #include <stdlib.h>
...@@ -60,21 +59,6 @@ void TestLog_get_at_idx_returns_null_where_out_of_bounds(CuTest * tc) ...@@ -60,21 +59,6 @@ void TestLog_get_at_idx_returns_null_where_out_of_bounds(CuTest * tc)
CuAssertTrue(tc, NULL == log_get_from_idx(l, 2)); CuAssertTrue(tc, NULL == log_get_from_idx(l, 2));
} }
void TestLog_mark_node_has_committed_adds_nodes(CuTest * tc)
{
void *l;
raft_entry_t e1;
l = log_new();
e1.id = 1;
log_append_entry(l, &e1);
CuAssertTrue(tc, 0 == log_get_from_idx(l, 1)->num_nodes);
log_mark_node_has_committed(l, 1);
CuAssertTrue(tc, 1 == log_get_from_idx(l, 1)->num_nodes);
log_mark_node_has_committed(l, 1);
CuAssertTrue(tc, 2 == log_get_from_idx(l, 1)->num_nodes);
}
void TestLog_delete(CuTest * tc) void TestLog_delete(CuTest * tc)
{ {
void *l; void *l;
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment