diff options
author | Aris Adamantiadis <aris@0xbadc0de.be> | 2012-12-27 22:01:37 +0100 |
---|---|---|
committer | Aris Adamantiadis <aris@0xbadc0de.be> | 2012-12-27 22:01:37 +0100 |
commit | de096910b37ca3474fc37d421fb051a234f5cce0 (patch) | |
tree | ce4a59c155ced14e4a833ee55ba83daf67be40c5 /src/channels.c | |
parent | ce33633bcb6fe0ba93b92a7c9c0ccd11cc2a213a (diff) | |
download | libssh-de096910b37ca3474fc37d421fb051a234f5cce0.tar.gz libssh-de096910b37ca3474fc37d421fb051a234f5cce0.tar.xz libssh-de096910b37ca3474fc37d421fb051a234f5cce0.zip |
Report according status when errors are detected
Diffstat (limited to 'src/channels.c')
-rw-r--r-- | src/channels.c | 21 |
1 files changed, 18 insertions, 3 deletions
diff --git a/src/channels.c b/src/channels.c index b51ff574..6e9b2eb0 100644 --- a/src/channels.c +++ b/src/channels.c @@ -1270,7 +1270,10 @@ int channel_write_common(ssh_channel channel, const void *data, leave_function(); return -1; } - + if (channel->session->session_state == SSH_SESSION_STATE_ERROR){ + leave_function(); + return SSH_ERROR; + } #ifdef WITH_SSH1 if (channel->version == 1) { rc = channel_write1(channel, data, len); @@ -2690,6 +2693,10 @@ int ssh_channel_read(ssh_channel channel, void *dest, uint32_t count, int is_std leave_function(); return rc; } + if (channel->session->session_state == SSH_SESSION_STATE_ERROR){ + leave_function(); + return SSH_ERROR; + } if (channel->remote_eof && buffer_get_rest_len(stdbuf) == 0) { leave_function(); return 0; @@ -2753,8 +2760,12 @@ int ssh_channel_read_nonblocking(ssh_channel channel, void *dest, uint32_t count to_read = ssh_channel_poll(channel, is_stderr); if (to_read <= 0) { - leave_function(); - return to_read; /* may be an error code */ + if (channel->session->session_state == SSH_SESSION_STATE_ERROR){ + leave_function(); + return SSH_ERROR; + } + leave_function(); + return to_read; /* may be an error code */ } if (to_read > (int)count) { @@ -2799,6 +2810,10 @@ int ssh_channel_poll(ssh_channel channel, int is_stderr){ } if (buffer_get_rest_len(stdbuf) == 0 && channel->remote_eof == 0) { + if (channel->session->session_state == SSH_SESSION_STATE_ERROR){ + leave_function(); + return SSH_ERROR; + } if (ssh_handle_packets(channel->session, SSH_TIMEOUT_NONBLOCKING)==SSH_ERROR) { leave_function(); return SSH_ERROR; |