diff options
| author | Nikita Malyavin <nikitamalyavin@gmail.com> | 2022-02-23 22:38:51 +0300 |
|---|---|---|
| committer | Nikita Malyavin <nikitamalyavin@gmail.com> | 2022-06-19 14:53:32 +0300 |
| commit | 7bffc4fced4966a1ab939de7d6d6bfbb334726ac (patch) | |
| tree | 0cb91424a6fb78c98c27c6125a8d035df3e2e46e /sql/sql_parse.cc | |
| parent | 2946e51f2cac9d52be46ed018d26b98ec5f14fcd (diff) | |
| download | mariadb-git-bb-10.10-nikita.tar.gz | |
Add tests and code instrumentationsbb-10.10-nikita
Diffstat (limited to 'sql/sql_parse.cc')
| -rw-r--r-- | sql/sql_parse.cc | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc index eb2b52dbc18..ec86389d08f 100644 --- a/sql/sql_parse.cc +++ b/sql/sql_parse.cc @@ -1296,7 +1296,8 @@ dispatch_command_return do_command(THD *thd, bool blocking) goto out; } - thd->apc_target.process_apc_requests(); + if (unlikely(thd->apc_target.have_apc_requests())) + thd->apc_target.process_apc_requests(); packet= (char*) net->read_pos; /* @@ -1408,6 +1409,8 @@ dispatch_command_return do_command(THD *thd, bool blocking) resume: return_value= dispatch_command(command, thd, packet+1, (uint) (packet_length-1), blocking); + DEBUG_SYNC(thd, "after_dispatch_command"); + if (return_value == DISPATCH_COMMAND_WOULDBLOCK) { /* Save current state, and resume later.*/ |