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
GrowBuffer buffer
ProtocolReader reader
ProtocolWriter writer
ILogger logger
char[] client
Cluster cluster

Detailed Description

The socket QOS thread for handling client requests.

Definition at line 63 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 82 of file ClusterThread.d.

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

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

Definition at line 109 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 118 of file ClusterThread.d.

References msg().

Referenced by run().

ThreadReturn run  )  [inline]
 

Definition at line 132 of file ClusterThread.d.

References ProtocolWriter::AddQueue, buffer, cache, Buffer::clear(), client, IConduit::close(), ProtocolWriter::Copy, ILogger::error(), Exception, ClusterCache::extract(), ILogger::fatal(), Buffer::flush(), ProtocolWriter::full(), ClusterQueue::get(), ClusterCache::get(), Buffer::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, and writer.


Member Data Documentation

ClusterCache cache [private]
 

Definition at line 65 of file ClusterThread.d.

Referenced by run(), and this().

ClusterQueue queue [private]
 

Definition at line 66 of file ClusterThread.d.

Referenced by run(), and this().

GrowBuffer buffer [private]
 

Definition at line 67 of file ClusterThread.d.

Referenced by run(), and this().

ProtocolReader reader [private]
 

Definition at line 68 of file ClusterThread.d.

Referenced by run(), and this().

ProtocolWriter writer [private]
 

Definition at line 69 of file ClusterThread.d.

Referenced by run(), and this().

ILogger logger [private]
 

Definition at line 70 of file ClusterThread.d.

Referenced by run(), and this().

char [] client [private]
 

Definition at line 71 of file ClusterThread.d.

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

Cluster cluster [private]
 

Definition at line 72 of file ClusterThread.d.

Referenced by this().

public class VersionAres typedef void ThreadReturn
 

Definition at line 127 of file ClusterThread.d.

else typedef int ThreadReturn
 

Definition at line 130 of file ClusterThread.d.


The documentation for this class was generated from the following file:
Generated on Sat Dec 24 17:28:37 2005 for Mango by  doxygen 1.4.0