| 201 | } |
| 202 | |
| 203 | void signal_done(THD *queue) { |
| 204 | mysql_mutex_lock(&m_lock_done); |
| 205 | for (THD *thd= queue ; thd ; thd = thd->next_to_commit) |
| 206 | thd->transaction.flags.pending= false; |
| 207 | mysql_mutex_unlock(&m_lock_done); |
| 208 | mysql_cond_broadcast(&m_cond_done); |
| 209 | } |
| 210 | |
| 211 | private: |
| 212 | /** |
nothing calls this directly
no outgoing calls
no test coverage detected