~ubuntu-branches/ubuntu/wily/mysql-5.6/wily

« back to all changes in this revision

Viewing changes to storage/innobase/que/que0que.cc

  • Committer: Package Import Robot
  • Author(s): Marc Deslauriers
  • Date: 2015-04-16 20:07:10 UTC
  • mto: (1.3.9 vivid-proposed)
  • mto: This revision was merged to the branch mainline in revision 11.
  • Revision ID: package-import@ubuntu.com-20150416200710-pcrsa022082zj46k
Tags: upstream-5.6.24
ImportĀ upstreamĀ versionĀ 5.6.24

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
1
/*****************************************************************************
2
2
 
3
 
Copyright (c) 1996, 2012, Oracle and/or its affiliates. All Rights Reserved.
 
3
Copyright (c) 1996, 2015, Oracle and/or its affiliates. All Rights Reserved.
4
4
 
5
5
This program is free software; you can redistribute it and/or modify it under
6
6
the terms of the GNU General Public License as published by the Free Software
380
380
        return(thr);
381
381
}
382
382
 
383
 
/****************************************************************//**
384
 
Tests if all the query threads in the same fork have a given state.
385
 
@return TRUE if all the query threads in the same fork were in the
386
 
given state */
387
 
UNIV_INLINE
388
 
ibool
389
 
que_fork_all_thrs_in_state(
390
 
/*=======================*/
391
 
        que_fork_t*     fork,   /*!< in: query fork */
392
 
        ulint           state)  /*!< in: state */
393
 
{
394
 
        que_thr_t*      thr_node;
395
 
 
396
 
        for (thr_node = UT_LIST_GET_FIRST(fork->thrs);
397
 
             thr_node != NULL;
398
 
             thr_node = UT_LIST_GET_NEXT(thrs, thr_node)) {
399
 
 
400
 
                if (thr_node->state != state) {
401
 
 
402
 
                        return(FALSE);
403
 
                }
404
 
        }
405
 
 
406
 
        return(TRUE);
407
 
}
408
 
 
409
383
/**********************************************************************//**
410
384
Calls que_graph_free_recursive for statements in a statement list. */
411
385
static