Skip to content

Commit e7e46a2

Browse files
committed
remove some comments
1 parent 77a982c commit e7e46a2

File tree

3 files changed

+2
-6
lines changed

3 files changed

+2
-6
lines changed

README.md

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,6 @@ It is asynchronous(built on tokio runtime) and supports zero-copy. It does not a
2929
- [ ] Complete batch write implementation
3030
- [ ] Improve Log compaction
3131
- [ ] RDMA support
32-
- [ ] Add more comprehensive tests
33-
- [ ] Enhance documentation
3432
- [ ] Deterministic Simulation Testing
3533
- [ ] Benchmarking
3634

examples/simulate_replica_repair.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ async fn main() {
4949
let cc = cluster_config.clone();
5050
let server_handle = tokio::spawn(async move {
5151
// Simulate storage corruption when starting up
52-
let storage_location = "logs".to_string();
52+
let storage_location = "logs/".to_string();
5353
let corrupted = rand::thread_rng().gen_bool(0.3); // 30% chance of corruption
5454
if corrupted {
5555
fs::create_dir_all(&storage_location).unwrap();

src/server.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -266,8 +266,6 @@ impl Server {
266266
// Vote for self
267267
self.state.voted_for = Some(self.id);
268268
self.state.votes_received.insert(self.id, true);
269-
270-
// TODO: Send RequestVote RPCs with leadership preferences
271269
let data = self.prepare_request_vote(self.id, self.state.current_term);
272270
let addresses: Vec<SocketAddr> = self.peers_address();
273271
info!(
@@ -678,7 +676,7 @@ impl Server {
678676

679677
info!(
680678
self.log,
681-
"Append entry response received from node {}: (match_index = {}, next_index = {}), current quorum_index: {}",
679+
"Append entry response received from node {}: (match_index = {}, next_index = {}), current quorum_index: {}",
682680
sender_id,
683681
self.state.match_index[sender_id as usize - 1],
684682
self.state.next_index[sender_id as usize - 1],

0 commit comments

Comments
 (0)