log enrty indises for logging should be "absolute", i.e. contain base…

… offset
willemt · Jun 22, 2017 · b8dacf0 · b8dacf0
1 parent 9651a97
commit b8dacf0
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/raft_log.c b/src/raft_log.c
@@ -106,8 +106,8 @@ int log_append_entry(log_t* me_, raft_entry_t* c)
     if (me->cb && me->cb->log_offer)
     {
         void* ud = raft_get_udata(me->raft);
-        e = me->cb->log_offer(me->raft, ud, c, me->back);
-        raft_offer_log(me->raft, c, me->back);
+        e = me->cb->log_offer(me->raft, ud, c, me->back + 1 + me->base);
+        raft_offer_log(me->raft, c, me->back + 1 + me->base);
         if (e == RAFT_ERR_SHUTDOWN)
             return e;
     }
@@ -184,8 +184,8 @@ void log_delete(log_t* me_, int idx)
     {
         if (me->cb && me->cb->log_pop)
             me->cb->log_pop(me->raft, raft_get_udata(me->raft),
-                            &me->entries[me->back - 1], me->back);
-        raft_pop_log(me->raft, &me->entries[me->back - 1], me->back);
+                            &me->entries[me->back - 1], me->back + me->base);
+        raft_pop_log(me->raft, &me->entries[me->back - 1], me->back + me->base);
         me->back--;
         me->count--;
     }
@@ -201,7 +201,7 @@ void *log_poll(log_t * me_)
     const void *elem = &me->entries[me->front];
     if (me->cb && me->cb->log_poll)
         me->cb->log_poll(me->raft, raft_get_udata(me->raft),
-                         &me->entries[me->front], me->front);
+                         &me->entries[me->front], me->front + 1 + me->base);
     me->front++;
     me->count--;
     me->base++;