net.spy.memcached

Class MockMemcachedNode

java.lang.Object

net.spy.memcached.MockMemcachedNode

All Implemented Interfaces:

net.spy.memcached.MemcachedNode

public class MockMemcachedNode
extends java.lang.Object
implements net.spy.memcached.MemcachedNode

A MockMemcachedNode.

Constructor Summary

Constructors

Constructor and Description
MockMemcachedNode(java.net.InetSocketAddress socketAddress)

Method Summary

Methods

Modifier and Type	Method and Description
void	addOp(net.spy.memcached.ops.Operation op)
void	authComplete()
void	connected()
void	copyInputQueue()
java.util.Collection<net.spy.memcached.ops.Operation>	destroyInputQueue()
boolean	equals(java.lang.Object o)
void	fillWriteBuffer(boolean optimizeGets)
void	fixupOps()
int	getBytesRemainingToWrite()
java.nio.channels.SocketChannel	getChannel()
int	getContinuousTimeout()
net.spy.memcached.ops.Operation	getCurrentReadOp()
net.spy.memcached.ops.Operation	getCurrentWriteOp()
java.nio.ByteBuffer	getRbuf()
int	getReconnectCount()
int	getSelectionOps()
java.nio.channels.SelectionKey	getSk()
java.net.SocketAddress	getSocketAddress()
java.nio.ByteBuffer	getWbuf()
int	hashCode()
boolean	hasReadOp()
boolean	hasWriteOp()
void	insertOp(net.spy.memcached.ops.Operation op)
boolean	isActive()
void	reconnecting()
void	registerChannel(java.nio.channels.SocketChannel ch, java.nio.channels.SelectionKey selectionKey)
net.spy.memcached.ops.Operation	removeCurrentReadOp()
net.spy.memcached.ops.Operation	removeCurrentWriteOp()
void	setChannel(java.nio.channels.SocketChannel to)
void	setContinuousTimeout(boolean timedOut)
void	setSk(java.nio.channels.SelectionKey to)
void	setupForAuth()
void	setupResend()
void	transitionWriteItem()
int	writeSome()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MockMemcachedNode

public MockMemcachedNode(java.net.InetSocketAddress socketAddress)

Method Detail

getSocketAddress

public java.net.SocketAddress getSocketAddress()

Specified by:

getSocketAddress in interface net.spy.memcached.MemcachedNode

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

copyInputQueue

public void copyInputQueue()

Specified by:

copyInputQueue in interface net.spy.memcached.MemcachedNode

setupResend

public void setupResend()

Specified by:

setupResend in interface net.spy.memcached.MemcachedNode

fillWriteBuffer

public void fillWriteBuffer(boolean optimizeGets)

Specified by:

fillWriteBuffer in interface net.spy.memcached.MemcachedNode

transitionWriteItem

public void transitionWriteItem()

Specified by:

transitionWriteItem in interface net.spy.memcached.MemcachedNode

getCurrentReadOp

public net.spy.memcached.ops.Operation getCurrentReadOp()

Specified by:

getCurrentReadOp in interface net.spy.memcached.MemcachedNode

removeCurrentReadOp

public net.spy.memcached.ops.Operation removeCurrentReadOp()

Specified by:

removeCurrentReadOp in interface net.spy.memcached.MemcachedNode

getCurrentWriteOp

public net.spy.memcached.ops.Operation getCurrentWriteOp()

Specified by:

getCurrentWriteOp in interface net.spy.memcached.MemcachedNode

removeCurrentWriteOp

public net.spy.memcached.ops.Operation removeCurrentWriteOp()

Specified by:

removeCurrentWriteOp in interface net.spy.memcached.MemcachedNode

hasReadOp

public boolean hasReadOp()

Specified by:

hasReadOp in interface net.spy.memcached.MemcachedNode

hasWriteOp

public boolean hasWriteOp()

Specified by:

hasWriteOp in interface net.spy.memcached.MemcachedNode

addOp

public void addOp(net.spy.memcached.ops.Operation op)

Specified by:

addOp in interface net.spy.memcached.MemcachedNode

insertOp

public void insertOp(net.spy.memcached.ops.Operation op)

Specified by:

insertOp in interface net.spy.memcached.MemcachedNode

getSelectionOps

public int getSelectionOps()

Specified by:

getSelectionOps in interface net.spy.memcached.MemcachedNode

getRbuf

public java.nio.ByteBuffer getRbuf()

Specified by:

getRbuf in interface net.spy.memcached.MemcachedNode

getWbuf

public java.nio.ByteBuffer getWbuf()

Specified by:

getWbuf in interface net.spy.memcached.MemcachedNode

isActive

public boolean isActive()

Specified by:

isActive in interface net.spy.memcached.MemcachedNode

reconnecting

public void reconnecting()

Specified by:

reconnecting in interface net.spy.memcached.MemcachedNode

connected

public void connected()

Specified by:

connected in interface net.spy.memcached.MemcachedNode

getReconnectCount

public int getReconnectCount()

Specified by:

getReconnectCount in interface net.spy.memcached.MemcachedNode

registerChannel

public void registerChannel(java.nio.channels.SocketChannel ch,
                   java.nio.channels.SelectionKey selectionKey)

Specified by:

registerChannel in interface net.spy.memcached.MemcachedNode

setChannel

public void setChannel(java.nio.channels.SocketChannel to)

Specified by:

setChannel in interface net.spy.memcached.MemcachedNode

getChannel

public java.nio.channels.SocketChannel getChannel()

Specified by:

getChannel in interface net.spy.memcached.MemcachedNode

setSk

public void setSk(java.nio.channels.SelectionKey to)

Specified by:

setSk in interface net.spy.memcached.MemcachedNode

getSk

public java.nio.channels.SelectionKey getSk()

Specified by:

getSk in interface net.spy.memcached.MemcachedNode

getBytesRemainingToWrite

public int getBytesRemainingToWrite()

Specified by:

getBytesRemainingToWrite in interface net.spy.memcached.MemcachedNode

writeSome

public int writeSome()
              throws java.io.IOException

Specified by:

writeSome in interface net.spy.memcached.MemcachedNode

Throws:

java.io.IOException

fixupOps

public void fixupOps()

Specified by:

fixupOps in interface net.spy.memcached.MemcachedNode

destroyInputQueue

public java.util.Collection<net.spy.memcached.ops.Operation> destroyInputQueue()

Specified by:

destroyInputQueue in interface net.spy.memcached.MemcachedNode

authComplete

public void authComplete()

Specified by:

authComplete in interface net.spy.memcached.MemcachedNode

setupForAuth

public void setupForAuth()

Specified by:

setupForAuth in interface net.spy.memcached.MemcachedNode

getContinuousTimeout

public int getContinuousTimeout()

Specified by:

getContinuousTimeout in interface net.spy.memcached.MemcachedNode

setContinuousTimeout

public void setContinuousTimeout(boolean timedOut)

Specified by:

setContinuousTimeout in interface net.spy.memcached.MemcachedNode