Home
last modified time | relevance | path

Searched refs:bg_direct_sql (Results 1 – 18 of 18) sorted by relevance

/dports/databases/mariadb104-server/mariadb-10.4.24/storage/spider/
H A Dspd_direct_sql.cc1628 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 Dspd_conn.cc2556 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 Dspd_include.h530 volatile bool bg_direct_sql; member
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/spider/
H A Dspd_direct_sql.cc1628 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 Dspd_conn.cc2556 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 Dspd_include.h530 volatile bool bg_direct_sql; member
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/spider/
H A Dspd_direct_sql.cc1629 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 Dspd_conn.cc2522 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 Dspd_include.h525 volatile bool bg_direct_sql; member
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/spider/
H A Dspd_direct_sql.cc1629 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 Dspd_conn.cc2522 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 Dspd_include.h525 volatile bool bg_direct_sql;
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/spider/
H A Dspd_direct_sql.cc1747 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 Dspd_conn.cc3158 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 Dspd_include.h567 volatile bool bg_direct_sql; member
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/spider/
H A Dspd_direct_sql.cc1747 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 Dspd_conn.cc3158 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 Dspd_include.h567 volatile bool bg_direct_sql; member