lib/libssh
1
0
Fork 0
mirror of https://git.libssh.org/projects/libssh.git synced 2025-12-02 01:17:52 +03:00
Code Activity

socket: Reformat ssh_socket_unbuffered_write()

Browse Source 
Signed-off-by: Andreas Schneider <asn@cryptomilk.org>
This commit is contained in:
Andreas Schneider
2018-09-24 18:51:48 +02:00
parent caf50270c6
commit c5cadaa982
1 changed files with 23 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
src/socket.c
View File

@@ -584,32 +584,34 @@ static ssize_t ssh_socket_unbuffered_read(ssh_socket s,
* \brief writes len bytes from buffer to socket * \brief writes len bytes from buffer to socket
*/ */
static int ssh_socket_unbuffered_write(ssh_socket s, const void *buffer, static int ssh_socket_unbuffered_write(ssh_socket s, const void *buffer,
uint32_t len) { uint32_t len) {
int w = -1; int w = -1;
if (s->data_except) { if (s->data_except) {
return -1; return -1;
} }
if (s->fd_is_socket)
w = send(s->fd_out,buffer, len, 0); if (s->fd_is_socket) {
else w = send(s->fd_out,buffer, len, 0);
w = write(s->fd_out, buffer, len); } else {
w = write(s->fd_out, buffer, len);
}
#ifdef _WIN32 #ifdef _WIN32
s->last_errno = WSAGetLastError(); s->last_errno = WSAGetLastError();
#else #else
s->last_errno = errno; s->last_errno = errno;
#endif #endif
s->write_wontblock = 0; s->write_wontblock = 0;
/* Reactive the POLLOUT detector in the poll multiplexer system */ /* Reactive the POLLOUT detector in the poll multiplexer system */
if(s->poll_out){ if (s->poll_out) {
SSH_LOG(SSH_LOG_PACKET, "Enabling POLLOUT for socket"); SSH_LOG(SSH_LOG_PACKET, "Enabling POLLOUT for socket");
ssh_poll_set_events(s->poll_out,ssh_poll_get_events(s->poll_out) | POLLOUT); ssh_poll_set_events(s->poll_out,ssh_poll_get_events(s->poll_out) | POLLOUT);
} }
if (w < 0) { if (w < 0) {
s->data_except = 1; s->data_except = 1;
} }
return w; return w;
} }
/** \internal /** \internal