Skip navigation links

Recommended Servers for MySQL

The world's most popular open source database

Contact a MySQL Representative

Login | Register

• MySQL.com
• Downloads
• Developer Zone
• Partners & Solutions
• Customer Login

• DevZone
• Documentation
• Librarian
• Articles
• Forums
• Bugs
• Forge
• Planet MySQL
• Labs

 

 

 

The world's most popular open source database

mysql/src/5.1-dbg/tests/deadlock_test.c File Reference

#include <mysql.h>
#include <stdio.h>
#include <stdarg.h>
#include <string.h>
#include <stdlib.h>

Include dependency graph for deadlock_test.c:

Go to the source code of this file.

Classes
struct	query
Typedefs
typedef unsigned char	uchar
Functions
static void	die (char *fmt,...)
static void	safe_query (MYSQL *mysql, char *query, int read_ok)
static void	run_query_batch (int *order, int num_queries)
static void	permute (int *order, int num_queries)
static void	permute_aux (int *order, int num_queries, int *fixed)
static void	dump_result (MYSQL *mysql, char *query)
static	order_ok (int *order, int num_queries)
static void	safe_net_read (NET *net, char *query)
static int *	init_order (int *num_queries)
int	main ()
Variables
int	count = 0
MYSQL	lock
MYSQL	sel
MYSQL	del_ins
query	queries []

---

Typedef Documentation

typedef unsigned char uchar

Definition at line 24 of file deadlock_test.c.

---

Function Documentation

static void die	(	char *	fmt,
			...
	)			[static]

Definition at line 57 of file deadlock_test.c.

References args, and exit.

{
  va_list args;
  va_start(args, fmt);
  fprintf(stderr, "ERROR: ");
  vfprintf(stderr, fmt, args);
  fprintf(stderr, "\n");
  va_end(args);
  exit(1);
}

static void dump_result	(	MYSQL *	mysql,
		char *	query
	)			[static]

Definition at line 186 of file deadlock_test.c.

References mysql, mysql_free_result(), mysql_store_result(), st_mysql::net, and safe_net_read().

Referenced by run_query_batch().

{
  MYSQL_RES* res;
  safe_net_read(&mysql->net, query);
  res = mysql_store_result(mysql);
  if(res)
   mysql_free_result(res);
}

Here is the call graph for this function:

Here is the caller graph for this function:

static int* init_order

(

int *

num_queries

)

[static]

Definition at line 195 of file deadlock_test.c.

References die(), malloc, query::mysql, n, order, p, and queries.

Referenced by main().

