aboutsummaryrefslogtreecommitdiff
path: root/src/session.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/session.c
parenta92545517ab6d57f8725fa53a7efd8ba7f44e916 (diff)
downloadlibssh-75a0281a6b04772b818cb7a6a01216fdf523d206.tar.gz
libssh-75a0281a6b04772b818cb7a6a01216fdf523d206.tar.xz
libssh-75a0281a6b04772b818cb7a6a01216fdf523d206.zip
Fixed outgoing flow control + writes behaviours
Diffstat (limited to 'src/session.c')
-rw-r--r--src/session.c6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/session.c b/src/session.c
index bce63afe..dbcb2809 100644
--- a/src/session.c
+++ b/src/session.c
@@ -308,7 +308,7 @@ void ssh_set_fd_toread(ssh_session session) {
return;
}
- ssh_socket_set_toread(session->socket);
+ ssh_socket_set_read_wontblock(session->socket);
}
/**
@@ -321,7 +321,7 @@ void ssh_set_fd_towrite(ssh_session session) {
return;
}
- ssh_socket_set_towrite(session->socket);
+ ssh_socket_set_write_wontblock(session->socket);
}
/**
@@ -362,7 +362,7 @@ int ssh_handle_packets(ssh_session session, int timeout) {
enter_function();
spoll_in=ssh_socket_get_poll_handle_in(session->socket);
spoll_out=ssh_socket_get_poll_handle_out(session->socket);
- ssh_poll_set_events(spoll_in, POLLIN | POLLERR);
+ ssh_poll_add_events(spoll_in, POLLIN | POLLERR);
ctx=ssh_poll_get_ctx(spoll_in);
if(ctx==NULL){
ctx=ssh_get_global_poll_ctx(session);