Function fetch_queue_for

phx_percona/percona/sql/binlog.h:198–201

Fetch the entire queue and empty it. @return Pointer to the first session of the queue. */

    @return Pointer to the first session of the queue.
   */
  THD *fetch_queue_for(StageID stage) {
    DBUG_PRINT("debug", ("Fetching queue for stage %d", stage));
    return m_queue[stage].fetch_and_empty();
  }

  void signal_done(THD *queue) {
    mysql_mutex_lock(&m_lock_done);