com.couchbase.client

Class CouchbaseConnection

java.lang.Object

java.lang.Thread

net.spy.memcached.compat.SpyThread

net.spy.memcached.MemcachedConnection

com.couchbase.client.CouchbaseConnection

All Implemented Interfaces:

Reconfigurable, java.lang.Runnable

public class CouchbaseConnection
extends MemcachedConnection
implements Reconfigurable

Maintains connections to each node in a cluster of Couchbase Nodes.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	reconfiguring

Fields inherited from class net.spy.memcached.MemcachedConnection

addedQueue, failureMode, locator, nodesToShutdown, running, selector, shutDown

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
CouchbaseConnection(int bufSize, CouchbaseConnectionFactory f, java.util.List<java.net.InetSocketAddress> a, java.util.Collection<ConnectionObserver> obs, FailureMode fm, OperationFactory opfactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	addOperation(java.lang.String key, Operation o) Add an operation to the given connection.
void	addOperations(java.util.Map<MemcachedNode,Operation> ops)
void	reconfigure(Bucket bucket) Call on a configuration update.
void	run() Infinitely loop processing IO.

Methods inherited from class net.spy.memcached.MemcachedConnection

addObserver, addOperation, broadcastOperation, broadcastOperation, checkState, createConnections, enqueueOperation, getLocator, handleIO, insertOperation, opSucceeded, opTimedOut, queueReconnect, removeObserver, shutdown, toString

Methods inherited from class net.spy.memcached.compat.SpyThread

getLogger

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

reconfiguring

protected volatile boolean reconfiguring

Constructor Detail

CouchbaseConnection

public CouchbaseConnection(int bufSize,
                   CouchbaseConnectionFactory f,
                   java.util.List<java.net.InetSocketAddress> a,
                   java.util.Collection<ConnectionObserver> obs,
                   FailureMode fm,
                   OperationFactory opfactory)
                    throws java.io.IOException

Throws:

java.io.IOException

Method Detail

reconfigure

public void reconfigure(Bucket bucket)

Description copied from interface: Reconfigurable

Call on a configuration update.

Specified by:

reconfigure in interface Reconfigurable

Parameters:

bucket - updated vbucket configuration

addOperation

public void addOperation(java.lang.String key,
                Operation o)

Add an operation to the given connection.

Overrides:

addOperation in class MemcachedConnection

Parameters:

key - the key the operation is operating upon

o - the operation

addOperations

public void addOperations(java.util.Map<MemcachedNode,Operation> ops)

Overrides:

addOperations in class MemcachedConnection

run

public void run()

Infinitely loop processing IO.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class MemcachedConnection