# HG changeset patch # User Ruslan Ermilov # Date 1459452806 -10800 # Node ID 4b420f9c4c5dbd186948de8a0ca151ac1c2f8c2d # Parent 3a50ccd9433330ef2c47d13a69b30bfce831168f Removed the prototype mysql module. diff --git a/contrib/vim/syntax/nginx.vim b/contrib/vim/syntax/nginx.vim --- a/contrib/vim/syntax/nginx.vim +++ b/contrib/vim/syntax/nginx.vim @@ -57,6 +57,7 @@ syn keyword ngxDirectiveError post_actio syn keyword ngxDirectiveDeprecated connections syn keyword ngxDirectiveDeprecated imap syn keyword ngxDirectiveDeprecated limit_zone +syn keyword ngxDirectiveDeprecated mysql_test syn keyword ngxDirectiveDeprecated open_file_cache_retest syn keyword ngxDirectiveDeprecated optimize_server_names syn keyword ngxDirectiveDeprecated satisfy_any @@ -246,7 +247,6 @@ syn keyword ngxDirective mp4_max_buffer_ syn keyword ngxDirective msie_padding syn keyword ngxDirective msie_refresh syn keyword ngxDirective multi_accept -syn keyword ngxDirective mysql_test syn keyword ngxDirective open_file_cache syn keyword ngxDirective open_file_cache_errors syn keyword ngxDirective open_file_cache_events diff --git a/misc/GNUmakefile b/misc/GNUmakefile --- a/misc/GNUmakefile +++ b/misc/GNUmakefile @@ -20,8 +20,6 @@ release: export rm $(TEMP)/$(NGINX)/src/event/modules/ngx_iocp_module.* rm -r $(TEMP)/$(NGINX)/src/os/win32 - rm -r $(TEMP)/$(NGINX)/src/mysql - mv $(TEMP)/$(NGINX)/docs/text/LICENSE $(TEMP)/$(NGINX) mv $(TEMP)/$(NGINX)/docs/text/README $(TEMP)/$(NGINX) mv $(TEMP)/$(NGINX)/docs/html $(TEMP)/$(NGINX) diff --git a/src/core/ngx_log.c b/src/core/ngx_log.c --- a/src/core/ngx_log.c +++ b/src/core/ngx_log.c @@ -86,7 +86,7 @@ static ngx_str_t err_levels[] = { static const char *debug_levels[] = { "debug_core", "debug_alloc", "debug_mutex", "debug_event", - "debug_http", "debug_mail", "debug_mysql", "debug_stream" + "debug_http", "debug_mail", "debug_stream" }; diff --git a/src/core/ngx_log.h b/src/core/ngx_log.h --- a/src/core/ngx_log.h +++ b/src/core/ngx_log.h @@ -29,8 +29,7 @@ #define NGX_LOG_DEBUG_EVENT 0x080 #define NGX_LOG_DEBUG_HTTP 0x100 #define NGX_LOG_DEBUG_MAIL 0x200 -#define NGX_LOG_DEBUG_MYSQL 0x400 -#define NGX_LOG_DEBUG_STREAM 0x800 +#define NGX_LOG_DEBUG_STREAM 0x400 /* * do not forget to update debug_levels[] in src/core/ngx_log.c diff --git a/src/mysql/config b/src/mysql/config deleted file mode 100644 --- a/src/mysql/config +++ /dev/null @@ -1,13 +0,0 @@ - -ngx_addon_name=ngx_mysql - -HTTP_MODULES="$HTTP_MODULES ngx_http_mysql_test_module" - -HTTP_INCS="$HTTP_INCS $ngx_addon_dir" -HTTP_DEPS="$HTTP_DEPS $ngx_addon_dir/ngx_mysql.h" -#CORE_LIBS="$CORE_LIBS -lmd" - -USE_SHA1=YES - -NGX_ADDON_SRCS="$NGX_ADDON_SRCS $ngx_addon_dir/ngx_mysql.c" -NGX_ADDON_SRCS="$NGX_ADDON_SRCS $ngx_addon_dir/ngx_http_mysql_test.c" diff --git a/src/mysql/ngx_http_mysql_test.c b/src/mysql/ngx_http_mysql_test.c deleted file mode 100644 --- a/src/mysql/ngx_http_mysql_test.c +++ /dev/null @@ -1,204 +0,0 @@ - -/* - * Copyright (C) Igor Sysoev - * Copyright (C) Nginx, Inc. - */ - -#include -#include -#include -#include - - -typedef struct { - ngx_addr_t *peers; - ngx_uint_t npeers; -} ngx_http_mysql_test_conf_t; - - -static void ngx_http_mysql_auth(ngx_mysql_t *m); -static void ngx_http_mysql_done(ngx_mysql_t *m); -static void *ngx_http_mysql_test_create_loc_conf(ngx_conf_t *cf); -static char *ngx_http_mysql_test(ngx_conf_t *cf, ngx_command_t *cmd, - void *conf); - -static ngx_command_t ngx_http_mysql_test_commands[] = { - - { ngx_string("mysql_test"), - NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, - ngx_http_mysql_test, - NGX_HTTP_LOC_CONF_OFFSET, - 0, - NULL }, - - ngx_null_command -}; - - -static ngx_http_module_t ngx_http_mysql_test_module_ctx = { - NULL, /* preconfiguration */ - NULL, /* postconfiguration */ - - NULL, /* create main configuration */ - NULL, /* init main configuration */ - - NULL, /* create server configuration */ - NULL, /* merge server configuration */ - - ngx_http_mysql_test_create_loc_conf, /* create location configuration */ - NULL /* merge location configuration */ -}; - - -ngx_module_t ngx_http_mysql_test_module = { - NGX_MODULE_V1, - &ngx_http_mysql_test_module_ctx, /* module context */ - ngx_http_mysql_test_commands, /* module directives */ - NGX_HTTP_MODULE, /* module type */ - NULL, /* init master */ - NULL, /* init module */ - NULL, /* init process */ - NULL, /* init thread */ - NULL, /* exit thread */ - NULL, /* exit process */ - NULL, /* exit master */ - NGX_MODULE_V1_PADDING -}; - - -static ngx_str_t ngx_mysql_login = ngx_string("root"); -static ngx_str_t ngx_mysql_passwd = ngx_string("tp"); -static ngx_str_t ngx_mysql_database = ngx_string("mysql"); -static ngx_str_t ngx_mysql_command_query = - ngx_string("select * from user"); - - -static ngx_int_t -ngx_http_mysql_test_handler(ngx_http_request_t *r) -{ - ngx_int_t rc; - ngx_mysql_t *m; - ngx_http_mysql_test_conf_t *mtcf; - - mtcf = ngx_http_get_module_loc_conf(r, ngx_http_mysql_test_module); - - m = ngx_pcalloc(r->pool, sizeof(ngx_mysql_t)); - - if (m == NULL) { - return NGX_HTTP_INTERNAL_SERVER_ERROR; - } - - m->pool = r->pool; - m->handler = ngx_http_mysql_auth; - m->data = r; - - m->login = &ngx_mysql_login; - m->passwd = &ngx_mysql_passwd; - m->database = &ngx_mysql_database; - - /* STUB */ - m->peer.sockaddr = mtcf->peers[0].sockaddr; - m->peer.socklen = mtcf->peers[0].socklen; - m->peer.name = &mtcf->peers[0].name; - m->peer.tries = mtcf->npeers; - m->peer.get = ngx_event_get_peer; - /**/ - m->peer.log = r->connection->log; - m->peer.log_error = NGX_ERROR_ERR; - - rc = ngx_mysql_connect(m); - - if (rc == NGX_OK || rc == NGX_AGAIN) { - return NGX_DONE; - } - - return NGX_HTTP_INTERNAL_SERVER_ERROR; -} - - -static void -ngx_http_mysql_auth(ngx_mysql_t *m) -{ - ngx_http_request_t *r; - - r = m->data; - - if (m->state != NGX_OK) { - ngx_http_finalize_request(r, NGX_HTTP_NO_CONTENT); - return; - } - - m->query.len = NGX_MYSQL_CMDPKT_LEN + ngx_mysql_command_query.len; - - m->query.data = ngx_pnalloc(r->pool, m->query.len); - if (m->query.data == NULL) { - ngx_http_finalize_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR); - return; - } - - ngx_memcpy(m->query.data + NGX_MYSQL_CMDPKT_LEN, - ngx_mysql_command_query.data, ngx_mysql_command_query.len); - - m->handler = ngx_http_mysql_done; - - ngx_mysql_query(m); -} - - -static void -ngx_http_mysql_done(ngx_mysql_t *m) -{ - ngx_http_request_t *r; - - r = m->data; - - ngx_http_finalize_request(r, NGX_HTTP_NO_CONTENT); -} - - -static void * -ngx_http_mysql_test_create_loc_conf(ngx_conf_t *cf) -{ - ngx_http_mysql_test_conf_t *conf; - - conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_mysql_test_conf_t)); - if (conf == NULL) { - return NGX_CONF_ERROR; - } - - return conf; -} - -static char * -ngx_http_mysql_test(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) -{ - ngx_http_mysql_test_conf_t *mtcf = conf; - - ngx_str_t *value; - ngx_url_t u; - ngx_http_core_loc_conf_t *clcf; - - clcf = ngx_http_conf_get_module_loc_conf(cf, ngx_http_core_module); - clcf->handler = ngx_http_mysql_test_handler; - - value = cf->args->elts; - - ngx_memzero(&u, sizeof(ngx_url_t)); - - u.url = value[1]; - u.default_port = 3306; - - if (ngx_parse_url(cf->pool, &u) != NGX_OK) { - if (u.err) { - ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, - "%s in upstream \"%V\"", u.err, &u.url); - } - - return NGX_CONF_ERROR; - } - - mtcf->peers = u.addrs; - mtcf->npeers = u.naddrs; - - return NGX_CONF_OK; -} diff --git a/src/mysql/ngx_mysql.c b/src/mysql/ngx_mysql.c deleted file mode 100644 --- a/src/mysql/ngx_mysql.c +++ /dev/null @@ -1,465 +0,0 @@ - -/* - * Copyright (C) Igor Sysoev - * Copyright (C) Nginx, Inc. - */ - - -/* the library supports the subset of the MySQL 4.1+ protocol (version 10) */ - - -#include -#include -#include -#include -#include -#include - - -#define NGX_MYSQL_LONG_PASSWORD 0x0001 -#define NGX_MYSQL_CONNECT_WITH_DB 0x0008 -#define NGX_MYSQL_PROTOCOL_41 0x0200 -#define NGX_MYSQL_SECURE_CONNECTION 0x8000 - - -#define NGX_MYSQL_CMD_QUERY 3 - - -typedef struct { - u_char pktlen[3]; - u_char pktn; - - u_char protocol; - u_char version[1]; /* NULL-terminated string */ -} ngx_mysql_greeting1_pkt_t; - - -typedef struct { - u_char thread[4]; - u_char salt1[9]; - u_char capacity[2]; - u_char charset; - u_char status[2]; - u_char zero[13]; - u_char salt2[13]; -} ngx_mysql_greeting2_pkt_t; - - -typedef struct { - u_char pktlen[3]; - u_char pktn; - - u_char capacity[4]; - u_char max_packet[4]; - u_char charset; - u_char zero[23]; - u_char login[1]; /* NULL-terminated string */ - - /* - * u_char passwd_len; 0 if no password - * u_char passwd[20]; - * - * u_char database[1]; NULL-terminated string - */ - -} ngx_mysql_auth_pkt_t; - - -typedef struct { - u_char pktlen[3]; - u_char pktn; - u_char fields; -} ngx_mysql_response_pkt_t; - - -typedef struct { - u_char pktlen[3]; - u_char pktn; - u_char err; - u_char code[2]; - u_char message[1]; /* string */ -} ngx_mysql_error_pkt_t; - - -typedef struct { - u_char pktlen[3]; - u_char pktn; - u_char command; - u_char arg[1]; /* string */ -} ngx_mysql_command_pkt_t; - - -static void ngx_mysql_read_server_greeting(ngx_event_t *rev); -static void ngx_mysql_empty_handler(ngx_event_t *wev); -static void ngx_mysql_read_auth_result(ngx_event_t *rev); -static void ngx_mysql_read_query_result(ngx_event_t *rev); -static void ngx_mysql_close(ngx_mysql_t *m, ngx_int_t rc); - - -ngx_int_t -ngx_mysql_connect(ngx_mysql_t *m) -{ - ngx_int_t rc; - -#if 0 - if (cached) { - return NGX_OK; - } -#endif - - m->peer.log->action = "connecting to mysql server"; - - rc = ngx_event_connect_peer(&m->peer); - - if (rc == NGX_ERROR || rc == NGX_BUSY || rc == NGX_DECLINED) { - return rc; - } - - m->peer.connection->data = m; - - m->peer.connection->read->handler = ngx_mysql_read_server_greeting; - m->peer.connection->write->handler = ngx_mysql_empty_handler; - - ngx_add_timer(m->peer.connection->read, /* STUB */ 5000); - - return NGX_OK; -} - - -static void -ngx_mysql_read_server_greeting(ngx_event_t *rev) -{ - size_t len; - u_char *p; - ssize_t n; - ngx_uint_t i, capacity; - ngx_mysql_t *m; - ngx_connection_t *c; - ngx_mysql_greeting1_pkt_t *gr1; - ngx_mysql_greeting2_pkt_t *gr2; - ngx_mysql_auth_pkt_t *auth; - ngx_sha1_t sha; - u_char hash1[20], hash2[20]; - - c = rev->data; - m = c->data; - - if (rev->timedout) { - ngx_log_error(NGX_LOG_ERR, rev->log, NGX_ETIMEDOUT, - "mysql server %V timed out", m->peer.name); - - ngx_mysql_close(m, NGX_ERROR); - return; - } - - if (m->buf == NULL) { - m->peer.log->action = "reading mysql server greeting"; - - m->buf = ngx_create_temp_buf(m->pool, /* STUB */ 1024); - if (m->buf == NULL) { - ngx_mysql_close(m, NGX_ERROR); - return; - } - } - - n = ngx_recv(m->peer.connection, m->buf->pos, /* STUB */ 1024); - - if (n == NGX_AGAIN) { - return; - } - - if (n < 5) { - ngx_mysql_close(m, NGX_ERROR); - return; - } - - gr1 = (ngx_mysql_greeting1_pkt_t *) m->buf->pos; - - if (ngx_m24toh(gr1->pktlen) > n - 4) { - ngx_log_error(NGX_LOG_ERR, rev->log, 0, - "mysql server %V sent incomplete greeting packet", - m->peer.name); - - ngx_mysql_close(m, NGX_ERROR); - return; - } - - if (gr1->protocol < 10) { - ngx_log_error(NGX_LOG_ERR, rev->log, 0, - "mysql server %V sent unsupported protocol version %ud", - m->peer.name, gr1->protocol); - - ngx_mysql_close(m, NGX_ERROR); - return; - } - - gr2 = (ngx_mysql_greeting2_pkt_t *) - (gr1->version + ngx_strlen(gr1->version) + 1); - - capacity = ngx_m16toh(gr2->capacity); - - ngx_log_debug8(NGX_LOG_DEBUG_MYSQL, rev->log, 0, - "mysql version: %ud, \"%s\", thread: %ud, salt: \"%s\", " - "capacity: %Xd, charset: %ud, status: %ud, salt rest \"%s\"", - gr1->protocol, gr1->version, ngx_m32toh(gr2->thread), - gr2->salt1, capacity, gr2->charset, - ngx_m16toh(gr2->status), &gr2->salt2); - - capacity = NGX_MYSQL_LONG_PASSWORD - | NGX_MYSQL_CONNECT_WITH_DB - | NGX_MYSQL_PROTOCOL_41 - | NGX_MYSQL_SECURE_CONNECTION; - - len = 4 + 4 + 4 + 1 + 23 + m->login->len + 1 + 1 + m->database->len + 1; - - if (m->passwd->len) { - len += 20; - } - - auth = ngx_pnalloc(m->pool, len); - if (auth == NULL) { - ngx_mysql_close(m, NGX_ERROR); - return; - } - - ngx_htom24(auth->pktlen, len - 4); - auth->pktn = (u_char) (gr1->pktn + 1); - - ngx_htom32(auth->capacity, capacity); - ngx_htom32(auth->max_packet, 0x01000000); /* max packet size 2^24 */ - ngx_memzero(auth->zero, 24); - auth->charset = gr2->charset; - - p = ngx_copy(auth->login, m->login->data, m->login->len); - *p++ = '\0'; - - if (m->passwd->len) { - - *p++ = (u_char) 20; - - ngx_sha1_init(&sha); - ngx_sha1_update(&sha, m->passwd->data, m->passwd->len); - ngx_sha1_final(hash1, &sha); - - ngx_sha1_init(&sha); - ngx_sha1_update(&sha, hash1, 20); - ngx_sha1_final(hash2, &sha); - - ngx_sha1_init(&sha); - ngx_sha1_update(&sha, gr2->salt1, 8); - ngx_sha1_update(&sha, gr2->salt2, 12); - ngx_sha1_update(&sha, hash2, 20); - ngx_sha1_final(hash2, &sha); - - for (i = 0; i < 20; i++) { - *p++ = (u_char) (hash1[i] ^ hash2[i]); - } - - } else { - *p++ = '\0'; - } - - p = ngx_copy(p, m->database->data, m->database->len); - *p = '\0'; - - - n = ngx_send(m->peer.connection, (void *) auth, len); - - if (n < (ssize_t) len) { - ngx_log_error(NGX_LOG_ERR, rev->log, 0, - "the incomplete packet was sent to mysql server %V", - m->peer.name); - - ngx_mysql_close(m, NGX_ERROR); - return; - } - - m->peer.connection->read->handler = ngx_mysql_read_auth_result; - - ngx_add_timer(m->peer.connection->read, /* STUB */ 5000); -} - - -static void -ngx_mysql_empty_handler(ngx_event_t *wev) -{ - ngx_log_debug0(NGX_LOG_DEBUG_HTTP, wev->log, 0, "mysql empty handler"); - - return; -} - - -static void -ngx_mysql_read_auth_result(ngx_event_t *rev) -{ - ssize_t n, len; - ngx_str_t msg; - ngx_mysql_t *m; - ngx_connection_t *c; - ngx_mysql_error_pkt_t *epkt; - ngx_mysql_response_pkt_t *pkt; - - ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, "mysql read auth"); - - c = rev->data; - m = c->data; - - m->peer.log->action = "reading mysql auth result"; - - n = ngx_recv(m->peer.connection, m->buf->pos, /* STUB */ 1024); - - if (n == NGX_AGAIN) { - return; - } - - if (n < 5) { - ngx_mysql_close(m, NGX_ERROR); - return; - } - - pkt = (ngx_mysql_response_pkt_t *) m->buf->pos; - - len = ngx_m24toh(pkt->pktlen); - - if (len > n - 4) { - ngx_log_error(NGX_LOG_ERR, rev->log, 0, - "mysql server %V sent incomplete response packet", - m->peer.name); - - ngx_mysql_close(m, NGX_ERROR); - return; - } - - if (pkt->fields == 0) { - ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, "mysql auth OK"); - - m->state = NGX_OK; - m->pktn = 0; - - m->handler(m); - - return; - } - - epkt = (ngx_mysql_error_pkt_t *) pkt; - - msg.len = (u_char *) epkt + 4 + len - epkt->message; - msg.data = epkt->message; - - ngx_log_error(NGX_LOG_ERR, rev->log, 0, - "mysql server %V sent error (%ud): \"%V\"", - m->peer.name, ngx_m16toh(epkt->code), &msg); - - ngx_mysql_close(m, NGX_ERROR); -} - - -ngx_int_t -ngx_mysql_query(ngx_mysql_t *m) -{ - ssize_t n; - ngx_mysql_command_pkt_t *pkt; - - pkt = (ngx_mysql_command_pkt_t *) m->query.data; - - ngx_htom24(pkt->pktlen, m->query.len - 4); - pkt->pktn = (u_char) m->pktn++; - pkt->command = NGX_MYSQL_CMD_QUERY; - - n = ngx_send(m->peer.connection, m->query.data, m->query.len); - - if (n < (ssize_t) m->query.len) { - ngx_log_error(NGX_LOG_ERR, m->peer.log, 0, - "the incomplete packet was sent to mysql server %V", - m->peer.name); - - ngx_mysql_close(m, NGX_ERROR); - return NGX_OK; - } - - m->peer.connection->read->handler = ngx_mysql_read_query_result; - - ngx_add_timer(m->peer.connection->read, /* STUB */ 5000); - - /* STUB handle event */ - - return NGX_OK; -} - - -static void -ngx_mysql_read_query_result(ngx_event_t *rev) -{ - ssize_t n, len; - ngx_str_t msg; - ngx_mysql_t *m; - ngx_connection_t *c; - ngx_mysql_error_pkt_t *epkt; - ngx_mysql_response_pkt_t *pkt; - - ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, "mysql read query result"); - - c = rev->data; - m = c->data; - - m->peer.log->action = "reading mysql read query result"; - - n = ngx_recv(m->peer.connection, m->buf->pos, /* STUB */ 1024); - - if (n == NGX_AGAIN) { - return; - } - - if (n < 5) { - ngx_mysql_close(m, NGX_ERROR); - return; - } - - pkt = (ngx_mysql_response_pkt_t *) m->buf->pos; - - len = ngx_m24toh(pkt->pktlen); - - if (len > n - 4) { - ngx_log_error(NGX_LOG_ERR, rev->log, 0, - "mysql server %V sent incomplete response packet", - m->peer.name); - - ngx_mysql_close(m, NGX_ERROR); - return; - } - - if (pkt->fields != 0xff) { - ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, "mysql query OK"); - - m->state = NGX_OK; - m->pktn = pkt->pktn; - - m->handler(m); - - return; - } - - epkt = (ngx_mysql_error_pkt_t *) pkt; - - msg.len = (u_char *) epkt + 4 + len - epkt->message; - msg.data = epkt->message; - - ngx_log_error(NGX_LOG_ERR, rev->log, 0, - "mysql server %V sent error (%ud): \"%V\"", - m->peer.name, ngx_m16toh(epkt->code), &msg); - - ngx_mysql_close(m, NGX_ERROR); -} - - -static void -ngx_mysql_close(ngx_mysql_t *m, ngx_int_t rc) -{ - if (rc == NGX_ERROR) { - ngx_close_connection(m->peer.connection); - } - - m->state = rc; - - m->handler(m); -} diff --git a/src/mysql/ngx_mysql.h b/src/mysql/ngx_mysql.h deleted file mode 100644 --- a/src/mysql/ngx_mysql.h +++ /dev/null @@ -1,85 +0,0 @@ - -/* - * Copyright (C) Igor Sysoev - * Copyright (C) Nginx, Inc. - */ - - -#ifndef _NGX_MYSQL_H_INCLUDED_ -#define _NGX_MYSQL_H_INCLUDED_ - - -#include -#include -#include -#include - - -typedef struct ngx_mysql_s ngx_mysql_t; - -typedef void (*ngx_mysql_handler_pt)(ngx_mysql_t *m); - - -struct ngx_mysql_s { - ngx_peer_connection_t peer; - - ngx_buf_t *buf; - ngx_pool_t *pool; - - ngx_str_t *login; - ngx_str_t *passwd; - ngx_str_t *database; - - ngx_str_t query; - - ngx_uint_t pktn; - - ngx_mysql_handler_pt handler; - void *data; - ngx_int_t state; - -}; - - -#define NGX_MYSQL_CMDPKT_LEN 5 - - -#if (NGX_HAVE_LITTLE_ENDIAN && NGX_HAVE_NONALIGNED && 0) - -#define ngx_m16toh(n) (*(uint32_t *) n & 0x0000ffff) -#define ngx_m24toh(n) (*(uint32_t *) n & 0x00ffffff) -#define ngx_m32toh(n) *(uint32_t *) n - -#define ngx_htom16(n, m) *(uint16_t *) n = (uint16_t) ((m) & 0xffff) - -#define ngx_htom24(n, m) (n)[0] = (u_char) ((m) & 0xff); \ - (n)[1] = (u_char) (((m) >> 8) & 0xff); \ - (n)[2] = (u_char) (((m) >> 16) & 0xff) - -#define ngx_htom32(n, m) *(uint32_t *) (n) = (m) - -#else - -#define ngx_m16toh(n) (n[0] | n[1] << 8) -#define ngx_m24toh(n) (n[0] | n[1] << 8 | n[2] << 16) -#define ngx_m32toh(n) (n[0] | n[1] << 8 | n[2] << 16 | n[3] << 24) - -#define ngx_htom16(n, m) (n)[0] = (u_char) (m); (n)[1] = (u_char) ((m) >> 8) - -#define ngx_htom24(n, m) (n)[0] = (u_char) ((m) & 0xff); \ - (n)[1] = (u_char) (((m) >> 8) & 0xff); \ - (n)[2] = (u_char) (((m) >> 16) & 0xff) - -#define ngx_htom32(n, m) (n)[0] = (u_char) ((m) & 0xff); \ - (n)[1] = (u_char) (((m) >> 8) & 0xff); \ - (n)[2] = (u_char) (((m) >> 16) & 0xff); \ - (n)[3] = (u_char) (((m) >> 24) & 0xff) - -#endif - - -ngx_int_t ngx_mysql_connect(ngx_mysql_t *m); -ngx_int_t ngx_mysql_query(ngx_mysql_t *m); - - -#endif /* _NGX_MYSQL_H_INCLUDED_ */