| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/x/src/io/ |
| H A D | xpl_listener_unix_socket.cc | 44 m_system_interface(operations_factory.create_system_interface()) { in Unixsocket_creator()
51 if (!m_system_interface) in unlink_unixsocket_file()
56 (void) m_system_interface->unlink(unix_socket_file.c_str()); in unlink_unixsocket_file()
57 (void) m_system_interface->unlink(unix_socket_lockfile.c_str()); in unlink_unixsocket_file()
114 m_system_interface->unlink(unix_socket_file.c_str()); in create_and_bind_unixsocket()
167 const pid_t cur_pid= m_system_interface->get_pid(); in create_unixsocket_lockfile()
186 if (EEXIST != m_system_interface->get_errno()) { in create_unixsocket_lockfile()
231 pid_t parent_pid= m_system_interface->get_ppid(); in create_unixsocket_lockfile()
242 if (m_system_interface->kill(read_pid, 0) == 0) { in create_unixsocket_lockfile()
256 if (m_system_interface->unlink(lock_filename.c_str()) < 0) { in create_unixsocket_lockfile()
[all …]
|
| H A D | xpl_listener_tcp.cc | 43 m_system_interface(m_factory.create_system_interface()) { in Tcp_creator()
85 ngs::bind(&ngs::System_interface::freeaddrinfo, m_system_interface, ngs::placeholders::_1)); in resolve_bind_address()
103 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
142 (int) m_system_interface->get_socket_errno()); in create_and_bind_socket()
150 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
162 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
225 if (!m_system_interface->getaddrinfo(address.c_str(), service.c_str(), &hints, &ai)) { in resolve_addr_info()
234 ngs::System_interface::Shared_ptr m_system_interface; member in xpl::Tcp_creator
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/x/src/io/ |
| H A D | xpl_listener_unix_socket.cc | 44 m_system_interface(operations_factory.create_system_interface()) { in Unixsocket_creator()
51 if (!m_system_interface) in unlink_unixsocket_file()
56 (void) m_system_interface->unlink(unix_socket_file.c_str()); in unlink_unixsocket_file()
57 (void) m_system_interface->unlink(unix_socket_lockfile.c_str()); in unlink_unixsocket_file()
114 m_system_interface->unlink(unix_socket_file.c_str()); in create_and_bind_unixsocket()
167 const pid_t cur_pid= m_system_interface->get_pid(); in create_unixsocket_lockfile()
186 if (EEXIST != m_system_interface->get_errno()) { in create_unixsocket_lockfile()
231 pid_t parent_pid= m_system_interface->get_ppid(); in create_unixsocket_lockfile()
242 if (m_system_interface->kill(read_pid, 0) == 0) { in create_unixsocket_lockfile()
256 if (m_system_interface->unlink(lock_filename.c_str()) < 0) { in create_unixsocket_lockfile()
[all …]
|
| H A D | xpl_listener_tcp.cc | 43 m_system_interface(m_factory.create_system_interface()) { in Tcp_creator()
85 ngs::bind(&ngs::System_interface::freeaddrinfo, m_system_interface, ngs::placeholders::_1)); in resolve_bind_address()
103 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
142 (int) m_system_interface->get_socket_errno()); in create_and_bind_socket()
150 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
162 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
225 if (!m_system_interface->getaddrinfo(address.c_str(), service.c_str(), &hints, &ai)) { in resolve_addr_info()
234 ngs::System_interface::Shared_ptr m_system_interface; member in xpl::Tcp_creator
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/x/src/io/ |
| H A D | xpl_listener_unix_socket.cc | 44 m_system_interface(operations_factory.create_system_interface()) { in Unixsocket_creator()
51 if (!m_system_interface) in unlink_unixsocket_file()
56 (void) m_system_interface->unlink(unix_socket_file.c_str()); in unlink_unixsocket_file()
57 (void) m_system_interface->unlink(unix_socket_lockfile.c_str()); in unlink_unixsocket_file()
114 m_system_interface->unlink(unix_socket_file.c_str()); in create_and_bind_unixsocket()
167 const pid_t cur_pid= m_system_interface->get_pid(); in create_unixsocket_lockfile()
186 if (EEXIST != m_system_interface->get_errno()) { in create_unixsocket_lockfile()
231 pid_t parent_pid= m_system_interface->get_ppid(); in create_unixsocket_lockfile()
242 if (m_system_interface->kill(read_pid, 0) == 0) { in create_unixsocket_lockfile()
256 if (m_system_interface->unlink(lock_filename.c_str()) < 0) { in create_unixsocket_lockfile()
[all …]
|
| H A D | xpl_listener_tcp.cc | 43 m_system_interface(m_factory.create_system_interface()) { in Tcp_creator()
85 ngs::bind(&ngs::System_interface::freeaddrinfo, m_system_interface, ngs::placeholders::_1)); in resolve_bind_address()
103 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
142 (int) m_system_interface->get_socket_errno()); in create_and_bind_socket()
150 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
162 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
225 if (!m_system_interface->getaddrinfo(address.c_str(), service.c_str(), &hints, &ai)) { in resolve_addr_info()
234 ngs::System_interface::Shared_ptr m_system_interface; member in xpl::Tcp_creator
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/x/src/io/ |
| H A D | xpl_listener_unix_socket.cc | 44 m_system_interface(operations_factory.create_system_interface()) { in Unixsocket_creator()
51 if (!m_system_interface) in unlink_unixsocket_file()
56 (void) m_system_interface->unlink(unix_socket_file.c_str()); in unlink_unixsocket_file()
57 (void) m_system_interface->unlink(unix_socket_lockfile.c_str()); in unlink_unixsocket_file()
114 m_system_interface->unlink(unix_socket_file.c_str()); in create_and_bind_unixsocket()
167 const pid_t cur_pid= m_system_interface->get_pid(); in create_unixsocket_lockfile()
186 if (EEXIST != m_system_interface->get_errno()) { in create_unixsocket_lockfile()
231 pid_t parent_pid= m_system_interface->get_ppid(); in create_unixsocket_lockfile()
242 if (m_system_interface->kill(read_pid, 0) == 0) { in create_unixsocket_lockfile()
256 if (m_system_interface->unlink(lock_filename.c_str()) < 0) { in create_unixsocket_lockfile()
[all …]
|
| H A D | xpl_listener_tcp.cc | 43 m_system_interface(m_factory.create_system_interface()) { in Tcp_creator()
85 ngs::bind(&ngs::System_interface::freeaddrinfo, m_system_interface, ngs::placeholders::_1)); in resolve_bind_address()
103 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
142 (int) m_system_interface->get_socket_errno()); in create_and_bind_socket()
150 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
162 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
225 if (!m_system_interface->getaddrinfo(address.c_str(), service.c_str(), &hints, &ai)) { in resolve_addr_info()
234 ngs::System_interface::Shared_ptr m_system_interface; member in xpl::Tcp_creator
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/x/src/io/ |
| H A D | xpl_listener_unix_socket.cc | 44 m_system_interface(operations_factory.create_system_interface()) { in Unixsocket_creator()
51 if (!m_system_interface) in unlink_unixsocket_file()
56 (void) m_system_interface->unlink(unix_socket_file.c_str()); in unlink_unixsocket_file()
57 (void) m_system_interface->unlink(unix_socket_lockfile.c_str()); in unlink_unixsocket_file()
114 m_system_interface->unlink(unix_socket_file.c_str()); in create_and_bind_unixsocket()
167 const pid_t cur_pid= m_system_interface->get_pid(); in create_unixsocket_lockfile()
186 if (EEXIST != m_system_interface->get_errno()) { in create_unixsocket_lockfile()
231 pid_t parent_pid= m_system_interface->get_ppid(); in create_unixsocket_lockfile()
242 if (m_system_interface->kill(read_pid, 0) == 0) { in create_unixsocket_lockfile()
256 if (m_system_interface->unlink(lock_filename.c_str()) < 0) { in create_unixsocket_lockfile()
[all …]
|
| H A D | xpl_listener_tcp.cc | 43 m_system_interface(m_factory.create_system_interface()) { in Tcp_creator()
85 ngs::bind(&ngs::System_interface::freeaddrinfo, m_system_interface, ngs::placeholders::_1)); in resolve_bind_address()
103 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
142 (int) m_system_interface->get_socket_errno()); in create_and_bind_socket()
150 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
162 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
225 if (!m_system_interface->getaddrinfo(address.c_str(), service.c_str(), &hints, &ai)) { in resolve_addr_info()
234 ngs::System_interface::Shared_ptr m_system_interface; member in xpl::Tcp_creator
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/x/src/io/ |
| H A D | xpl_listener_unix_socket.cc | 44 m_system_interface(operations_factory.create_system_interface()) { in Unixsocket_creator()
51 if (!m_system_interface) in unlink_unixsocket_file()
56 (void) m_system_interface->unlink(unix_socket_file.c_str()); in unlink_unixsocket_file()
57 (void) m_system_interface->unlink(unix_socket_lockfile.c_str()); in unlink_unixsocket_file()
114 m_system_interface->unlink(unix_socket_file.c_str()); in create_and_bind_unixsocket()
167 const pid_t cur_pid= m_system_interface->get_pid(); in create_unixsocket_lockfile()
186 if (EEXIST != m_system_interface->get_errno()) { in create_unixsocket_lockfile()
231 pid_t parent_pid= m_system_interface->get_ppid(); in create_unixsocket_lockfile()
242 if (m_system_interface->kill(read_pid, 0) == 0) { in create_unixsocket_lockfile()
256 if (m_system_interface->unlink(lock_filename.c_str()) < 0) { in create_unixsocket_lockfile()
[all …]
|
| H A D | xpl_listener_tcp.cc | 43 m_system_interface(m_factory.create_system_interface()) { in Tcp_creator()
85 ngs::bind(&ngs::System_interface::freeaddrinfo, m_system_interface, ngs::placeholders::_1)); in resolve_bind_address()
103 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
142 (int) m_system_interface->get_socket_errno()); in create_and_bind_socket()
150 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
162 m_system_interface->get_socket_error_and_message(error_code, errstr); in create_and_bind_socket()
225 if (!m_system_interface->getaddrinfo(address.c_str(), service.c_str(), &hints, &ai)) { in resolve_addr_info()
234 ngs::System_interface::Shared_ptr m_system_interface; member in xpl::Tcp_creator
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/src/io/ |
| H A D | xpl_listener_unix_socket.cc | 57 if (!m_system_interface) return; in unlink_unixsocket_file()
62 (void)m_system_interface->unlink(unix_socket_file.c_str()); in unlink_unixsocket_file()
63 (void)m_system_interface->unlink(unix_socket_lockfile.c_str()); in unlink_unixsocket_file()
105 m_system_interface->get_socket_error_and_message(&err, &errstr); in create_and_bind_unixsocket()
120 m_system_interface->unlink(unix_socket_file.c_str()); in create_and_bind_unixsocket()
182 const pid_t cur_pid = m_system_interface->get_pid(); in create_unixsocket_lockfile()
205 if (EEXIST != m_system_interface->get_errno()) { in create_unixsocket_lockfile()
252 pid_t parent_pid = m_system_interface->get_ppid(); in create_unixsocket_lockfile()
263 if (m_system_interface->kill(read_pid, 0) == 0) { in create_unixsocket_lockfile()
277 if (m_system_interface->unlink(lock_filename.c_str()) < 0) { in create_unixsocket_lockfile()
[all …]
|
| H A D | xpl_listener_tcp.cc | 54 m_system_interface(m_factory.create_system_interface()) {} in Tcp_creator()
90 result, std::bind(&iface::System::freeaddrinfo, m_system_interface, in resolve_bind_address()
108 m_system_interface->get_socket_error_and_message(&error_code, &errstr); in create_and_bind_socket()
150 static_cast<int>(m_system_interface->get_socket_errno())); in create_and_bind_socket()
159 m_system_interface->get_socket_error_and_message(&error_code, &errstr); in create_and_bind_socket()
176 m_system_interface->get_socket_error_and_message(&error_code, &errstr); in create_and_bind_socket()
239 if (!m_system_interface->getaddrinfo(address.c_str(), service.c_str(), in resolve_addr_info()
249 std::shared_ptr<iface::System> m_system_interface; member in xpl::Tcp_creator
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/x/ngs/src/ |
| H A D | socket_events.cc | 50 m_system_interface(system_interface) { in Connection_acceptor_socket()
66 const int error_code = m_system_interface.get_socket_errno(); in accept()
86 System_interface &m_system_interface; member in ngs::Connection_acceptor_socket
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/x/ngs/src/ |
| H A D | socket_events.cc | 50 m_system_interface(system_interface) { in Connection_acceptor_socket()
66 const int error_code = m_system_interface.get_socket_errno(); in accept()
86 System_interface &m_system_interface; member in ngs::Connection_acceptor_socket
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/x/ngs/src/ |
| H A D | socket_events.cc | 50 m_system_interface(system_interface) { in Connection_acceptor_socket()
66 const int error_code = m_system_interface.get_socket_errno(); in accept()
86 System_interface &m_system_interface; member in ngs::Connection_acceptor_socket
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/ngs/src/ |
| H A D | socket_events.cc | 55 : m_socket_listener(listener), m_system_interface(system_interface) {} in Connection_acceptor_socket()
71 const int error_code = m_system_interface.get_socket_errno(); in accept()
91 xpl::iface::System &m_system_interface; member in ngs::Connection_acceptor_socket
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/x/ngs/src/ |
| H A D | socket_events.cc | 50 m_system_interface(system_interface) { in Connection_acceptor_socket()
66 const int error_code = m_system_interface.get_socket_errno(); in accept()
86 System_interface &m_system_interface; member in ngs::Connection_acceptor_socket
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/x/ngs/src/ |
| H A D | socket_events.cc | 50 m_system_interface(system_interface) { in Connection_acceptor_socket()
66 const int error_code = m_system_interface.get_socket_errno(); in accept()
86 System_interface &m_system_interface; member in ngs::Connection_acceptor_socket
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/x/ngs/src/ |
| H A D | socket_events.cc | 50 m_system_interface(system_interface) { in Connection_acceptor_socket()
66 const int error_code = m_system_interface.get_socket_errno(); in accept()
86 System_interface &m_system_interface; member in ngs::Connection_acceptor_socket
|