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 |
Definition at line 63 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 82 of file ClusterThread.d. References buffer, cache, client, cluster, GrowBuffer, logger, ProtocolReader, ProtocolWriter, queue, reader, Buffer::setConduit(), and writer. |
|
Definition at line 109 of file ClusterThread.d. References client. |
|
Definition at line 118 of file ClusterThread.d. References msg(). Referenced by run(). |
|
|
Definition at line 65 of file ClusterThread.d. |
|
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. Referenced by this(). |
|
Definition at line 127 of file ClusterThread.d. |
|
Definition at line 130 of file ClusterThread.d. |