aboutsummaryrefslogtreecommitdiff
path: root/src/channels.c
diff options
context:
space:
mode:
authorAris Adamantiadis <aris@0xbadc0de.be>2010-09-26 22:33:58 +0200
committerAris Adamantiadis <aris@0xbadc0de.be>2010-09-26 22:33:58 +0200
commit75a0281a6b04772b818cb7a6a01216fdf523d206 (patch)
tree63de7051ba09bee96d6b257fdd0c2b4c4778d7ec /src/channels.c
parenta92545517ab6d57f8725fa53a7efd8ba7f44e916 (diff)
downloadlibssh-75a0281a6b04772b818cb7a6a01216fdf523d206.tar.gz
libssh-75a0281a6b04772b818cb7a6a01216fdf523d206.tar.xz
libssh-75a0281a6b04772b818cb7a6a01216fdf523d206.zip
Fixed outgoing flow control + writes behaviours
Diffstat (limited to 'src/channels.c')
-rw-r--r--src/channels.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/channels.c b/src/channels.c
index 6900beea..90fee25e 100644
--- a/src/channels.c
+++ b/src/channels.c
@@ -2469,13 +2469,13 @@ int ssh_channel_select(ssh_channel *readchans, ssh_channel *writechans,
for (i = 0; readchans[i] != NULL; i++) {
if (ssh_socket_fd_isset(readchans[i]->session->socket, &rset)) {
- ssh_socket_set_toread(readchans[i]->session->socket);
+ ssh_socket_set_read_wontblock(readchans[i]->session->socket);
}
}
for (i = 0; writechans[i] != NULL; i++) {
if (ssh_socket_fd_isset(writechans[i]->session->socket, &wset)) {
- ssh_socket_set_towrite(writechans[i]->session->socket);
+ ssh_socket_set_write_wontblock(writechans[i]->session->socket);
}
}