mirror of
				https://github.com/MariaDB/server.git
				synced 2025-10-31 10:56:12 +01:00 
			
		
		
		
	
		
			
				
	
	
		
			245 lines
		
	
	
	
		
			5.9 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			245 lines
		
	
	
	
		
			5.9 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| /*****************************************************************************
 | |
| 
 | |
| Copyright (c) 1996, 2013, Oracle and/or its affiliates. All Rights Reserved.
 | |
| Copyright (c) 2020, 2021, MariaDB Corporation.
 | |
| 
 | |
| This program is free software; you can redistribute it and/or modify it under
 | |
| the terms of the GNU General Public License as published by the Free Software
 | |
| Foundation; version 2 of the License.
 | |
| 
 | |
| This program is distributed in the hope that it will be useful, but WITHOUT
 | |
| ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 | |
| FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
 | |
| 
 | |
| You should have received a copy of the GNU General Public License along with
 | |
| this program; if not, write to the Free Software Foundation, Inc.,
 | |
| 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA
 | |
| 
 | |
| *****************************************************************************/
 | |
| 
 | |
| /**************************************************//**
 | |
| @file include/que0que.ic
 | |
| Query graph
 | |
| 
 | |
| Created 5/27/1996 Heikki Tuuri
 | |
| *******************************************************/
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Gets the trx of a query thread. */
 | |
| UNIV_INLINE
 | |
| trx_t*
 | |
| thr_get_trx(
 | |
| /*========*/
 | |
| 	que_thr_t*	thr)	/*!< in: query thread */
 | |
| {
 | |
| 	ut_ad(thr);
 | |
| 
 | |
| 	return(thr->graph->trx);
 | |
| }
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Gets the first thr in a fork. */
 | |
| UNIV_INLINE
 | |
| que_thr_t*
 | |
| que_fork_get_first_thr(
 | |
| /*===================*/
 | |
| 	que_fork_t*	fork)	/*!< in: query fork */
 | |
| {
 | |
| 	return(UT_LIST_GET_FIRST(fork->thrs));
 | |
| }
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Gets the child node of the first thr in a fork. */
 | |
| UNIV_INLINE
 | |
| que_node_t*
 | |
| que_fork_get_child(
 | |
| /*===============*/
 | |
| 	que_fork_t*	fork)	/*!< in: query fork */
 | |
| {
 | |
| 	que_thr_t*	thr;
 | |
| 
 | |
| 	thr = UT_LIST_GET_FIRST(fork->thrs);
 | |
| 
 | |
| 	return(thr->child);
 | |
| }
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Gets the type of a graph node. */
 | |
| UNIV_INLINE
 | |
| ulint
 | |
| que_node_get_type(
 | |
| /*==============*/
 | |
| 	const que_node_t*	node)	/*!< in: graph node */
 | |
| {
 | |
| 	return(reinterpret_cast<const que_common_t*>(node)->type);
 | |
| }
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Gets pointer to the value dfield of a graph node. */
 | |
| UNIV_INLINE
 | |
| dfield_t*
 | |
| que_node_get_val(
 | |
| /*=============*/
 | |
| 	que_node_t*	node)	/*!< in: graph node */
 | |
| {
 | |
| 	ut_ad(node);
 | |
| 
 | |
| 	return(&(((que_common_t*) node)->val));
 | |
| }
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Gets the value buffer size of a graph node.
 | |
| @return val buffer size, not defined if val.data == NULL in node */
 | |
| UNIV_INLINE
 | |
| ulint
 | |
| que_node_get_val_buf_size(
 | |
| /*======================*/
 | |
| 	que_node_t*	node)	/*!< in: graph node */
 | |
| {
 | |
| 	ut_ad(node);
 | |
| 
 | |
| 	return(((que_common_t*) node)->val_buf_size);
 | |
| }
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Sets the value buffer size of a graph node. */
 | |
| UNIV_INLINE
 | |
| void
 | |
| que_node_set_val_buf_size(
 | |
| /*======================*/
 | |
| 	que_node_t*	node,	/*!< in: graph node */
 | |
| 	ulint		size)	/*!< in: size */
 | |
| {
 | |
| 	ut_ad(node);
 | |
| 
 | |
| 	((que_common_t*) node)->val_buf_size = size;
 | |
| }
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Sets the parent of a graph node. */
 | |
| UNIV_INLINE
 | |
| void
 | |
| que_node_set_parent(
 | |
| /*================*/
 | |
| 	que_node_t*	node,	/*!< in: graph node */
 | |
| 	que_node_t*	parent)	/*!< in: parent */
 | |
