Author: eevans
Date: Tue Dec 29 21:33:52 2009
New Revision: 894486
URL: http://svn.apache.org/viewvc?rev=894486&view=rev
Log:
audit classes implementing Serializable
Patch by eevans for CASSANDRA-655
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationMessage.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/StreamInitiateMessage.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Header.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Message.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/io/StreamContextManager.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageLoadBalancer.java
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java?rev=894486&r1=894485&r2=894486&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java
(original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java
Tue Dec 29 21:33:52 2009
@@ -22,7 +22,6 @@
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
-import java.io.Serializable;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
@@ -43,7 +42,7 @@
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.concurrent.StageManager;
-public class RowMutation implements Serializable
+public class RowMutation
{
private static ICompactSerializer<RowMutation> serializer_;
public static final String HINT = "HINT";
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationMessage.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationMessage.java?rev=894486&r1=894485&r2=894486&view=diff
==============================================================================
---
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationMessage.java
(original)
+++
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationMessage.java
Tue Dec 29 21:33:52 2009
@@ -22,7 +22,6 @@
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
-import java.io.Serializable;
import javax.xml.bind.annotation.XmlElement;
@@ -32,7 +31,7 @@
import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.concurrent.StageManager;
-public class RowMutationMessage implements Serializable
+public class RowMutationMessage
{
public static final String hint_ = "HINT";
private static RowMutationMessageSerializer serializer_ = new
RowMutationMessageSerializer();
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/StreamInitiateMessage.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/StreamInitiateMessage.java?rev=894486&r1=894485&r2=894486&view=diff
==============================================================================
---
incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/StreamInitiateMessage.java
(original)
+++
incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/StreamInitiateMessage.java
Tue Dec 29 21:33:52 2009
@@ -22,7 +22,6 @@
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
-import java.io.Serializable;
import org.apache.cassandra.io.ICompactSerializer;
import org.apache.cassandra.net.Message;
@@ -30,7 +29,7 @@
import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.utils.FBUtilities;
-public class StreamInitiateMessage implements Serializable
+public class StreamInitiateMessage
{
private static ICompactSerializer<StreamInitiateMessage> serializer_;
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Header.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Header.java?rev=894486&r1=894485&r2=894486&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Header.java
(original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Header.java Tue
Dec 29 21:33:52 2009
@@ -28,9 +28,8 @@
import org.apache.cassandra.io.ICompactSerializer;
import org.apache.cassandra.utils.GuidGenerator;
-public class Header implements java.io.Serializable
+public class Header
{
- static final long serialVersionUID = -3194851946523170022L;
private static ICompactSerializer<Header> serializer_;
private static AtomicInteger idGen_ = new AtomicInteger(0);
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Message.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Message.java?rev=894486&r1=894485&r2=894486&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Message.java
(original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/net/Message.java
Tue Dec 29 21:33:52 2009
@@ -26,9 +26,8 @@
import org.apache.cassandra.io.ICompactSerializer;
-public class Message implements java.io.Serializable
-{
- static final long serialVersionUID = 6329198792470413221L;
+public class Message
+{
private static ICompactSerializer<Message> serializer_;
static
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/io/StreamContextManager.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/io/StreamContextManager.java?rev=894486&r1=894485&r2=894486&view=diff
==============================================================================
---
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/io/StreamContextManager.java
(original)
+++
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/io/StreamContextManager.java
Tue Dec 29 21:33:52 2009
@@ -22,7 +22,6 @@
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
-import java.io.Serializable;
import java.util.*;
import java.net.InetAddress;
@@ -43,7 +42,7 @@
STREAM
}
- public static class StreamContext implements Serializable
+ public static class StreamContext
{
private static ICompactSerializer<StreamContext> serializer_;
@@ -126,7 +125,7 @@
}
}
- public static class StreamStatus implements Serializable
+ public static class StreamStatus
{
private static ICompactSerializer<StreamStatus> serializer_;
@@ -201,7 +200,7 @@
}
}
- public static class StreamStatusMessage implements Serializable
+ public static class StreamStatusMessage
{
private static ICompactSerializer<StreamStatusMessage> serializer_;
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageLoadBalancer.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageLoadBalancer.java?rev=894486&r1=894485&r2=894486&view=diff
==============================================================================
---
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageLoadBalancer.java
(original)
+++
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageLoadBalancer.java
Tue Dec 29 21:33:52 2009
@@ -18,7 +18,6 @@
package org.apache.cassandra.service;
-import java.io.Serializable;
import java.util.*;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.atomic.AtomicBoolean;
@@ -387,7 +386,7 @@
}
}
-class MoveMessage implements Serializable
+class MoveMessage
{
private final Token targetToken_;
