~mdw
/
sgt
/
putty
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
xfer_{up,down}load_gotpkt free their input sftp_packet as a side
[sgt/putty]
/
psftp.c
diff --git
a/psftp.c
b/psftp.c
index
65d0dc5
..
5bc7d7c
100644
(file)
--- a/
psftp.c
+++ b/
psftp.c
@@
-291,6
+291,11
@@
int sftp_get_file(char *fname, char *outfname, int recurse, int restart)
if (fxp_error_type() == SSH_FX_EOF)
break;
printf("%s: reading directory: %s\n", fname, fxp_error());
if (fxp_error_type() == SSH_FX_EOF)
break;
printf("%s: reading directory: %s\n", fname, fxp_error());
+
+ req = fxp_close_send(dirhandle);
+ pktin = sftp_wait_for_reply(req);
+ fxp_close_recv(pktin, req);
+
sfree(ournames);
return 0;
}
sfree(ournames);
return 0;
}
@@
-463,6
+468,8
@@
int sftp_get_file(char *fname, char *outfname, int recurse, int restart)
printf("error while reading: %s\n", fxp_error());
shown_err = TRUE;
}
printf("error while reading: %s\n", fxp_error());
shown_err = TRUE;
}
+ if (ret == INT_MIN) /* pktin not even freed */
+ sfree(pktin);
ret = 0;
}
ret = 0;
}
@@
-715,9
+722,13
@@
int sftp_put_file(char *fname, char *outfname, int recurse, int restart)
if (!xfer_done(xfer)) {
pktin = sftp_recv();
ret = xfer_upload_gotpkt(xfer, pktin);
if (!xfer_done(xfer)) {
pktin = sftp_recv();
ret = xfer_upload_gotpkt(xfer, pktin);
- if (ret <= 0 && !err) {
- printf("error while writing: %s\n", fxp_error());
- err = 1;
+ if (ret <= 0) {
+ if (ret == INT_MIN) /* pktin not even freed */
+ sfree(pktin);
+ if (!err) {
+ printf("error while writing: %s\n", fxp_error());
+ err = 1;
+ }
}
}
}
}
}
}