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 |
Definition at line 64 of file ClusterThread.d.
|
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, IBuffer::setConduit(), and writer. |
|
Definition at line 110 of file ClusterThread.d. References client. |
|
Definition at line 119 of file ClusterThread.d. References msg(). Referenced by run(). |
|
|
Definition at line 66 of file ClusterThread.d. |
|
Definition at line 67 of file ClusterThread.d. |
|
Definition at line 68 of file ClusterThread.d. |
|
Definition at line 69 of file ClusterThread.d. |
|
Definition at line 70 of file ClusterThread.d. |
|
Definition at line 71 of file ClusterThread.d. |
|
Definition at line 72 of file ClusterThread.d. |
|
Definition at line 73 of file ClusterThread.d. Referenced by this(). |
|
Definition at line 128 of file ClusterThread.d. |
|
Definition at line 131 of file ClusterThread.d. |