Index: mysql-test/suite/innosql/r/rpl_batch_commit.result

Index: mysql-test/suite/innosql/t/rpl_batch_commit-slave.opt

Index: mysql-test/suite/innosql/t/rpl_batch_commit.test

Index: mysql-test/suite/sys_vars/r/batch_commit_max_basic.result

Index: mysql-test/suite/sys_vars/r/enable_table_relay_info_basic.result

Index: mysql-test/suite/sys_vars/t/enable_table_relay_info_basic.test

Index: mysql-test/suite/sys_vars/t/batch_commit_max_basic.test

Index: mysql-test/mysql-test-run.pl

# If you add a new suite, please check TEST_DIRS in Makefile.am.

#

my $opt_suites;

our $opt_verbose= 0; # Verbose output, enable with --verbose

Index: mysys/array.c

FALSE Ok

*/

{

uchar* buffer;

if (array->elements == array->max_element)

Index: scripts/mysql_system_tables.sql

CREATE TABLE IF NOT EXISTS ndb_binlog_index (Position BIGINT UNSIGNED NOT NULL, File VARCHAR(255) NOT NULL, epoch BIGINT UNSIGNED NOT NULL, inserts BIGINT UNSIGNED NOT NULL, updates BIGINT UNSIGNED NOT NULL, deletes BIGINT UNSIGNED NOT NULL, schemaops BIGINT UNSIGNED NOT NULL, PRIMARY KEY(epoch)) ENGINE=MYISAM;

--

-- PERFORMANCE SCHEMA INSTALLATION

-- Note that this script is also reused by mysql_upgrade,

Index: scripts/mysql_install_db.sh

# Configure mysqld command line

mysqld_bootstrap="${MYSQLD_BOOTSTRAP-$mysqld}"

mysqld_install_cmd_line="$mysqld_bootstrap $defaults $mysqld_opt --bootstrap \

--loose-skip-ndbcluster $args --max_allowed_packet=8M \

--default-storage-engine=myisam \

--net_buffer_length=16K"

Index: storage/innobase/handler/ha_innodb.cc

/* We were instructed to commit the whole transaction, or

this is an SQL statement end and autocommit is on */

/* We need current binlog position for ibbackup to work.

Note, the position is current because of

prepare_commit_mutex */

/* Now do a write + flush of logs. */

trx_commit_complete_for_mysql(trx);

/* We just mark the SQL statement ended and do not do a

transaction commit */

/* If we had reserved the auto-inc lock for some

table in this SQL statement we release it now */

XID* xid) /*!< in: X/Open XA transaction identification */

{

trx_t* trx;

DBUG_ASSERT(hton == innodb_hton_ptr);

trx = trx_get_trx_by_xid(xid);

if (trx) {

innobase_commit_low(trx);

trx_free_for_background(trx);

} else {

}

}

Index: include/my_sys.h

/* init_dynamic_array() function is deprecated */

extern my_bool init_dynamic_array(DYNAMIC_ARRAY *array, uint element_size,

uint init_alloc, uint alloc_increment);

extern uchar *alloc_dynamic(DYNAMIC_ARRAY *array);

extern uchar *pop_dynamic(DYNAMIC_ARRAY*);

extern my_bool set_dynamic(DYNAMIC_ARRAY *array,uchar * element,uint array_index);

Index: sql/slave.cc

// Create_file_log_event,

// Format_description_log_event

#ifdef HAVE_REPLICATION

#include "rpl_tblmap.h"

thd_proc_info(current_thd, "Flushing relay-log info file.");

if (flush_relay_log_info(&mi->rli))

DBUG_RETURN(ER_ERROR_DURING_FLUSH_LOGS);

mysql_mutex_unlock(log_lock);

}

if (thread_mask & (SLAVE_IO|SLAVE_FORCE_ALL))

int apply_event_and_update_pos(Log_event* ev, THD* thd, Relay_log_info* rli)