{
  struct query* q;
  int *order, *order_end, *p;
  int n,i;

  for(q = queries; q->mysql; q++)
    ;

  n = q - queries;
  if(!(order = (int*) malloc(n * sizeof(int))))
    die("malloc() failed");
  order_end = order + n;
  for(p = order,i = 0; p < order_end; p++,i++)
    *p = i;
  *num_queries = n;
  return order;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int main

(

void

)

Definition at line 214 of file deadlock_test.c.

References count, db, del_ins, die(), free, host, init_order(), lock, mysql_close(), mysql_error(), mysql_init(), mysql_options(), MYSQL_READ_DEFAULT_GROUP, mysql_real_connect(), order, pass, permute(), st_mysql::reconnect, sel, and user.

{
  char* user = "root", *pass = "", *host = "localhost", *db = "test";
  int *order, num_queries;
  order = init_order(&num_queries);
  if(!mysql_init(&lock) || !mysql_init(&sel) || !mysql_init(&del_ins))
    die("error in mysql_init()");

  mysql_options(&lock, MYSQL_READ_DEFAULT_GROUP, "mysql");
  mysql_options(&sel, MYSQL_READ_DEFAULT_GROUP, "mysql");
  mysql_options(&del_ins, MYSQL_READ_DEFAULT_GROUP, "mysql");

  if(!mysql_real_connect(&lock, host, user, pass, db, 0,0,0 ) ||
     !mysql_real_connect(&sel, host, user, pass, db, 0,0,0 ) ||
     !mysql_real_connect(&del_ins, host, user, pass, db, 0,0,0 ))
    die("Error in mysql_real_connect(): %s", mysql_error(&lock));
  lock.reconnect= sel.reconnect= del_ins.reconnect= 1;

  permute(order, num_queries);
  printf("count = %d\n", count);

  mysql_close(&lock);
  mysql_close(&sel);
  mysql_close(&del_ins);
  free(order);
}

Here is the call graph for this function:

static order_ok	(	int *	order,
		int	num_queries
	)			[static]

Definition at line 81 of file deadlock_test.c.

References query::pri, and queries.

Referenced by permute_aux().

{
  int i,j, pri_i, pri_j;
  for(i = 0; i < num_queries; i++)
    {
      if((pri_i = queries[order[i]].pri))
        for(j = i + 1; j < num_queries; j++)
          {
            pri_j = queries[order[j]].pri;
            if(pri_j && pri_i > pri_j)
              return 0;
          }
    }

  return 1;
}

Here is the caller graph for this function:

static void permute	(	int *	order,
		int	num_queries
	)			[static]

Definition at line 68 of file deadlock_test.c.

References die(), free, malloc, memset, and permute_aux().

Referenced by main().

{
  int *fixed;
  if(num_queries < 2) return;
  if(!(fixed = (int*)malloc(num_queries * sizeof(int))))
    die("malloc() failed");

  memset(fixed, 0, num_queries * sizeof(int));
  permute_aux(order, num_queries, fixed);

  free(fixed);
}

Here is the call graph for this function:

Here is the caller graph for this function:

static void permute_aux	(	int *	order,
		int	num_queries,
		int *	fixed
	)			[static]

Definition at line 98 of file deadlock_test.c.

References count, order_ok(), p, and run_query_batch().

Referenced by permute().

{
  int *p,*p1,j,i,tmp, num_free = 0;
  p = fixed;
  for(i = 0; i < num_queries; i++, p++)
    {
      if(!*p)
        {
          num_free++;
          *p = 1;
          for(j = 0, p1 = fixed ;
              j < num_queries; j++,p1++)
            {
              if(!*p1)
                {
                  tmp = order[i];
                  order[i] = order[j];
                  order[j] = tmp;
                  *p1 = 1;
                  permute_aux(order, num_queries, fixed);
                  tmp = order[i];
                  order[i] = order[j];
                  order[j] = tmp;
                  *p1 = 0;
                }
            }
          *p = 0;
        }
    }

  /*printf("num_free = %d\n", num_free); */

  if(num_free <= 1)
    {
      count++;
      if(order_ok(order, num_queries))
        run_query_batch(order, num_queries);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

static void run_query_batch	(	int *	order,
		int	num_queries
	)			[static]

Definition at line 138 of file deadlock_test.c.

References dump_result(), query::dump_result, lock, query::mysql, queries, query::query, query::read_ok, and safe_query().

Referenced by permute_aux().

{
  int i;
  struct query* q;
  int *save_order;
  safe_query(&lock, "delete from foo", 1);
  save_order = order;
  for(i = 0; i < num_queries; i++,order++)
    {
      q = queries + *order;
      printf("query='%s'\n", q->query);
      safe_query(q->mysql, q->query, q->read_ok);
    }
  order = save_order;
  for(i = 0; i < num_queries; i++,order++)
    {
      q = queries + *order;
      if(q->dump_result)
       dump_result(q->mysql, q->query);
    }
  printf("\n");

}

Here is the call graph for this function:

Here is the caller graph for this function:

static void safe_net_read	(	NET *	net,
		char *	query
	)			[static]

Definition at line 162 of file deadlock_test.c.

References die(), my_net_read(), packet_error, and st_net::read_pos.

Referenced by dump_result(), and safe_query().

{
  int len;
  len = my_net_read(net); 
  if(len == packet_error || !len)
    die("Error running query '%s'", query);
  if(net->read_pos[0] == 255)
    die("Error running query '%s'", query);
}

Here is the call graph for this function:

Here is the caller graph for this function:

static void safe_query	(	MYSQL *	mysql,
		char *	query,
		int	read_ok
	)			[static]

Definition at line 173 of file deadlock_test.c.

References COM_QUERY, die(), mysql, mysql_error(), st_mysql::net, net_clear(), net_write_command(), safe_net_read(), and strlen().

Referenced by run_query_batch().

{
  int len;
  NET* net = &mysql->net;
  net_clear(net);
  if(net_write_command(net,(uchar)COM_QUERY, query,strlen(query)))
    die("Error running query '%s': %s", query, mysql_error(mysql));
  if(read_ok)
    {
      safe_net_read(net, query);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

---

Variable Documentation

int count = 0

Definition at line 32 of file deadlock_test.c.

MYSQL del_ins

Definition at line 44 of file deadlock_test.c.

Referenced by main().

MYSQL lock

Definition at line 44 of file deadlock_test.c.

Referenced by btr_search_update_block_hash_info(), clean_up_mutexes(), MutexVector< T >::clear(), create_table_from_items(), display_table_locks(), MutexVector< T >::erase(), Dbdict::execBACKUP_FRAGMENT_REQ(), handle_delayed_insert(), init_thread_environment(), lock_cancel_waiting_and_release(), lock_deadlock_occurs(), lock_deadlock_recursive(), lock_get_mode(), lock_get_n_rec_locks(), lock_get_src_table(), lock_get_type(), lock_get_wait(), lock_grant(), lock_is_table_exclusive(), lock_move_rec_list_end(), lock_move_rec_list_start(), lock_move_reorganize_page(), lock_number_of_rows_locked(), lock_print_info_all_transactions(), lock_rec_add_to_queue(), lock_rec_bitmap_reset(), lock_rec_cancel(), lock_rec_copy(), lock_rec_create(), lock_rec_dequeue_from_page(), lock_rec_enqueue_waiting(), lock_rec_find_set_bit(), lock_rec_find_similar_on_page(), lock_rec_free_all_from_discard_page(), lock_rec_get_first(), lock_rec_get_first_on_page(), lock_rec_get_first_on_page_addr(), lock_rec_get_gap(), lock_rec_get_insert_intention(), lock_rec_get_n_bits(), lock_rec_get_next(), lock_rec_get_next_on_page(), lock_rec_get_nth_bit(), lock_rec_get_prev(), lock_rec_get_rec_not_gap(), lock_rec_has_expl(), lock_rec_has_to_wait_in_queue(), lock_rec_inherit_to_gap(), lock_rec_inherit_to_gap_if_gap_lock(), lock_rec_insert_check_and_lock(), lock_rec_lock_fast(), lock_rec_move(), lock_rec_other_has_conflicting(), lock_rec_other_has_expl_req(), lock_rec_print(), lock_rec_queue_validate(), lock_rec_reset_and_release_wait(), lock_rec_reset_nth_bit(), lock_rec_set_nth_bit(), lock_rec_unlock(), lock_rec_validate_page(), lock_release_off_kernel(), lock_reset_all_on_table(), lock_reset_all_on_table_for_trx(), lock_reset_lock_and_trx_wait(), lock_set_lock_and_trx_wait(), lock_table_create(), lock_table_dequeue(), lock_table_enqueue_waiting(), lock_table_has(), lock_table_has_to_wait_in_queue(), lock_table_other_has_incompatible(), lock_table_print(), lock_table_queue_validate(), lock_table_remove_low(), lock_table_unlock(), lock_validate(), main(), mysql_ha_read(), mysql_unlock_read_tables(), MutexVector< T >::push_back(), reopen_tables(), run_query_batch(), rw_lock_create_func(), rw_lock_free(), rw_lock_is_locked(), rw_lock_s_lock_spin(), rw_lock_validate(), rw_lock_x_lock_func(), rw_lock_x_lock_low(), rw_lock_x_lock_move_ownership(), Dbtc::sendlqhkeyreq(), start_test(), sync_arr_cell_can_wake_up(), sync_thread_levels_g(), test_read(), test_rrnd(), test_update(), and test_write().

struct query queries[]

Initial value:

{
  {&del_ins, "insert delayed into foo values(1)", 1, 0, 0},
  {&del_ins, "insert delayed into foo values(1)", 1, 0, 0},
  {&lock, "lock tables foo write", 1, 1, 0},
  {&lock, "unlock tables", 1,2, 0},
  {&sel, "select * from foo", 0,0, 0},
  {&del_ins, "insert  into foo values(4)", 0,3, 0},
  {0,0,0}
}

Definition at line 46 of file deadlock_test.c.

Referenced by init_order(), order_ok(), run_query_batch(), run_task(), test_basic_cursors(), test_cursors_with_union(), and test_ps_null_param().

MYSQL sel

Definition at line 44 of file deadlock_test.c.

---

• Products
• MySQL Enterprise
• MySQL Cluster
• MySQL Embedded (OEM/ISV)
• MySQL Data Warehouse
• MySQL Backup & Recovery
• MySQL Workbench
• MySQL Connectors
• Online Shop

• Downloads
• MySQL Community Server
• MySQL Enterprise
• MySQL Proxy
• MySQL Cluster
• MySQL Workbench
• GUI Tools
• Connectors
• Archives
• Snapshots
• Mirrors

• Developer Zone
• Documentation
• Librarian
• Developer Articles
• Forums
• Bugs
• Forge
• Planet MySQL
• Labs
• MySQL Meetups
• Guilds
• Lists

• About
• About MySQL
• Contact Us
• Legal
• Privacy Policy
• Job Opportunities
• Site Map

© 1995-2008 MySQL AB, 2008- Sun Microsystems, Inc.