@@ -5771,8 +5771,6 @@ static int write_locked_table_maps(THD *thd)
5771
5771
5772
5772
typedef bool Log_func (THD*, TABLE*, bool , const uchar*, const uchar*);
5773
5773
5774
- static int check_wsrep_max_ws_rows ();
5775
-
5776
5774
static int binlog_log_row (TABLE* table,
5777
5775
const uchar *before_record,
5778
5776
const uchar *after_record,
@@ -5826,13 +5824,6 @@ static int binlog_log_row(TABLE* table,
5826
5824
bool const has_trans= thd->lex ->sql_command == SQLCOM_CREATE_TABLE ||
5827
5825
table->file ->has_transactions ();
5828
5826
error= (*log_func)(thd, table, has_trans, before_record, after_record);
5829
-
5830
- /*
5831
- Now that the record has been logged, increment wsrep_affected_rows and
5832
- also check whether its within the allowable limits (wsrep_max_ws_rows).
5833
- */
5834
- if (error == 0 )
5835
- error= check_wsrep_max_ws_rows ();
5836
5827
}
5837
5828
}
5838
5829
return error ? HA_ERR_RBR_LOGGING_FAILED : 0 ;
@@ -5943,30 +5934,6 @@ int handler::ha_reset()
5943
5934
}
5944
5935
5945
5936
5946
- static int check_wsrep_max_ws_rows ()
5947
- {
5948
- #ifdef WITH_WSREP
5949
- if (wsrep_max_ws_rows)
5950
- {
5951
- THD *thd= current_thd;
5952
-
5953
- if (!WSREP (thd))
5954
- return 0 ;
5955
-
5956
- thd->wsrep_affected_rows ++;
5957
- if (thd->wsrep_exec_mode != REPL_RECV &&
5958
- thd->wsrep_affected_rows > wsrep_max_ws_rows)
5959
- {
5960
- trans_rollback_stmt (thd) || trans_rollback (thd);
5961
- my_message (ER_ERROR_DURING_COMMIT, " wsrep_max_ws_rows exceeded" , MYF (0 ));
5962
- return ER_ERROR_DURING_COMMIT;
5963
- }
5964
- }
5965
- #endif /* WITH_WSREP */
5966
- return 0 ;
5967
- }
5968
-
5969
-
5970
5937
int handler::ha_write_row (uchar *buf)
5971
5938
{
5972
5939
int error;
0 commit comments