Commit 079237a9 authored by andrey@lmy004's avatar andrey@lmy004

Merge ahristov@bk-internal.mysql.com:/home/bk/mysql-5.1-new

into lmy004.:/work/mysql-5.1-tt-copy-works
parents b7117c44 be55de4f
...@@ -41,7 +41,7 @@ ...@@ -41,7 +41,7 @@
int _mysql_plugin_interface_version_= MYSQL_PLUGIN_INTERFACE_VERSION; \ int _mysql_plugin_interface_version_= MYSQL_PLUGIN_INTERFACE_VERSION; \
int _mysql_sizeof_struct_st_plugin_= sizeof(struct st_mysql_plugin); \ int _mysql_sizeof_struct_st_plugin_= sizeof(struct st_mysql_plugin); \
struct st_mysql_plugin _mysql_plugin_declarations_[]= { struct st_mysql_plugin _mysql_plugin_declarations_[]= {
#define mysql_declare_plugin_end ,{0,0,0,0,0,0,0,0}} #define mysql_declare_plugin_end ,{0,0,0,0,0,0,0,0,0}}
/* /*
declarations for SHOW STATUS support in plugins declarations for SHOW STATUS support in plugins
......
...@@ -24,9 +24,8 @@ SHOW TABLES; ...@@ -24,9 +24,8 @@ SHOW TABLES;
Tables_in_test_ignore Tables_in_test_ignore
t2 t2
INSERT INTO t2 VALUES (3,3), (4,4); INSERT INTO t2 VALUES (3,3), (4,4);
SHOW BINLOG EVENTS; SHOW BINLOG EVENTS FROM 102;
Log_name Pos Event_type Server_id End_log_pos Info Log_name Pos Event_type Server_id End_log_pos Info
master-bin.000001 4 Format_desc 1 102 Server ver: 5.1.5-alpha-debug-log, Binlog ver: 4
master-bin.000001 102 Query 1 195 use `test`; CREATE TABLE t1 (a INT, b INT) master-bin.000001 102 Query 1 195 use `test`; CREATE TABLE t1 (a INT, b INT)
master-bin.000001 195 Table_map 1 235 test.t1 master-bin.000001 195 Table_map 1 235 test.t1
master-bin.000001 235 Write_rows 1 282 master-bin.000001 235 Write_rows 1 282
......
...@@ -17,7 +17,7 @@ USE test_ignore; ...@@ -17,7 +17,7 @@ USE test_ignore;
CREATE TABLE t2 (a INT, b INT); CREATE TABLE t2 (a INT, b INT);
SHOW TABLES; SHOW TABLES;
INSERT INTO t2 VALUES (3,3), (4,4); INSERT INTO t2 VALUES (3,3), (4,4);
SHOW BINLOG EVENTS; SHOW BINLOG EVENTS FROM 102;
sync_slave_with_master; sync_slave_with_master;
--echo **** On Slave **** --echo **** On Slave ****
SHOW DATABASES; SHOW DATABASES;
......
...@@ -98,7 +98,8 @@ static int simple_parser_plugin_deinit(void) ...@@ -98,7 +98,8 @@ static int simple_parser_plugin_deinit(void)
1 failure (cannot happen) 1 failure (cannot happen)
*/ */
static int simple_parser_init(MYSQL_FTPARSER_PARAM *param) static int simple_parser_init(MYSQL_FTPARSER_PARAM *param
__attribute__((unused)))
{ {
return(0); return(0);
} }
...@@ -118,7 +119,8 @@ static int simple_parser_init(MYSQL_FTPARSER_PARAM *param) ...@@ -118,7 +119,8 @@ static int simple_parser_init(MYSQL_FTPARSER_PARAM *param)
1 failure (cannot happen) 1 failure (cannot happen)
*/ */
static int simple_parser_deinit(MYSQL_FTPARSER_PARAM *param) static int simple_parser_deinit(MYSQL_FTPARSER_PARAM *param
__attribute__((unused)))
{ {
return(0); return(0);
} }
...@@ -179,7 +181,7 @@ int simple_parser_parse(MYSQL_FTPARSER_PARAM *param) ...@@ -179,7 +181,7 @@ int simple_parser_parse(MYSQL_FTPARSER_PARAM *param)
add_word(param, start, end - start); add_word(param, start, end - start);
break; break;
} }
else if (isspace(*end)) else if (my_isspace(param->cs, *end))
{ {
if (end > start) if (end > start)
add_word(param, start, end - start); add_word(param, start, end - start);
...@@ -208,7 +210,7 @@ static struct st_mysql_ftparser simple_parser_descriptor= ...@@ -208,7 +210,7 @@ static struct st_mysql_ftparser simple_parser_descriptor=
struct st_mysql_show_var simple_status[]= struct st_mysql_show_var simple_status[]=
{ {
{"static", "just a static text", SHOW_CHAR}, {"static", (char *)"just a static text", SHOW_CHAR},
{"called", (char *)&number_of_calls, SHOW_LONG}, {"called", (char *)&number_of_calls, SHOW_LONG},
{0,0,0} {0,0,0}
}; };
...@@ -227,6 +229,6 @@ mysql_declare_plugin ...@@ -227,6 +229,6 @@ mysql_declare_plugin
simple_parser_plugin_init, /* init function (when loaded) */ simple_parser_plugin_init, /* init function (when loaded) */
simple_parser_plugin_deinit,/* deinit function (when unloaded) */ simple_parser_plugin_deinit,/* deinit function (when unloaded) */
0x0001, /* version */ 0x0001, /* version */
&simple_status /* status variables */ simple_status /* status variables */
} }
mysql_declare_plugin_end; mysql_declare_plugin_end;
...@@ -1589,22 +1589,10 @@ static int write_delayed(THD *thd,TABLE *table,enum_duplicates duplic, ...@@ -1589,22 +1589,10 @@ static int write_delayed(THD *thd,TABLE *table,enum_duplicates duplic,
if (thd->killed || !(row= new delayed_row(duplic, ignore, log_on))) if (thd->killed || !(row= new delayed_row(duplic, ignore, log_on)))
goto err; goto err;
#if 0
if (!query)
query_length=0;
#endif
if (!(row->record= (char*) my_malloc(table->s->reclength, MYF(MY_WME)))) if (!(row->record= (char*) my_malloc(table->s->reclength, MYF(MY_WME))))
goto err; goto err;
memcpy(row->record, table->record[0], table->s->reclength); memcpy(row->record, table->record[0], table->s->reclength);
di->set_query(query, query_length); di->set_query(query, query_length);
#if 0
if (query_length)
{
row->query= row->record+table->s->reclength;
memcpy(row->query,query,query_length+1);
}
row->query_length= query_length;
#endif
row->start_time= thd->start_time; row->start_time= thd->start_time;
row->query_start_used= thd->query_start_used; row->query_start_used= thd->query_start_used;
row->last_insert_id_used= thd->last_insert_id_used; row->last_insert_id_used= thd->last_insert_id_used;
...@@ -1931,18 +1919,6 @@ bool delayed_insert::handle_inserts(void) ...@@ -1931,18 +1919,6 @@ bool delayed_insert::handle_inserts(void)
bool using_ignore=0, bool using_ignore=0,
using_bin_log= mysql_bin_log.is_open(); using_bin_log= mysql_bin_log.is_open();
#if 0
/*
The actual text for the query is added to the first row in the
list. Since the row is destroyed, with all it's memory, we need
to take a copy of it to be able to log it after all rows have been
applied.
*/
uint const query_length= rows.head()->query_length;
char *const query= static_cast<char*>(my_alloca(query_length+1));
memcpy(query, rows.head()->query, query_length);
#endif
delayed_row *row; delayed_row *row;
DBUG_ENTER("handle_inserts"); DBUG_ENTER("handle_inserts");
...@@ -2060,6 +2036,7 @@ bool delayed_insert::handle_inserts(void) ...@@ -2060,6 +2036,7 @@ bool delayed_insert::handle_inserts(void)
pthread_mutex_unlock(&mutex); pthread_mutex_unlock(&mutex);
/* After releasing the mutex, to prevent deadlocks. */ /* After releasing the mutex, to prevent deadlocks. */
if (mysql_bin_log.is_open())
thd.binlog_query(THD::ROW_QUERY_TYPE, query, query_length, FALSE, FALSE); thd.binlog_query(THD::ROW_QUERY_TYPE, query, query_length, FALSE, FALSE);
if ((error=table->file->extra(HA_EXTRA_NO_CACHE))) if ((error=table->file->extra(HA_EXTRA_NO_CACHE)))
......
...@@ -7,6 +7,6 @@ ndbapiincludedir = "$(pkgincludedir)/storage/ndb/ndbapi" ...@@ -7,6 +7,6 @@ ndbapiincludedir = "$(pkgincludedir)/storage/ndb/ndbapi"
mgmapiincludedir = "$(pkgincludedir)/storage/ndb/mgmapi" mgmapiincludedir = "$(pkgincludedir)/storage/ndb/mgmapi"
INCLUDES = $(INCLUDES_LOC) INCLUDES = $(INCLUDES_LOC)
LDADD = $(top_srcdir)/storage/ndb/src/common/portlib/gcc.cpp $(LDADD_LOC) LDADD = $(LDADD_LOC)
DEFS = @DEFS@ @NDB_DEFS@ $(DEFS_LOC) $(NDB_EXTRA_FLAGS) DEFS = @DEFS@ @NDB_DEFS@ $(DEFS_LOC) $(NDB_EXTRA_FLAGS)
NDB_CXXFLAGS=@ndb_cxxflags_fix@ $(NDB_CXXFLAGS_LOC) NDB_CXXFLAGS=@ndb_cxxflags_fix@ $(NDB_CXXFLAGS_LOC)
noinst_HEADERS = gcc.cpp
noinst_LTLIBRARIES = libportlib.la noinst_LTLIBRARIES = libportlib.la
libportlib_la_SOURCES = \ libportlib_la_SOURCES = \
......
/**
* GCC linking problem...
*/
#if 0
extern "C" { int __cxa_pure_virtual() { return 0;} }
#endif
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment