diff options
author | Aris Adamantiadis <aris@0xbadc0de.be> | 2008-11-05 16:45:37 +0000 |
---|---|---|
committer | Aris Adamantiadis <aris@0xbadc0de.be> | 2008-11-05 16:45:37 +0000 |
commit | 14c66c9bc504d837dc6a134bfd0628e5c98d210b (patch) | |
tree | 0c82c4cf083fb58fd802b0108a168ab0a2ea0219 /libssh | |
parent | 11e3d3ebab09112cd163268178bafeb5d6b48f87 (diff) | |
download | libssh-14c66c9bc504d837dc6a134bfd0628e5c98d210b.tar.gz libssh-14c66c9bc504d837dc6a134bfd0628e5c98d210b.tar.xz libssh-14c66c9bc504d837dc6a134bfd0628e5c98d210b.zip |
oops miscompilation
git-svn-id: svn+ssh://svn.berlios.de/svnroot/repos/libssh/trunk@189 7dcaeef0-15fb-0310-b436-a5af3365683c
Diffstat (limited to 'libssh')
-rw-r--r-- | libssh/sftp.c | 32 |
1 files changed, 19 insertions, 13 deletions
diff --git a/libssh/sftp.c b/libssh/sftp.c index 7318255a..d69bb927 100644 --- a/libssh/sftp.c +++ b/libssh/sftp.c @@ -1056,7 +1056,7 @@ u32 sftp_async_read_begin(SFTP_FILE *file, int len){ SFTP_SESSION *sftp=file->sftp; BUFFER *buffer; u32 id; - sftp_function_start(); + sftp_enter_function(); buffer=buffer_new(); id=sftp_get_new_id(sftp); buffer_add_u32(buffer,id); @@ -1066,7 +1066,7 @@ u32 sftp_async_read_begin(SFTP_FILE *file, int len){ sftp_packet_write(sftp,SSH_FXP_READ,buffer); buffer_free(buffer); file->offset += len; // assume we'll read len bytes - sftp_function_end(); + sftp_leave_function(); return id; } @@ -1091,9 +1091,9 @@ int sftp_async_read(SFTP_FILE *file, void *data, int size, u32 id){ STRING *datastring; int err=0; int len; - sftp_function_start(); + sftp_enter_function(); if(file->eof){ - sftp_function_end(); + sftp_leave_function(); return 0; } @@ -1105,38 +1105,43 @@ int sftp_async_read(SFTP_FILE *file, void *data, int size, u32 id){ return SSH_AGAIN; } } - if(sftp_read_and_dispatch(sftp)) - /* something nasty has happened */ - return -1; + if(sftp_read_and_dispatch(sftp)){ + /* something nasty has happened */ + sftp_leave_function(); + return SSH_ERROR; + } msg=sftp_dequeue(sftp,id); } switch (msg->packet_type){ case SSH_FXP_STATUS: status=parse_status_msg(msg); sftp_message_free(msg); - if(!status) + if(!status){ + sftp_leave_function(); return -1; + } if(status->status != SSH_FX_EOF){ ssh_set_error(sftp->session,SSH_REQUEST_DENIED,"sftp server : %s",status->errormsg); + sftp_leave_function(); err=-1; } else file->eof=1; status_msg_free(status); - sftp_function_end(); + sftp_leave_function(); return err?err:0; case SSH_FXP_DATA: datastring=buffer_get_ssh_string(msg->payload); sftp_message_free(msg); if(!datastring){ ssh_set_error(sftp->session,SSH_FATAL,"Received invalid DATA packet from sftp server"); - sftp_function_end(); + sftp_leave_function(); return -1; } if(string_len(datastring)>size){ ssh_set_error(sftp->session,SSH_FATAL,"Received a too big DATA packet from sftp server : %d and asked for %d", string_len(datastring),size); free(datastring); - sftp_function_end(); + sftp_leave_function(); return SSH_ERROR; } len=string_len(datastring); @@ -1145,14 +1150,15 @@ int sftp_async_read(SFTP_FILE *file, void *data, int size, u32 id){ * and effective lengths are different */ memcpy(data,datastring->string,len); free(datastring); - sftp_function_end(); + sftp_leave_function(); return len; default: ssh_set_error(sftp->session,SSH_FATAL,"Received message %d during read!",msg->packet_type); sftp_message_free(msg); - sftp_function_end(); + sftp_leave_function(); return SSH_ERROR; } + sftp_leave_function(); } int sftp_write(SFTP_FILE *file, void *data, int len){ |