ports/libssh
ports/libssh
1
1
Fork 0
Code Releases 1 Activity

sample: fix ssh_channel_read

Browse Source
This commit is contained in:
Aris Adamantiadis 2011-08-30 22:14:30 +03:00
parent cb2a111fa1
commit 7f5206b8ac
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
examples/sample.c
View File

@ -311,6 +311,7 @@ static void select_loop(ssh_session session,ssh_channel channel){
int lus;
int eof=0;
int maxfd;
unsigned int r;
int ret;
while(channel){
do{
@ -345,8 +346,8 @@ static void select_loop(ssh_session session,ssh_channel channel){
channels[0]=NULL;
}
if(outchannels[0]){
while(channel && ssh_channel_is_open(channel) && ssh_channel_poll(channel,0)!=0){
lus=ssh_channel_read(channel,buffer,sizeof(buffer),0);
while(channel && ssh_channel_is_open(channel) && (r = ssh_channel_poll(channel,0))!=0){
lus=ssh_channel_read(channel,buffer,sizeof(buffer) > r ? r : sizeof(buffer),0);
if(lus==-1){
fprintf(stderr, "Error reading channel: %s\n",
ssh_get_error(session));
@ -364,8 +365,8 @@ static void select_loop(ssh_session session,ssh_channel channel){
return;
}
}
while(channel && ssh_channel_is_open(channel) && ssh_channel_poll(channel,1)!=0){ /* stderr */
lus=ssh_channel_read(channel,buffer,sizeof(buffer),1);
while(channel && ssh_channel_is_open(channel) && (r = ssh_channel_poll(channel,1))!=0){ /* stderr */
lus=ssh_channel_read(channel,buffer,sizeof(buffer) > r ? r : sizeof(buffer),1);
if(lus==-1){
fprintf(stderr, "Error reading channel: %s\n",
ssh_get_error(session));