/* Peer Session IO handler states */
/**********************************/
-#define PEER_SESSION_ACCEPT 1000 /* Initial state for session create by an accept */
-#define PEER_SESSION_GETVERSION 1001 /* Validate supported protocol version*/
-#define PEER_SESSION_GETHOST 1002 /* Validate host ID correspond to local host id */
-#define PEER_SESSION_GETPEER 1003 /* Validate peer ID correspond to a known remote peer id */
-#define PEER_SESSION_GETTABLE 1004 /* Search into registered table for a table with same id and
- validate type and size */
-#define PEER_SESSION_SENDSUCCESS 1005 /* Send ret code 200 (success) and wait for message */
-/* next state is WAITMSG */
-
-#define PEER_SESSION_CONNECT 2000 /* Initial state for session create on a connect,
- push presentation into buffer */
-#define PEER_SESSION_GETSTATUS 2001 /* Wait for the welcome message */
-#define PEER_SESSION_WAITMSG 2002 /* Wait for datamessages*/
-/* loop on WAITMSG */
-
-#define PEER_SESSION_EXIT 10000 /* Exit with status code */
-#define PEER_SESSION_END 10001 /* Killed session */
-/* session ended */
-
+enum {
+ PEER_SESS_ST_ACCEPT = 0, /* Initial state for session create by an accept, must be zero! */
+ PEER_SESS_ST_GETVERSION, /* Validate supported protocol version */
+ PEER_SESS_ST_GETHOST, /* Validate host ID correspond to local host id */
+ PEER_SESS_ST_GETPEER, /* Validate peer ID correspond to a known remote peer id */
+ PEER_SESS_ST_GETTABLE, /* Search into registered table for a table with same id and validate type and size */
+ /* after this point, data were possibly exchanged */
+ PEER_SESS_ST_SENDSUCCESS, /* Send ret code 200 (success) and wait for message */
+ PEER_SESS_ST_CONNECT, /* Initial state for session create on a connect, push presentation into buffer */
+ PEER_SESS_ST_GETSTATUS, /* Wait for the welcome message */
+ PEER_SESS_ST_WAITMSG, /* Wait for data messages */
+ PEER_SESS_ST_EXIT, /* Exit with status code */
+ PEER_SESS_ST_END, /* Killed session */
+};
-/**********************************/
-/* Peer Session status code */
-/**********************************/
+/***************************************************/
+/* Peer Session status code - part of the protocol */
+/***************************************************/
-#define PEER_SESSION_CONNECTCODE 100 /* connect in progress */
-#define PEER_SESSION_CONNECTEDCODE 110 /* tcp connect success */
+#define PEER_SESS_SC_CONNECTCODE 100 /* connect in progress */
+#define PEER_SESS_SC_CONNECTEDCODE 110 /* tcp connect success */
-#define PEER_SESSION_SUCCESSCODE 200 /* accept or connect successful */
+#define PEER_SESS_SC_SUCCESSCODE 200 /* accept or connect successful */
-#define PEER_SESSION_TRYAGAIN 300 /* try again later */
+#define PEER_SESS_SC_TRYAGAIN 300 /* try again later */
-#define PEER_SESSION_ERRPROTO 501 /* error protocol */
-#define PEER_SESSION_ERRVERSION 502 /* unknown protocol version */
-#define PEER_SESSION_ERRHOST 503 /* bad host name */
-#define PEER_SESSION_ERRPEER 504 /* unknown peer */
-#define PEER_SESSION_ERRTYPE 505 /* table key type mismatch */
-#define PEER_SESSION_ERRSIZE 506 /* table key size mismatch */
-#define PEER_SESSION_ERRTABLE 507 /* unknown table */
+#define PEER_SESS_SC_ERRPROTO 501 /* error protocol */
+#define PEER_SESS_SC_ERRVERSION 502 /* unknown protocol version */
+#define PEER_SESS_SC_ERRHOST 503 /* bad host name */
+#define PEER_SESS_SC_ERRPEER 504 /* unknown peer */
+#define PEER_SESS_SC_ERRTYPE 505 /* table key type mismatch */
+#define PEER_SESS_SC_ERRSIZE 506 /* table key size mismatch */
+#define PEER_SESS_SC_ERRTABLE 507 /* unknown table */
#define PEER_SESSION_PROTO_NAME "HAProxyS"
struct peer_session *ps = (struct peer_session *)appctx->ctx.peers.ptr;
/* appctx->ctx.peers.ptr is not a peer session */
- if (appctx->st0 < PEER_SESSION_SENDSUCCESS)
+ if (appctx->st0 < PEER_SESS_ST_SENDSUCCESS)
return;
/* peer session identified */
while (1) {
switchstate:
switch(appctx->st0) {
- case PEER_SESSION_ACCEPT:
+ case PEER_SESS_ST_ACCEPT:
appctx->ctx.peers.ptr = NULL;
- appctx->st0 = PEER_SESSION_GETVERSION;
+ appctx->st0 = PEER_SESS_ST_GETVERSION;
/* fall through */
- case PEER_SESSION_GETVERSION:
+ case PEER_SESS_ST_GETVERSION:
reql = bo_getline(si->ob, trash.str, trash.size);
if (reql <= 0) { /* closed or EOL not found */
if (reql == 0)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
if (trash.str[reql-1] != '\n') {
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
else if (reql > 1 && (trash.str[reql-2] == '\r'))
/* test version */
if (strcmp(PEER_SESSION_PROTO_NAME " 1.0", trash.str) != 0) {
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRVERSION;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRVERSION;
/* test protocol */
if (strncmp(PEER_SESSION_PROTO_NAME " ", trash.str, strlen(PEER_SESSION_PROTO_NAME)+1) != 0)
- appctx->st1 = PEER_SESSION_ERRPROTO;
+ appctx->st1 = PEER_SESS_SC_ERRPROTO;
goto switchstate;
}
- appctx->st0 = PEER_SESSION_GETHOST;
+ appctx->st0 = PEER_SESS_ST_GETHOST;
/* fall through */
- case PEER_SESSION_GETHOST:
+ case PEER_SESS_ST_GETHOST:
reql = bo_getline(si->ob, trash.str, trash.size);
if (reql <= 0) { /* closed or EOL not found */
if (reql == 0)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
if (trash.str[reql-1] != '\n') {
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
else if (reql > 1 && (trash.str[reql-2] == '\r'))
/* test hostname match */
if (strcmp(localpeer, trash.str) != 0) {
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRHOST;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRHOST;
goto switchstate;
}
- appctx->st0 = PEER_SESSION_GETPEER;
+ appctx->st0 = PEER_SESS_ST_GETPEER;
/* fall through */
- case PEER_SESSION_GETPEER: {
+ case PEER_SESS_ST_GETPEER: {
struct peer *curpeer;
char *p;
reql = bo_getline(si->ob, trash.str, trash.size);
if (reql <= 0) { /* closed or EOL not found */
if (reql == 0)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
if (trash.str[reql-1] != '\n') {
/* Incomplete line, we quit */
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
else if (reql > 1 && (trash.str[reql-2] == '\r'))
/* parse line "<peer name> <pid>" */
p = strchr(trash.str, ' ');
if (!p) {
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRPROTO;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRPROTO;
goto switchstate;
}
*p = 0;
/* if unknown peer */
if (!curpeer) {
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRPEER;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRPEER;
goto switchstate;
}
appctx->ctx.peers.ptr = curpeer;
- appctx->st0 = PEER_SESSION_GETTABLE;
+ appctx->st0 = PEER_SESS_ST_GETTABLE;
/* fall through */
}
- case PEER_SESSION_GETTABLE: {
+ case PEER_SESS_ST_GETTABLE: {
struct peer *curpeer = (struct peer *)appctx->ctx.peers.ptr;
struct shared_table *st;
struct peer_session *ps = NULL;
if (reql == 0)
goto out;
appctx->ctx.peers.ptr = NULL;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
/* Re init appctx->ctx.peers.ptr to null, to handle correctly a release case */
if (trash.str[reql-1] != '\n') {
/* Incomplete line, we quit */
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
else if (reql > 1 && (trash.str[reql-2] == '\r'))
/* Parse line "<table name> <type> <size>" */
p = strchr(trash.str, ' ');
if (!p) {
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRPROTO;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRPROTO;
goto switchstate;
}
*p = 0;
p = strchr(p+1, ' ');
if (!p) {
appctx->ctx.peers.ptr = NULL;
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRPROTO;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRPROTO;
goto switchstate;
}
if (key_size != st->table->key_size &&
(key_type != STKTABLE_TYPE_STRING ||
1 + 4 + 4 + key_size - 1 >= trash.size)) {
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRSIZE;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRSIZE;
goto switchstate;
}
/* If key type mismatches */
if (key_type != st->table->type) {
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRTYPE;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRTYPE;
goto switchstate;
}
if (ps->session && ps->session != s) {
if (ps->peer->local) {
/* Local connection, reply a retry */
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_TRYAGAIN;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_TRYAGAIN;
goto switchstate;
}
peer_session_forceshutdown(ps->session);
/* If table not found */
if (!st){
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRTABLE;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRTABLE;
goto switchstate;
}
/* If no peer session for current peer */
if (!ps) {
- appctx->st0 = PEER_SESSION_EXIT;
- appctx->st1 = PEER_SESSION_ERRPEER;
+ appctx->st0 = PEER_SESS_ST_EXIT;
+ appctx->st1 = PEER_SESS_SC_ERRPEER;
goto switchstate;
}
appctx->ctx.peers.ptr = ps;
- appctx->st0 = PEER_SESSION_SENDSUCCESS;
+ appctx->st0 = PEER_SESS_ST_SENDSUCCESS;
/* fall through */
}
- case PEER_SESSION_SENDSUCCESS:{
+ case PEER_SESS_ST_SENDSUCCESS: {
struct peer_session *ps = (struct peer_session *)appctx->ctx.peers.ptr;
- repl = snprintf(trash.str, trash.size, "%d\n", PEER_SESSION_SUCCESSCODE);
+ repl = snprintf(trash.str, trash.size, "%d\n", PEER_SESS_SC_SUCCESSCODE);
repl = bi_putblk(si->ib, trash.str, repl);
if (repl <= 0) {
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
/* Register status code */
- ps->statuscode = PEER_SESSION_SUCCESSCODE;
+ ps->statuscode = PEER_SESS_SC_SUCCESSCODE;
/* Awake main task */
task_wakeup(ps->table->sync_task, TASK_WOKEN_MSG);
ps->table->flags |= SHTABLE_F_RESYNC_ASSIGN;
}
/* switch to waiting message state */
- appctx->st0 = PEER_SESSION_WAITMSG;
+ appctx->st0 = PEER_SESS_ST_WAITMSG;
goto switchstate;
}
- case PEER_SESSION_CONNECT: {
+ case PEER_SESS_ST_CONNECT: {
struct peer_session *ps = (struct peer_session *)appctx->ctx.peers.ptr;
/* Send headers */
(int)ps->table->table->key_size);
if (repl >= trash.size) {
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
if (repl <= 0) {
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
/* switch to the waiting statuscode state */
- appctx->st0 = PEER_SESSION_GETSTATUS;
+ appctx->st0 = PEER_SESS_ST_GETSTATUS;
/* fall through */
}
- case PEER_SESSION_GETSTATUS: {
+ case PEER_SESS_ST_GETSTATUS: {
struct peer_session *ps = (struct peer_session *)appctx->ctx.peers.ptr;
if (si->ib->flags & CF_WRITE_PARTIAL)
- ps->statuscode = PEER_SESSION_CONNECTEDCODE;
+ ps->statuscode = PEER_SESS_SC_CONNECTEDCODE;
reql = bo_getline(si->ob, trash.str, trash.size);
if (reql <= 0) { /* closed or EOL not found */
if (reql == 0)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
if (trash.str[reql-1] != '\n') {
/* Incomplete line, we quit */
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
else if (reql > 1 && (trash.str[reql-2] == '\r'))
task_wakeup(ps->table->sync_task, TASK_WOKEN_MSG);
/* If status code is success */
- if (ps->statuscode == PEER_SESSION_SUCCESSCODE) {
+ if (ps->statuscode == PEER_SESS_SC_SUCCESSCODE) {
/* Init cursors */
ps->teaching_origin = ps->lastpush = ps->lastack = ps->pushack = 0;
ps->pushed = ps->update;
}
else {
/* Status code is not success, abort */
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
- appctx->st0 = PEER_SESSION_WAITMSG;
+ appctx->st0 = PEER_SESS_ST_WAITMSG;
/* fall through */
}
- case PEER_SESSION_WAITMSG: {
+ case PEER_SESS_ST_WAITMSG: {
struct peer_session *ps = (struct peer_session *)appctx->ctx.peers.ptr;
struct stksess *ts, *newts = NULL;
char c;
if (stopping) {
/* Close session, push resync no more needed */
ps->flags |= PEER_F_TEACH_COMPLETE;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
}
else {
/* Unknown message */
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
if (reql < 0) {
/* there was an error */
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
/* no more write possible */
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
ps->confirm--;
/* no more write possible */
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
ps->table->flags |= SHTABLE_F_RESYNC_PROCESS;
/* no more write possible */
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
ps->lastack = ps->pushack;
/* no more write possible */
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
ps->lastpush = ps->pushed = ts->upd.key;
/* no more write possible */
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
ps->lastpush = ps->pushed = ts->upd.key;
/* no more write possible */
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
/* no more write possible */
if (repl == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
goto switchstate;
}
ps->lastpush = ps->pushed = ts->upd.key;
/* noting more to do */
goto out;
}
- case PEER_SESSION_EXIT:
+ case PEER_SESS_ST_EXIT:
repl = snprintf(trash.str, trash.size, "%d\n", appctx->st1);
if (bi_putblk(si->ib, trash.str, repl) == -1)
goto out;
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
/* fall through */
- case PEER_SESSION_END: {
+ case PEER_SESS_ST_END: {
si_shutw(si);
si_shutr(si);
si->ib->flags |= CF_READ_NULL;
/* call release to reinit resync states if needed */
peer_session_release(oldsi);
- appctx->st0 = PEER_SESSION_END;
+ appctx->st0 = PEER_SESS_ST_END;
appctx->ctx.peers.ptr = NULL;
task_wakeup(session->task, TASK_WOKEN_MSG);
}
appctx = stream_int_register_handler(&s->si[1], objt_applet(s->target));
if (!appctx)
return -1;
- appctx->st0 = PEER_SESSION_ACCEPT;
+ appctx->st0 = PEER_SESS_ST_ACCEPT;
appctx->ctx.peers.ptr = s;
tv_zero(&s->logs.tv_request);
}
ps->reconnect = tick_add(now_ms, MS_TO_TICKS(5000));
- ps->statuscode = PEER_SESSION_CONNECTCODE;
+ ps->statuscode = PEER_SESS_SC_CONNECTCODE;
t->process = l->handler;
t->context = s;
appctx = stream_int_register_handler(&s->si[0], &peer_applet);
if (!appctx)
goto out_fail_conn1;
- appctx->st0 = PEER_SESSION_CONNECT;
+ appctx->st0 = PEER_SESS_ST_CONNECT;
appctx->ctx.peers.ptr = (void *)ps;
si_reset(&s->si[1], t);
if (!ps->session) {
/* no active session */
if (ps->statuscode == 0 ||
- ps->statuscode == PEER_SESSION_SUCCESSCODE ||
- ((ps->statuscode == PEER_SESSION_CONNECTCODE ||
- ps->statuscode == PEER_SESSION_CONNECTEDCODE) &&
+ ps->statuscode == PEER_SESS_SC_SUCCESSCODE ||
+ ((ps->statuscode == PEER_SESS_SC_CONNECTCODE ||
+ ps->statuscode == PEER_SESS_SC_CONNECTEDCODE) &&
tick_is_expired(ps->reconnect, now_ms))) {
/* connection never tried
* or previous session established with success
/* retry a connect */
ps->session = peer_session_create(ps->peer, ps);
}
- else if (ps->statuscode == PEER_SESSION_CONNECTCODE ||
- ps->statuscode == PEER_SESSION_CONNECTEDCODE) {
+ else if (ps->statuscode == PEER_SESS_SC_CONNECTCODE ||
+ ps->statuscode == PEER_SESS_SC_CONNECTEDCODE) {
/* If previous session failed during connection
* but reconnection timer is not expired */
}
/* else do nothing */
} /* !ps->session */
- else if (ps->statuscode == PEER_SESSION_SUCCESSCODE) {
+ else if (ps->statuscode == PEER_SESS_SC_SUCCESSCODE) {
/* current session is active and established */
if (((st->flags & SHTABLE_RESYNC_STATEMASK) == SHTABLE_RESYNC_FROMREMOTE) &&
!(st->flags & SHTABLE_F_RESYNC_ASSIGN) &&
else if (!ps->session) {
/* If session is not active */
if (ps->statuscode == 0 ||
- ps->statuscode == PEER_SESSION_SUCCESSCODE ||
- ps->statuscode == PEER_SESSION_CONNECTEDCODE ||
- ps->statuscode == PEER_SESSION_TRYAGAIN) {
+ ps->statuscode == PEER_SESS_SC_SUCCESSCODE ||
+ ps->statuscode == PEER_SESS_SC_CONNECTEDCODE ||
+ ps->statuscode == PEER_SESS_SC_TRYAGAIN) {
/* connection never tried
* or previous session was successfully established
* or previous session tcp connect success but init state incomplete
}
}
}
- else if (ps->statuscode == PEER_SESSION_SUCCESSCODE &&
+ else if (ps->statuscode == PEER_SESS_SC_SUCCESSCODE &&
(int)(ps->pushed - ps->table->table->localupdate) < 0) {
/* current session active and established
awake session to push remaining local updates */
projects / thirdparty / haproxy.git / commitdiff
