system/freebsd-src
system/freebsd-src
1
0
Fork 0
mirror of https://github.com/freebsd/freebsd-src synced 2024-10-14 20:37:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

dma: update to 2022-01-27 snapshot

Browse source 
(cherry picked from commit d045091ea2)
This commit is contained in:
Ed Maste 2022-01-27 14:30:58 -05:00
parent 74c7755fe9
commit 73df35607d
1 changed files with 33 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

53
contrib/dma/net.c
View file

@ -95,25 +95,29 @@ send_remote_command(int fd, const char* fmt, ...)
strcat(cmd, "\r\n");
len = strlen(cmd);
if (((config.features & SECURETRANSFER) != 0) &&
((config.features & NOSSL) == 0)) {
while ((s = SSL_write(config.ssl, (const char*)cmd, len)) <= 0) {
s = SSL_get_error(config.ssl, s);
if (s != SSL_ERROR_WANT_READ &&
s != SSL_ERROR_WANT_WRITE) {
strlcpy(neterr, ssl_errstr(), sizeof(neterr));
return (-1);
pos = 0;
while (pos < len) {
if (((config.features & SECURETRANSFER) != 0) &&
((config.features & NOSSL) == 0)) {
if ((n = SSL_write(config.ssl, (const char*)(cmd + pos), len - pos)) <= 0) {
s = SSL_get_error(config.ssl, n);
if (s == SSL_ERROR_ZERO_RETURN ||
s == SSL_ERROR_SYSCALL ||
s == SSL_ERROR_SSL) {
strlcpy(neterr, ssl_errstr(), sizeof(neterr));
return (-1);
}
n = 0;
}
} else {
n = write(fd, cmd + pos, len - pos);
if (n < 0) {
if ((errno != EAGAIN) && (errno != EINTR))
return (-1);
n = 0;
}
}
}
else {
pos = 0;
while (pos < len) {
n = write(fd, cmd + pos, len - pos);
if (n < 0)
return (-1);
pos += n;
}
pos += n;
}
return (len);
@ -150,9 +154,18 @@ read_remote(int fd, int extbufsize, char *extbuf)
pos = 0;
if (((config.features & SECURETRANSFER) != 0) &&
(config.features & NOSSL) == 0) {
if ((rlen = SSL_read(config.ssl, buff + len, sizeof(buff) - len)) == -1) {
strlcpy(neterr, ssl_errstr(), sizeof(neterr));
goto error;
if ((rlen = SSL_read(config.ssl, buff + len, sizeof(buff) - len)) <= 0) {
switch (SSL_get_error(config.ssl, rlen)) {
case SSL_ERROR_ZERO_RETURN:
case SSL_ERROR_SYSCALL:
case SSL_ERROR_SSL:
strlcpy(neterr, ssl_errstr(), sizeof(neterr));
goto error;
default:
/* in case of recoverable error, retry after short sleep */
usleep(10000);
continue;
}
}
} else {
if ((rlen = read(fd, buff + len, sizeof(buff) - len)) == -1) {