[infinispan-commits] Infinispan SVN: r1644 - in trunk/server: core/src/main/scala/org/infinispan/server/core/transport and 3 other directories.
infinispan-commits at lists.jboss.org
infinispan-commits at lists.jboss.org
Wed Mar 31 08:55:21 EDT 2010
Author: galder.zamarreno at jboss.com
Date: 2010-03-31 08:55:19 -0400 (Wed, 31 Mar 2010)
New Revision: 1644
Modified:
trunk/server/core/src/main/scala/org/infinispan/server/core/AbstractProtocolDecoder.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/AbstractProtocolServer.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/CacheValue.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/Main.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/Operation.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/ProtocolServer.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/VersionGenerator.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Channel.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelBuffer.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelBuffers.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelFuture.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelHandlerContext.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Decoder.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Encoder.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ExceptionEvent.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Transport.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelAdapter.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelBufferAdapter.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelBuffersAdapter.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelFutureAdapter.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelHandlerContextAdapter.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/DecoderAdapter.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/EncoderAdapter.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ExceptionEventAdapter.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyChannelPipelineFactory.scala
trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyTransport.scala
trunk/server/core/src/test/scala/org/infinispan/server/core/VariableLengthTest.scala
trunk/server/core/src/test/scala/org/infinispan/server/core/VersionGeneratorTest.scala
trunk/server/hotrod/src/main/scala/org/infinispan/server/hotrod/HotRodDecoder.scala
Log:
Updated @since tags.
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/AbstractProtocolDecoder.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/AbstractProtocolDecoder.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/AbstractProtocolDecoder.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -17,9 +17,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class AbstractProtocolDecoder[K, V <: CacheValue] extends Decoder {
import AbstractProtocolDecoder._
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/AbstractProtocolServer.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/AbstractProtocolServer.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/AbstractProtocolServer.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -8,9 +8,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class AbstractProtocolServer extends ProtocolServer {
private var host: String = _
private var port: Int = _
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/CacheValue.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/CacheValue.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/CacheValue.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -7,7 +7,7 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
// TODO: putting Ids.SERVER_CACHE_VALUE fails compilation in 2.8
@Marshallable(externalizer = classOf[CacheValueExternalizer], id = 55)
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/Main.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/Main.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/Main.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -14,9 +14,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
object Main extends Logging {
val PROP_KEY_PORT = "infinispan.server.port"
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/Operation.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/Operation.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/Operation.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -3,9 +3,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
object Operation extends Enumeration {
type Operation = Value
val PutRequest, PutIfAbsentRequest, ReplaceRequest, ReplaceIfUnmodifiedRequest = Value
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/ProtocolServer.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/ProtocolServer.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/ProtocolServer.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -5,9 +5,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
trait ProtocolServer {
def start(host: String, port: Int, cacheManager: CacheManager, masterThreads: Int, workerThreads: Int)
def stop
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/VersionGenerator.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/VersionGenerator.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/VersionGenerator.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -7,9 +7,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
object VersionGenerator {
private val versionCounter = new AtomicInteger
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Channel.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Channel.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Channel.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -3,9 +3,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class Channel {
def write(message: Any): ChannelFuture
def disconnect: ChannelFuture
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelBuffer.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelBuffer.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelBuffer.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -3,9 +3,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class ChannelBuffer {
def readByte: Byte
def readBytes(dst: Array[Byte], dstIndex: Int, length: Int)
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelBuffers.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelBuffers.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelBuffers.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -5,9 +5,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
object ChannelBuffers {
def wrappedBuffer(array: Array[Byte]*): ChannelBuffer = {
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelFuture.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelFuture.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelFuture.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -5,9 +5,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class ChannelFuture {
def getChannel: Channel
def isDone: Boolean
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelHandlerContext.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelHandlerContext.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ChannelHandlerContext.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -3,9 +3,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class ChannelHandlerContext {
def getChannel: Channel
}
\ No newline at end of file
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Decoder.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Decoder.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Decoder.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -3,9 +3,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class Decoder {
def decode(ctx: ChannelHandlerContext, buffer: ChannelBuffer): AnyRef
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Encoder.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Encoder.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Encoder.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -3,9 +3,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class Encoder {
def encode(ctx: ChannelHandlerContext, channel: Channel, msg: AnyRef): AnyRef
}
\ No newline at end of file
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ExceptionEvent.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ExceptionEvent.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/ExceptionEvent.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -3,9 +3,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class ExceptionEvent {
def getCause: Throwable
}
\ No newline at end of file
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Transport.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Transport.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/Transport.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -5,9 +5,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
abstract class Transport {
def start
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelAdapter.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelAdapter.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelAdapter.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -6,9 +6,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
class ChannelAdapter(val ch: NettyChannel) extends Channel {
override def disconnect: ChannelFuture = new ChannelFutureAdapter(ch.disconnect());
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelBufferAdapter.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelBufferAdapter.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelBufferAdapter.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -6,9 +6,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
class ChannelBufferAdapter(val buffer: NettyChannelBuffer) extends ChannelBuffer {
override def readByte: Byte = buffer.readByte
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelBuffersAdapter.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelBuffersAdapter.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelBuffersAdapter.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -6,9 +6,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
object ChannelBuffersAdapter {
def wrappedBuffer(array: Array[Byte]*): ChannelBuffer = {
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelFutureAdapter.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelFutureAdapter.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelFutureAdapter.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -7,9 +7,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
class ChannelFutureAdapter(val future: NettyChannelFuture) extends ChannelFuture {
override def getChannel: Channel = new ChannelAdapter(future.getChannel())
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelHandlerContextAdapter.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelHandlerContextAdapter.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ChannelHandlerContextAdapter.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -6,9 +6,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
class ChannelHandlerContextAdapter(val ctx: NettyChannelHandlerContext) extends ChannelHandlerContext {
override def getChannel: Channel = new ChannelAdapter(ctx.getChannel)
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/DecoderAdapter.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/DecoderAdapter.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/DecoderAdapter.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -8,9 +8,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
class DecoderAdapter(decoder: Decoder) extends ReplayingDecoder[NoState](true) {
override def decode(nCtx: NettyChannelHandlerContext, channel: NettyChannel,
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/EncoderAdapter.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/EncoderAdapter.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/EncoderAdapter.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -9,9 +9,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
@ChannelHandler.Sharable
class EncoderAdapter(encoder: Encoder) extends OneToOneEncoder {
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ExceptionEventAdapter.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ExceptionEventAdapter.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/ExceptionEventAdapter.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -6,9 +6,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
class ExceptionEventAdapter(event: NettyExceptionEvent) extends ExceptionEvent {
override def getCause: Throwable = return event.getCause
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyChannelPipelineFactory.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyChannelPipelineFactory.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyChannelPipelineFactory.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -5,9 +5,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
class NettyChannelPipelineFactory(decoder: ChannelUpstreamHandler, encoder: ChannelDownstreamHandler)
extends ChannelPipelineFactory {
Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyTransport.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyTransport.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyTransport.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -14,9 +14,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
class NettyTransport(decoder: ChannelUpstreamHandler, encoder: ChannelDownstreamHandler,
address: SocketAddress, masterThreads: Int, workerThreads: Int, cacheName: String) extends Transport {
import NettyTransport._
Modified: trunk/server/core/src/test/scala/org/infinispan/server/core/VariableLengthTest.scala
===================================================================
--- trunk/server/core/src/test/scala/org/infinispan/server/core/VariableLengthTest.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/test/scala/org/infinispan/server/core/VariableLengthTest.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -14,7 +14,6 @@
* @author Galder Zamarreño
* @since 4.1
*/
-
@Test(groups = Array("functional"), testName = "server.hotrod.VariableLengthTest")
class VariableLengthTest {
Modified: trunk/server/core/src/test/scala/org/infinispan/server/core/VersionGeneratorTest.scala
===================================================================
--- trunk/server/core/src/test/scala/org/infinispan/server/core/VersionGeneratorTest.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/core/src/test/scala/org/infinispan/server/core/VersionGeneratorTest.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -8,9 +8,8 @@
/**
* // TODO: Document this
* @author Galder Zamarreño
- * @since
+ * @since 4.1
*/
-
@Test(groups = Array("functional"), testName = "server.core.VersionGeneratorTest")
class VersionGeneratorTest {
Modified: trunk/server/hotrod/src/main/scala/org/infinispan/server/hotrod/HotRodDecoder.scala
===================================================================
--- trunk/server/hotrod/src/main/scala/org/infinispan/server/hotrod/HotRodDecoder.scala 2010-03-31 11:16:34 UTC (rev 1643)
+++ trunk/server/hotrod/src/main/scala/org/infinispan/server/hotrod/HotRodDecoder.scala 2010-03-31 12:55:19 UTC (rev 1644)
@@ -23,7 +23,6 @@
type SuitableHeader = HotRodHeader
type SuitableParameters = RequestParameters
- // TODO: Ask trustin whether this needs to be a volatile or not, depends on how decoders are shared
@volatile private var isError = false
override def readHeader(buffer: ChannelBuffer): HotRodHeader = {
More information about the infinispan-commits
mailing list