Main Page | Class Hierarchy | Alphabetical List | Class List | 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)
int run ()

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 61 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 80 of file ClusterThread.d.

References client, ProtocolReader, ProtocolWriter, and IBuffer::setConduit().

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

Definition at line 107 of file ClusterThread.d.

References client.

Referenced by msg1().

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

Definition at line 116 of file ClusterThread.d.

References msg().

int run  )  [inline]
 

Definition at line 125 of file ClusterThread.d.

References IBuffer::clear(), client, IResource::close(), ClusterContent, ProtocolWriter::Command, ILogger::error(), Exception, ClusterCache::extract(), ILogger::fatal(), IBuffer::flush(), ProtocolWriter::full(), ClusterQueue::get(), ClusterCache::get(), IBuffer::getConduit(), ProtocolReader::getPacket(), ILogger::info(), ILogger::isEnabled(), ILevel::Level, ClusterQueue::put(), ClusterCache::put(), ProtocolWriter::reply(), ProtocolWriter::success(), and ILogger::trace().


Member Data Documentation

ClusterCache cache [private]
 

Definition at line 63 of file ClusterThread.d.

ClusterQueue queue [private]
 

Definition at line 64 of file ClusterThread.d.

IBuffer buffer [private]
 

Definition at line 65 of file ClusterThread.d.

ProtocolReader reader [private]
 

Definition at line 66 of file ClusterThread.d.

ProtocolWriter writer [private]
 

Definition at line 67 of file ClusterThread.d.

ILogger logger [private]
 

Definition at line 68 of file ClusterThread.d.

char [] client [private]
 

Definition at line 69 of file ClusterThread.d.

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

Cluster cluster [private]
 

Definition at line 70 of file ClusterThread.d.


The documentation for this class was generated from the following file:
Generated on Sun Nov 7 19:07:00 2004 for Mango by doxygen 1.3.6