Home
last modified time | relevance | path

Searched refs:originating_server_id (Results 1 – 13 of 13) sorted by relevance

/dports/databases/mysql55-client/mysql-5.5.62/sql/
H A Dha_ndbcluster_binlog.cc3340 uint32 originating_server_id= pOp->getAnyValue(); in ndb_binlog_thread_handle_data_event() local
3341 if (originating_server_id == 0) in ndb_binlog_thread_handle_data_event()
3342 originating_server_id= ::server_id; in ndb_binlog_thread_handle_data_event()
3343 else if (originating_server_id & NDB_ANYVALUE_RESERVED) in ndb_binlog_thread_handle_data_event()
3345 if (originating_server_id != NDB_ANYVALUE_FOR_NOLOGGING) in ndb_binlog_thread_handle_data_event()
3348 originating_server_id); in ndb_binlog_thread_handle_data_event()
3405 int ret __attribute__((unused))= trans.write_row(originating_server_id, in ndb_binlog_thread_handle_data_event()
3445 int ret __attribute__((unused))= trans.delete_row(originating_server_id, in ndb_binlog_thread_handle_data_event()
3475 trans.write_row(originating_server_id, in ndb_binlog_thread_handle_data_event()
3496 int ret __attribute__((unused))= trans.update_row(originating_server_id, in ndb_binlog_thread_handle_data_event()
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Dha_ndbcluster_binlog.cc5639 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in handle_data_event() local
5652 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in handle_data_event()
5704 originating_server_id= 0; /* Will be set to our ::serverid below */ in handle_data_event()
5735 if (originating_server_id == 0) in handle_data_event()
5736 originating_server_id= ::server_id; in handle_data_event()
5762 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in handle_data_event()
5857 ndb_find_binlog_index_row(rows, originating_server_id, 0); in handle_data_event()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Dha_ndbcluster_binlog.cc5639 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in handle_data_event() local
5652 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in handle_data_event()
5704 originating_server_id= 0; /* Will be set to our ::serverid below */ in handle_data_event()
5735 if (originating_server_id == 0) in handle_data_event()
5736 originating_server_id= ::server_id; in handle_data_event()
5762 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in handle_data_event()
5857 ndb_find_binlog_index_row(rows, originating_server_id, 0); in handle_data_event()
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Dha_ndbcluster_binlog.cc5639 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in handle_data_event() local
5652 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in handle_data_event()
5704 originating_server_id= 0; /* Will be set to our ::serverid below */ in handle_data_event()
5735 if (originating_server_id == 0) in handle_data_event()
5736 originating_server_id= ::server_id; in handle_data_event()
5762 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in handle_data_event()
5857 ndb_find_binlog_index_row(rows, originating_server_id, 0); in handle_data_event()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Dha_ndbcluster_binlog.cc5639 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in handle_data_event() local
5652 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in handle_data_event()
5704 originating_server_id= 0; /* Will be set to our ::serverid below */ in handle_data_event()
5735 if (originating_server_id == 0) in handle_data_event()
5736 originating_server_id= ::server_id; in handle_data_event()
5762 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in handle_data_event()
5857 ndb_find_binlog_index_row(rows, originating_server_id, 0); in handle_data_event()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Dha_ndbcluster_binlog.cc5639 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in handle_data_event() local
5652 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in handle_data_event()
5704 originating_server_id= 0; /* Will be set to our ::serverid below */ in handle_data_event()
5735 if (originating_server_id == 0) in handle_data_event()
5736 originating_server_id= ::server_id; in handle_data_event()
5762 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in handle_data_event()
5857 ndb_find_binlog_index_row(rows, originating_server_id, 0); in handle_data_event()
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Dha_ndbcluster_binlog.cc5639 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in handle_data_event() local
5652 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in handle_data_event()
5704 originating_server_id= 0; /* Will be set to our ::serverid below */ in handle_data_event()
5735 if (originating_server_id == 0) in handle_data_event()
5736 originating_server_id= ::server_id; in handle_data_event()
5762 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in handle_data_event()
5857 ndb_find_binlog_index_row(rows, originating_server_id, 0); in handle_data_event()
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Dha_ndbcluster_binlog.cc5928 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in ndb_binlog_thread_handle_data_event() local
5941 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in ndb_binlog_thread_handle_data_event()
5993 originating_server_id= 0; /* Will be set to our ::serverid below */ in ndb_binlog_thread_handle_data_event()
6024 if (originating_server_id == 0) in ndb_binlog_thread_handle_data_event()
6025 originating_server_id= ::server_id; in ndb_binlog_thread_handle_data_event()
6050 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in ndb_binlog_thread_handle_data_event()
6081 ndb_find_binlog_index_row(rows, originating_server_id, 0); in ndb_binlog_thread_handle_data_event()
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/
H A Dha_ndbcluster_binlog.cc5928 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in ndb_binlog_thread_handle_data_event() local
5941 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in ndb_binlog_thread_handle_data_event()
5993 originating_server_id= 0; /* Will be set to our ::serverid below */ in ndb_binlog_thread_handle_data_event()
6024 if (originating_server_id == 0) in ndb_binlog_thread_handle_data_event()
6025 originating_server_id= ::server_id; in ndb_binlog_thread_handle_data_event()
6050 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in ndb_binlog_thread_handle_data_event()
6081 ndb_find_binlog_index_row(rows, originating_server_id, 0); in ndb_binlog_thread_handle_data_event()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/plugin/
H A Dha_ndbcluster_binlog.cc5932 uint32 originating_server_id = ndbcluster_anyvalue_get_serverid(anyValue); in handle_data_event() local
5942 Uint32 ndb_apply_status_logging_server_id = originating_server_id; in handle_data_event()
5991 originating_server_id = in handle_data_event()
6019 if (originating_server_id == 0) in handle_data_event()
6020 originating_server_id = ::server_id; in handle_data_event()
6043 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in handle_data_event()
6128 ndb_find_binlog_index_row(rows, originating_server_id, 0); in handle_data_event()
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/
H A Dha_ndbcluster_binlog.cc5928 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in ndb_binlog_thread_handle_data_event() local
5941 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in ndb_binlog_thread_handle_data_event()
5993 originating_server_id= 0; /* Will be set to our ::serverid below */ in ndb_binlog_thread_handle_data_event()
6024 if (originating_server_id == 0) in ndb_binlog_thread_handle_data_event()
6025 originating_server_id= ::server_id; in ndb_binlog_thread_handle_data_event()
6050 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in ndb_binlog_thread_handle_data_event()
6081 ndb_find_binlog_index_row(rows, originating_server_id, 0); in ndb_binlog_thread_handle_data_event()
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/
H A Dha_ndbcluster_binlog.cc5928 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in ndb_binlog_thread_handle_data_event() local
5941 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in ndb_binlog_thread_handle_data_event()
5993 originating_server_id= 0; /* Will be set to our ::serverid below */ in ndb_binlog_thread_handle_data_event()
6024 if (originating_server_id == 0) in ndb_binlog_thread_handle_data_event()
6025 originating_server_id= ::server_id; in ndb_binlog_thread_handle_data_event()
6050 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in ndb_binlog_thread_handle_data_event()
6081 ndb_find_binlog_index_row(rows, originating_server_id, 0); in ndb_binlog_thread_handle_data_event()
/dports/databases/mysql56-client/mysql-5.6.51/sql/
H A Dha_ndbcluster_binlog.cc5928 uint32 originating_server_id= ndbcluster_anyvalue_get_serverid(anyValue); in ndb_binlog_thread_handle_data_event() local
5941 Uint32 ndb_apply_status_logging_server_id= originating_server_id; in ndb_binlog_thread_handle_data_event()
5993 originating_server_id= 0; /* Will be set to our ::serverid below */ in ndb_binlog_thread_handle_data_event()
6024 if (originating_server_id == 0) in ndb_binlog_thread_handle_data_event()
6025 originating_server_id= ::server_id; in ndb_binlog_thread_handle_data_event()
6050 ndbcluster_anyvalue_set_serverid(logged_server_id, originating_server_id); in ndb_binlog_thread_handle_data_event()
6081 ndb_find_binlog_index_row(rows, originating_server_id, 0); in ndb_binlog_thread_handle_data_event()