| /dports/databases/percona57-server/percona-server-5.7.36-39/plugin/semisync/ |
| H A D | semisync_master_socket_listener.h | 56 m_slaves= slaves; in init_slave_sockets()
58 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
61 poll_fd.fd= m_slaves[i].sock_fd(); in init_slave_sockets()
69 return m_slaves.size(); in number_of_slave_sockets()
74 return m_slaves[index]; in get_slave_obj()
78 Slave_vector m_slaves;
114 m_slaves= slaves; in init_slave_sockets()
116 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
135 return m_slaves.size(); in number_of_slave_sockets()
140 return m_slaves[index]; in get_slave_obj()
[all …]
|
| H A D | semisync_master_ack_receiver.cc | 152 m_slaves.push_back(slave); in add_slave()
173 for (it= m_slaves.begin(); it != m_slaves.end(); it++) in remove_slave()
177 m_slaves.erase(it); in remove_slave()
236 if (unlikely(m_slaves.empty())) in run()
242 if (!listener.init_slave_sockets(m_slaves)) in run()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/plugin/semisync/ |
| H A D | semisync_master_socket_listener.h | 56 m_slaves= slaves; in init_slave_sockets()
58 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
61 poll_fd.fd= m_slaves[i].sock_fd(); in init_slave_sockets()
69 return m_slaves.size(); in number_of_slave_sockets()
74 return m_slaves[index]; in get_slave_obj()
78 Slave_vector m_slaves;
114 m_slaves= slaves; in init_slave_sockets()
116 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
135 return m_slaves.size(); in number_of_slave_sockets()
140 return m_slaves[index]; in get_slave_obj()
[all …]
|
| H A D | semisync_master_ack_receiver.cc | 152 m_slaves.push_back(slave); in add_slave()
173 for (it= m_slaves.begin(); it != m_slaves.end(); it++) in remove_slave()
177 m_slaves.erase(it); in remove_slave()
236 if (unlikely(m_slaves.empty())) in run()
242 if (!listener.init_slave_sockets(m_slaves)) in run()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/plugin/semisync/ |
| H A D | semisync_master_socket_listener.h | 56 m_slaves= slaves; in init_slave_sockets()
58 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
61 poll_fd.fd= m_slaves[i].sock_fd(); in init_slave_sockets()
69 return m_slaves.size(); in number_of_slave_sockets()
74 return m_slaves[index]; in get_slave_obj()
78 Slave_vector m_slaves;
114 m_slaves= slaves; in init_slave_sockets()
116 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
135 return m_slaves.size(); in number_of_slave_sockets()
140 return m_slaves[index]; in get_slave_obj()
[all …]
|
| H A D | semisync_master_ack_receiver.cc | 152 m_slaves.push_back(slave); in add_slave()
173 for (it= m_slaves.begin(); it != m_slaves.end(); it++) in remove_slave()
177 m_slaves.erase(it); in remove_slave()
236 if (unlikely(m_slaves.empty())) in run()
242 if (!listener.init_slave_sockets(m_slaves)) in run()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/plugin/semisync/ |
| H A D | semisync_master_socket_listener.h | 56 m_slaves= slaves; in init_slave_sockets()
58 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
61 poll_fd.fd= m_slaves[i].sock_fd(); in init_slave_sockets()
69 return m_slaves.size(); in number_of_slave_sockets()
74 return m_slaves[index]; in get_slave_obj()
78 Slave_vector m_slaves;
114 m_slaves= slaves; in init_slave_sockets()
116 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
135 return m_slaves.size(); in number_of_slave_sockets()
140 return m_slaves[index]; in get_slave_obj()
[all …]
|
| H A D | semisync_master_ack_receiver.cc | 152 m_slaves.push_back(slave); in add_slave()
173 for (it= m_slaves.begin(); it != m_slaves.end(); it++) in remove_slave()
177 m_slaves.erase(it); in remove_slave()
236 if (unlikely(m_slaves.empty())) in run()
242 if (!listener.init_slave_sockets(m_slaves)) in run()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/plugin/semisync/ |
| H A D | semisync_master_socket_listener.h | 56 m_slaves= slaves; in init_slave_sockets()
58 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
61 poll_fd.fd= m_slaves[i].sock_fd(); in init_slave_sockets()
69 return m_slaves.size(); in number_of_slave_sockets()
74 return m_slaves[index]; in get_slave_obj()
78 Slave_vector m_slaves;
114 m_slaves= slaves; in init_slave_sockets()
116 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
135 return m_slaves.size(); in number_of_slave_sockets()
140 return m_slaves[index]; in get_slave_obj()
[all …]
|
| H A D | semisync_master_ack_receiver.cc | 152 m_slaves.push_back(slave); in add_slave()
173 for (it= m_slaves.begin(); it != m_slaves.end(); it++) in remove_slave()
177 m_slaves.erase(it); in remove_slave()
236 if (unlikely(m_slaves.empty())) in run()
242 if (!listener.init_slave_sockets(m_slaves)) in run()
|
| /dports/databases/mysql57-client/mysql-5.7.36/plugin/semisync/ |
| H A D | semisync_master_socket_listener.h | 56 m_slaves= slaves; in init_slave_sockets()
58 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
61 poll_fd.fd= m_slaves[i].sock_fd(); in init_slave_sockets()
69 return m_slaves.size(); in number_of_slave_sockets()
74 return m_slaves[index]; in get_slave_obj()
78 Slave_vector m_slaves;
114 m_slaves= slaves; in init_slave_sockets()
116 for (uint i= 0; i < m_slaves.size(); i++) in init_slave_sockets()
135 return m_slaves.size(); in number_of_slave_sockets()
140 return m_slaves[index]; in get_slave_obj()
[all …]
|
| H A D | semisync_master_ack_receiver.cc | 152 m_slaves.push_back(slave); in add_slave()
173 for (it= m_slaves.begin(); it != m_slaves.end(); it++) in remove_slave()
177 m_slaves.erase(it); in remove_slave()
236 if (unlikely(m_slaves.empty())) in run()
242 if (!listener.init_slave_sockets(m_slaves)) in run()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/semisync/ |
| H A D | semisync_master_socket_listener.h | 47 m_slaves.clear(); in init_slave_sockets()
63 m_slaves.push_back(slaves[i]); in init_slave_sockets()
67 uint number_of_slave_sockets() { return m_slaves.size(); } in number_of_slave_sockets()
69 Slave get_slave_obj(int index) { return m_slaves[index]; } in get_slave_obj()
72 Slave_vector m_slaves;
93 return FD_ISSET(m_slaves[index].sock_fd(), &m_fds); in is_socket_active()
97 FD_CLR(m_slaves[index].sock_fd(), &m_init_fds); in clear_socket_info()
101 m_slaves.clear(); in init_slave_sockets()
122 m_slaves.push_back(slaves[i]); in init_slave_sockets()
126 uint number_of_slave_sockets() { return m_slaves.size(); } in number_of_slave_sockets()
[all …]
|
| H A D | semisync_master_ack_receiver.cc | 165 m_slaves.push_back(slave); in add_slave()
188 for (it = m_slaves.begin(); it != m_slaves.end(); ++it) { in remove_slave()
195 DBUG_ASSERT(it != m_slaves.end()); in remove_slave()
200 while ((it != m_slaves.end()) && (it->is_leaving) && (m_status == ST_UP)) { in remove_slave()
208 for (it = m_slaves.begin(); it != m_slaves.end(); ++it) { in remove_slave()
212 if (it != m_slaves.end()) { in remove_slave()
214 m_slaves.erase(it); in remove_slave()
271 if (unlikely(m_slaves.empty())) { in run()
276 if (!listener.init_slave_sockets(m_slaves)) goto end; in run()
|
| /dports/emulators/dolphin-emu/dolphin-3152428/Source/Core/Core/HW/WiimoteEmu/ |
| H A D | I2CBus.cpp | 13 m_slaves.emplace_back(slave); in AddSlave()
18 m_slaves.erase(std::remove(m_slaves.begin(), m_slaves.end(), slave), m_slaves.end()); in RemoveSlave()
23 m_slaves.clear(); in Reset()
29 for (auto& slave : m_slaves) in BusRead()
44 for (auto& slave : m_slaves) in BusWrite()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
| H A D | semisync_master_ack_receiver.h | 111 Slave_ilist m_slaves; variable
131 :m_slaves(slaves) in Poll_socket_listener()
153 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
170 const Slave_ilist &m_slaves;
180 :m_slaves(slaves), m_max_fd(INVALID_SOCKET) in Select_socket_listener()
205 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
231 const Slave_ilist &m_slaves;
|
| H A D | semisync_master_ack_receiver.cc | 135 m_slaves.push_back(slave); in add_slave()
145 I_List_iterator<Slave> it(m_slaves); in remove_slave()
197 Poll_socket_listener listener(m_slaves); in run()
199 Select_socket_listener listener(m_slaves); in run()
227 if (unlikely(m_slaves.is_empty())) in run()
261 Slave_ilist_iterator it(m_slaves); in run()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
| H A D | semisync_master_ack_receiver.h | 111 Slave_ilist m_slaves; variable
131 :m_slaves(slaves) in Poll_socket_listener()
153 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
170 const Slave_ilist &m_slaves;
180 :m_slaves(slaves), m_max_fd(INVALID_SOCKET) in Select_socket_listener()
205 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
231 const Slave_ilist &m_slaves;
|
| H A D | semisync_master_ack_receiver.cc | 135 m_slaves.push_back(slave); in add_slave()
145 I_List_iterator<Slave> it(m_slaves); in remove_slave()
197 Poll_socket_listener listener(m_slaves); in run()
199 Select_socket_listener listener(m_slaves); in run()
227 if (unlikely(m_slaves.is_empty())) in run()
261 Slave_ilist_iterator it(m_slaves); in run()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/sql/ |
| H A D | semisync_master_ack_receiver.h | 111 Slave_ilist m_slaves; variable
131 :m_slaves(slaves) in Poll_socket_listener()
153 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
170 const Slave_ilist &m_slaves;
180 :m_slaves(slaves), m_max_fd(INVALID_SOCKET) in Select_socket_listener()
205 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
231 const Slave_ilist &m_slaves;
|
| H A D | semisync_master_ack_receiver.cc | 135 m_slaves.push_back(slave); in add_slave()
145 I_List_iterator<Slave> it(m_slaves); in remove_slave()
197 Poll_socket_listener listener(m_slaves); in run()
199 Select_socket_listener listener(m_slaves); in run()
227 if (unlikely(m_slaves.is_empty())) in run()
261 Slave_ilist_iterator it(m_slaves); in run()
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/sql/ |
| H A D | semisync_master_ack_receiver.h | 111 Slave_ilist m_slaves;
131 :m_slaves(slaves)
153 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves));
170 const Slave_ilist &m_slaves;
180 :m_slaves(slaves), m_max_fd(INVALID_SOCKET)
205 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in r_consonant_pair()
231 const Slave_ilist &m_slaves;
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/sql/ |
| H A D | semisync_master_ack_receiver.h | 111 Slave_ilist m_slaves; variable
131 :m_slaves(slaves) in Poll_socket_listener()
153 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
170 const Slave_ilist &m_slaves;
180 :m_slaves(slaves), m_max_fd(INVALID_SOCKET) in Select_socket_listener()
205 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
231 const Slave_ilist &m_slaves;
|
| H A D | semisync_master_ack_receiver.cc | 135 m_slaves.push_back(slave);
145 I_List_iterator<Slave> it(m_slaves);
197 Poll_socket_listener listener(m_slaves);
199 Select_socket_listener listener(m_slaves);
228 if (unlikely(m_slaves.is_empty()))
262 Slave_ilist_iterator it(m_slaves);
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
| H A D | semisync_master_ack_receiver.h | 111 Slave_ilist m_slaves; variable
131 :m_slaves(slaves) in Poll_socket_listener()
153 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
170 const Slave_ilist &m_slaves;
180 :m_slaves(slaves), m_max_fd(INVALID_SOCKET) in Select_socket_listener()
205 Slave_ilist_iterator it(const_cast<Slave_ilist&>(m_slaves)); in init_slave_sockets()
231 const Slave_ilist &m_slaves;
|