Home
last modified time | relevance | path

Searched refs:ndb_socket_valid (Results 1 – 17 of 17) sorted by relevance

/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/common/portlib/
H A Dndb_socket.cpp45 if (!ndb_socket_valid(listener)) in ndb_socketpair()
66 if (!ndb_socket_valid(s[0])) in ndb_socketpair()
73 if (!ndb_socket_valid(s[1])) in ndb_socketpair()
83 if (ndb_socket_valid(listener)) in ndb_socketpair()
86 if (ndb_socket_valid(s[0])) in ndb_socketpair()
89 if (ndb_socket_valid(s[1])) in ndb_socketpair()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/common/util/
H A DSocketClient.cpp47 if (ndb_socket_valid(m_sockfd)) in ~SocketClient()
56 if (ndb_socket_valid(m_sockfd)) in init()
60 if (!ndb_socket_valid(m_sockfd)) { in init()
74 if (!ndb_socket_valid(m_sockfd)) in bind()
137 if (!ndb_socket_valid(m_sockfd)) in connect()
H A DSocketServer.cpp61 if(ndb_socket_valid(m_services[i].m_socket)) in ~SocketServer()
81 if (!ndb_socket_valid(sock)) in tryBind()
121 if (!ndb_socket_valid(sock)) in setup()
225 if (!ndb_socket_valid(childSock)) in doAccept()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/common/transporter/
H A DLoopback_Transporter.cpp87 if (ndb_socket_valid(pair[0])) in disconnectImpl()
90 if (ndb_socket_valid(pair[1])) in disconnectImpl()
H A DTCP_Transporter.cpp191 if (ndb_socket_valid(theSocket)) in ~TCP_Transporter()
307 if (!ndb_socket_valid(fd)) in send_is_possible()
525 if (ndb_socket_valid(theSocket)) in shutdown()
682 if(ndb_socket_valid(sock)) in disconnectImpl()
H A DTransporter.cpp167 if (ndb_socket_valid(theSocket)) in do_disconnect()
321 if (!ndb_socket_valid(sockfd)) in connect_client()
H A DSHM_Transporter.cpp598 if (ndb_socket_valid(theSocket)) in remove_mutexes()
628 if(ndb_socket_valid(sock)) in disconnect_socket()
H A DTransporterRegistry.cpp211 if (!ndb_socket_valid(sock_fd)) in epoll_add()
1680 if (is_connected(node_id) && t->isConnected() && ndb_socket_valid(socket)) in poll_TCP()
1706 if (is_connected(node_id) && t->isConnected() && ndb_socket_valid(socket)) in poll_TCP()
3639 if (!ndb_socket_valid(sockfd)) in connect_ndb_mgmd()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/test/include/
H A DNdbMgmd.hpp438 return ndb_socket_valid(m_event_socket); in subscribe_to_events()
450 if (!ndb_socket_valid(m_event_socket)) in get_next_event_line()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/include/portlib/
H A Dndb_socket_win32.h48 int ndb_socket_valid(ndb_socket_t s) in ndb_socket_valid() function
H A Dndb_socket_posix.h52 int ndb_socket_valid(ndb_socket_t s) in ndb_socket_valid() function
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/test/ndbapi/
H A DtestLcp.cpp390 require(ndb_socket_valid(my_fd)); in pause_lcp()
486 require(ndb_socket_valid(my_fd)); in continue_lcp()
H A DtestMgm.cpp465 if(!ndb_socket_valid(my_fd)) in runTestMgmApiEventTimeout()
H A Dtest_event.cpp5528 if(!ndb_socket_valid(my_fd)) in runGetLogEventPretty()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/test/src/
H A DCpcClient.cpp433 if (ndb_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
457 if (!ndb_socket_valid(cpc_sock)) return -1; in open_connection()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/mgmsrv/
H A DServices.cpp388 if(ndb_socket_valid(m_socket)) in ~MgmApiSession()
483 if(ndb_socket_valid(m_socket)) in runSession()
1565 if(!ndb_socket_valid(m_clients[i].m_socket)) in log()
1641 if(!ndb_socket_valid(m_clients[i].m_socket)) in check_listeners()
1687 if(ndb_socket_valid(m_clients[i].m_socket)) in stop_sessions()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/mgmapi/
H A Dmgmapi.cpp768 while (!ndb_socket_valid(sockfd)) in ndb_mgm_connect()
828 if (ndb_socket_valid(sockfd)) in ndb_mgm_connect()
831 if (ndb_socket_valid(sockfd)) in ndb_mgm_connect()
2055 if (!ndb_socket_valid(sockfd)) in ndb_mgm_listen_event_internal()