diff options
-rw-r--r-- | src/mysqlerl.c | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/src/mysqlerl.c b/src/mysqlerl.c index 0f88a49..dfd7ef0 100644 --- a/src/mysqlerl.c +++ b/src/mysqlerl.c @@ -175,8 +175,16 @@ write_cmd(const char *cmd, msglen_t len) void dispatch_db_cmd(MYSQL *dbh, msg_t *msg) { - logmsg("DEBUG: type: %d, msg: %s.", msg->type, msg->msg); - write_cmd(msg->msg, msg->msglen); + switch (msg->type) { + case QUERY_MSG: + logmsg("DEBUG: got query msg: %s.", msg->msg); + write_cmd(msg->msg, msg->msglen); + break; + + default: + logmsg("WARNING: message type %d unknown.", msg->type); + exit(3); + } } void |