#include <EventServer.h>
Public Attributes | |
Thread * | t |
thread related to that connection | |
struct event | readEvent |
read event registered on the client socket | |
struct event | writeEvent |
write event registered on the client socket | |
int | clientSocket |
client socket | |
char | buffer [2 *Cache::MAX_OBJECT_SIZE] |
buffer for receiving data | |
char | sendBuffer [Cache::MAX_OBJECT_SIZE+MAX_HEADER_LENGTH+sizeof(LINE_TERMINATOR)-1+sizeof(REQUEST_TERMINATOR)-1] |
buffer for sending data | |
const char * | sendIt |
pointer to the beginning of data to send | |
Value | value |
value to pass as a reference to get() | |
unsigned int | offset |
mark of the end of recieved data | |
unsigned int | writeOffset |
mark of the end of sent data | |
unsigned int | cursor |
mark of the beginning of data to parse | |
int | tokens [6] |
information of where tokens are | |
int | tokGet |
information of where the last get token is | |
int | tokenCount |
tokens count | |
bool | tokenFlag |
flag to indicate that ' ' was found in the reading buffer | |
bool | endFlag |
flag to indicate that '\r' was found in the reading buffer | |
bool | continueFlag |
set to true in writeCallback when requests were sent in one package to make normal timeout from fake one. | |
unsigned int | length |
length of data chunk to send | |
bool | active |
flag to indicate whether the connection is active. | |
State | state |
connection state | |
char | protocol |
1 - ascii protocol; 2 - binary protocol; 0 - unrecognized yet | |
char | quit |
a flag to indicate whether we are closing the connection | |
char * | queueBuffer |
buffer dedicated for queuing response messages for binary protocol | |
unsigned int | queueLength |
queue length | |
unsigned int | queueCapacity |
already malloced memory |
It is related to one of the working threads
Definition at line 229 of file EventServer.h.
bool Info::active |
flag to indicate whether the connection is active.
Inactive connections are purged after configurable timeout.
Definition at line 313 of file EventServer.h.