| {
 | |
| 	ut_ad(node);
 | |
| 
 | |
| 	((que_common_t*) node)->parent = parent;
 | |
| }
 | |
| 
 | |
| /***********************************************************************//**
 | |
| Gets pointer to the value data type field of a graph node. */
 | |
| UNIV_INLINE
 | |
| dtype_t*
 | |
| que_node_get_data_type(
 | |
| /*===================*/
 | |
| 	que_node_t*	node)	/*!< in: graph node */
 | |
| {
 | |
| 	ut_ad(node);
 | |
| 
 | |
| 	return(dfield_get_type(&((que_common_t*) node)->val));
 | |
| }
 | |
| 
 | |
| /*********************************************************************//**
 | |
| Catenates a query graph node to a list of them, possible empty list.
 | |
| @return one-way list of nodes */
 | |
| UNIV_INLINE
 | |
| que_node_t*
 | |
| que_node_list_add_last(
 | |
| /*===================*/
 | |
| 	que_node_t*	node_list,	/*!< in: node list, or NULL */
 | |
| 	que_node_t*	node)		/*!< in: node */
 | |
| {
 | |
| 	que_common_t*	cnode;
 | |
| 	que_common_t*	cnode2;
 | |
| 
 | |
| 	cnode = (que_common_t*) node;
 | |
| 
 | |
| 	cnode->brother = NULL;
 | |
| 
 | |
| 	if (node_list == NULL) {
 | |
| 
 | |
| 		return(node);
 | |
| 	}
 | |
| 
 | |
| 	cnode2 = (que_common_t*) node_list;
 | |
| 
 | |
| 	while (cnode2->brother != NULL) {
 | |
| 		cnode2 = (que_common_t*) cnode2->brother;
 | |
| 	}
 | |
| 
 | |
| 	cnode2->brother = node;
 | |
| 
 | |
| 	return(node_list);
 | |
| }
 | |
| 
 | |
| /*************************************************************************
 | |
| Removes a query graph node from the list.*/
 | |
| UNIV_INLINE
 | |
| que_node_t*
 | |
| que_node_list_get_last(
 | |
| /*===================*/
 | |
| 					/* out: last node in list.*/
 | |
| 	que_node_t*	node_list)	/* in: node list */
 | |
| {
 | |
| 	que_common_t*	node;
 | |
| 
 | |
| 	ut_a(node_list != NULL);
 | |
| 
 | |
| 	node = (que_common_t*) node_list;
 | |
| 
 | |
| 	/* We need the last element */
 | |
| 	while (node->brother != NULL) {
 | |
| 		node = (que_common_t*) node->brother;
 | |
| 	}
 | |
| 
 | |
| 	return(node);
 | |
| }
 | |
| /*********************************************************************//**
 | |
| Gets the next list node in a list of query graph nodes.
 | |
| @return next node in a list of nodes */
 | |
| UNIV_INLINE
 | |
| que_node_t*
 | |
| que_node_get_next(
 | |
| /*==============*/
 | |
| 	que_node_t*	node)	/*!< in: node in a list */
 | |
| {
 | |
| 	return(((que_common_t*) node)->brother);
 | |
| }
 | |
| 
 | |
| /*********************************************************************//**
 | |
| Gets a query graph node list length.
 | |
| @return length, for NULL list 0 */
 | |
| UNIV_INLINE
 | |
| ulint
 | |
| que_node_list_get_len(
 | |
| /*==================*/
 | |
| 	que_node_t*	node_list)	/*!< in: node list, or NULL */
 | |
| {
 | |
| 	const que_common_t*	cnode;
 | |
| 	ulint			len;
 | |
| 
 | |
| 	cnode = (const que_common_t*) node_list;
 | |
| 	len = 0;
 | |
| 
 | |
| 	while (cnode != NULL) {
 | |
| 		len++;
 | |
| 		cnode = (const que_common_t*) cnode->brother;
 | |
| 	}
 | |
| 
 | |
| 	return(len);
 | |
| }
 | |
| 
 | |
| /*********************************************************************//**
 | |
| Gets the parent node of a query graph node.
 | |
| @return parent node or NULL */
 | |
| UNIV_INLINE
 | |
| que_node_t*
 | |
| que_node_get_parent(
 | |
| /*================*/
 | |
| 	que_node_t*	node)	/*!< in: node */
 | |
| {
 | |
| 	return(((que_common_t*) node)->parent);
 | |
| }
 | 
