Skip to content

Commit

Permalink
Merge pull request #448 from rystsov/fix-idempotent-init-rpc
Browse files Browse the repository at this point in the history
fixes skewed merge of id_allocator
  • Loading branch information
Alexander Gallego committed Jan 22, 2021
2 parents 230f3fd + 3f00ef2 commit bc1c80a
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/v/cluster/controller.h
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ class controller {
ss::sharded<shard_table>& st,
ss::sharded<storage::api>& storage);

model::node_id self() { return _raft0->self(); }
model::node_id self() { return _raft0->self().id(); }
ss::sharded<topics_frontend>& get_topics_frontend() { return _tp_frontend; }
ss::sharded<members_manager>& get_members_manager() {
return _members_manager;
Expand Down
2 changes: 1 addition & 1 deletion src/v/raft/id_allocator_stm.h
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ class id_allocator_stm final : public raft::state_machine {
private:
struct sequence_id {
model::run_id run_id;
model::node_id node_id;
raft::vnode node_id;
int64_t tick;

bool operator==(const sequence_id& other) const {
Expand Down

0 comments on commit bc1c80a

Please sign in to comment.