Home
last modified time | relevance | path

Searched refs:cpc_sock (Results 1 – 24 of 24) sorted by relevance

/dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/test/src/
H A DCpcClient.cpp431 cpc_sock = -1; in SimpleCpcClient()
442 if(cpc_sock == -1) { in ~SimpleCpcClient()
443 close(cpc_sock); in ~SimpleCpcClient()
444 cpc_sock = -1; in ~SimpleCpcClient()
454 cpc_sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
455 if(cpc_sock < 0) in connect()
468 if (::connect(cpc_sock, (struct sockaddr*) &sa, sizeof(sa)) < 0) in connect()
477 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
517 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
520 ParserDummy session(cpc_sock); in cpc_recv()
[all …]
/dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/test/src/
H A DCpcClient.cpp386 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
397 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
398 my_socket_close(cpc_sock); in ~SimpleCpcClient()
399 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
409 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
410 if(!my_socket_valid(cpc_sock)) in connect()
423 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
432 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
481 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
484 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/test/src/
H A DCpcClient.cpp386 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
397 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
398 my_socket_close(cpc_sock); in ~SimpleCpcClient()
399 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
409 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
410 if(!my_socket_valid(cpc_sock)) in connect()
423 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
432 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
481 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
484 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/test/src/
H A DCpcClient.cpp385 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
396 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
397 my_socket_close(cpc_sock); in ~SimpleCpcClient()
398 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
408 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
409 if(!my_socket_valid(cpc_sock)) in connect()
422 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
431 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
480 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
483 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/test/src/
H A DCpcClient.cpp385 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
396 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
397 my_socket_close(cpc_sock); in ~SimpleCpcClient()
398 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
408 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
409 if(!my_socket_valid(cpc_sock)) in connect()
422 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
431 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
480 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
483 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/test/src/
H A DCpcClient.cpp385 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
396 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
397 my_socket_close(cpc_sock); in ~SimpleCpcClient()
398 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
408 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
409 if(!my_socket_valid(cpc_sock)) in connect()
422 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
431 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
480 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
483 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/test/src/
H A DCpcClient.cpp386 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
397 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
398 my_socket_close(cpc_sock); in ~SimpleCpcClient()
399 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
409 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
410 if(!my_socket_valid(cpc_sock)) in connect()
423 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
432 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
481 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
484 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/test/src/
H A DCpcClient.cpp385 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
396 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
397 my_socket_close(cpc_sock); in ~SimpleCpcClient()
398 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
408 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
409 if(!my_socket_valid(cpc_sock)) in connect()
422 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
431 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
480 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
483 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/test/src/
H A DCpcClient.cpp385 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
396 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
397 my_socket_close(cpc_sock); in ~SimpleCpcClient()
398 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
408 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
409 if(!my_socket_valid(cpc_sock)) in connect()
422 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
431 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
480 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
483 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/test/src/
H A DCpcClient.cpp386 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
397 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
398 my_socket_close(cpc_sock); in ~SimpleCpcClient()
399 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
409 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
410 if(!my_socket_valid(cpc_sock)) in connect()
423 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
432 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
481 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
484 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/test/src/
H A DCpcClient.cpp386 my_socket_invalidate(&cpc_sock); in SimpleCpcClient()
397 if(my_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
398 my_socket_close(cpc_sock); in ~SimpleCpcClient()
399 my_socket_invalidate(&cpc_sock); in ~SimpleCpcClient()
409 cpc_sock = my_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in connect()
410 if(!my_socket_valid(cpc_sock)) in connect()
423 if (my_connect_inet(cpc_sock, &sa) < 0) in connect()
432 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
481 SocketInputStream cpc_in(cpc_sock); in cpc_recv()
484 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/test/src/
H A DCpcClient.cpp421 ndb_socket_invalidate(&cpc_sock); in SimpleCpcClient()
433 if (ndb_socket_valid(cpc_sock)) { in ~SimpleCpcClient()
456 cpc_sock = ndb_socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP); in open_connection()
457 if (!ndb_socket_valid(cpc_sock)) return -1; in open_connection()
470 return ndb_connect_inet(cpc_sock, &sa); in open_connection()
491 ndb_socket_close(cpc_sock); in close_connection()
492 ndb_socket_invalidate(&cpc_sock); in close_connection()
496 SocketOutputStream cpc_out(cpc_sock); in cpc_send()
560 SocketInputStream cpc_in(cpc_sock, 2 * 60 * 1000); in cpc_recv()
563 ParserDummy session(cpc_sock); in cpc_recv()
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/test/include/
H A DCpcClient.hpp80 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/test/include/
H A DCpcClient.hpp73 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/test/include/
H A DCpcClient.hpp81 NDB_SOCKET_TYPE cpc_sock; member in SimpleCpcClient