{

int exec_res= 0;

DBUG_ENTER("apply_event_and_update_pos");

int reason= ev->shall_skip(rli);

if (reason == Log_event::EVENT_SKIP_COUNT)

mysql_mutex_unlock(&rli->data_lock);

if (reason == Log_event::EVENT_SKIP_NOT)

#ifndef DBUG_OFF

/*

DBUG_PRINT("info", ("apply_event error = %d", exec_res));

if (exec_res == 0)

{

#ifdef HAVE_purify

if (!rli->is_fake)

#endif

mysql_mutex_lock(&mi->data_lock);

switch (buf[EVENT_TYPE_OFFSET]) {

case STOP_EVENT:

/*

We needn't write this event to the relay log. Indeed, it just indicates a

mysql_options(mysql, MYSQL_SET_CHARSET_DIR, (char *) charsets_dir);

/* Set MYSQL_PLUGIN_DIR in case master asks for an external authentication plugin */

/* we disallow empty users */

if (mi->user == NULL || mi->user[0] == 0)

bool flush_relay_log_info(Relay_log_info* rli)

{

DBUG_ENTER("flush_relay_log_info");

DBUG_RETURN(error);

}

/*

Called when we notice that the current "hot" log got rotated under our feet.

*/

*/

#endif /* HAVE_REPLICATION */

Index: sql/sql_parse.h

bool sqlcom_can_generate_row_events(const THD *thd);

bool is_update_query(enum enum_sql_command command);

bool is_log_table_write_query(enum enum_sql_command command);

bool alloc_query(THD *thd, const char *packet, uint packet_length);

void mysql_init_select(LEX *lex);

void mysql_parse(THD *thd, char *rawbuf, uint length,

Index: sql/rpl_info_table_access.h

Index: sql/sql_class.h

*/

#define CF_CAN_GENERATE_ROW_EVENTS (1U << 9)

/* Bits in server_command_flags */

/**

Index: sql/table.cc

/* SLOW_LOG name */

LEX_STRING SLOW_LOG_NAME= {C_STRING_WITH_LEN("slow_log")};

/* Functions defined in this file */

void open_table_error(TABLE_SHARE *share, int error, int db_errno,

SLOW_LOG_NAME.str,

name->str) == 0))

return TABLE_CATEGORY_LOG;

}

return TABLE_CATEGORY_USER;

Index: sql/rpl_info_values.cc

Index: sql/rpl_rli.cc

#include "sql_parse.h" // end_trans, ROLLBACK

#include <mysql/plugin.h>

#include <mysql/service_thd_wait.h>

static int count_relay_log_space(Relay_log_info* rli);

// Defined in slave.cc

group_relay_log_name[0]= event_relay_log_name[0]=

group_master_log_name[0]= 0;

until_log_name[0]= ign_master_log_name_end[0]= 0;

bzero((char*) &info_file, sizeof(info_file));

bzero((char*) &cache_buf, sizeof(cache_buf));

mysql_cond_init(key_relay_log_info_stop_cond, &stop_cond, NULL);

mysql_cond_init(key_relay_log_info_log_space_cond, &log_space_cond, NULL);

relay_log.init_pthread_objects();

DBUG_VOID_RETURN;

}

Relay_log_info::~Relay_log_info()

{

DBUG_ENTER("Relay_log_info::~Relay_log_info");

mysql_mutex_destroy(&run_lock);

mysql_mutex_destroy(&data_lock);

mysql_mutex_destroy(&log_space_lock);

DBUG_VOID_RETURN;

}

int init_relay_log_info(Relay_log_info* rli,

const char* info_fname)

{

const char* msg = 0;

int error = 0;

DBUG_ENTER("init_relay_log_info");

if (rli->inited) // Set if this function called

DBUG_RETURN(0);

mysql_mutex_lock(&rli->data_lock);

rli->cur_log_fd = -1;

rli->slave_skip_counter=0;

rli->abort_pos_wait=0;

rli->log_space_total= 0;

rli->tables_to_lock= 0;

rli->tables_to_lock_count= 0;

(void) my_realpath(pattern, slave_load_tmpdir, 0);

if (fn_format(pattern, PREFIX_SQL_LOAD, pattern, "",

MY_SAFE_PATH | MY_RETURN_REAL_PATH) == NullS)

rli->relay_log.is_relay_log= TRUE;

}

{

goto err;

}

}

{

goto err;