Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160496553
--- Diff: src/java/org/apache/cassandra/hadoop/ConfigHelper.java ---
@@ -349,6 +350,16 @@ public static String
getOutputInitialAddress(Configuration con
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160518717
--- Diff:
src/java/org/apache/cassandra/net/CompactEndpointSerializationHelper.java ---
@@ -21,28 +21,142 @@
import java.net.Inet4Address;
imp
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160533135
--- Diff: src/java/org/apache/cassandra/net/ForwardToContainer.java ---
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160535682
--- Diff: src/java/org/apache/cassandra/net/MessageDeliveryTask.java ---
@@ -96,19 +98,11 @@ private void handleFailure(Throwable t)
if (mes
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160520881
--- Diff:
src/java/org/apache/cassandra/net/CompactEndpointSerializationHelper.java ---
@@ -21,28 +21,142 @@
import java.net.Inet4Address;
imp
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160490807
--- Diff: src/java/org/apache/cassandra/gms/Gossiper.java ---
@@ -623,18 +641,19 @@ else if
(newState.getHeartBeatState().getHeartBeatVersion() != heart
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160490410
--- Diff: src/java/org/apache/cassandra/gms/Gossiper.java ---
@@ -319,14 +323,25 @@ public long getEndpointDowntime(InetAddress ep)
retu
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160496090
--- Diff: src/java/org/apache/cassandra/gms/VersionedValue.java ---
@@ -138,6 +139,11 @@ public VersionedValue bootReplacing(InetAddress
oldNode)
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160491216
--- Diff: src/java/org/apache/cassandra/gms/Gossiper.java ---
@@ -1112,21 +1131,34 @@ public boolean isSilentShutdownState(EndpointState
epState)
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160285588
--- Diff: src/java/org/apache/cassandra/db/SystemKeyspace.java ---
@@ -607,39 +672,65 @@ public static long getTruncatedAt(TableId id)
/**
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160539548
--- Diff: src/java/org/apache/cassandra/net/MessageOut.java ---
@@ -80,12 +81,17 @@
public class MessageOut
{
private static final int
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160283145
--- Diff:
src/java/org/apache/cassandra/db/LegacySystemKeyspaceMigrator.java ---
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the Apache Software Found
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160276907
--- Diff:
src/java/org/apache/cassandra/db/LegacySystemKeyspaceMigrator.java ---
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the Apache Software Found
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160538757
--- Diff: src/java/org/apache/cassandra/net/MessageOut.java ---
@@ -133,11 +139,13 @@ public MessageOut(InetAddress from,
MessagingService.Verb verb, T
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160540192
--- Diff: src/java/org/apache/cassandra/net/MessageOut.java ---
@@ -80,12 +81,17 @@
public class MessageOut
{
private static final int
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160281918
--- Diff:
src/java/org/apache/cassandra/db/LegacySystemKeyspaceMigrator.java ---
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the Apache Software Found
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160523743
--- Diff:
src/java/org/apache/cassandra/net/CompactEndpointSerializationHelper.java ---
@@ -21,28 +21,142 @@
import java.net.Inet4Address;
imp
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160537959
--- Diff: src/java/org/apache/cassandra/net/MessageIn.java ---
@@ -89,37 +88,39 @@ private MessageIn(InetAddress from,
public static Mess
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160495552
--- Diff: src/java/org/apache/cassandra/gms/Gossiper.java ---
@@ -1207,12 +1239,27 @@ private void applyNewStates(InetAddress addr,
EndpointState localS
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160284046
--- Diff: src/java/org/apache/cassandra/db/SystemKeyspace.java ---
@@ -91,47 +92,52 @@ private SystemKeyspace()
public static final String PAXOS
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r159255891
--- Diff: src/java/org/apache/cassandra/locator/InetAddressAndPort.java ---
@@ -0,0 +1,193 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160288035
--- Diff:
src/java/org/apache/cassandra/db/commitlog/CommitLogDescriptor.java ---
@@ -40,6 +40,7 @@
import org.apache.cassandra.config.Parameterize
22 matches
Mail list logo
