| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/src/protocol/ |
| H A D | x_protocol.cc | 134 if (!read_res) { in get_next_message()
136 read_res.error().value(), read_res.error().message().c_str()); in get_next_message()
139 } else if (read_res.value() == 0) { in get_next_message()
147 bytes_left += read_res.value(); in get_next_message()
172 const auto read_res = in get_next_message() local
175 if (!read_res) { in get_next_message()
182 } else if (read_res.value() == 0) { in get_next_message()
189 bytes_left += read_res.value(); in get_next_message()
207 if (!read_res) { in copy_packets()
209 read_res.error().value(), read_res.error().message().c_str()); in copy_packets()
[all …]
|
| H A D | classic_protocol.cc | 70 const auto read_res = so->read(sender, &buffer.front(), buffer_length); in copy_packets() local
71 if (!read_res) { in copy_packets()
72 log_debug("fd=%d read failed: (%d %s)", sender, read_res.error().value(), in copy_packets()
73 read_res.error().message().c_str()); in copy_packets()
74 return stdx::make_unexpected(read_res.error()); in copy_packets()
75 } else if (read_res.value() == 0) { in copy_packets()
80 bytes_read += read_res.value(); in copy_packets()
|
| /dports/comms/sms_client/sms_client-3.0.2/src/terminal/ |
| H A D | terminal_io.c | 134 read_res, in terminal_io() local
271 { read_res = read(client_fdin, &c, 1); in terminal_io()
273 } while ((read_res == -1) && in terminal_io()
276 if (read_res == -1) in terminal_io()
281 if (read_res == 0) in terminal_io()
391 { read_res = read(server_fdin, &c, 1); in terminal_io()
393 } while ((read_res == -1) && in terminal_io()
397 if (read_res == -1) in terminal_io()
402 if (read_res == 0) in terminal_io()
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 35 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
36 if (read_res == -1) in gets()
39 if (!add_buffer(buf, read_res)) in gets()
75 size_t read_res = ndb_recv(m_socket, buf, len, 0); in read_socket() local
76 if (read_res == 0) in read_socket()
79 return read_res; in read_socket()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/test/src/ |
| H A D | SocketInputStream2.cpp | 36 ssize_t read_res = read_socket(buf, sizeof(buf)); in gets() local
37 if (read_res == -1) in gets()
40 if (!add_buffer(buf, read_res)) in gets()
76 size_t read_res = my_recv(m_socket, buf, len, 0); in read_socket() local
77 if (read_res == 0) in read_socket()
80 return read_res; in read_socket()
|
| /dports/science/py-ase/ase-3.22.0/ase/test/fio/ |
| H A D | test_res.py | 4 from ase.io.res import Res, read_res, write_res
278 atoms = read_res(filepath)
286 atoms2 = read_res(filepath)
290 atoms3 = read_res('test3.res')
|
| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/tdutils/td/utils/port/detail/ |
| H A D | EventFdLinux.cpp | 100 …auto read_res = detail::skip_eintr([&] { return ::read(native_fd, slice.begin(), slice.size()); }); in acquire() local
102 if (read_res >= 0) { in acquire()
103 CHECK(read_res != 0); in acquire()
104 return narrow_cast<size_t>(read_res); in acquire()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chromeos/memory/userspace_swap/ |
| H A D | swap_storage.cc | 355 ssize_t read_res = in ReadFromSwap() local
357 if (read_res != static_cast<ssize_t>(swap_region.length)) { in ReadFromSwap()
358 return read_res; in ReadFromSwap()
360 compressed_buf.resize(read_res); in ReadFromSwap()
443 ssize_t read_res = in ReadFromSwap() local
445 if (read_res == -1) { in ReadFromSwap()
446 PLOG(ERROR) << "Read failed " << read_res; in ReadFromSwap()
447 return read_res; in ReadFromSwap()
449 compressed_buf.resize(read_res); in ReadFromSwap()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/nix/test/sys/ |
| H A D | test_uio.rs | 41 let read_res = read(reader, &mut read_buf[..]); in test_writev() localVariable
43 assert!(read_res.is_ok()); in test_writev()
44 let read = read_res.ok().unwrap() as usize; in test_writev()
79 let read_res = readv(reader, &mut iovecs[..]); in test_readv() localVariable
80 assert!(read_res.is_ok()); in test_readv()
81 let read = read_res.ok().unwrap(); in test_readv()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/nix/test/sys/ |
| H A D | test_uio.rs | 41 let read_res = read(reader, &mut read_buf[..]); in test_writev() localVariable
43 assert!(read_res.is_ok()); in test_writev()
44 let read = read_res.ok().unwrap() as usize; in test_writev()
79 let read_res = readv(reader, &mut iovecs[..]); in test_readv() localVariable
80 assert!(read_res.is_ok()); in test_readv()
81 let read = read_res.ok().unwrap(); in test_readv()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/nix/test/sys/ |
| H A D | test_uio.rs | 41 let read_res = read(reader, &mut read_buf[..]); in test_writev() localVariable
43 assert!(read_res.is_ok()); in test_writev()
44 let read = read_res.ok().unwrap() as usize; in test_writev()
79 let read_res = readv(reader, &mut iovecs[..]); in test_readv() localVariable
80 assert!(read_res.is_ok()); in test_readv()
81 let read = read_res.ok().unwrap(); in test_readv()
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/plugin/semisync/ |
| H A D | semisync_slave.cc | 57 int read_res = 0; in slaveReadSyncHeader() local
73 read_res = -1; in slaveReadSyncHeader()
76 return function_exit(kWho, read_res); in slaveReadSyncHeader()
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/plugin/semisync/ |
| H A D | semisync_slave.cc | 57 int read_res = 0; in slaveReadSyncHeader() local
73 read_res = -1; in slaveReadSyncHeader()
76 return function_exit(kWho, read_res); in slaveReadSyncHeader()
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/plugin/semisync/ |
| H A D | semisync_slave.cc | 57 int read_res = 0; in slaveReadSyncHeader() local
73 read_res = -1; in slaveReadSyncHeader()
76 return function_exit(kWho, read_res); in slaveReadSyncHeader()
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/plugin/semisync/ |
| H A D | semisync_slave.cc | 57 int read_res = 0; in slaveReadSyncHeader() local
73 read_res = -1; in slaveReadSyncHeader()
76 return function_exit(kWho, read_res); in slaveReadSyncHeader()
|
| /dports/databases/mysql56-client/mysql-5.6.51/plugin/semisync/ |
| H A D | semisync_slave.cc | 57 int read_res = 0; in slaveReadSyncHeader() local
73 read_res = -1; in slaveReadSyncHeader()
76 return function_exit(kWho, read_res); in slaveReadSyncHeader()
|