Skip to content

Commit b17b083

Browse files
committed
Merge commit 'mysql-8.0' into mysql-trunk
Change-Id: I1da6faa2718a36b427519b25392be79d7acf88e6
2 parents b78b46a + 273cb07 commit b17b083

File tree

2 files changed

+9
-0
lines changed

2 files changed

+9
-0
lines changed

storage/ndb/include/util/NdbSocket.h

+3
Original file line numberDiff line numberDiff line change
@@ -307,20 +307,23 @@ uint NdbSocket::add_writable(ndb_socket_poller * poller) const {
307307

308308
inline
309309
int NdbSocket::poll_readable(int timeout) const {
310+
if (!is_valid()) return -1;
310311
ndb_socket_poller poller;
311312
poller.add_readable(s, ssl);
312313
return poller.poll(timeout);
313314
}
314315

315316
inline
316317
int NdbSocket::poll_writable(int timeout) const {
318+
if (!is_valid()) return -1;
317319
ndb_socket_poller poller;
318320
poller.add_writable(s);
319321
return poller.poll(timeout);
320322
}
321323

322324
inline
323325
bool NdbSocket::check_hup() const {
326+
if (!is_valid()) return true;
324327
ndb_socket_poller poller;
325328
poller.add_readable(s);
326329
if(poller.poll_unsafe(0) > 0 && poller.has_hup(0))

storage/ndb/src/common/util/socket_io.cpp

+6
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,9 @@ poll_socket(ndb_socket_t socket, bool read, bool write,
5757
int
5858
read_socket(ndb_socket_t socket, int timeout_millis,
5959
char * buf, int buflen){
60+
if (!ndb_socket_valid(socket))
61+
return -1;
62+
6063
if(buflen < 1)
6164
return 0;
6265

@@ -72,6 +75,9 @@ read_socket(ndb_socket_t socket, int timeout_millis,
7275
int
7376
readln_socket(ndb_socket_t socket, int timeout_millis, int *time,
7477
char * buf, int buflen, NdbMutex *mutex){
78+
if (!ndb_socket_valid(socket))
79+
return -1;
80+
7581
if(buflen <= 1)
7682
return 0;
7783

0 commit comments

Comments
 (0)