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
62efd9aa
Commit
62efd9aa
authored
Sep 14, 2004
by
unknown
Browse files
Options
Browse Files
Download
Plain Diff
Merge abotchkov@bk-internal.mysql.com:/home/bk/mysql-4.0
into deer.(none):/home/hf/work/mysql-4.0.4809
parents
4015c585
e6503e1e
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
44 additions
and
34 deletions
+44
-34
innobase/include/row0mysql.h
innobase/include/row0mysql.h
+5
-3
innobase/sync/sync0arr.c
innobase/sync/sync0arr.c
+1
-4
sql/ha_innodb.cc
sql/ha_innodb.cc
+38
-27
No files found.
innobase/include/row0mysql.h
View file @
62efd9aa
...
@@ -508,9 +508,11 @@ struct row_prebuilt_struct {
...
@@ -508,9 +508,11 @@ struct row_prebuilt_struct {
dtuple_t
*
clust_ref
;
/* prebuilt dtuple used in
dtuple_t
*
clust_ref
;
/* prebuilt dtuple used in
sel/upd/del */
sel/upd/del */
ulint
select_lock_type
;
/* LOCK_NONE, LOCK_S, or LOCK_X */
ulint
select_lock_type
;
/* LOCK_NONE, LOCK_S, or LOCK_X */
ulint
stored_select_lock_type
;
/* inside LOCK TABLES, either
ulint
stored_select_lock_type
;
/* this field is used to
LOCK_S or LOCK_X depending on the lock
remember the original select_lock_type
type */
that was decided in ha_innodb.cc,
::store_lock(), ::external_lock(),
etc. */
ulint
mysql_row_len
;
/* length in bytes of a row in the
ulint
mysql_row_len
;
/* length in bytes of a row in the
MySQL format */
MySQL format */
ulint
n_rows_fetched
;
/* number of rows fetched after
ulint
n_rows_fetched
;
/* number of rows fetched after
...
...
innobase/sync/sync0arr.c
View file @
62efd9aa
...
@@ -61,10 +61,7 @@ struct sync_cell_struct {
...
@@ -61,10 +61,7 @@ struct sync_cell_struct {
thread */
thread */
ibool
waiting
;
/* TRUE if the thread has already
ibool
waiting
;
/* TRUE if the thread has already
called sync_array_event_wait
called sync_array_event_wait
on this cell but not yet
on this cell */
sync_array_free_cell (which
actually resets wait_object and thus
whole cell) */
ibool
event_set
;
/* TRUE if the event is set */
ibool
event_set
;
/* TRUE if the event is set */
os_event_t
event
;
/* operating system event
os_event_t
event
;
/* operating system event
semaphore handle */
semaphore handle */
...
...
sql/ha_innodb.cc
View file @
62efd9aa
...
@@ -767,6 +767,7 @@ ha_innobase::init_table_handle_for_HANDLER(void)
...
@@ -767,6 +767,7 @@ ha_innobase::init_table_handle_for_HANDLER(void)
if the trx isolation level would have been specified as SERIALIZABLE */
if the trx isolation level would have been specified as SERIALIZABLE */
prebuilt
->
select_lock_type
=
LOCK_NONE
;
prebuilt
->
select_lock_type
=
LOCK_NONE
;
prebuilt
->
stored_select_lock_type
=
LOCK_NONE
;
/* Always fetch all columns in the index record */
/* Always fetch all columns in the index record */
...
@@ -4562,40 +4563,40 @@ ha_innobase::start_stmt(
...
@@ -4562,40 +4563,40 @@ ha_innobase::start_stmt(
prebuilt
->
select_lock_type
=
LOCK_X
;
prebuilt
->
select_lock_type
=
LOCK_X
;
}
else
{
}
else
{
/* When we first come here after LOCK TABLES,
if
(
trx
->
isolation_level
!=
TRX_ISO_SERIALIZABLE
select_lock_type is set to LOCK_S or LOCK_X. Store the value
&&
thd
->
lex
.
sql_command
==
SQLCOM_SELECT
in case we run also consistent reads and need to restore the
&&
thd
->
lex
.
lock_option
==
TL_READ
)
{
value later. */
/* For other than temporary tables, we obtain
no lock for consistent read (plain SELECT). */
if
(
prebuilt
->
select_lock_type
!=
LOCK_NONE
)
{
prebuilt
->
select_lock_type
=
LOCK_NONE
;
prebuilt
->
stored_select_lock_type
=
}
else
{
prebuilt
->
select_lock_type
;
/* Not a consistent read: restore the
select_lock_type value. The value of
stored_select_lock_type was decided in:
1) ::store_lock(),
2) ::external_lock(), and
3) ::init_table_handle_for_HANDLER(). */
prebuilt
->
select_lock_type
=
prebuilt
->
stored_select_lock_type
;
}
}
if
(
prebuilt
->
stored_select_lock_type
!=
LOCK_S
if
(
prebuilt
->
stored_select_lock_type
!=
LOCK_S
&&
prebuilt
->
stored_select_lock_type
!=
LOCK_X
)
{
&&
prebuilt
->
stored_select_lock_type
!=
LOCK_X
)
{
fprintf
(
stderr
,
fprintf
(
stderr
,
"InnoDB: Error: select_lock_type is %lu inside ::start_stmt()!
\n
"
,
"InnoDB: Error: s
tored_s
elect_lock_type is %lu inside ::start_stmt()!
\n
"
,
prebuilt
->
stored_select_lock_type
);
prebuilt
->
stored_select_lock_type
);
ut_error
;
/* Set the value to LOCK_X: this is just fault
}
tolerance, we do not know what the correct value
should be! */
if
(
thd
->
lex
.
sql_command
==
SQLCOM_SELECT
prebuilt
->
select_lock_type
=
LOCK_X
;
&&
thd
->
lex
.
lock_option
==
TL_READ
)
{
/* For other than temporary tables, we obtain
no lock for consistent read (plain SELECT) */
prebuilt
->
select_lock_type
=
LOCK_NONE
;
}
else
{
/* Not a consistent read: restore the
select_lock_type value */
prebuilt
->
select_lock_type
=
prebuilt
->
stored_select_lock_type
;
}
}
}
}
/* Set the MySQL flag to mark that there is an active transaction */
/* Set the MySQL flag to mark that there is an active transaction */
thd
->
transaction
.
all
.
innodb_active_trans
=
1
;
thd
->
transaction
.
all
.
innodb_active_trans
=
1
;
...
@@ -4656,6 +4657,7 @@ ha_innobase::external_lock(
...
@@ -4656,6 +4657,7 @@ ha_innobase::external_lock(
/* If this is a SELECT, then it is in UPDATE TABLE ...
/* If this is a SELECT, then it is in UPDATE TABLE ...
or SELECT ... FOR UPDATE */
or SELECT ... FOR UPDATE */
prebuilt
->
select_lock_type
=
LOCK_X
;
prebuilt
->
select_lock_type
=
LOCK_X
;
prebuilt
->
stored_select_lock_type
=
LOCK_X
;
}
}
if
(
lock_type
!=
F_UNLCK
)
{
if
(
lock_type
!=
F_UNLCK
)
{
...
@@ -4910,14 +4912,22 @@ ha_innobase::store_lock(
...
@@ -4910,14 +4912,22 @@ ha_innobase::store_lock(
{
{
row_prebuilt_t
*
prebuilt
=
(
row_prebuilt_t
*
)
innobase_prebuilt
;
row_prebuilt_t
*
prebuilt
=
(
row_prebuilt_t
*
)
innobase_prebuilt
;
if
(
lock_type
==
TL_READ_WITH_SHARED_LOCKS
||
if
((
lock_type
==
TL_READ
&&
thd
->
in_lock_tables
)
||
(
lock_type
==
TL_READ_HIGH_PRIORITY
&&
thd
->
in_lock_tables
)
||
lock_type
==
TL_READ_WITH_SHARED_LOCKS
||
lock_type
==
TL_READ_NO_INSERT
)
{
lock_type
==
TL_READ_NO_INSERT
)
{
/* This is a SELECT ... IN SHARE MODE, or
/* The OR cases above are in this order:
we are doing a complex SQL statement like
1) MySQL is doing LOCK TABLES ... READ LOCAL, or
2) (we do not know when TL_READ_HIGH_PRIORITY is used), or
3) this is a SELECT ... IN SHARE MODE, or
4) we are doing a complex SQL statement like
INSERT INTO ... SELECT ... and the logical logging (MySQL
INSERT INTO ... SELECT ... and the logical logging (MySQL
binlog) requires the use of a locking read */
binlog) requires the use of a locking read, or
MySQL is doing LOCK TABLES ... READ. */
prebuilt
->
select_lock_type
=
LOCK_S
;
prebuilt
->
select_lock_type
=
LOCK_S
;
prebuilt
->
stored_select_lock_type
=
LOCK_S
;
}
else
if
(
lock_type
!=
TL_IGNORE
)
{
}
else
if
(
lock_type
!=
TL_IGNORE
)
{
/* In ha_berkeley.cc there is a comment that MySQL
/* In ha_berkeley.cc there is a comment that MySQL
...
@@ -4928,6 +4938,7 @@ ha_innobase::store_lock(
...
@@ -4928,6 +4938,7 @@ ha_innobase::store_lock(
here even if this would be SELECT ... FOR UPDATE */
here even if this would be SELECT ... FOR UPDATE */
prebuilt
->
select_lock_type
=
LOCK_NONE
;
prebuilt
->
select_lock_type
=
LOCK_NONE
;
prebuilt
->
stored_select_lock_type
=
LOCK_NONE
;
}
}
if
(
lock_type
!=
TL_IGNORE
&&
lock
.
type
==
TL_UNLOCK
)
{
if
(
lock_type
!=
TL_IGNORE
&&
lock
.
type
==
TL_UNLOCK
)
{
...
...
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