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

Delete unused connection data (#90)

parent db36d981
......@@ -12,13 +12,6 @@
#include "raft_types.h"
enum {
RAFT_NODE_STATUS_DISCONNECTED,
RAFT_NODE_STATUS_CONNECTED,
RAFT_NODE_STATUS_CONNECTING,
RAFT_NODE_STATUS_DISCONNECTING
};
struct raft_log_impl;
typedef struct raft_read_request {
......@@ -88,10 +81,6 @@ typedef struct {
/* the log which has a voting cfg change, otherwise -1 */
raft_index_t voting_cfg_change_log_idx;
/* Our membership with the cluster is confirmed (ie. configuration log was
* committed) */
int connected;
int snapshot_in_progress;
int snapshot_flags;
......
......@@ -1254,10 +1254,7 @@ int raft_apply_entry(raft_server_t* me_)
case RAFT_LOGTYPE_ADD_NODE:
raft_node_set_addition_committed(node, 1);
raft_node_set_voting_committed(node, 1);
/* Membership Change: confirm connection with cluster */
raft_node_set_has_sufficient_logs(node);
if (node_id == raft_get_nodeid(me_))
me->connected = RAFT_NODE_STATUS_CONNECTED;
break;
case RAFT_LOGTYPE_ADD_NONVOTING_NODE:
raft_node_set_addition_committed(node, 1);
......
......@@ -232,11 +232,6 @@ raft_term_t raft_get_last_log_term(raft_server_t* me_)
return 0;
}
int raft_is_connected(raft_server_t* me_)
{
return ((raft_server_private_t*)me_)->connected;
}
int raft_snapshot_is_in_progress(raft_server_t *me_)
{
return ((raft_server_private_t*)me_)->snapshot_in_progress;
......
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