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 |
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 client, ProtocolReader, ProtocolWriter, and IBuffer::setConduit(). |
|
Definition at line 110 of file ClusterThread.d. References client. Referenced by msg1(). |
|
Definition at line 119 of file ClusterThread.d. References msg(). |
|
|
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. |