Skip to content

Commit d29857c

Browse files
committed
Make private raft methods 'static'.
1 parent 9e4385a commit d29857c

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

contrib/pg_dtm/dtmd/src/raft.c

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ static void raft_server_init(raft_server_t *s) {
1515
s->port = DEFAULT_LISTENPORT;
1616
}
1717

18-
void raft_reset_timer(raft_t *r) {
18+
static void raft_reset_timer(raft_t *r) {
1919
if (r->role == ROLE_LEADER) {
2020
r->timer = HEARTBEAT_TIMEOUT_MS;
2121
} else {
@@ -186,7 +186,7 @@ static void raft_send(raft_t *r, int dst, void *m, int mlen) {
186186
}
187187
}
188188

189-
void raft_beat(raft_t *r, int dst) {
189+
static void raft_beat(raft_t *r, int dst) {
190190
if (dst == NOBODY) {
191191
// send a beat/update to everybody
192192
int i;
@@ -235,7 +235,7 @@ void raft_beat(raft_t *r, int dst) {
235235
raft_send(r, dst, &m, sizeof(m));
236236
}
237237

238-
void raft_claim(raft_t *r) {
238+
static void raft_claim(raft_t *r) {
239239
assert(r->role == ROLE_CANDIDATE);
240240
assert(r->leader == NOBODY);
241241

@@ -414,7 +414,7 @@ static bool log_append(raft_log_t *l, int previndex, int prevterm, raft_entry_t
414414
return true;
415415
}
416416

417-
void raft_handle_update(raft_t *r, raft_msg_update_t *m) {
417+
static void raft_handle_update(raft_t *r, raft_msg_update_t *m) {
418418
int sender = m->msg.from;
419419

420420
raft_msg_done_t reply;
@@ -492,7 +492,7 @@ static void raft_refresh_acked(raft_t *r) {
492492
}
493493
}
494494

495-
void raft_handle_done(raft_t *r, raft_msg_done_t *m) {
495+
static void raft_handle_done(raft_t *r, raft_msg_done_t *m) {
496496
if (r->role != ROLE_LEADER) {
497497
return;
498498
}
@@ -539,7 +539,7 @@ static void raft_set_term(raft_t *r, int term) {
539539
r->votes = 0;
540540
}
541541

542-
void raft_handle_claim(raft_t *r, raft_msg_claim_t *m) {
542+
static void raft_handle_claim(raft_t *r, raft_msg_claim_t *m) {
543543
int candidate = m->msg.from;
544544

545545
if (m->msg.term >= r->term) {
@@ -579,7 +579,7 @@ void raft_handle_claim(raft_t *r, raft_msg_claim_t *m) {
579579
raft_send(r, candidate, &reply, sizeof(reply));
580580
}
581581

582-
void raft_handle_vote(raft_t *r, raft_msg_vote_t *m) {
582+
static void raft_handle_vote(raft_t *r, raft_msg_vote_t *m) {
583583
int sender = m->msg.from;
584584
raft_server_t *server = r->servers + sender;
585585
if (m->msg.seqno != server->seqno) return;

0 commit comments

Comments
 (0)