ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java (4 lines): - line 1022: // TODO: this client request will not be added to pending requests until - line 1751: // TODO: should pause() be limited on only working for a follower? - line 1760: // TODO: any other operations that needs to be paused? - line 1772: // TODO: any other operations that needs to be resumed? ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLog.java (3 lines): - line 262: // TODO we should let raft peer persist its committed index periodically - line 363: // TODO if the cache is hitting the maximum size and we cannot evict any - line 544: // TODO purge normal/tmp/corrupt snapshot files ratis-server/src/main/java/org/apache/ratis/server/storage/SnapshotManager.java (2 lines): - line 51: * TODO: snapshot should be treated as compaction log thus can be merged into - line 114: // TODO: Make sure that subsequent requests for the same installSnapshot are coming in order, ratis-proto/src/main/proto/RMap.proto (2 lines): - line 24: // TODO: This .proto file should go to the ratis-replicated-map module, but we need it here - line 44: // TODO: raft client should allow a Service decleration, and calling a method from the service ratis-server/src/main/java/org/apache/ratis/statemachine/impl/TransactionContextImpl.java (2 lines): - line 222: // TODO: Hook this up in the server to bypass the RAFT Log and send back a response to client - line 233: // TODO: This is not called from Raft server / log yet. When an IOException happens, we should ratis-server/src/main/java/org/apache/ratis/server/impl/ConfigurationManager.java (1 line): - line 117: // TODO: remove Configuration entries after they are committed ratis-client/src/main/java/org/apache/ratis/client/impl/DataStreamClientImpl.java (1 line): - line 139: // TODO: RATIS-1938: In order not to auto-flush the header, remove the FLUSH below. ratis-common/src/main/java/org/apache/ratis/util/MD5FileUtil.java (1 line): - line 39: // TODO: we should provide something like Hadoop's checksum fs for the local filesystem ratis-common/src/main/java/org/apache/ratis/util/LeakDetector.java (1 line): - line 152: // TODO: A rate filter can be put here to only track a subset of all objects, e.g. 5%, 10%, ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcClientProtocolService.java (1 line): - line 265: // TODO: the exception may be from either raft or state machine. ratis-server-api/src/main/java/org/apache/ratis/statemachine/StateMachineStorage.java (1 line): - line 34: // TODO: StateMachine can decide to compact the files independently of concurrent install snapshot ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientRpc.java (1 line): - line 125: // TODO: timeout support ratis-server/src/main/java/org/apache/ratis/server/impl/ServerState.java (1 line): - line 457: // TODO: verify that we need to install the snapshot ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/LogSegment.java (1 line): - line 183: // TODO: use reference count to support zero buffer copying for readSegmentFile ratis-server-api/src/main/java/org/apache/ratis/statemachine/StateMachine.java (1 line): - line 524: // TODO: refactor this ratis-proto/src/main/proto/Raft.proto (1 line): - line 73: // TODO: This is not super efficient if the SM itself uses PB to serialize its own data for a ratis-server/src/main/java/org/apache/ratis/server/leader/LogAppenderDefault.java (1 line): - line 83: // TODO should have more detailed retry policy here. ratis-server/src/main/java/org/apache/ratis/server/impl/SnapshotInstallationHandler.java (1 line): - line 216: //TODO: We should only update State with installed snapshot once the request is done. ratis-client/src/main/java/org/apache/ratis/client/impl/OrderedAsync.java (1 line): - line 123: // TODO: this is a work around, it is better to fix the underlying RPC implementation