diff --git a/modules/routing/debugcli.c b/modules/routing/debugcli.c index da6676b5d..696f28b36 100644 --- a/modules/routing/debugcli.c +++ b/modules/routing/debugcli.c @@ -158,6 +158,11 @@ CLI_SESSION *client; spinlock_release(&inst->lock); session->state = SESSION_STATE_READY; + + dcb_printf(session->client, "Welcome the SkySQL Gateway Debug Interface (%s).\n", + version_str); + dcb_printf(session->client, "Type help for a list of available commands.\n\n"); + return (void *)client; } diff --git a/modules/routing/readwritesplit/readwritesplit.c b/modules/routing/readwritesplit/readwritesplit.c index 78492cb30..d63232c4e 100644 --- a/modules/routing/readwritesplit/readwritesplit.c +++ b/modules/routing/readwritesplit/readwritesplit.c @@ -449,7 +449,7 @@ static int routeQuery( { GWBUF *cq = gwbuf_clone(queue); ret = session->masterconn->func.write(session->masterconn, queue); - session->slaveconn->func.write(session->masterconn, cq); + session->slaveconn->func.write(session->slaveconn, cq); } atomic_add(&inst->stats.n_all, 1); goto return_ret;