diff options
| author | Brian Cully <bjc@kublai.com> | 2008-03-02 15:40:17 -0500 |
|---|---|---|
| committer | Brian Cully <github.20.shmit@spamgourmet.com> | 2008-03-02 15:40:17 -0500 |
| commit | 04f18c9d501b444d3bde4d38fd674df8c3a2db3d (patch) | |
| tree | b81c487d53e9fba3d57795b9f37008da791123b8 /src/mysqlerl.c | |
| parent | 9778362e464451f1be6943d2d37a47b4afbcb091 (diff) | |
| download | mysqlerl-04f18c9d501b444d3bde4d38fd674df8c3a2db3d.tar.gz mysqlerl-04f18c9d501b444d3bde4d38fd674df8c3a2db3d.zip | |
Change supervision heirarchy to allow ports to support:
1) Owner process dies - shut down connection cleanly.
2) Port driver dies - restart port driver
Diffstat (limited to 'src/mysqlerl.c')
| -rw-r--r-- | src/mysqlerl.c | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/mysqlerl.c b/src/mysqlerl.c index b2a6ab3..5cec054 100644 --- a/src/mysqlerl.c +++ b/src/mysqlerl.c @@ -13,6 +13,7 @@ #include <string.h> const char *QUERY_MSG = "sql_query"; +const char *PARAM_QUERY_MSG = "param_query_msg"; void usage() @@ -173,6 +174,11 @@ handle_sql_query(MYSQL *dbh, ETERM *cmd) } void +handle_sql_param_query(MYSQL *dbh, ETERM *cmd) +{ +} + +void dispatch_db_cmd(MYSQL *dbh, ETERM *msg) { ETERM *tag; @@ -181,6 +187,9 @@ dispatch_db_cmd(MYSQL *dbh, ETERM *msg) if (strncmp((char *)ERL_ATOM_PTR(tag), QUERY_MSG, strlen(QUERY_MSG)) == 0) { handle_sql_query(dbh, msg); + } else if (strncmp((char *)ERL_ATOM_PTR(tag), + PARAM_QUERY_MSG, strlen(PARAM_QUERY_MSG)) == 0) { + handle_sql_param_query(dbh, msg); } else { logmsg("WARNING: message type %s unknown.", (char *)ERL_ATOM_PTR(tag)); erl_free_term(tag); |