mirror of
https://github.com/MariaDB/server.git
synced 2025-01-16 20:12:31 +01:00
09346e6e2d
This includes both code and test cases. BitKeeper/deleted/.del-ctype_ucs_binlog.result~280d136b1a0bcf17: Delete: mysql-test/r/ctype_ucs_binlog.result BitKeeper/deleted/.del-rpl_delete_all.result~7c050d592614b3f: Delete: mysql-test/r/rpl_delete_all.result BitKeeper/deleted/.del-rpl000013-slave.opt~18266ad8a2403e8d: Delete: mysql-test/t/rpl000013-slave.opt BitKeeper/deleted/.del-rpl_delete_all.test~700a1490277780e0: Delete: mysql-test/t/rpl_delete_all.test mysql-test/extra/binlog_tests/binlog.test: Import patch wl1012.patch mysql-test/extra/binlog_tests/blackhole.test: Import patch wl1012.patch mysql-test/extra/binlog_tests/ctype_cp932.test: Import patch wl1012.patch mysql-test/extra/binlog_tests/ctype_cp932_binlog.test: Import patch wl1012.patch mysql-test/extra/binlog_tests/ctype_ucs_binlog.test: Import patch wl1012.patch mysql-test/extra/binlog_tests/drop_temp_table.test: Import patch wl1012.patch mysql-test/extra/binlog_tests/insert_select-binlog.test: Import patch wl1012.patch mysql-test/extra/binlog_tests/mix_innodb_myisam_binlog.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_ddl.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_deadlock.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_err_ignoredtable.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_flsh_tbls.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_loaddata_m.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_log.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_max_relay_size.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_multi_query.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_reset_slave.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_stm_000001.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_stm_EE_err.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_stm_charset.test: Import patch wl1012.patch mysql-test/extra/rpl_tests/rpl_user_variables.test: Import patch wl1012.patch mysql-test/r/binlog_stm_binlog.result: Import patch wl1012.patch mysql-test/r/binlog_stm_blackhole.result: Import patch wl1012.patch mysql-test/r/binlog_stm_ctype_cp932.result: Import patch wl1012.patch mysql-test/r/binlog_stm_ctype_ucs.result: Import patch wl1012.patch mysql-test/r/binlog_stm_drop_tmp_tbl.result: Import patch wl1012.patch mysql-test/r/binlog_stm_insert_select.result: Import patch wl1012.patch mysql-test/r/binlog_stm_mix_innodb_myisam.result: Import patch wl1012.patch mysql-test/r/rpl_000012.result: Import patch wl1012.patch mysql-test/r/rpl_000015.result: Import patch wl1012.patch mysql-test/r/rpl_deadlock_innodb.result: Import patch wl1012.patch mysql-test/r/rpl_flushlog_loop.result: Import patch wl1012.patch mysql-test/r/rpl_loaddata_s.result: Import patch wl1012.patch mysql-test/r/rpl_stm_000001.result: Import patch wl1012.patch mysql-test/r/rpl_stm_EE_err.result: Import patch wl1012.patch mysql-test/r/rpl_stm_charset.result: Import patch wl1012.patch mysql-test/r/rpl_stm_ddl.result: Import patch wl1012.patch mysql-test/r/rpl_stm_err_ignoredtable.result: Import patch wl1012.patch mysql-test/r/rpl_stm_flsh_tbls.result: Import patch wl1012.patch mysql-test/r/rpl_stm_loaddata_m.result: Import patch wl1012.patch mysql-test/r/rpl_stm_log.result: Import patch wl1012.patch mysql-test/r/rpl_stm_max_relay_size.result: Import patch wl1012.patch mysql-test/r/rpl_stm_multi_query.result: Import patch wl1012.patch mysql-test/r/rpl_stm_mystery22.result: Import patch wl1012.patch mysql-test/r/rpl_stm_reset_slave.result: Import patch wl1012.patch mysql-test/r/rpl_stm_rewrt_db.result: Import patch wl1012.patch mysql-test/r/rpl_stm_sp.result: Import patch wl1012.patch mysql-test/r/rpl_stm_timezone.result: Import patch wl1012.patch mysql-test/r/rpl_stm_until.result: Import patch wl1012.patch mysql-test/r/rpl_stm_user_variables.result: Import patch wl1012.patch mysql-test/r/rpl_stm_view.result: Import patch wl1012.patch mysql-test/t/binlog_row_binlog-master.opt: Import patch wl1012.patch mysql-test/t/rpl_000012.test: Import patch wl1012.patch mysql-test/t/rpl_000015-slave.sh: Import patch wl1012.patch mysql-test/t/rpl_000015.slave-mi: Import patch wl1012.patch mysql-test/t/rpl_000015.test: Import patch wl1012.patch mysql-test/t/rpl_deadlock_innodb-slave.opt: Import patch wl1012.patch mysql-test/t/rpl_flushlog_loop-master.opt: Import patch wl1012.patch mysql-test/t/rpl_flushlog_loop-master.sh: Import patch wl1012.patch mysql-test/t/rpl_flushlog_loop-slave.opt: Import patch wl1012.patch mysql-test/t/rpl_flushlog_loop-slave.sh: Import patch wl1012.patch mysql-test/t/rpl_flushlog_loop.test: Import patch wl1012.patch mysql-test/t/rpl_loaddata_s-slave.opt: Import patch wl1012.patch mysql-test/t/rpl_loaddata_s.test: Import patch wl1012.patch mysql-test/t/rpl_stm_000001-slave.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_err_ignoredtable-slave.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_loaddata_m-master.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_log-master.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_log-slave.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_mystery22.test: Import patch wl1012.patch mysql-test/t/rpl_stm_rewrt_db-slave.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_rewrt_db.test: Import patch wl1012.patch mysql-test/t/rpl_stm_sp-master.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_sp-slave.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_sp.test: Import patch wl1012.patch mysql-test/t/rpl_stm_timezone-master.opt: Import patch wl1012.patch mysql-test/t/rpl_stm_timezone-slave.opt: Import patch wl1012.patch BUILD/SETUP.sh: Import patch wl1012.patch Makefile.am: Import patch wl1012.patch mysql-test/t/rpl_stm_timezone.test: Import patch wl1012.patch mysql-test/t/rpl_stm_until.test: Import patch wl1012.patch mysql-test/t/rpl_stm_view.test: Import patch wl1012.patch client/Makefile.am: Import patch wl1012.patch client/client_priv.h: Import patch wl1012.patch client/mysqlbinlog.cc: Import patch wl1012.patch configure.in: Import patch wl1012.patch include/Makefile.am: Import patch wl1012.patch include/base64.h: Import patch wl1012.patch include/config-win.h: Import patch wl1012.patch include/my_base.h: Import patch wl1012.patch include/my_global.h: Import patch wl1012.patch mysql-test/Makefile.am: Import patch wl1012.patch mysql-test/mysql-test-run.pl: Import patch wl1012.patch mysql-test/mysql-test-run.sh: Import patch wl1012.patch mysql-test/r/date_formats.result: Import patch wl1012.patch mysql-test/r/flush_block_commit.result: Import patch wl1012.patch mysql-test/r/innodb.result: Import patch wl1012.patch mysql-test/r/rpl000017.result: Import patch wl1012.patch mysql-test/r/rpl_change_master.result: Import patch wl1012.patch mysql-test/r/rpl_commit_after_flush.result: Import patch wl1012.patch mysql-test/r/rpl_create_database.result: Import patch wl1012.patch mysql-test/r/rpl_do_grant.result: Import patch wl1012.patch mysql-test/r/rpl_loaddata.result: Import patch wl1012.patch mysql-test/r/rpl_log_pos.result: Import patch wl1012.patch mysql-test/r/rpl_multi_delete.result: Import patch wl1012.patch mysql-test/r/rpl_multi_update.result: Import patch wl1012.patch mysql-test/r/rpl_openssl.result: Import patch wl1012.patch mysql-test/r/rpl_replicate_do.result: Import patch wl1012.patch mysql-test/r/rpl_rotate_logs.result: Import patch wl1012.patch mysql-test/r/rpl_server_id1.result: Import patch wl1012.patch mysql-test/r/rpl_server_id2.result: Import patch wl1012.patch mysql-test/r/rpl_temporary.result: Import patch wl1012.patch mysql-test/r/user_var-binlog.result: Import patch wl1012.patch mysql-test/t/create_select_tmp.test: Import patch wl1012.patch mysql-test/t/date_formats.test: Import patch wl1012.patch mysql-test/t/disabled.def: Import patch wl1012.patch mysql-test/t/innodb.test: Import patch wl1012.patch mysql-test/t/mysqlbinlog.test: Import patch wl1012.patch mysql-test/t/mysqlbinlog2.test: Import patch wl1012.patch mysql-test/t/rpl000002.test: Import patch wl1012.patch mysql-test/t/rpl000006.test: Import patch wl1012.patch mysql-test/t/rpl000013.test: Import patch wl1012.patch mysql-test/t/rpl000017.test: Import patch wl1012.patch mysql-test/t/rpl_auto_increment.test: Import patch wl1012.patch mysql-test/t/rpl_change_master.test: Import patch wl1012.patch mysql-test/t/rpl_commit_after_flush.test: Import patch wl1012.patch mysql-test/t/rpl_create_database.test: Import patch wl1012.patch mysql-test/t/rpl_do_grant.test: Import patch wl1012.patch mysql-test/t/rpl_drop.test: Import patch wl1012.patch mysql-test/t/rpl_empty_master_crash.test: Import patch wl1012.patch mysql-test/t/rpl_failed_optimize.test: Import patch wl1012.patch mysql-test/t/rpl_heap.test: Import patch wl1012.patch mysql-test/t/rpl_insert_id.test: Import patch wl1012.patch mysql-test/t/rpl_insert_ignore.test: Import patch wl1012.patch mysql-test/t/rpl_loaddata.test: Import patch wl1012.patch mysql-test/t/rpl_log_pos.test: Import patch wl1012.patch mysql-test/t/rpl_multi_delete.test: Import patch wl1012.patch mysql-test/t/rpl_multi_update.test: Import patch wl1012.patch mysql-test/t/rpl_multi_update2.test: Import patch wl1012.patch mysql-test/t/rpl_multi_update3.test: Import patch wl1012.patch mysql-test/t/rpl_openssl.test: Import patch wl1012.patch mysql-test/t/rpl_redirect.test: Import patch wl1012.patch mysql-test/t/rpl_relayrotate.test: Import patch wl1012.patch mysql-test/t/rpl_replicate_do.test: Import patch wl1012.patch mysql-test/t/rpl_rotate_logs.test: Import patch wl1012.patch mysql-test/t/rpl_server_id1.test: Import patch wl1012.patch mysql-test/t/rpl_sp_effects.test: Import patch wl1012.patch mysql-test/t/rpl_temporary.test: Import patch wl1012.patch mysql-test/t/rpl_trigger.test: Import patch wl1012.patch mysql-test/t/sp.test: Import patch wl1012.patch mysql-test/t/user_var-binlog.test: Import patch wl1012.patch mysys/Makefile.am: Import patch wl1012.patch mysys/base64.c: Import patch wl1012.patch sql/Makefile.am: Import patch wl1012.patch sql/ha_innodb.cc: Import patch wl1012.patch sql/ha_innodb.h: Import patch wl1012.patch sql/ha_partition.cc: Import patch wl1012.patch sql/handler.cc: Import patch wl1012.patch sql/handler.h: Import patch wl1012.patch sql/item_sum.cc: Import patch wl1012.patch sql/log.cc: Import patch wl1012.patch sql/log_event.cc: Import patch wl1012.patch sql/log_event.h: Import patch wl1012.patch sql/mysql_priv.h: Import patch wl1012.patch sql/mysqld.cc: Import patch wl1012.patch sql/rpl_filter.h: Import patch wl1012.patch sql/set_var.cc: Import patch wl1012.patch sql/share/errmsg.txt: Import patch wl1012.patch sql/slave.cc: Import patch wl1012.patch sql/slave.h: Import patch wl1012.patch sql/sp.cc: Import patch wl1012.patch sql/sp_head.cc: Import patch wl1012.patch sql/sql_acl.cc: Import patch wl1012.patch sql/sql_base.cc: Import patch wl1012.patch sql/sql_class.cc: Import patch wl1012.patch sql/sql_class.h: Import patch wl1012.patch sql/sql_delete.cc: Import patch wl1012.patch sql/sql_insert.cc: Import patch wl1012.patch sql/sql_lex.h: Import patch wl1012.patch sql/sql_list.h: Import patch wl1012.patch sql/sql_load.cc: Import patch wl1012.patch sql/sql_parse.cc: Import patch wl1012.patch sql/sql_plugin.cc: Import patch wl1012.patch sql/sql_rename.cc: Import patch wl1012.patch sql/sql_repl.h: Import patch wl1012.patch sql/sql_select.cc: Import patch wl1012.patch sql/sql_show.cc: Import patch wl1012.patch sql/sql_table.cc: Import patch wl1012.patch sql/sql_udf.cc: Import patch wl1012.patch sql/sql_union.cc: Import patch wl1012.patch sql/sql_update.cc: Import patch wl1012.patch sql/sql_yacc.yy: Import patch wl1012.patch sql/table.cc: Import patch wl1012.patch sql/table.h: Import patch wl1012.patch storage/innobase/include/lock0lock.h: Import patch wl1012.patch storage/innobase/include/row0mysql.h: Import patch wl1012.patch storage/innobase/include/row0vers.h: Import patch wl1012.patch storage/innobase/lock/lock0lock.c: Import patch wl1012.patch storage/innobase/row/row0mysql.c: Import patch wl1012.patch storage/innobase/row/row0sel.c: Import patch wl1012.patch storage/innobase/row/row0vers.c: Import patch wl1012.patch
279 lines
5.9 KiB
C
279 lines
5.9 KiB
C
/* Copyright (C) 2003 MySQL AB
|
|
|
|
This program 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; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
|
|
#include <base64.h>
|
|
#include <m_string.h> /* strchr() */
|
|
#include <m_ctype.h> /* my_isspace() */
|
|
|
|
#ifndef MAIN
|
|
|
|
static char base64_table[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
|
|
"abcdefghijklmnopqrstuvwxyz"
|
|
"0123456789+/";
|
|
|
|
|
|
int
|
|
base64_needed_encoded_length(int length_of_data)
|
|
{
|
|
int nb_base64_chars;
|
|
nb_base64_chars= (length_of_data + 2) / 3 * 4;
|
|
|
|
return
|
|
nb_base64_chars + /* base64 char incl padding */
|
|
(nb_base64_chars - 1)/ 76 + /* newlines */
|
|
1; /* NUL termination of string */
|
|
}
|
|
|
|
|
|
int
|
|
base64_needed_decoded_length(int length_of_encoded_data)
|
|
{
|
|
return ceil(length_of_encoded_data * 3 / 4);
|
|
}
|
|
|
|
|
|
/*
|
|
Encode a data as base64.
|
|
|
|
Note: We require that dst is pre-allocated to correct size.
|
|
See base64_needed_encoded_length().
|
|
*/
|
|
|
|
int
|
|
base64_encode(const void *src, size_t src_len, char *dst)
|
|
{
|
|
const unsigned char *s= (const unsigned char*)src;
|
|
size_t i= 0;
|
|
size_t len= 0;
|
|
|
|
for (; i < src_len; len += 4)
|
|
{
|
|
unsigned c;
|
|
|
|
if (len == 76)
|
|
{
|
|
len= 0;
|
|
*dst++= '\n';
|
|
}
|
|
|
|
c= s[i++];
|
|
c <<= 8;
|
|
|
|
if (i < src_len)
|
|
c += s[i];
|
|
c <<= 8;
|
|
i++;
|
|
|
|
if (i < src_len)
|
|
c += s[i];
|
|
i++;
|
|
|
|
*dst++= base64_table[(c >> 18) & 0x3f];
|
|
*dst++= base64_table[(c >> 12) & 0x3f];
|
|
|
|
if (i > (src_len + 1))
|
|
*dst++= '=';
|
|
else
|
|
*dst++= base64_table[(c >> 6) & 0x3f];
|
|
|
|
if (i > src_len)
|
|
*dst++= '=';
|
|
else
|
|
*dst++= base64_table[(c >> 0) & 0x3f];
|
|
}
|
|
*dst= '\0';
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
static inline unsigned
|
|
pos(unsigned char c)
|
|
{
|
|
return strchr(base64_table, c) - base64_table;
|
|
}
|
|
|
|
|
|
#define SKIP_SPACE(src, i, size) \
|
|
{ \
|
|
while (i < size && my_isspace(&my_charset_latin1, * src)) \
|
|
{ \
|
|
i++; \
|
|
src++; \
|
|
} \
|
|
if (i == size) \
|
|
{ \
|
|
break; \
|
|
} \
|
|
}
|
|
|
|
|
|
/*
|
|
Decode a base64 string
|
|
|
|
Note: We require that dst is pre-allocated to correct size.
|
|
See base64_needed_decoded_length().
|
|
|
|
RETURN Number of bytes produced in dst or -1 in case of failure
|
|
*/
|
|
int
|
|
base64_decode(const char *src, size_t size, void *dst)
|
|
{
|
|
char b[3];
|
|
size_t i= 0;
|
|
char *dst_base= (char *)dst;
|
|
char *d= dst_base;
|
|
size_t j;
|
|
|
|
while (i < size)
|
|
{
|
|
unsigned c= 0;
|
|
size_t mark= 0;
|
|
|
|
SKIP_SPACE(src, i, size);
|
|
|
|
c += pos(*src++);
|
|
c <<= 6;
|
|
i++;
|
|
|
|
SKIP_SPACE(src, i, size);
|
|
|
|
c += pos(*src++);
|
|
c <<= 6;
|
|
i++;
|
|
|
|
SKIP_SPACE(src, i, size);
|
|
|
|
if (* src != '=')
|
|
c += pos(*src++);
|
|
else
|
|
{
|
|
i= size;
|
|
mark= 2;
|
|
c <<= 6;
|
|
goto end;
|
|
}
|
|
c <<= 6;
|
|
i++;
|
|
|
|
SKIP_SPACE(src, i, size);
|
|
|
|
if (*src != '=')
|
|
c += pos(*src++);
|
|
else
|
|
{
|
|
i= size;
|
|
mark= 1;
|
|
goto end;
|
|
}
|
|
i++;
|
|
|
|
end:
|
|
b[0]= (c >> 16) & 0xff;
|
|
b[1]= (c >> 8) & 0xff;
|
|
b[2]= (c >> 0) & 0xff;
|
|
|
|
for (j=0; j<3-mark; j++)
|
|
*d++= b[j];
|
|
}
|
|
|
|
if (i != size)
|
|
{
|
|
return -1;
|
|
}
|
|
return d - dst_base;
|
|
}
|
|
|
|
|
|
#else /* MAIN */
|
|
|
|
#define require(b) { \
|
|
if (!(b)) { \
|
|
printf("Require failed at %s:%d\n", __FILE__, __LINE__); \
|
|
abort(); \
|
|
} \
|
|
}
|
|
|
|
|
|
int
|
|
main(void)
|
|
{
|
|
int i;
|
|
size_t j;
|
|
size_t k, l;
|
|
size_t dst_len;
|
|
size_t needed_length;
|
|
|
|
for (i= 0; i < 500; i++)
|
|
{
|
|
/* Create source data */
|
|
const size_t src_len= rand() % 1000 + 1;
|
|
|
|
char * src= (char *) malloc(src_len);
|
|
char * s= src;
|
|
char * str;
|
|
char * dst;
|
|
|
|
for (j= 0; j<src_len; j++)
|
|
{
|
|
char c= rand();
|
|
*s++= c;
|
|
}
|
|
|
|
/* Encode */
|
|
needed_length= base64_needed_encoded_length(src_len);
|
|
str= (char *) malloc(needed_length);
|
|
for (k= 0; k < needed_length; k++)
|
|
str[k]= 0xff; /* Fill memory to check correct NUL termination */
|
|
require(base64_encode(src, src_len, str) == 0);
|
|
require(needed_length == strlen(str) + 1);
|
|
|
|
/* Decode */
|
|
dst= (char *) malloc(base64_needed_decoded_length(strlen(str)));
|
|
dst_len= base64_decode(str, strlen(str), dst);
|
|
require(dst_len == src_len);
|
|
|
|
if (memcmp(src, dst, src_len) != 0)
|
|
{
|
|
printf(" --------- src --------- --------- dst ---------\n");
|
|
for (k= 0; k<src_len; k+=8)
|
|
{
|
|
printf("%.4x ", (uint) k);
|
|
for (l=0; l<8 && k+l<src_len; l++)
|
|
{
|
|
unsigned char c= src[k+l];
|
|
printf("%.2x ", (unsigned)c);
|
|
}
|
|
|
|
printf(" ");
|
|
|
|
for (l=0; l<8 && k+l<dst_len; l++)
|
|
{
|
|
unsigned char c= dst[k+l];
|
|
printf("%.2x ", (unsigned)c);
|
|
}
|
|
printf("\n");
|
|
}
|
|
printf("src length: %.8x, dst length: %.8x\n",
|
|
(uint) src_len, (uint) dst_len);
|
|
require(0);
|
|
}
|
|
}
|
|
printf("Test succeeded.\n");
|
|
return 0;
|
|
}
|
|
|
|
#endif
|