Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
mariadb
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Kirill Smelkov
mariadb
Commits
079d8590
Commit
079d8590
authored
Sep 28, 2000
by
sasha@mysql.sashanet.com
Browse files
Options
Browse Files
Download
Plain Diff
merge/resolve conflicts
parents
43120631
ea0f48ff
Changes
9
Hide whitespace changes
Inline
Side-by-side
Showing
9 changed files
with
172 additions
and
64 deletions
+172
-64
sql/log_event.cc
sql/log_event.cc
+61
-29
sql/log_event.h
sql/log_event.h
+58
-18
sql/mysql_priv.h
sql/mysql_priv.h
+1
-0
sql/mysqlbinlog.cc
sql/mysqlbinlog.cc
+2
-0
sql/mysqld.cc
sql/mysqld.cc
+40
-15
sql/share/romanian/errmsg.sys
sql/share/romanian/errmsg.sys
+0
-0
sql/slave.cc
sql/slave.cc
+8
-2
sql/sql_class.cc
sql/sql_class.cc
+1
-0
sql/sql_class.h
sql/sql_class.h
+1
-0
No files found.
sql/log_event.cc
View file @
079d8590
...
...
@@ -22,11 +22,11 @@
#include "mysql_priv.h"
#endif
/* MYSQL_CLIENT */
#define LOG_EVENT_HEADER_LEN
9
#define LOG_EVENT_HEADER_LEN
13
#define QUERY_HEADER_LEN (sizeof(uint32) + sizeof(uint32) + sizeof(uchar))
#define LOAD_HEADER_LEN (sizeof(uint32) + sizeof(uint32) + \
+ sizeof(uint32) + 2 + sizeof(uint32))
#define EVENT_LEN_OFFSET
5
#define EVENT_LEN_OFFSET
9
#define EVENT_TYPE_OFFSET 4
#define MAX_EVENT_LEN 4*1024*1024
#define QUERY_EVENT_OVERHEAD LOG_EVENT_HEADER_LEN+QUERY_HEADER_LEN
...
...
@@ -71,6 +71,8 @@ int Log_event::write_header(FILE* file)
int4store
(
pos
,
when
);
// timestamp
pos
+=
4
;
*
pos
++
=
get_type_code
();
// event type code
int4store
(
pos
,
server_id
);
pos
+=
4
;
int4store
(
pos
,
get_data_size
()
+
LOG_EVENT_HEADER_LEN
);
pos
+=
4
;
return
(
my_fwrite
(
file
,
(
byte
*
)
buf
,
(
uint
)
(
pos
-
buf
),
...
...
@@ -106,16 +108,19 @@ int Log_event::read_log_event(FILE* file, String* packet)
Log_event
*
Log_event
::
read_log_event
(
FILE
*
file
)
{
time_t
timestamp
;
char
buf
[
5
];
uint32
server_id
;
char
buf
[
LOG_EVENT_HEADER_LEN
-
4
];
if
(
my_fread
(
file
,
(
byte
*
)
buf
,
sizeof
(
buf
),
MY_NABP
))
return
NULL
;
timestamp
=
uint4korr
(
buf
);
server_id
=
uint4korr
(
buf
+
5
);
switch
(
buf
[
EVENT_TYPE_OFFSET
])
{
case
QUERY_EVENT
:
{
Query_log_event
*
q
=
new
Query_log_event
(
file
,
timestamp
);
Query_log_event
*
q
=
new
Query_log_event
(
file
,
timestamp
,
server_id
);
if
(
!
q
->
query
)
{
delete
q
;
...
...
@@ -127,7 +132,7 @@ Log_event* Log_event::read_log_event(FILE* file)
case
LOAD_EVENT
:
{
Load_log_event
*
l
=
new
Load_log_event
(
file
,
timestamp
);
Load_log_event
*
l
=
new
Load_log_event
(
file
,
timestamp
,
server_id
);
if
(
!
l
->
table_name
)
{
delete
l
;
...
...
@@ -140,7 +145,7 @@ Log_event* Log_event::read_log_event(FILE* file)
case
ROTATE_EVENT
:
{
Rotate_log_event
*
r
=
new
Rotate_log_event
(
file
,
timestamp
);
Rotate_log_event
*
r
=
new
Rotate_log_event
(
file
,
timestamp
,
server_id
);
if
(
!
r
->
new_log_ident
)
{
delete
r
;
...
...
@@ -152,7 +157,7 @@ Log_event* Log_event::read_log_event(FILE* file)
case
INTVAR_EVENT
:
{
Intvar_log_event
*
e
=
new
Intvar_log_event
(
file
,
timestamp
);
Intvar_log_event
*
e
=
new
Intvar_log_event
(
file
,
timestamp
,
server_id
);
if
(
e
->
type
==
INVALID_INT_EVENT
)
{
delete
e
;
...
...
@@ -162,8 +167,8 @@ Log_event* Log_event::read_log_event(FILE* file)
return
e
;
}
case
START_EVENT
:
return
new
Start_log_event
(
file
,
timestamp
);
case
STOP_EVENT
:
return
new
Stop_log_event
(
file
,
timestamp
);
case
START_EVENT
:
return
new
Start_log_event
(
file
,
timestamp
,
server_id
);
case
STOP_EVENT
:
return
new
Stop_log_event
(
file
,
timestamp
,
server_id
);
default:
return
NULL
;
}
...
...
@@ -221,12 +226,23 @@ Log_event* Log_event::read_log_event(const char* buf, int max_buf)
return
NULL
;
}
void
Log_event
::
print_timestamp
(
FILE
*
file
)
void
Log_event
::
print_header
(
FILE
*
file
)
{
fputc
(
'#'
,
file
);
print_timestamp
(
file
);
fprintf
(
file
,
" server id %d "
,
server_id
);
}
void
Log_event
::
print_timestamp
(
FILE
*
file
,
time_t
*
ts
=
0
)
{
struct
tm
tm_tmp
;
localtime_r
(
&
when
,
&
tm_tmp
);
if
(
!
ts
)
{
ts
=
&
when
;
}
localtime_r
(
ts
,
&
tm_tmp
);
fprintf
(
file
,
"
#
%02d%02d%02d %2d:%02d:%02d"
,
fprintf
(
file
,
"%02d%02d%02d %2d:%02d:%02d"
,
tm_tmp
.
tm_year
%
100
,
tm_tmp
.
tm_mon
+
1
,
tm_tmp
.
tm_mday
,
...
...
@@ -241,8 +257,11 @@ void Start_log_event::print(FILE* file, bool short_form)
if
(
short_form
)
return
;
print_timestamp
(
file
);
fprintf
(
file
,
"
\t
Start
\n
"
);
print_header
(
file
);
fprintf
(
file
,
"
\t
Start: binlog v %d, server v %s created "
,
binlog_version
,
server_version
);
print_timestamp
(
file
,
(
time_t
*
)
&
created
);
fputc
(
'\n'
,
file
);
fflush
(
file
);
}
...
...
@@ -251,7 +270,7 @@ void Stop_log_event::print(FILE* file, bool short_form)
if
(
short_form
)
return
;
print_
timestamp
(
file
);
print_
header
(
file
);
fprintf
(
file
,
"
\t
Stop
\n
"
);
fflush
(
file
);
}
...
...
@@ -261,7 +280,7 @@ void Rotate_log_event::print(FILE* file, bool short_form)
if
(
short_form
)
return
;
print_
timestamp
(
file
);
print_
header
(
file
);
fprintf
(
file
,
"
\t
Rotate to "
);
if
(
new_log_ident
)
my_fwrite
(
file
,
(
byte
*
)
new_log_ident
,
(
uint
)
ident_len
,
...
...
@@ -270,8 +289,9 @@ void Rotate_log_event::print(FILE* file, bool short_form)
fflush
(
file
);
}
Rotate_log_event
::
Rotate_log_event
(
FILE
*
file
,
time_t
when_arg
)
:
Log_event
(
when_arg
),
new_log_ident
(
NULL
),
alloced
(
0
)
Rotate_log_event
::
Rotate_log_event
(
FILE
*
file
,
time_t
when_arg
,
uint32
server_id
)
:
Log_event
(
when_arg
,
0
,
0
,
server_id
),
new_log_ident
(
NULL
),
alloced
(
0
)
{
char
*
tmp_ident
;
char
buf
[
4
];
...
...
@@ -298,6 +318,14 @@ Rotate_log_event::Rotate_log_event(FILE* file, time_t when_arg):
alloced
=
1
;
}
Start_log_event
::
Start_log_event
(
const
char
*
buf
)
:
Log_event
(
buf
)
{
buf
+=
EVENT_LEN_OFFSET
+
4
;
// skip even length
binlog_version
=
uint2korr
(
buf
);
memcpy
(
server_version
,
buf
+
2
,
sizeof
(
server_version
));
created
=
uint4korr
(
buf
+
2
+
sizeof
(
server_version
));
}
Rotate_log_event
::
Rotate_log_event
(
const
char
*
buf
,
int
max_buf
)
:
Log_event
(
buf
),
new_log_ident
(
NULL
),
alloced
(
0
)
{
...
...
@@ -322,8 +350,9 @@ int Rotate_log_event::write_data(FILE* file)
return
0
;
}
Query_log_event
::
Query_log_event
(
FILE
*
file
,
time_t
when_arg
)
:
Log_event
(
when_arg
),
data_buf
(
0
),
query
(
NULL
),
db
(
NULL
)
Query_log_event
::
Query_log_event
(
FILE
*
file
,
time_t
when_arg
,
uint32
server_id
)
:
Log_event
(
when_arg
,
0
,
0
,
server_id
),
data_buf
(
0
),
query
(
NULL
),
db
(
NULL
)
{
char
buf
[
QUERY_HEADER_LEN
+
4
];
ulong
data_len
;
...
...
@@ -382,7 +411,7 @@ void Query_log_event::print(FILE* file, bool short_form)
{
if
(
!
short_form
)
{
print_
timestamp
(
file
);
print_
header
(
file
);
fprintf
(
file
,
"
\t
Query
\t
thread_id=%lu
\t
exec_time=%lu
\n
"
,
(
ulong
)
thread_id
,
(
ulong
)
exec_time
);
}
...
...
@@ -414,8 +443,9 @@ int Query_log_event::write_data(FILE* file)
return
0
;
}
Intvar_log_event
::
Intvar_log_event
(
FILE
*
file
,
time_t
when_arg
)
:
Log_event
(
when_arg
),
type
(
INVALID_INT_EVENT
)
Intvar_log_event
::
Intvar_log_event
(
FILE
*
file
,
time_t
when_arg
,
uint32
server_id
)
:
Log_event
(
when_arg
,
0
,
0
,
server_id
),
type
(
INVALID_INT_EVENT
)
{
my_fseek
(
file
,
4L
,
MY_SEEK_CUR
,
MYF
(
MY_WME
));
// skip the event length
char
buf
[
9
];
...
...
@@ -444,7 +474,7 @@ void Intvar_log_event::print(FILE* file, bool short_form)
char
llbuff
[
22
];
if
(
!
short_form
)
{
print_
timestamp
(
file
);
print_
header
(
file
);
fprintf
(
file
,
"
\t
Intvar
\n
"
);
}
...
...
@@ -493,8 +523,9 @@ int Load_log_event::write_data(FILE* file __attribute__((unused)))
return
0
;
}
Load_log_event
::
Load_log_event
(
FILE
*
file
,
time_t
when
)
:
Log_event
(
when
),
data_buf
(
0
),
num_fields
(
0
),
fields
(
0
),
field_lens
(
0
),
field_block_len
(
0
),
Load_log_event
::
Load_log_event
(
FILE
*
file
,
time_t
when
,
uint32
server_id
)
:
Log_event
(
when
,
0
,
0
,
server_id
),
data_buf
(
0
),
num_fields
(
0
),
fields
(
0
),
field_lens
(
0
),
field_block_len
(
0
),
table_name
(
0
),
db
(
0
),
fname
(
0
)
{
...
...
@@ -539,7 +570,8 @@ Load_log_event::Load_log_event(FILE* file, time_t when):
}
Load_log_event
::
Load_log_event
(
const
char
*
buf
,
int
max_buf
)
:
Log_event
(
when
),
data_buf
(
0
),
num_fields
(
0
),
fields
(
0
),
field_lens
(
0
),
field_block_len
(
0
),
Log_event
(
when
,
0
,
0
,
server_id
),
data_buf
(
0
),
num_fields
(
0
),
fields
(
0
),
field_lens
(
0
),
field_block_len
(
0
),
table_name
(
0
),
db
(
0
),
fname
(
0
)
{
...
...
@@ -594,7 +626,7 @@ void Load_log_event::print(FILE* file, bool short_form)
{
if
(
!
short_form
)
{
print_
timestamp
(
file
);
print_
header
(
file
);
fprintf
(
file
,
"
\t
Query
\t
thread_id=%d
\t
exec_time=%ld
\n
"
,
thread_id
,
exec_time
);
}
...
...
sql/log_event.h
View file @
079d8590
...
...
@@ -28,7 +28,7 @@
#define LOG_READ_MEM -5
#define LOG_EVENT_OFFSET 4
#define BINLOG_VERSION 1
enum
Log_event_type
{
START_EVENT
=
1
,
QUERY_EVENT
=
2
,
STOP_EVENT
=
3
,
ROTATE_EVENT
=
4
,
INTVAR_EVENT
=
5
,
...
...
@@ -40,25 +40,32 @@ enum Int_event_type { INVALID_INT_EVENT = 0, LAST_INSERT_ID_EVENT = 1, INSERT_ID
class
String
;
#endif
extern
uint32
server_id
;
class
Log_event
{
public:
time_t
when
;
ulong
exec_time
;
int
valid_exec_time
;
// if false, the exec time setting is bogus and needs
int
valid_exec_time
;
// if false, the exec time setting is bogus
uint32
server_id
;
int
write
(
FILE
*
file
);
int
write_header
(
FILE
*
file
);
virtual
int
write_data
(
FILE
*
file
__attribute__
((
unused
)))
{
return
0
;
}
virtual
Log_event_type
get_type_code
()
=
0
;
Log_event
(
time_t
when_arg
,
ulong
exec_time_arg
=
0
,
int
valid_exec_time_arg
=
0
)
:
when
(
when_arg
),
exec_time
(
exec_time_arg
),
valid_exec_time
(
valid_exec_time_arg
)
{}
int
valid_exec_time_arg
=
0
,
uint32
server_id
=
0
)
:
when
(
when_arg
),
exec_time
(
exec_time_arg
),
valid_exec_time
(
valid_exec_time_arg
)
{
if
(
!
server_id
)
this
->
server_id
=
::
server_id
;
else
this
->
server_id
=
server_id
;
}
Log_event
(
const
char
*
buf
)
:
valid_exec_time
(
1
)
Log_event
(
const
char
*
buf
)
:
valid_exec_time
(
0
)
{
when
=
uint4korr
(
buf
);
exec_time
=
uint4korr
(
buf
+
5
);
server_id
=
uint4korr
(
buf
+
5
);
}
virtual
~
Log_event
()
{}
...
...
@@ -66,7 +73,8 @@ public:
virtual
int
get_data_size
()
{
return
0
;}
virtual
void
print
(
FILE
*
file
,
bool
short_form
=
0
)
=
0
;
void
print_timestamp
(
FILE
*
file
);
void
print_timestamp
(
FILE
*
file
,
time_t
*
ts
=
0
);
void
print_header
(
FILE
*
file
);
static
Log_event
*
read_log_event
(
FILE
*
file
);
static
Log_event
*
read_log_event
(
const
char
*
buf
,
int
max_buf
);
...
...
@@ -93,7 +101,7 @@ public:
#if !defined(MYSQL_CLIENT)
THD
*
thd
;
Query_log_event
(
THD
*
thd_arg
,
const
char
*
query_arg
)
:
Log_event
(
thd_arg
->
start_time
),
data_buf
(
0
),
Log_event
(
thd_arg
->
start_time
,
0
,
0
,
thd
->
server_id
),
data_buf
(
0
),
query
(
query_arg
),
db
(
thd_arg
->
db
),
q_len
(
thd_arg
->
query_length
),
thread_id
(
thd_arg
->
thread_id
),
thd
(
thd_arg
)
{
...
...
@@ -105,7 +113,7 @@ public:
}
#endif
Query_log_event
(
FILE
*
file
,
time_t
when
);
Query_log_event
(
FILE
*
file
,
time_t
when
,
uint32
server_id
);
Query_log_event
(
const
char
*
buf
,
int
max_buf
);
~
Query_log_event
()
{
...
...
@@ -244,7 +252,7 @@ public:
void
set_fields
(
List
<
Item
>
&
fields
);
#endif
Load_log_event
(
FILE
*
file
,
time_t
when
);
Load_log_event
(
FILE
*
file
,
time_t
when
,
uint32
server_id
);
Load_log_event
(
const
char
*
buf
,
int
max_buf
);
~
Load_log_event
()
{
...
...
@@ -269,21 +277,52 @@ public:
void
print
(
FILE
*
file
,
bool
short_form
=
0
);
};
extern
char
server_version
[
50
];
class
Start_log_event
:
public
Log_event
{
public:
Start_log_event
()
:
Log_event
(
time
(
NULL
))
{}
Start_log_event
(
FILE
*
file
,
time_t
when_arg
)
:
Log_event
(
when_arg
)
uint16
binlog_version
;
char
server_version
[
50
];
uint32
created
;
Start_log_event
()
:
Log_event
(
time
(
NULL
)),
binlog_version
(
BINLOG_VERSION
)
{
my_fseek
(
file
,
4L
,
MY_SEEK_CUR
,
MYF
(
MY_WME
));
// skip the event length
created
=
when
;
memcpy
(
server_version
,
::
server_version
,
sizeof
(
server_version
));
}
Start_log_event
(
const
char
*
buf
)
:
Log_event
(
buf
)
Start_log_event
(
FILE
*
file
,
time_t
when_arg
,
uint32
server_id
)
:
Log_event
(
when_arg
,
0
,
0
,
server_id
)
{
char
buf
[
sizeof
(
server_version
)
+
sizeof
(
binlog_version
)
+
sizeof
(
created
)];
my_fseek
(
file
,
4L
,
MY_SEEK_CUR
,
MYF
(
MY_WME
));
// skip the event length
if
(
my_fread
(
file
,
(
byte
*
)
buf
,
sizeof
(
buf
),
MYF
(
MY_NABP
|
MY_WME
)))
return
;
binlog_version
=
uint2korr
(
buf
);
memcpy
(
server_version
,
buf
+
2
,
sizeof
(
server_version
));
created
=
uint4korr
(
buf
+
2
+
sizeof
(
server_version
));
}
Start_log_event
(
const
char
*
buf
);
~
Start_log_event
()
{}
Log_event_type
get_type_code
()
{
return
START_EVENT
;}
int
write_data
(
FILE
*
file
)
{
if
(
my_fwrite
(
file
,
(
byte
*
)
&
binlog_version
,
sizeof
(
binlog_version
),
MYF
(
MY_NABP
|
MY_WME
))
||
my_fwrite
(
file
,
(
byte
*
)
server_version
,
sizeof
(
server_version
),
MYF
(
MY_NABP
|
MY_WME
))
||
my_fwrite
(
file
,
(
byte
*
)
&
created
,
sizeof
(
created
),
MYF
(
MY_NABP
|
MY_WME
)))
return
-
1
;
return
0
;
}
int
get_data_size
()
{
return
sizeof
(
binlog_version
)
+
sizeof
(
server_version
)
+
sizeof
(
created
);
}
void
print
(
FILE
*
file
,
bool
short_form
=
0
);
};
...
...
@@ -295,7 +334,7 @@ public:
Intvar_log_event
(
uchar
type_arg
,
ulonglong
val_arg
)
:
Log_event
(
time
(
NULL
)),
val
(
val_arg
),
type
(
type_arg
)
{}
Intvar_log_event
(
FILE
*
file
,
time_t
when
);
Intvar_log_event
(
FILE
*
file
,
time_t
when
,
uint32
server_id
);
Intvar_log_event
(
const
char
*
buf
);
~
Intvar_log_event
()
{}
Log_event_type
get_type_code
()
{
return
INTVAR_EVENT
;}
...
...
@@ -311,7 +350,8 @@ class Stop_log_event: public Log_event
public:
Stop_log_event
()
:
Log_event
(
time
(
NULL
))
{}
Stop_log_event
(
FILE
*
file
,
time_t
when_arg
)
:
Log_event
(
when_arg
)
Stop_log_event
(
FILE
*
file
,
time_t
when_arg
,
uint32
server_id
)
:
Log_event
(
when_arg
,
0
,
0
,
server_id
)
{
my_fseek
(
file
,
4L
,
MY_SEEK_CUR
,
MYF
(
MY_WME
));
// skip the event length
}
...
...
@@ -337,7 +377,7 @@ public:
alloced
(
0
)
{}
Rotate_log_event
(
FILE
*
file
,
time_t
when
)
;
Rotate_log_event
(
FILE
*
file
,
time_t
when
,
uint32
server_id
)
;
Rotate_log_event
(
const
char
*
buf
,
int
max_buf
);
~
Rotate_log_event
()
{
...
...
sql/mysql_priv.h
View file @
079d8590
...
...
@@ -437,6 +437,7 @@ void sql_perror(const char *message);
void
sql_print_error
(
const
char
*
format
,...)
__attribute__
((
format
(
printf
,
1
,
2
)));
extern
uint32
server_id
;
extern
char
mysql_data_home
[
2
],
server_version
[
50
],
max_sort_char
,
mysql_real_data_home
[];
extern
my_string
mysql_unix_port
,
mysql_tmpdir
;
...
...
sql/mysqlbinlog.cc
View file @
079d8590
...
...
@@ -29,6 +29,8 @@
#define CLIENT_CAPABILITIES (CLIENT_LONG_PASSWORD | CLIENT_LONG_FLAG | CLIENT_LOCAL_FILES)
char
server_version
[
50
];
uint32
server_id
=
0
;
// needed by net_serv.c
ulong
bytes_sent
=
0L
,
bytes_received
=
0L
;
...
...
sql/mysqld.cc
View file @
079d8590
...
...
@@ -142,6 +142,7 @@ static uint handler_count;
static
bool
opt_console
=
0
;
#endif
static
bool
opt_skip_slave_start
=
0
;
// if set, slave is not autostarted
static
ulong
opt_specialflag
=
SPECIAL_ENGLISH
;
static
my_socket
unix_sock
=
INVALID_SOCKET
,
ip_sock
=
INVALID_SOCKET
;
static
ulong
back_log
,
connect_timeout
,
concurrency
;
...
...
@@ -180,6 +181,7 @@ I_List<i_string> replicate_do_db, replicate_ignore_db;
// allow the user to tell us which db to replicate and which to ignore
I_List
<
i_string
>
binlog_do_db
,
binlog_ignore_db
;
uint32
server_id
=
0
;
// server id for replication
uint
mysql_port
;
uint
test_flags
,
select_errors
=
0
,
dropping_tables
=
0
,
ha_open_options
=
0
;
uint
volatile
thread_count
=
0
,
thread_running
=
0
,
kill_cached_threads
=
0
,
...
...
@@ -1482,17 +1484,23 @@ int main(int argc, char **argv)
LOG_NEW
);
if
(
opt_bin_log
)
{
if
(
!
opt_bin_logname
)
{
char
tmp
[
FN_REFLEN
];
strnmov
(
tmp
,
hostname
,
FN_REFLEN
-
5
);
strmov
(
strcend
(
tmp
,
'.'
),
"-bin"
);
opt_bin_logname
=
my_strdup
(
tmp
,
MYF
(
MY_WME
));
}
mysql_bin_log
.
set_index_file_name
(
opt_binlog_index_name
);
open_log
(
&
mysql_bin_log
,
hostname
,
opt_bin_logname
,
"-bin"
,
LOG_BIN
);
if
(
server_id
)
{
if
(
!
opt_bin_logname
)
{
char
tmp
[
FN_REFLEN
];
strnmov
(
tmp
,
hostname
,
FN_REFLEN
-
5
);
strmov
(
strcend
(
tmp
,
'.'
),
"-bin"
);
opt_bin_logname
=
my_strdup
(
tmp
,
MYF
(
MY_WME
));
}
mysql_bin_log
.
set_index_file_name
(
opt_binlog_index_name
);
open_log
(
&
mysql_bin_log
,
hostname
,
opt_bin_logname
,
"-bin"
,
LOG_BIN
);
}
else
sql_print_error
(
"Server id is not set - binary logging disabled"
);
}
if
(
opt_slow_log
)
open_log
(
&
mysql_slow_log
,
hostname
,
opt_slow_logname
,
"-slow.log"
,
LOG_NORMAL
);
...
...
@@ -1596,10 +1604,15 @@ int main(int argc, char **argv)
// slave thread
if
(
master_host
)
{
pthread_t
hThread
;
if
(
pthread_create
(
&
hThread
,
&
connection_attrib
,
handle_slave
,
0
))
sql_print_error
(
"Warning: Can't create thread to handle slave"
);
if
(
server_id
)
{
pthread_t
hThread
;
if
(
!
opt_skip_slave_start
&&
pthread_create
(
&
hThread
,
&
connection_attrib
,
handle_slave
,
0
))
sql_print_error
(
"Warning: Can't create thread to handle slave"
);
}
else
sql_print_error
(
"Server id is not set, slave thread will not be started"
);
}
printf
(
ER
(
ER_READY
),
my_progname
,
server_version
,
""
);
...
...
@@ -2201,7 +2214,8 @@ enum options {
OPT_REPLICATE_DO_DB
,
OPT_REPLICATE_IGNORE_DB
,
OPT_LOG_SLAVE_UPDATES
,
OPT_BINLOG_DO_DB
,
OPT_BINLOG_IGNORE_DB
,
OPT_WANT_CORE
,
OPT_SKIP_CONCURRENT_INSERT
,
OPT_MEMLOCK
,
OPT_MYISAM_RECOVER
OPT_SKIP_CONCURRENT_INSERT
,
OPT_MEMLOCK
,
OPT_MYISAM_RECOVER
,
OPT_REPLICATE_REWRITE_DB
,
OPT_SERVER_ID
,
OPT_SKIP_SLAVE_START
};
static
struct
option
long_options
[]
=
{
...
...
@@ -2266,8 +2280,11 @@ static struct option long_options[] = {
{
"port"
,
required_argument
,
0
,
'P'
},
{
"replicate-do-db"
,
required_argument
,
0
,
(
int
)
OPT_REPLICATE_DO_DB
},
{
"replicate-ignore-db"
,
required_argument
,
0
,
(
int
)
OPT_REPLICATE_IGNORE_DB
},
{
"replicate-rewrite-db"
,
required_argument
,
0
,
(
int
)
OPT_REPLICATE_REWRITE_DB
},
{
"safe-mode"
,
no_argument
,
0
,
(
int
)
OPT_SAFE
},
{
"socket"
,
required_argument
,
0
,
(
int
)
OPT_SOCKET
},
{
"server-id"
,
required_argument
,
0
,
(
int
)
OPT_SERVER_ID
},
{
"set-variable"
,
required_argument
,
0
,
'O'
},
#ifdef HAVE_BERKELEY_DB
{
"skip-bdb"
,
no_argument
,
0
,
(
int
)
OPT_BDB_SKIP
},
...
...
@@ -2280,6 +2297,7 @@ static struct option long_options[] = {
{
"skip-name-resolve"
,
no_argument
,
0
,
(
int
)
OPT_SKIP_RESOLVE
},
{
"skip-new"
,
no_argument
,
0
,
(
int
)
OPT_SKIP_NEW
},
{
"skip-show-database"
,
no_argument
,
0
,
(
int
)
OPT_SKIP_SHOW_DB
},
{
"skip-slave-start"
,
no_argument
,
0
,
(
int
)
OPT_SKIP_SLAVE_START
},
{
"skip-networking"
,
no_argument
,
0
,
(
int
)
OPT_SKIP_NETWORKING
},
{
"skip-thread-priority"
,
no_argument
,
0
,
(
int
)
OPT_SKIP_PRIOR
},
{
"sql-bin-update-same"
,
no_argument
,
0
,
(
int
)
OPT_SQL_BIN_UPDATE_SAME
},
...
...
@@ -2428,6 +2446,7 @@ struct show_var_st init_vars[]= {
{
"port"
,
(
char
*
)
&
mysql_port
,
SHOW_INT
},
{
"protocol_version"
,
(
char
*
)
&
protocol_version
,
SHOW_INT
},
{
"record_buffer"
,
(
char
*
)
&
my_default_record_cache_size
,
SHOW_LONG
},
{
"server_id"
,
(
char
*
)
&
server_id
,
SHOW_LONG
},
{
"skip_locking"
,
(
char
*
)
&
my_disable_locking
,
SHOW_MY_BOOL
},
{
"skip_networking"
,
(
char
*
)
&
opt_disable_networking
,
SHOW_BOOL
},
{
"skip_show_database"
,
(
char
*
)
&
opt_skip_show_db
,
SHOW_BOOL
},
...
...
@@ -2851,6 +2870,9 @@ static void get_options(int argc,char **argv)
opt_slow_log
=
1
;
opt_slow_logname
=
optarg
;
break
;
case
(
int
)
OPT_SKIP_SLAVE_START
:
opt_skip_slave_start
=
1
;
break
;
case
(
int
)
OPT_SKIP_NEW
:
opt_specialflag
|=
SPECIAL_NO_NEW_FUNC
;
default_table_type
=
DB_TYPE_ISAM
;
...
...
@@ -2972,6 +2994,9 @@ static void get_options(int argc,char **argv)
default_table_type
=
(
enum
db_type
)
type
;
break
;
}
case
OPT_SERVER_ID
:
server_id
=
atoi
(
optarg
);
break
;
case
OPT_DELAY_KEY_WRITE
:
ha_open_options
|=
HA_OPEN_DELAY_KEY_WRITE
;
myisam_delay_key_write
=
1
;
...
...
sql/share/romanian/errmsg.sys
View file @
079d8590
No preview for this file type
sql/slave.cc
View file @
079d8590
...
...
@@ -797,11 +797,17 @@ pthread_handler_decl(handle_slave,arg __attribute__((unused)))
THD
*
thd
;;
// needs to be first for thread_stack
MYSQL
*
mysql
=
NULL
;
if
(
!
server_id
)
{
sql_print_error
(
"Server id not set, will not start slave"
);
pthread_exit
(
1
);
}
pthread_mutex_lock
(
&
LOCK_slave
);
if
(
slave_running
)
{
pthread_mutex_unlock
(
&
LOCK_slave
);
return
0
;
// safety just in case
pthread_exit
(
1
)
;
// safety just in case
}
slave_running
=
1
;
abort_slave
=
0
;
...
...
@@ -938,7 +944,7 @@ static void safe_reconnect(THD* thd, MYSQL* mysql, MASTER_INFO* mi)
while
(
!
slave_killed
(
thd
)
&&
mc_mysql_reconnect
(
mysql
))
{
sql_print_error
(
"Slave thread: error connecting to
slave
:%s, retry in %d sec"
,
"Slave thread: error connecting to
master
:%s, retry in %d sec"
,
mc_mysql_error
(
mysql
),
mi
->
connect_retry
);
safe_sleep
(
thd
,
mi
->
connect_retry
);
}
...
...
sql/sql_class.cc
View file @
079d8590
...
...
@@ -83,6 +83,7 @@ THD::THD()
user_time
=
bootstrap
=
in_lock_tables
=
global_read_lock
=
0
;
query_length
=
col_access
=
0
;
query_error
=
0
;
server_id
=
::
server_id
;
server_status
=
SERVER_STATUS_AUTOCOMMIT
;
next_insert_id
=
last_insert_id
=
0
;
open_tables
=
temporary_tables
=
0
;
...
...
sql/sql_class.h
View file @
079d8590
...
...
@@ -243,6 +243,7 @@ public:
ULL
*
ull
;
struct
st_my_thread_var
*
mysys_var
;
enum
enum_server_command
command
;
uint32
server_id
;
const
char
*
where
;
char
*
last_nx_table
;
// last non-existent table, we need this for replication
char
*
last_nx_db
;
// database of the last nx table
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment