Unverified Commit c5aee21b authored by Ozan Tezcan's avatar Ozan Tezcan Committed by GitHub
Browse files

Use raft_size_t for entry len (#160)

Currently, entry len type is unsigned int which limits entry size to 4 gb.
Changing it to raft_size_t (unsigned long long) to allow larger entries.
parent ef5d4ebb
...@@ -110,7 +110,7 @@ typedef struct raft_entry ...@@ -110,7 +110,7 @@ typedef struct raft_entry
void (*free_func) (struct raft_entry *entry); void (*free_func) (struct raft_entry *entry);
/** data length */ /** data length */
unsigned int data_len; raft_size_t data_len;
/** data */ /** data */
char data[]; char data[];
...@@ -1401,7 +1401,7 @@ void *raft_get_log(raft_server_t* me); ...@@ -1401,7 +1401,7 @@ void *raft_get_log(raft_server_t* me);
* initial refcount value of 1. Calling raft_entry_release() immediately would * initial refcount value of 1. Calling raft_entry_release() immediately would
* therefore result with deallocation. * therefore result with deallocation.
*/ */
raft_entry_t *raft_entry_new(unsigned int data_len); raft_entry_t *raft_entry_new(raft_size_t data_len);
/** Hold the raft_entry_t, i.e. increment refcount by one. /** Hold the raft_entry_t, i.e. increment refcount by one.
*/ */
......
...@@ -1159,7 +1159,7 @@ int raft_recv_entry(raft_server_t *me, ...@@ -1159,7 +1159,7 @@ int raft_recv_entry(raft_server_t *me,
r->term = me->current_term; r->term = me->current_term;
} }
raft_log(me, "recv entry t:%ld, id:%d, type:%d, len:%d. assigned idx:%ld", raft_log(me, "recv entry t:%ld, id:%d, type:%d, len:%llu. assigned idx:%ld",
ety->term, ety->id, ety->type, ety->data_len, ety->term, ety->id, ety->type, ety->data_len,
raft_get_current_idx(me)); raft_get_current_idx(me));
...@@ -1243,7 +1243,7 @@ int raft_apply_entry(raft_server_t* me) ...@@ -1243,7 +1243,7 @@ int raft_apply_entry(raft_server_t* me)
if (!ety) if (!ety)
return -1; return -1;
raft_log(me, "applying log: %ld, id: %d size: %d", raft_log(me, "applying log: %ld, id: %d size: %llu",
idx, ety->id, ety->data_len); idx, ety->id, ety->data_len);
if (me->cb.applylog) if (me->cb.applylog)
...@@ -1900,7 +1900,7 @@ void *raft_get_log(raft_server_t *me) ...@@ -1900,7 +1900,7 @@ void *raft_get_log(raft_server_t *me)
return me->log; return me->log;
} }
raft_entry_t *raft_entry_new(unsigned int data_len) raft_entry_t *raft_entry_new(raft_size_t data_len)
{ {
raft_entry_t *ety = raft_calloc(1, sizeof(raft_entry_t) + data_len); raft_entry_t *ety = raft_calloc(1, sizeof(raft_entry_t) + data_len);
ety->data_len = data_len; ety->data_len = data_len;
......
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