aboutsummaryrefslogtreecommitdiff
path: root/src/channels.c
diff options
context:
space:
mode:
authorFabiano FidĂȘncio <fidencio@redhat.com>2015-09-25 00:34:42 +0200
committerFabiano FidĂȘncio <fidencio@redhat.com>2016-01-19 11:31:08 +0100
commit05fd0acf457f6514f4dff4d6d2d3906776a76437 (patch)
treebf60c88a30f7a7feb2026d6034f7697682c77d94 /src/channels.c
parent25707e97520c7787f0a742dea419afca4c8cad41 (diff)
downloadlibssh-05fd0acf457f6514f4dff4d6d2d3906776a76437.tar.gz
libssh-05fd0acf457f6514f4dff4d6d2d3906776a76437.tar.xz
libssh-05fd0acf457f6514f4dff4d6d2d3906776a76437.zip
buffer: do not use ssh_buffer_get_rest_len()
As ssh_buffer_get_len() actually calls ssh_buffer_get_rest_len(), let's just use the first one. This is a preparatory step for removing ssh_buffer_get_rest_len(). Signed-off-by: Fabiano FidĂȘncio <fidencio@redhat.com> Reviewed-by: Andreas Schneider <asn@cryptomilk.org>
Diffstat (limited to 'src/channels.c')
-rw-r--r--src/channels.c42
1 files changed, 21 insertions, 21 deletions
diff --git a/src/channels.c b/src/channels.c
index 5cfc6ed7..ffcb1d5b 100644
--- a/src/channels.c
+++ b/src/channels.c
@@ -547,7 +547,7 @@ SSH_PACKET_CALLBACK(channel_rcv_data){
rest = channel->callbacks->channel_data_function(channel->session,
channel,
ssh_buffer_get(buf),
- ssh_buffer_get_rest_len(buf),
+ ssh_buffer_get_len(buf),
is_stderr,
channel->callbacks->userdata);
if(rest > 0) {
@@ -556,7 +556,7 @@ SSH_PACKET_CALLBACK(channel_rcv_data){
}
ssh_buffer_pass_bytes(buf, rest);
}
- if (channel->local_window + ssh_buffer_get_rest_len(buf) < WINDOWLIMIT) {
+ if (channel->local_window + ssh_buffer_get_len(buf) < WINDOWLIMIT) {
if (grow_window(session, channel, 0) < 0) {
return -1;
}
@@ -612,9 +612,9 @@ SSH_PACKET_CALLBACK(channel_rcv_close) {
channel->remote_channel);
if ((channel->stdout_buffer &&
- ssh_buffer_get_rest_len(channel->stdout_buffer) > 0) ||
+ ssh_buffer_get_len(channel->stdout_buffer) > 0) ||
(channel->stderr_buffer &&
- ssh_buffer_get_rest_len(channel->stderr_buffer) > 0)) {
+ ssh_buffer_get_len(channel->stderr_buffer) > 0)) {
channel->delayed_close = 1;
} else {
channel->state = SSH_CHANNEL_STATE_CLOSED;
@@ -1414,9 +1414,9 @@ int ssh_channel_is_eof(ssh_channel channel) {
return SSH_ERROR;
}
if ((channel->stdout_buffer &&
- ssh_buffer_get_rest_len(channel->stdout_buffer) > 0) ||
+ ssh_buffer_get_len(channel->stdout_buffer) > 0) ||
(channel->stderr_buffer &&
- ssh_buffer_get_rest_len(channel->stderr_buffer) > 0)) {
+ ssh_buffer_get_len(channel->stderr_buffer) > 0)) {
return 0;
}
@@ -1541,7 +1541,7 @@ static int channel_request(ssh_channel channel, const char *request,
if (buffer != NULL) {
if (ssh_buffer_add_data(session->out_buffer, ssh_buffer_get(buffer),
- ssh_buffer_get_rest_len(buffer)) < 0) {
+ ssh_buffer_get_len(buffer)) < 0) {
ssh_set_error_oom(session);
goto error;
}
@@ -2100,7 +2100,7 @@ static int global_request(ssh_session session, const char *request,
if (buffer != NULL) {
rc = ssh_buffer_add_data(session->out_buffer,
ssh_buffer_get(buffer),
- ssh_buffer_get_rest_len(buffer));
+ ssh_buffer_get_len(buffer));
if (rc < 0) {
ssh_set_error_oom(session);
rc = SSH_ERROR;
@@ -2584,7 +2584,7 @@ struct ssh_channel_read_termination_struct {
static int ssh_channel_read_termination(void *s){
struct ssh_channel_read_termination_struct *ctx = s;
- if (ssh_buffer_get_rest_len(ctx->buffer) >= ctx->count ||
+ if (ssh_buffer_get_len(ctx->buffer) >= ctx->count ||
ctx->channel->remote_eof ||
ctx->channel->session->session_state == SSH_SESSION_STATE_ERROR)
return 1;
@@ -2681,11 +2681,11 @@ int ssh_channel_read_timeout(ssh_channel channel,
SSH_LOG(SSH_LOG_PACKET,
"Read (%d) buffered : %d bytes. Window: %d",
count,
- ssh_buffer_get_rest_len(stdbuf),
+ ssh_buffer_get_len(stdbuf),
channel->local_window);
- if (count > ssh_buffer_get_rest_len(stdbuf) + channel->local_window) {
- if (grow_window(session, channel, count - ssh_buffer_get_rest_len(stdbuf)) < 0) {
+ if (count > ssh_buffer_get_len(stdbuf) + channel->local_window) {
+ if (grow_window(session, channel, count - ssh_buffer_get_len(stdbuf)) < 0) {
return -1;
}
}
@@ -2711,10 +2711,10 @@ int ssh_channel_read_timeout(ssh_channel channel,
if (channel->session->session_state == SSH_SESSION_STATE_ERROR){
return SSH_ERROR;
}
- if (channel->remote_eof && ssh_buffer_get_rest_len(stdbuf) == 0) {
+ if (channel->remote_eof && ssh_buffer_get_len(stdbuf) == 0) {
return 0;
}
- len = ssh_buffer_get_rest_len(stdbuf);
+ len = ssh_buffer_get_len(stdbuf);
/* Read count bytes if len is greater, everything otherwise */
len = (len > count ? count : len);
memcpy(dest, ssh_buffer_get(stdbuf), len);
@@ -2818,7 +2818,7 @@ int ssh_channel_poll(ssh_channel channel, int is_stderr){
stdbuf = channel->stderr_buffer;
}
- if (ssh_buffer_get_rest_len(stdbuf) == 0 && channel->remote_eof == 0) {
+ if (ssh_buffer_get_len(stdbuf) == 0 && channel->remote_eof == 0) {
if (channel->session->session_state == SSH_SESSION_STATE_ERROR){
return SSH_ERROR;
}
@@ -2827,15 +2827,15 @@ int ssh_channel_poll(ssh_channel channel, int is_stderr){
}
}
- if (ssh_buffer_get_rest_len(stdbuf) > 0){
- return ssh_buffer_get_rest_len(stdbuf);
+ if (ssh_buffer_get_len(stdbuf) > 0){
+ return ssh_buffer_get_len(stdbuf);
}
if (channel->remote_eof) {
return SSH_EOF;
}
- return ssh_buffer_get_rest_len(stdbuf);
+ return ssh_buffer_get_len(stdbuf);
}
/**
@@ -2882,7 +2882,7 @@ int ssh_channel_poll_timeout(ssh_channel channel, int timeout, int is_stderr){
rc = SSH_ERROR;
goto end;
}
- rc = ssh_buffer_get_rest_len(stdbuf);
+ rc = ssh_buffer_get_len(stdbuf);
if(rc > 0)
goto end;
if (channel->remote_eof)
@@ -2971,8 +2971,8 @@ static int channel_protocol_select(ssh_channel *rchans, ssh_channel *wchans,
ssh_handle_packets(chan->session, SSH_TIMEOUT_NONBLOCKING);
}
- if ((chan->stdout_buffer && ssh_buffer_get_rest_len(chan->stdout_buffer) > 0) ||
- (chan->stderr_buffer && ssh_buffer_get_rest_len(chan->stderr_buffer) > 0) ||
+ if ((chan->stdout_buffer && ssh_buffer_get_len(chan->stdout_buffer) > 0) ||
+ (chan->stderr_buffer && ssh_buffer_get_len(chan->stderr_buffer) > 0) ||
chan->remote_eof) {
rout[j] = chan;
j++;