Skip to content

Commit

Permalink
Rename BaseMessage to BaseRaftMessage
Browse files Browse the repository at this point in the history
  • Loading branch information
davidegrohmann committed Aug 16, 2016
1 parent 102ae1e commit 192e0b5
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 14 deletions.
Expand Up @@ -92,7 +92,7 @@ public String toString()

interface Vote
{
class Request extends BaseMessage
class Request extends BaseRaftMessage
{
private long term;
private MemberId candidate;
Expand Down Expand Up @@ -164,7 +164,7 @@ public MemberId candidate()
}
}

class Response extends BaseMessage
class Response extends BaseRaftMessage
{
private long term;
private boolean voteGranted;
Expand Down Expand Up @@ -222,7 +222,7 @@ public boolean voteGranted()

interface AppendEntries
{
class Request extends BaseMessage
class Request extends BaseRaftMessage
{
private long leaderTerm;
private long prevLogIndex;
Expand Down Expand Up @@ -303,7 +303,7 @@ public String toString()
}
}

class Response extends BaseMessage
class Response extends BaseRaftMessage
{
private long term;
private boolean success;
Expand Down Expand Up @@ -376,7 +376,7 @@ public String toString()
}
}

class Heartbeat extends BaseMessage
class Heartbeat extends BaseRaftMessage
{
private long leaderTerm;
private long commitIndex;
Expand Down Expand Up @@ -446,7 +446,7 @@ public String toString()
}
}

class LogCompactionInfo extends BaseMessage
class LogCompactionInfo extends BaseRaftMessage
{
private long leaderTerm;
private long prevIndex;
Expand Down Expand Up @@ -508,7 +508,7 @@ public String toString()

interface Timeout
{
class Election extends BaseMessage
class Election extends BaseRaftMessage
{
public Election( MemberId from )
{
Expand All @@ -522,7 +522,7 @@ public String toString()
}
}

class Heartbeat extends BaseMessage
class Heartbeat extends BaseRaftMessage
{
public Heartbeat( MemberId from )
{
Expand All @@ -539,7 +539,7 @@ public String toString()

interface NewEntry
{
class Request extends BaseMessage
class Request extends BaseRaftMessage
{
private ReplicatedContent content;

Expand Down Expand Up @@ -584,7 +584,7 @@ public ReplicatedContent content()
}
}

class Batch extends BaseMessage
class Batch extends BaseRaftMessage
{
private List<ReplicatedContent> list;

Expand Down Expand Up @@ -684,12 +684,12 @@ public String toString()

}

abstract class BaseMessage implements RaftMessage
abstract class BaseRaftMessage implements RaftMessage
{
protected MemberId from;
private Type type;

public BaseMessage( MemberId from, Type type )
public BaseRaftMessage( MemberId from, Type type )
{
this.from = from;
this.type = type;
Expand Down Expand Up @@ -718,7 +718,7 @@ public boolean equals( Object o )
{
return false;
}
BaseMessage that = (BaseMessage) o;
BaseRaftMessage that = (BaseRaftMessage) o;
return Objects.equals( from, that.from ) && type == that.type;
}

Expand Down
Expand Up @@ -37,7 +37,7 @@ private Matchers()
{
}

public static Matcher<? super List<RaftMessages.RaftMessage>> hasMessage( RaftMessages.BaseMessage message )
public static Matcher<? super List<RaftMessages.RaftMessage>> hasMessage( RaftMessages.BaseRaftMessage message )
{
return new TypeSafeMatcher<List<RaftMessages.RaftMessage>>()
{
Expand Down

0 comments on commit 192e0b5

Please sign in to comment.