mirror of
https://github.com/samba-team/samba.git
synced 2025-02-26 21:57:41 +03:00
read_socket_with_timeout_ntstatus->read_socket_with_timeout
(This used to be commit 90554799afa42855c3e7b87dc632e67f0952f988)
This commit is contained in:
parent
5e43eeb1b6
commit
6ddfa6ae77
@ -913,10 +913,10 @@ ssize_t read_udp_v4_socket(int fd,
|
||||
time_out = timeout in milliseconds
|
||||
****************************************************************************/
|
||||
|
||||
NTSTATUS read_socket_with_timeout_ntstatus(int fd, char *buf,
|
||||
size_t mincnt, size_t maxcnt,
|
||||
unsigned int time_out,
|
||||
size_t *size_ret)
|
||||
NTSTATUS read_socket_with_timeout(int fd, char *buf,
|
||||
size_t mincnt, size_t maxcnt,
|
||||
unsigned int time_out,
|
||||
size_t *size_ret)
|
||||
{
|
||||
fd_set fds;
|
||||
int selrtn;
|
||||
@ -1052,7 +1052,7 @@ ssize_t read_data(int fd,char *buffer,size_t N, enum smb_read_errors *pre)
|
||||
|
||||
set_smb_read_error(pre, SMB_READ_OK);
|
||||
|
||||
status = read_socket_with_timeout_ntstatus(fd, buffer, N, N, 0, NULL);
|
||||
status = read_socket_with_timeout(fd, buffer, N, N, 0, NULL);
|
||||
|
||||
if (NT_STATUS_IS_OK(status)) {
|
||||
return N;
|
||||
@ -1138,8 +1138,7 @@ NTSTATUS read_smb_length_return_keepalive(int fd, char *inbuf,
|
||||
int msg_type;
|
||||
NTSTATUS status;
|
||||
|
||||
status = read_socket_with_timeout_ntstatus(fd, inbuf, 4, 4, timeout,
|
||||
NULL);
|
||||
status = read_socket_with_timeout(fd, inbuf, 4, 4, timeout, NULL);
|
||||
|
||||
if (!NT_STATUS_IS_OK(status)) {
|
||||
return status;
|
||||
@ -1255,7 +1254,7 @@ ssize_t receive_smb_raw(int fd,
|
||||
|
||||
set_smb_read_error(pre, SMB_READ_OK);
|
||||
|
||||
status = read_socket_with_timeout_ntstatus(
|
||||
status = read_socket_with_timeout(
|
||||
fd, buffer+4, len, len, timeout, &len);
|
||||
|
||||
if (!NT_STATUS_IS_OK(status)) {
|
||||
|
@ -184,7 +184,7 @@ ssize_t cli_receive_smb_data(struct cli_state *cli, char *buffer, size_t len)
|
||||
|
||||
set_smb_read_error(&cli->smb_rw_error, SMB_READ_OK);
|
||||
|
||||
status = read_socket_with_timeout_ntstatus(
|
||||
status = read_socket_with_timeout(
|
||||
cli->fd, buffer, len, len, cli->timeout, NULL);
|
||||
if (NT_STATUS_IS_OK(status)) {
|
||||
return len;
|
||||
|
@ -265,7 +265,7 @@ static int expect(int master, char *issue, char *expected)
|
||||
|
||||
while (True) {
|
||||
NTSTATUS status;
|
||||
status = read_socket_with_timeout_ntstatus(
|
||||
status = read_socket_with_timeout(
|
||||
master, buffer + nread, 1,
|
||||
sizeof(buffer) - nread - 1,
|
||||
timeout, &len);
|
||||
|
@ -141,8 +141,7 @@ static NTSTATUS read_packet_remainder(int fd, char *buffer,
|
||||
return NT_STATUS_OK;
|
||||
}
|
||||
|
||||
return read_socket_with_timeout_ntstatus(fd, buffer, len, len,
|
||||
timeout, NULL);
|
||||
return read_socket_with_timeout(fd, buffer, len, len, timeout, NULL);
|
||||
}
|
||||
|
||||
/****************************************************************************
|
||||
@ -176,7 +175,7 @@ static NTSTATUS receive_smb_raw_talloc_partial_read(TALLOC_CTX *mem_ctx,
|
||||
|
||||
memcpy(writeX_header, lenbuf, sizeof(lenbuf));
|
||||
|
||||
status = read_socket_with_timeout_ntstatus(
|
||||
status = read_socket_with_timeout(
|
||||
fd, writeX_header + 4,
|
||||
STANDARD_WRITE_AND_X_HEADER_SIZE,
|
||||
STANDARD_WRITE_AND_X_HEADER_SIZE,
|
||||
|
Loading…
x
Reference in New Issue
Block a user