diff --git a/server/core/Makefile b/server/core/Makefile index 86aea51c7..4d94b246a 100644 --- a/server/core/Makefile +++ b/server/core/Makefile @@ -59,7 +59,7 @@ SRCS= atomic.c buffer.c spinlock.c gateway.c \ monitor.c adminusers.c secrets.c HDRS= ../include/atomic.h ../include/buffer.h ../include/dcb.h \ - ../include/gateway_mysql.h ../include/gw.h ../include/mysql_protocol.h \ + ../include/gw.h ../include/mysql_protocol.h \ ../include/session.h ../include/spinlock.h ../include/thread.h \ ../include/modules.h ../include/poll.h ../include/config.h \ ../include/users.h ../include/hashtable.h ../include/gwbitmask.h \ diff --git a/server/core/utils.c b/server/core/utils.c index 9e7b3d633..ea8ce837d 100644 --- a/server/core/utils.c +++ b/server/core/utils.c @@ -37,7 +37,6 @@ #include #include #include -#include #include #include #include diff --git a/server/include/gw.h b/server/include/gw.h index 1b2b3c392..4115ff293 100644 --- a/server/include/gw.h +++ b/server/include/gw.h @@ -45,8 +45,6 @@ #define MYSQL_CONN_DEBUG #undef MYSQL_CONN_DEBUG -#include "gateway_mysql.h" -#include "mysql_protocol.h" #include "dcb.h" void gw_daemonize(void); @@ -54,11 +52,9 @@ int do_read_dcb(DCB *dcb); void MySQLListener(int epfd, char *config_bind); int MySQLAccept(DCB *listener); int gw_mysql_do_authentication(DCB *dcb, GWBUF *); -void gw_mysql_close(MySQLProtocol **ptr); char *gw_strend(register const char *s); int do_read_dcb(DCB *dcb); int do_read_10(DCB *dcb, uint8_t *buffer); -MySQLProtocol * gw_mysql_init(MySQLProtocol *ptr); int MySQLWrite(DCB *dcb, GWBUF *queue); int gw_write_backend_event(DCB *dcb); int gw_read_backend_event(DCB *dcb); diff --git a/server/include/mysql_protocol.h b/server/include/mysql_protocol.h deleted file mode 100644 index 2a1f0a881..000000000 --- a/server/include/mysql_protocol.h +++ /dev/null @@ -1,74 +0,0 @@ -#ifndef _MYSQL_PROTOCOL_H -#define _MYSQL_PROTOCOL_H -/* - * This file is distributed as part of the SkySQL Gateway. It is free - * software: you can redistribute it and/or modify it under the terms of the - * GNU General Public License as published by the Free Software Foundation, - * version 2. - * - * This program is distributed in the hope that it will be useful, but WITHOUT - * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS - * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more - * details. - * - * You should have received a copy of the GNU General Public License along with - * this program; if not, write to the Free Software Foundation, Inc., 51 - * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. - * - * Copyright SkySQL Ab 2013 - */ - -/* - * Revision History - * - * Date Who Description - * 01-06-2013 Mark Riddoch Initial implementation - * 14-06-2013 Massimiliano Pinto Added specific data - * for MySQL session - */ - -#ifndef MYSQL_SCRAMBLE_LEN -#define MYSQL_SCRAMBLE_LEN GW_MYSQL_SCRAMBLE_SIZE -#endif - -#define MYSQL_USER_MAXLEN 128 -#define MYSQL_DATABASE_MAXLEN 128 - -typedef enum { - MYSQL_ALLOC, - MYSQL_AUTH_SENT, - MYSQL_AUTH_RECV, - MYSQL_AUTH_FAILED, - MYSQL_IDLE, - MYSQL_ROUTING, - MYSQL_WAITING_RESULT, -} mysql_pstate_t; - -struct dcb; - -/** - * MySQL Protocol specific state data - */ -typedef struct { - skygw_chk_t protocol_chk_top; - int fd; /**< The socket descriptor */ - struct dcb *descriptor; /**< The DCB of the socket we are running on */ - mysql_pstate_t state; /**< Current descriptor state */ - char scramble[MYSQL_SCRAMBLE_LEN]; /**< server scramble, created or received */ - uint32_t server_capabilities; /**< server capabilities, created or received */ - uint32_t client_capabilities; /**< client capabilities, created or received */ - unsigned long tid; /**< MySQL Thread ID, in handshake */ - skygw_chk_t protocol_chk_tail; -} MySQLProtocol; - -/** - * MySQL session specific data - * - */ -typedef struct mysql_session { - uint8_t client_sha1[MYSQL_SCRAMBLE_LEN]; /**< SHA1(passowrd) */ - char user[MYSQL_USER_MAXLEN]; /**< username */ - char db[MYSQL_DATABASE_MAXLEN]; /**< database */ -} MYSQL_session; - -#endif