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 61 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 80 of file ClusterThread.d. References client, ProtocolReader, ProtocolWriter, and IBuffer::setConduit(). |
|
Definition at line 107 of file ClusterThread.d. References client. Referenced by msg1(). |
|
Definition at line 116 of file ClusterThread.d. References msg(). |
|
|
Definition at line 63 of file ClusterThread.d. |
|
Definition at line 64 of file ClusterThread.d. |
|
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. |