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
cd049201
Commit
cd049201
authored
Jun 23, 2004
by
monty@mysql.com
Browse files
Options
Browse Files
Download
Plain Diff
Merge bk-internal.mysql.com:/home/bk/mysql-4.1
into mysql.com:/home/my/mysql-4.1
parents
b42fc1e7
d0507ca7
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
24 additions
and
19 deletions
+24
-19
sql/handler.cc
sql/handler.cc
+11
-10
sql/tztime.cc
sql/tztime.cc
+13
-9
No files found.
sql/handler.cc
View file @
cd049201
...
@@ -578,10 +578,11 @@ int ha_rollback_trans(THD *thd, THD_TRANS *trans)
...
@@ -578,10 +578,11 @@ int ha_rollback_trans(THD *thd, THD_TRANS *trans)
if
((
trans
==
&
thd
->
transaction
.
all
)
&&
mysql_bin_log
.
is_open
())
if
((
trans
==
&
thd
->
transaction
.
all
)
&&
mysql_bin_log
.
is_open
())
{
{
/*
/*
Update the binary log with a BEGIN/ROLLBACK block if we have cached some
Update the binary log with a BEGIN/ROLLBACK block if we have
queries and we updated some non-transactional table. Such cases should
cached some queries and we updated some non-transactional
be rare (updating a non-transactional table inside a transaction...).
table. Such cases should be rare (updating a
Count disk writes to trans_log in any case.
non-transactional table inside a transaction...). Count disk
writes to trans_log in any case.
*/
*/
if
(
my_b_tell
(
&
thd
->
transaction
.
trans_log
))
if
(
my_b_tell
(
&
thd
->
transaction
.
trans_log
))
{
{
...
@@ -626,12 +627,12 @@ int ha_rollback_trans(THD *thd, THD_TRANS *trans)
...
@@ -626,12 +627,12 @@ int ha_rollback_trans(THD *thd, THD_TRANS *trans)
simply truncate the binlog cache, we lose the part of the binlog cache where
simply truncate the binlog cache, we lose the part of the binlog cache where
the update is. If we want to not lose it, we need to write the SAVEPOINT
the update is. If we want to not lose it, we need to write the SAVEPOINT
command and the ROLLBACK TO SAVEPOINT command to the binlog cache. The latter
command and the ROLLBACK TO SAVEPOINT command to the binlog cache. The latter
is easy: it's just write at the end of the binlog cache, but the former
should
is easy: it's just write at the end of the binlog cache, but the former
be *inserted* to the place where the user called SAVEPOINT. The solution is
should be *inserted* to the place where the user called SAVEPOINT. The
that when the user calls SAVEPOINT, we write it to the binlog cache (so no
solution is that when the user calls SAVEPOINT, we write it to the binlog
need to later insert it). As transactions are never intermixed in the binary log
cache (so no need to later insert it). As transactions are never intermixed
(i.e. they are serialized), we won't have conflicts with savepoint names when
in the binary log (i.e. they are serialized), we won't have conflicts with
using mysqlbinlog or in the slave SQL thread.
savepoint names when
using mysqlbinlog or in the slave SQL thread.
Then when ROLLBACK TO SAVEPOINT is called, if we updated some
Then when ROLLBACK TO SAVEPOINT is called, if we updated some
non-transactional table, we don't truncate the binlog cache but instead write
non-transactional table, we don't truncate the binlog cache but instead write
ROLLBACK TO SAVEPOINT to it; otherwise we truncate the binlog cache (which
ROLLBACK TO SAVEPOINT to it; otherwise we truncate the binlog cache (which
...
...
sql/tztime.cc
View file @
cd049201
...
@@ -24,13 +24,11 @@
...
@@ -24,13 +24,11 @@
#pragma implementation // gcc: Class implementation
#pragma implementation // gcc: Class implementation
#endif
#endif
#include "mysql_priv.h"
#include "mysql_priv.h"
#include "tzfile.h"
#include "tzfile.h"
#include <m_string.h>
#include <m_string.h>
#include <my_dir.h>
#include <my_dir.h>
/*
/*
Now we don't use abbreviations in server but we will do this in future.
Now we don't use abbreviations in server but we will do this in future.
*/
*/
...
@@ -53,8 +51,8 @@ typedef struct ttinfo
...
@@ -53,8 +51,8 @@ typedef struct ttinfo
uint
tt_abbrind
;
// Index of start of abbreviation for this time type.
uint
tt_abbrind
;
// Index of start of abbreviation for this time type.
#endif
#endif
/*
/*
We don't use tt_ttisstd and tt_ttisgmt members of original elsie-code
struct
We don't use tt_ttisstd and tt_ttisgmt members of original elsie-code
since we don't support POSIX-style TZ descriptions in variables.
s
truct s
ince we don't support POSIX-style TZ descriptions in variables.
*/
*/
}
TRAN_TYPE_INFO
;
}
TRAN_TYPE_INFO
;
...
@@ -1337,6 +1335,7 @@ static MEM_ROOT tz_storage;
...
@@ -1337,6 +1335,7 @@ static MEM_ROOT tz_storage;
tz_storage. So contention is low.
tz_storage. So contention is low.
*/
*/
static
pthread_mutex_t
tz_LOCK
;
static
pthread_mutex_t
tz_LOCK
;
static
bool
tz_inited
=
0
;
/*
/*
This two static variables are inteded for holding info about leap seconds
This two static variables are inteded for holding info about leap seconds
...
@@ -1410,7 +1409,6 @@ my_tz_init(THD *org_thd, const char *default_tzname, my_bool bootstrap)
...
@@ -1410,7 +1409,6 @@ my_tz_init(THD *org_thd, const char *default_tzname, my_bool bootstrap)
my_bool
return_val
=
1
;
my_bool
return_val
=
1
;
int
res
;
int
res
;
uint
not_used
;
uint
not_used
;
DBUG_ENTER
(
"my_tz_init"
);
DBUG_ENTER
(
"my_tz_init"
);
/*
/*
...
@@ -1436,6 +1434,7 @@ my_tz_init(THD *org_thd, const char *default_tzname, my_bool bootstrap)
...
@@ -1436,6 +1434,7 @@ my_tz_init(THD *org_thd, const char *default_tzname, my_bool bootstrap)
}
}
init_alloc_root
(
&
tz_storage
,
32
*
1024
,
0
);
init_alloc_root
(
&
tz_storage
,
32
*
1024
,
0
);
VOID
(
pthread_mutex_init
(
&
tz_LOCK
,
MY_MUTEX_INIT_FAST
));
VOID
(
pthread_mutex_init
(
&
tz_LOCK
,
MY_MUTEX_INIT_FAST
));
tz_inited
=
1
;
/* Add 'SYSTEM' time zone to tz_names hash */
/* Add 'SYSTEM' time zone to tz_names hash */
if
(
!
(
tmp_tzname
=
new
(
&
tz_storage
)
TZ_NAMES_ENTRY
()))
if
(
!
(
tmp_tzname
=
new
(
&
tz_storage
)
TZ_NAMES_ENTRY
()))
...
@@ -1591,12 +1590,17 @@ end:
...
@@ -1591,12 +1590,17 @@ end:
SYNOPSIS
SYNOPSIS
my_tz_free()
my_tz_free()
*/
*/
void
my_tz_free
()
void
my_tz_free
()
{
{
VOID
(
pthread_mutex_destroy
(
&
tz_LOCK
));
if
(
tz_inited
)
hash_free
(
&
offset_tzs
);
{
hash_free
(
&
tz_names
);
tz_inited
=
0
;
free_root
(
&
tz_storage
,
MYF
(
0
));
VOID
(
pthread_mutex_destroy
(
&
tz_LOCK
));
hash_free
(
&
offset_tzs
);
hash_free
(
&
tz_names
);
free_root
(
&
tz_storage
,
MYF
(
0
));
}
}
}
...
...
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