diff options
| author | Johannes Krude <johannes@krude.de> | 2013-01-22 13:06:28 +0100 |
|---|---|---|
| committer | Andreas Schneider <asn@cryptomilk.org> | 2013-01-29 10:56:49 +0100 |
| commit | 186116f34a6f81eb9dea1c73a95e11ac18218691 (patch) | |
| tree | 0bfc814ac95d01eab6e684609de423d360254f56 /src/socket.c | |
| parent | b2f52799c231cc22a79ee4f5f47f9982f6e6ca75 (diff) | |
| download | libssh-186116f34a6f81eb9dea1c73a95e11ac18218691.tar.gz libssh-186116f34a6f81eb9dea1c73a95e11ac18218691.tar.xz libssh-186116f34a6f81eb9dea1c73a95e11ac18218691.zip | |
socket: Call data handler as long as handler takes data.
Reviewed-by: Andreas Schneider <asn@cryptomilk.org>
Diffstat (limited to 'src/socket.c')
| -rw-r--r-- | src/socket.c | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/socket.c b/src/socket.c index 6eab0aa..85b87b7 100644 --- a/src/socket.c +++ b/src/socket.c @@ -283,10 +283,12 @@ int ssh_socket_pollcallback(struct ssh_poll_handle_struct *p, socket_t fd, int r return -1; } if(s->callbacks && s->callbacks->data){ - r= s->callbacks->data(buffer_get_rest(s->in_buffer), - buffer_get_rest_len(s->in_buffer), - s->callbacks->userdata); - buffer_pass_bytes(s->in_buffer,r); + do { + r= s->callbacks->data(buffer_get_rest(s->in_buffer), + buffer_get_rest_len(s->in_buffer), + s->callbacks->userdata); + buffer_pass_bytes(s->in_buffer,r); + } while (r > 0); /* p may have been freed, so don't use it * anymore in this function */ p = NULL; |