returns the string representation of this socket @return string

Is the new socket connected yet @return

returns the host this socket is connected to @return String representation of host (hostname:port)

Adds a socket to a given pool for the given host. Internal utility method. @param pool pool to add to @param host host this socket is connected to @

sets closed flag and checks in to connection pool but does not close connections

closes socket and all streams connected to it @throws IOException if fails to close streams or socket

writes a byte array to the output stream @param b byte array to write @throws IOException if an io error happens

NATIVE_HASH = 0 OLD_COMPAT_HASH = 1 NEW_COMPAT_HASH = 2 KETAMA_HASH = 3 @param key @return

Returns a SockIO object from the pool for the passed in host. Meant to be called from a more intelligent method<br/> which handles choosing appropria

\brief Unlocks the semaphore. * \param sem_set_id The semaphore handle that you want to unlock. */

Creates a new SockIO obj for the given server. If server fails to connect, then return null and do not try<br/> again until a duration has passed. T

use the sockets hashcode for this object so we can key off of SockIOs @return int hashcode

ketama.h does not expose this function */

Checks a SockIO object in with the pool. This will remove SocketIO from busy pool, and optionally<br/> add to avail pool. @param socket socket to re

Closes all sockets in the passed in pool. Internal utility method. @param pool pool to close

\brief Retrieve the modification time of a file. * \param filename The full path to the file. * \return The timestamp of the latest modification t

Gets the first available key equal or above the given one, if none found, returns the first k in the bucket @param k key @return

flushes output stream @throws IOException if io problems during read

Factory to create/retrieve new pools given a unique poolName. @param poolName unique name of the pool @return instance of SockIOPool

Method which spawns thread to get a connection and then enforces a timeout on the initial connection. This should be backed by a thread pool. Any vo

checks if the connection is open @return true if connected

reads length bytes into the passed in byte array from dtream @param b byte array @throws IOException if io problems during read

Closes and removes all sockets from specified pool for host. Internal utility method. @param pool pool to clear @param host host to clear

Return the socket. @return

Did we have an exception while connecting? @return

Returns state of pool. @return <CODE>true</CODE> if initialized.

\brief Generates the continuum of servers (each server as many points on a circle). * \param key Shared memory key for storing the newly created con

\brief Initialize a semaphore. * \param key Semaphore key to use. * \return The freshly allocated semaphore handle. */

\brief Locks the semaphore. * \param sem_set_id The semaphore handle that you want to lock. */

Calculates the ketama hash value for a string @param s @return

Internal private hashing method. This is the new hashing algorithm from other clients. Found to be fast and have very good distribution. UPDATE: Thi

Internal private hashing method. This is the original hashing algorithm from other clients. Found to be slow and have poor distribution. @param key

\brief Retrieve all server definitions from a file. * \param filename The full path to the file which contains the server definitions. * \param co

\brief Retrieve a serverinfo struct for one a sever definition. * \param line The entire server definition in plain-text. * \return A serverinfo s

Removes a socket from specified pool for host. Internal utility method. @param pool pool to remove from @param host host pool @param socket socket t

Runs self maintenance on all internal pools. This is typically called by the maintenance thread to manage pool size.

Starts the maintenance thread. This thread will manage the size of the active pool<br/> as well as move any closed, but not checked in sockets<br/> b

Stops the maintenance thread.

sets stop variable and interupts any wait

Constructor @param host @param port

creates a new SockIO object wrapping a socket connection to host:port, and its input and output streams @param pool Pool this object is tied to @para

reads up to end of line and returns nothing @throws IOException if io problems during read

Returns current state of failover flag. @return true/false

Returns current status of customHash flag @return true/false

Returns the current setting for the initial number of connections per server in the available pool. @return number of connections

Returns the current maint thread sleep time. @return sleep time in ms

Returns the current max busy setting. @return max busy setting in ms

Returns the maximum number of spare connections allowed in available pool. @return number of connections

Returns the current max idle setting. @return max idle setting in ms

Returns the minimum number of spare connections in available pool. @return number of connections

Returns current status of nagle flag @return true/false

Returns the current list of all cache servers. @return String array of servers [host:port]

Returns appropriate SockIO object given string cache key. @param key hashcode for cache key @return SockIO obj connected to server

Returns appropriate SockIO object given string cache key and optional hashcode. Trys to get SockIO from pool. Fails over to additional pools in even

Returns the socket timeout for connects. @return timeout in ms

Returns the socket timeout for reads. @return timeout in ms

Returns the current list of weights. @return int array of weights

Initializes the pool.