From 27f3e955e871bc451246f6854aff8f88926b8b1b Mon Sep 17 00:00:00 2001 From: Jakub Jelen Date: Mon, 31 Oct 2022 16:08:53 +0100 Subject: [PATCH] Reformat and initialize pointers Signed-off-by: Jakub Jelen Reviewed-by: Andreas Schneider (cherry picked from commit 8f7c179bed894e4b44c876f782c8247ddb6a4722) --- src/bind.c | 3 ++- src/poll.c | 2 +- src/session.c | 18 ++++++++++-------- src/socket.c | 12 +++++++++--- 4 files changed, 22 insertions(+), 13 deletions(-) diff --git a/src/bind.c b/src/bind.c index 77acbb66..51a245cf 100644 --- a/src/bind.c +++ b/src/bind.c @@ -424,7 +424,8 @@ void ssh_bind_free(ssh_bind sshbind){ SAFE_FREE(sshbind); } -int ssh_bind_accept_fd(ssh_bind sshbind, ssh_session session, socket_t fd){ +int ssh_bind_accept_fd(ssh_bind sshbind, ssh_session session, socket_t fd) +{ int i, rc; if (sshbind == NULL) { diff --git a/src/poll.c b/src/poll.c index 1774e7e0..ba8e3706 100644 --- a/src/poll.c +++ b/src/poll.c @@ -621,7 +621,7 @@ int ssh_poll_ctx_add(ssh_poll_ctx ctx, ssh_poll_handle p) */ int ssh_poll_ctx_add_socket (ssh_poll_ctx ctx, ssh_socket s) { - ssh_poll_handle p; + ssh_poll_handle p = NULL; int ret; p = ssh_socket_get_poll_handle(s); diff --git a/src/session.c b/src/session.c index 9f18fea8..bcd38fda 100644 --- a/src/session.c +++ b/src/session.c @@ -633,9 +633,10 @@ void ssh_set_fd_except(ssh_session session) { * * @return SSH_OK on success, SSH_ERROR otherwise. */ -int ssh_handle_packets(ssh_session session, int timeout) { - ssh_poll_handle spoll; - ssh_poll_ctx ctx; +int ssh_handle_packets(ssh_session session, int timeout) +{ + ssh_poll_handle spoll = NULL; + ssh_poll_ctx ctx = NULL; int tm = timeout; int rc; @@ -653,11 +654,12 @@ int ssh_handle_packets(ssh_session session, int timeout) { } if (timeout == SSH_TIMEOUT_USER) { - if (ssh_is_blocking(session)) - tm = ssh_make_milliseconds(session->opts.timeout, - session->opts.timeout_usec); - else - tm = 0; + if (ssh_is_blocking(session)) { + tm = ssh_make_milliseconds(session->opts.timeout, + session->opts.timeout_usec); + } else { + tm = 0; + } } rc = ssh_poll_ctx_dopoll(ctx, tm); if (rc == SSH_ERROR) { diff --git a/src/socket.c b/src/socket.c index 4e637ae1..f55b237a 100644 --- a/src/socket.c +++ b/src/socket.c @@ -401,7 +401,7 @@ ssh_poll_handle ssh_socket_get_poll_handle(ssh_socket s) if (s->poll_handle) { return s->poll_handle; } - s->poll_handle = ssh_poll_new(s->fd,0,ssh_socket_pollcallback,s); + s->poll_handle = ssh_poll_new(s->fd, 0, ssh_socket_pollcallback, s); return s->poll_handle; } @@ -513,17 +513,23 @@ void ssh_socket_close(ssh_socket s) */ void ssh_socket_set_fd(ssh_socket s, socket_t fd) { + ssh_poll_handle h = NULL; + s->fd = fd; if (s->poll_handle) { ssh_poll_set_fd(s->poll_handle,fd); } else { s->state = SSH_SOCKET_CONNECTING; + h = ssh_socket_get_poll_handle(s); + if (h == NULL) { + return; + } /* POLLOUT is the event to wait for in a nonblocking connect */ - ssh_poll_set_events(ssh_socket_get_poll_handle(s), POLLOUT); + ssh_poll_set_events(h, POLLOUT); #ifdef _WIN32 - ssh_poll_add_events(ssh_socket_get_poll_handle(s), POLLWRNORM); + ssh_poll_add_events(h, POLLWRNORM); #endif } }