summaryrefslogtreecommitdiff
path: root/libmysqld
diff options
context:
space:
mode:
authorunknown <hf@genie.(none)>2002-10-23 16:55:35 +0500
committerunknown <hf@genie.(none)>2002-10-23 16:55:35 +0500
commitcda34818c1d7d8e431e21b0adeef577b4c5df277 (patch)
treeec9ef8a0098211094f3e71740f69bfa5c73272d8 /libmysqld
parenta62ee2202f86c47f6a8d6d05948e181d73d56ba1 (diff)
downloadmariadb-git-cda34818c1d7d8e431e21b0adeef577b4c5df277.tar.gz
Some code improvements
libmysqld/lib_sql.cc: embedded_send_row function trimmed libmysqld/libmysqld.c: code trimming process sql/ha_myisam.cc: SEND_ROW simplified sql/mysql_priv.h: SEND_ROW simplified sql/mysqld.cc: main() code trimming sql/sql_handler.cc: SEND_ROW macro simplified sql/sql_show.cc: SEND_ROW macro simplified sql/sql_table.cc: SEND_ROW macro simplified
Diffstat (limited to 'libmysqld')
-rw-r--r--libmysqld/lib_sql.cc16
-rw-r--r--libmysqld/libmysqld.c25
2 files changed, 10 insertions, 31 deletions
diff --git a/libmysqld/lib_sql.cc b/libmysqld/lib_sql.cc
index 4254be397d4..223ead97ff8 100644
--- a/libmysqld/lib_sql.cc
+++ b/libmysqld/lib_sql.cc
@@ -23,6 +23,11 @@
#define mysql_unix_port mysql_inix_port1
#define mysql_port mysql_port1
+static int fake_argc= 1;
+static char *fake_argv[]= {(char *)"", 0};
+static const char *fake_groups[] = { "server", "embedded", 0 };
+static char inited, org_my_init_done;
+
#if defined (__WIN__)
#include "../sql/mysqld.cpp"
#else
@@ -302,9 +307,9 @@ static bool check_user(THD *thd,enum_server_command command, const char *user,
extern "C"
{
-static my_bool inited, org_my_init_done;
ulong max_allowed_packet, net_buffer_length;
+
int STDCALL mysql_server_init(int argc, char **argv, char **groups)
{
char glob_hostname[FN_REFLEN];
@@ -587,7 +592,6 @@ int STDCALL mysql_server_init(int argc, char **argv, char **groups)
return 0;
}
-
void STDCALL mysql_server_end()
{
clean_up(0);
@@ -1009,14 +1013,12 @@ int embedded_send_row(THD *thd, int n_fields, char *data, int data_len)
DBUG_ENTER("embedded_send_row");
result->rows++;
- if (!(cur= (MYSQL_ROWS *)alloc_root(alloc, sizeof(MYSQL_ROWS))) ||
- !(cur->data=
- (MYSQL_ROW)alloc_root(alloc,
- (n_fields + 1) * sizeof(char *) + data_len)))
+ if (!(cur= (MYSQL_ROWS *)alloc_root(alloc, sizeof(MYSQL_ROWS) + (n_fields + 1) * sizeof(char *) + data_len)))
{
my_error(ER_OUT_OF_RESOURCES,MYF(0));
DBUG_RETURN(1);
}
+ cur->data= (MYSQL_ROW)((char *)cur) + sizeof(MYSQL_ROWS);
*result->prev_ptr= cur;
result->prev_ptr= &cur->next;
@@ -1024,7 +1026,7 @@ int embedded_send_row(THD *thd, int n_fields, char *data, int data_len)
cp= (uchar *)data;
end_field= cur->data + n_fields;
- for (cur_field=cur->data; cur_field<end_field; ++cur_field, ++mysql_fields)
+ for (cur_field=cur->data; cur_field<end_field; cur_field++, mysql_fields++)
{
if ((len= (ulong) net_field_length(&cp)) == NULL_LENGTH)
{
diff --git a/libmysqld/libmysqld.c b/libmysqld/libmysqld.c
index 36401138b24..47d38d153d0 100644
--- a/libmysqld/libmysqld.c
+++ b/libmysqld/libmysqld.c
@@ -723,6 +723,7 @@ static void mysql_once_init()
if (!mysql_client_init)
{
mysql_client_init=1;
+
my_init(); /* Will init threads */
init_client_errs();
mysql_port = MYSQL_PORT;
@@ -1131,24 +1132,6 @@ my_bool my_connect(my_socket s, const struct sockaddr *name, uint namelen,
#endif
}
-/*
-int STDCALL
-mysql_send_query(MYSQL* mysql, const char* query, ulong length)
-{
- if (mysql->options.separate_thread)
- {
- return -1;
- }
-
- mysql->result= NULL;
-
- free_old_query(mysql);
-
- return simple_command(mysql, COM_QUERY, query, length, 1);
-}
-*/
-
-
int STDCALL
mysql_real_query(MYSQL *mysql, const char *query, ulong length)
{
@@ -1250,12 +1233,6 @@ mysql_store_result(MYSQL *mysql)
return result;
}
-void _0dummy()
-{
- send_file_to_server(NULL, NULL);
- net_field_length_ll(NULL);
-}
-
/**************************************************************************
** Alloc struct for use with unbuffered reads. Data is fetched by domand
** when calling to mysql_fetch_row.