/dports/databases/mariadb104-server/mariadb-10.4.24/storage/spider/ |
H A D | spd_direct_sql.cc | 1628 bg_direct_sql->called_cnt++; in spider_direct_sql_body() 1921 if (bg_direct_sql) 1925 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 1945 bg_direct_sql->called_cnt = 0; 1946 bg_direct_sql->bg_error = 0; 1957 while (bg_direct_sql->direct_sql) 1958 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 1962 if (bg_direct_sql->bg_error) 1964 my_message(bg_direct_sql->bg_error, bg_direct_sql->bg_error_msg, MYF(0)); 1982 conn->bg_direct_sql = TRUE; [all …]
|
H A D | spd_conn.cc | 2556 if (conn->bg_direct_sql) in spider_bg_conn_action() 2596 conn->bg_direct_sql = FALSE; in spider_bg_conn_action() 2783 if (conn->bg_direct_sql) in spider_bg_conn_action() 2800 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 2803 bg_direct_sql->bg_error = spider_stmt_da_sql_errno(thd); in spider_bg_conn_action() 2804 strmov((char *) bg_direct_sql->bg_error_msg, in spider_bg_conn_action() 2813 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 2816 bg_direct_sql->modified_non_trans_table = TRUE; in spider_bg_conn_action() 2827 conn->bg_direct_sql = FALSE; in spider_bg_conn_action()
|
H A D | spd_include.h | 530 volatile bool bg_direct_sql; member
|
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/spider/ |
H A D | spd_direct_sql.cc | 1628 bg_direct_sql->called_cnt++; 1921 if (bg_direct_sql) 1925 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 1945 bg_direct_sql->called_cnt = 0; 1946 bg_direct_sql->bg_error = 0; 1957 while (bg_direct_sql->direct_sql) 1958 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 1962 if (bg_direct_sql->bg_error) 1964 my_message(bg_direct_sql->bg_error, bg_direct_sql->bg_error_msg, MYF(0)); 1982 conn->bg_direct_sql = TRUE; [all …]
|
H A D | spd_conn.cc | 2556 if (conn->bg_direct_sql) in spider_bg_conn_action() 2596 conn->bg_direct_sql = FALSE; in spider_bg_conn_action() 2783 if (conn->bg_direct_sql) in spider_bg_conn_action() 2800 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 2803 bg_direct_sql->bg_error = spider_stmt_da_sql_errno(thd); in spider_bg_conn_action() 2804 strmov((char *) bg_direct_sql->bg_error_msg, in spider_bg_conn_action() 2813 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 2816 bg_direct_sql->modified_non_trans_table = TRUE; in spider_bg_conn_action() 2827 conn->bg_direct_sql = FALSE; in spider_bg_conn_action()
|
H A D | spd_include.h | 530 volatile bool bg_direct_sql; member
|
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/spider/ |
H A D | spd_direct_sql.cc | 1629 bg_direct_sql->called_cnt++; in spider_direct_sql_body() 1922 if (bg_direct_sql) 1926 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 1946 bg_direct_sql->called_cnt = 0; 1947 bg_direct_sql->bg_error = 0; 1958 while (bg_direct_sql->direct_sql) 1959 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 1963 if (bg_direct_sql->bg_error) 1965 my_message(bg_direct_sql->bg_error, bg_direct_sql->bg_error_msg, MYF(0)); 1983 conn->bg_direct_sql = TRUE; [all …]
|
H A D | spd_conn.cc | 2522 if (conn->bg_direct_sql) in spider_bg_conn_action() 2562 conn->bg_direct_sql = FALSE; in spider_bg_conn_action() 2749 if (conn->bg_direct_sql) in spider_bg_conn_action() 2766 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 2769 bg_direct_sql->bg_error = spider_stmt_da_sql_errno(thd); in spider_bg_conn_action() 2770 strmov((char *) bg_direct_sql->bg_error_msg, in spider_bg_conn_action() 2779 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 2782 bg_direct_sql->modified_non_trans_table = TRUE; in spider_bg_conn_action() 2793 conn->bg_direct_sql = FALSE; in spider_bg_conn_action()
|
H A D | spd_include.h | 525 volatile bool bg_direct_sql; member
|
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/spider/ |
H A D | spd_direct_sql.cc | 1629 bg_direct_sql->called_cnt++; in spider_direct_sql_body() 1922 if (bg_direct_sql) 1926 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 1946 bg_direct_sql->called_cnt = 0; 1947 bg_direct_sql->bg_error = 0; 1958 while (bg_direct_sql->direct_sql) 1959 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 1963 if (bg_direct_sql->bg_error) 1965 my_message(bg_direct_sql->bg_error, bg_direct_sql->bg_error_msg, MYF(0)); 1983 conn->bg_direct_sql = TRUE; [all …]
|
H A D | spd_conn.cc | 2522 if (conn->bg_direct_sql) in spider_bg_conn_action() 2562 conn->bg_direct_sql = FALSE; in spider_bg_conn_action() 2749 if (conn->bg_direct_sql) in spider_bg_conn_action() 2766 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 2769 bg_direct_sql->bg_error = spider_stmt_da_sql_errno(thd); in spider_bg_conn_action() 2770 strmov((char *) bg_direct_sql->bg_error_msg, in spider_bg_conn_action() 2779 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 2782 bg_direct_sql->modified_non_trans_table = TRUE; in spider_bg_conn_action() 2793 conn->bg_direct_sql = FALSE; in spider_bg_conn_action()
|
H A D | spd_include.h | 525 volatile bool bg_direct_sql;
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/spider/ |
H A D | spd_direct_sql.cc | 1747 bg_direct_sql->called_cnt++; in spider_direct_sql_body() 2040 if (bg_direct_sql) 2044 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 2064 bg_direct_sql->called_cnt = 0; 2065 bg_direct_sql->bg_error = 0; 2076 while (bg_direct_sql->direct_sql) 2077 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 2081 if (bg_direct_sql->bg_error) 2083 my_message(bg_direct_sql->bg_error, bg_direct_sql->bg_error_msg, MYF(0)); 2101 conn->bg_direct_sql = TRUE; [all …]
|
H A D | spd_conn.cc | 3158 if (conn->bg_direct_sql) in spider_bg_conn_action() 3198 conn->bg_direct_sql = FALSE; in spider_bg_conn_action() 3385 if (conn->bg_direct_sql) in spider_bg_conn_action() 3402 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 3405 bg_direct_sql->bg_error = spider_stmt_da_sql_errno(thd); in spider_bg_conn_action() 3406 strmov((char *) bg_direct_sql->bg_error_msg, in spider_bg_conn_action() 3415 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 3418 bg_direct_sql->modified_non_trans_table = TRUE; in spider_bg_conn_action() 3429 conn->bg_direct_sql = FALSE; in spider_bg_conn_action()
|
H A D | spd_include.h | 567 volatile bool bg_direct_sql; member
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/spider/ |
H A D | spd_direct_sql.cc | 1747 bg_direct_sql->called_cnt++; in spider_direct_sql_body() 2040 if (bg_direct_sql) 2044 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 2064 bg_direct_sql->called_cnt = 0; 2065 bg_direct_sql->bg_error = 0; 2076 while (bg_direct_sql->direct_sql) 2077 pthread_cond_wait(&bg_direct_sql->bg_cond, &bg_direct_sql->bg_mutex); 2081 if (bg_direct_sql->bg_error) 2083 my_message(bg_direct_sql->bg_error, bg_direct_sql->bg_error_msg, MYF(0)); 2101 conn->bg_direct_sql = TRUE; [all …]
|
H A D | spd_conn.cc | 3158 if (conn->bg_direct_sql) in spider_bg_conn_action() 3198 conn->bg_direct_sql = FALSE; in spider_bg_conn_action() 3385 if (conn->bg_direct_sql) in spider_bg_conn_action() 3402 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 3405 bg_direct_sql->bg_error = spider_stmt_da_sql_errno(thd); in spider_bg_conn_action() 3406 strmov((char *) bg_direct_sql->bg_error_msg, in spider_bg_conn_action() 3415 SPIDER_BG_DIRECT_SQL *bg_direct_sql = in spider_bg_conn_action() local 3418 bg_direct_sql->modified_non_trans_table = TRUE; in spider_bg_conn_action() 3429 conn->bg_direct_sql = FALSE; in spider_bg_conn_action()
|
H A D | spd_include.h | 567 volatile bool bg_direct_sql; member
|