Main Page | Class Hierarchy | Alphabetical List | Class List | Directories | File List | Class Members | File Members | Related Pages

ClusterThread Class Reference

List of all members.

Public Member Functions

 this (AbstractServer server, IConduit conduit, Cluster cluster, ClusterCache cache, ClusterQueue queue)
ThreadReturn run ()

Public Attributes

public class VersionAres typedef
void 
ThreadReturn
else typedef int ThreadReturn

Private Member Functions

final char[] msg (char[] action, char[] target)
final char[] msg1 (char[] action, char[] target, char[] channel)

Private Attributes

ClusterCache cache
ClusterQueue queue
IBuffer buffer
ProtocolReader reader
ProtocolWriter writer
ILogger logger
char[] client
Cluster cluster

Detailed Description

The socket QOS thread for handling client requests.

Definition at line 64 of file ClusterThread.d.


Member Function Documentation

this AbstractServer  server,
IConduit  conduit,
Cluster  cluster,
ClusterCache  cache,
ClusterQueue  queue
[inline]
 

Note that the conduit stays open until the client kills it. Also note that we use a GrowableBuffer here, which expands as necessary to contain larger payloads.

Definition at line 83 of file ClusterThread.d.

References buffer, cache, client, cluster, logger, ProtocolReader, ProtocolWriter, queue, reader, server, IBuffer::setConduit(), and writer.

final char [] msg char[]  action,
char[]  target
[inline, private]
 

Definition at line 110 of file ClusterThread.d.

References client.

Referenced by msg1(), and run().

final char [] msg1 char[]  action,
char[]  target,
char[]  channel
[inline, private]
 

Definition at line 119 of file ClusterThread.d.

References msg().

Referenced by run().

ThreadReturn run  )  [inline]
 

Definition at line 133 of file ClusterThread.d.

References ProtocolWriter::AddQueue, buffer, cache, IBuffer::clear(), client, IResource::close(), ProtocolWriter::Copy, ILogger::error(), Exception, ClusterCache::extract(), ILogger::fatal(), IBuffer::flush(), ProtocolWriter::full(), ClusterQueue::get(), ClusterCache::get(), IBuffer::getConduit(), ProtocolReader::getPacket(), ILogger::info(), ILogger::isEnabled(), logger, msg(), msg1(), ClusterQueue::put(), ClusterCache::put(), queue, reader, ProtocolWriter::Remove, ProtocolWriter::RemoveQueue, ProtocolWriter::reply(), ProtocolWriter::success(), ILogger::trace(), ILevel::Trace, writer, and x.


Member Data Documentation

ClusterCache cache [private]
 

Definition at line 66 of file ClusterThread.d.

Referenced by run(), and this().

ClusterQueue queue [private]
 

Definition at line 67 of file ClusterThread.d.

Referenced by run(), and this().

IBuffer buffer [private]
 

Definition at line 68 of file ClusterThread.d.

Referenced by run(), and this().

ProtocolReader reader [private]
 

Definition at line 69 of file ClusterThread.d.

Referenced by run(), and this().

ProtocolWriter writer [private]
 

Definition at line 70 of file ClusterThread.d.

Referenced by run(), and this().

ILogger logger [private]
 

Definition at line 71 of file ClusterThread.d.

Referenced by run(), and this().

char [] client [private]
 

Definition at line 72 of file ClusterThread.d.

Referenced by msg(), run(), and this().

Cluster cluster [private]
 

Definition at line 73 of file ClusterThread.d.

Referenced by this().

public class VersionAres typedef void ThreadReturn
 

Definition at line 128 of file ClusterThread.d.

else typedef int ThreadReturn
 

Definition at line 131 of file ClusterThread.d.


The documentation for this class was generated from the following file:
Generated on Fri Nov 11 18:44:31 2005 for Mango by  doxygen 1.4.0