Line | Source | Count |
1 | | - |
2 | | - |
3 | | - |
4 | | - |
5 | | - |
6 | | - |
7 | | - |
8 | | - |
9 | | - |
10 | | - |
11 | | - |
12 | | - |
13 | | - |
14 | | - |
15 | | - |
16 | | - |
17 | | - |
18 | | - |
19 | | - |
20 | | - |
21 | | - |
22 | | - |
23 | #include "includes.h" | - |
24 | | - |
25 | #include <sys/types.h> | - |
26 | #ifdef HAVE_SYS_STATVFS_H | - |
27 | #include <sys/statvfs.h> | - |
28 | #endif | - |
29 | #include "openbsd-compat/sys-queue.h" | - |
30 | #ifdef HAVE_SYS_STAT_H | - |
31 | # include <sys/stat.h> | - |
32 | #endif | - |
33 | #ifdef HAVE_SYS_TIME_H | - |
34 | # include <sys/time.h> | - |
35 | #endif | - |
36 | #include <sys/uio.h> | - |
37 | | - |
38 | #include <dirent.h> | - |
39 | #include <errno.h> | - |
40 | #include <fcntl.h> | - |
41 | #include <signal.h> | - |
42 | #include <stdarg.h> | - |
43 | #include <stdio.h> | - |
44 | #include <stdlib.h> | - |
45 | #include <string.h> | - |
46 | #include <unistd.h> | - |
47 | | - |
48 | #include "xmalloc.h" | - |
49 | #include "ssherr.h" | - |
50 | #include "sshbuf.h" | - |
51 | #include "log.h" | - |
52 | #include "atomicio.h" | - |
53 | #include "progressmeter.h" | - |
54 | #include "misc.h" | - |
55 | #include "utf8.h" | - |
56 | | - |
57 | #include "sftp.h" | - |
58 | #include "sftp-common.h" | - |
59 | #include "sftp-client.h" | - |
60 | | - |
61 | extern volatile sig_atomic_t interrupted; | - |
62 | extern int showprogress; | - |
63 | | - |
64 | | - |
65 | #define MIN_READ_SIZE 512 | - |
66 | | - |
67 | | - |
68 | #define MAX_DIR_DEPTH 64 | - |
69 | | - |
70 | | - |
71 | #ifdef HAVE_CYGWIN | - |
72 | # define SFTP_DIRECTORY_CHARS "/\\" | - |
73 | #else /* HAVE_CYGWIN */ | - |
74 | # define SFTP_DIRECTORY_CHARS "/" | - |
75 | #endif /* HAVE_CYGWIN */ | - |
76 | | - |
77 | struct sftp_conn { | - |
78 | int fd_in; | - |
79 | int fd_out; | - |
80 | u_int transfer_buflen; | - |
81 | u_int num_requests; | - |
82 | u_int version; | - |
83 | u_int msg_id; | - |
84 | #define SFTP_EXT_POSIX_RENAME 0x00000001 | - |
85 | #define SFTP_EXT_STATVFS 0x00000002 | - |
86 | #define SFTP_EXT_FSTATVFS 0x00000004 | - |
87 | #define SFTP_EXT_HARDLINK 0x00000008 | - |
88 | #define SFTP_EXT_FSYNC 0x00000010 | - |
89 | u_int exts; | - |
90 | u_int64_t limit_kbps; | - |
91 | struct bwlimit bwlimit_in, bwlimit_out; | - |
92 | }; | - |
93 | | - |
94 | static u_char * | - |
95 | get_handle(struct sftp_conn *conn, u_int expected_id, size_t *len, | - |
96 | const char *errfmt, ...) __attribute__((format(printf, 4, 5))); | - |
97 | | - |
98 | | - |
99 | static int | - |
100 | sftpio(void *_bwlimit, size_t amount) | - |
101 | { | - |
102 | struct bwlimit *bwlimit = (struct bwlimit *)_bwlimit; | - |
103 | | - |
104 | bandwidth_limit(bwlimit, amount); | - |
105 | return 0; never executed: return 0; | 0 |
106 | } | - |
107 | | - |
108 | static void | - |
109 | send_msg(struct sftp_conn *conn, struct sshbuf *m) | - |
110 | { | - |
111 | u_char mlen[4]; | - |
112 | struct iovec iov[2]; | - |
113 | | - |
114 | if (sshbuf_len(m) > SFTP_MAX_MSG_LENGTH)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
115 | fatal("Outbound message too long %zu", sshbuf_len(m)); never executed: fatal("Outbound message too long %zu", sshbuf_len(m)); | 0 |
116 | | - |
117 | | - |
118 | put_u32(mlen, sshbuf_len(m)); | - |
119 | iov[0].iov_base = mlen; | - |
120 | iov[0].iov_len = sizeof(mlen); | - |
121 | iov[1].iov_base = (u_char *)sshbuf_ptr(m); | - |
122 | iov[1].iov_len = sshbuf_len(m); | - |
123 | | - |
124 | if (atomiciov6(writev, conn->fd_out, iov, 2,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
125 | conn->limit_kbps > 0 ? sftpio : NULL, &conn->bwlimit_out) !=TRUE | never evaluated | FALSE | never evaluated |
| 0 |
126 | sshbuf_len(m) + sizeof(mlen))TRUE | never evaluated | FALSE | never evaluated |
| 0 |
127 | fatal("Couldn't send packet: %s", strerror(errno)); never executed: fatal("Couldn't send packet: %s", strerror( (*__errno_location ()) )); | 0 |
128 | | - |
129 | sshbuf_reset(m); | - |
130 | } never executed: end of block | 0 |
131 | | - |
132 | static void | - |
133 | get_msg_extended(struct sftp_conn *conn, struct sshbuf *m, int initial) | - |
134 | { | - |
135 | u_int msg_len; | - |
136 | u_char *p; | - |
137 | int r; | - |
138 | | - |
139 | if ((r = sshbuf_reserve(m, 4, &p)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
140 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
141 | if (atomicio6(read, conn->fd_in, p, 4,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
142 | conn->limit_kbps > 0 ? sftpio : NULL, &conn->bwlimit_in) != 4) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
143 | if (errno == EPIPE || errno == ECONNRESET)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
144 | fatal("Connection closed"); never executed: fatal("Connection closed"); | 0 |
145 | else | - |
146 | fatal("Couldn't read packet: %s", strerror(errno)); never executed: fatal("Couldn't read packet: %s", strerror( (*__errno_location ()) )); | 0 |
147 | } | - |
148 | | - |
149 | if ((r = sshbuf_get_u32(m, &msg_len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
150 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
151 | if (msg_len > SFTP_MAX_MSG_LENGTH) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
152 | do_log2(initial ? SYSLOG_LEVEL_ERROR : SYSLOG_LEVEL_FATAL, | - |
153 | "Received message too long %u", msg_len); | - |
154 | fatal("Ensure the remote shell produces no output " | - |
155 | "for non-interactive sessions."); | - |
156 | } never executed: end of block | 0 |
157 | | - |
158 | if ((r = sshbuf_reserve(m, msg_len, &p)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
159 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
160 | if (atomicio6(read, conn->fd_in, p, msg_len,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
161 | conn->limit_kbps > 0 ? sftpio : NULL, &conn->bwlimit_in)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
162 | != msg_len) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
163 | if (errno == EPIPE)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
164 | fatal("Connection closed"); never executed: fatal("Connection closed"); | 0 |
165 | else | - |
166 | fatal("Read packet: %s", strerror(errno)); never executed: fatal("Read packet: %s", strerror( (*__errno_location ()) )); | 0 |
167 | } | - |
168 | } never executed: end of block | 0 |
169 | | - |
170 | static void | - |
171 | get_msg(struct sftp_conn *conn, struct sshbuf *m) | - |
172 | { | - |
173 | get_msg_extended(conn, m, 0); | - |
174 | } never executed: end of block | 0 |
175 | | - |
176 | static void | - |
177 | send_string_request(struct sftp_conn *conn, u_int id, u_int code, const char *s, | - |
178 | u_int len) | - |
179 | { | - |
180 | struct sshbuf *msg; | - |
181 | int r; | - |
182 | | - |
183 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
184 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
185 | if ((r = sshbuf_put_u8(msg, code)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
186 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
187 | (r = sshbuf_put_string(msg, s, len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
188 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
189 | send_msg(conn, msg); | - |
190 | debug3("Sent message fd %d T:%u I:%u", conn->fd_out, code, id); | - |
191 | sshbuf_free(msg); | - |
192 | } never executed: end of block | 0 |
193 | | - |
194 | static void | - |
195 | send_string_attrs_request(struct sftp_conn *conn, u_int id, u_int code, | - |
196 | const void *s, u_int len, Attrib *a) | - |
197 | { | - |
198 | struct sshbuf *msg; | - |
199 | int r; | - |
200 | | - |
201 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
202 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
203 | if ((r = sshbuf_put_u8(msg, code)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
204 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
205 | (r = sshbuf_put_string(msg, s, len)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
206 | (r = encode_attrib(msg, a)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
207 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
208 | send_msg(conn, msg); | - |
209 | debug3("Sent message fd %d T:%u I:%u", conn->fd_out, code, id); | - |
210 | sshbuf_free(msg); | - |
211 | } never executed: end of block | 0 |
212 | | - |
213 | static u_int | - |
214 | get_status(struct sftp_conn *conn, u_int expected_id) | - |
215 | { | - |
216 | struct sshbuf *msg; | - |
217 | u_char type; | - |
218 | u_int id, status; | - |
219 | int r; | - |
220 | | - |
221 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
222 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
223 | get_msg(conn, msg); | - |
224 | if ((r = sshbuf_get_u8(msg, &type)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
225 | (r = sshbuf_get_u32(msg, &id)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
226 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
227 | | - |
228 | if (id != expected_id)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
229 | fatal("ID mismatch (%u != %u)", id, expected_id); never executed: fatal("ID mismatch (%u != %u)", id, expected_id); | 0 |
230 | if (type != SSH2_FXP_STATUS)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
231 | fatal("Expected SSH2_FXP_STATUS(%u) packet, got %u", never executed: fatal("Expected SSH2_FXP_STATUS(%u) packet, got %u", 101, type); | 0 |
232 | SSH2_FXP_STATUS, type); never executed: fatal("Expected SSH2_FXP_STATUS(%u) packet, got %u", 101, type); | 0 |
233 | | - |
234 | if ((r = sshbuf_get_u32(msg, &status)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
235 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
236 | sshbuf_free(msg); | - |
237 | | - |
238 | debug3("SSH2_FXP_STATUS %u", status); | - |
239 | | - |
240 | return status; never executed: return status; | 0 |
241 | } | - |
242 | | - |
243 | static u_char * | - |
244 | get_handle(struct sftp_conn *conn, u_int expected_id, size_t *len, | - |
245 | const char *errfmt, ...) | - |
246 | { | - |
247 | struct sshbuf *msg; | - |
248 | u_int id, status; | - |
249 | u_char type; | - |
250 | u_char *handle; | - |
251 | char errmsg[256]; | - |
252 | va_list args; | - |
253 | int r; | - |
254 | | - |
255 | va_start(args, errfmt); | - |
256 | if (errfmt != NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
257 | vsnprintf(errmsg, sizeof(errmsg), errfmt, args); never executed: vsnprintf(errmsg, sizeof(errmsg), errfmt, args); | 0 |
258 | va_end(args); | - |
259 | | - |
260 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
261 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
262 | get_msg(conn, msg); | - |
263 | if ((r = sshbuf_get_u8(msg, &type)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
264 | (r = sshbuf_get_u32(msg, &id)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
265 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
266 | | - |
267 | if (id != expected_id)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
268 | fatal("%s: ID mismatch (%u != %u)", never executed: fatal("%s: ID mismatch (%u != %u)", errfmt == ((void *)0) ? __func__ : errmsg, id, expected_id); | 0 |
269 | errfmt == NULL ? __func__ : errmsg, id, expected_id); never executed: fatal("%s: ID mismatch (%u != %u)", errfmt == ((void *)0) ? __func__ : errmsg, id, expected_id); | 0 |
270 | if (type == SSH2_FXP_STATUS) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
271 | if ((r = sshbuf_get_u32(msg, &status)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
272 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
273 | if (errfmt != NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
274 | error("%s: %s", errmsg, fx2txt(status)); never executed: error("%s: %s", errmsg, fx2txt(status)); | 0 |
275 | sshbuf_free(msg); | - |
276 | return(NULL); never executed: return( ((void *)0) ); | 0 |
277 | } else if (type != SSH2_FXP_HANDLE)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
278 | fatal("%s: Expected SSH2_FXP_HANDLE(%u) packet, got %u", never executed: fatal("%s: Expected SSH2_FXP_HANDLE(%u) packet, got %u", errfmt == ((void *)0) ? __func__ : errmsg, 102, type); | 0 |
279 | errfmt == NULL ? __func__ : errmsg, SSH2_FXP_HANDLE, type); never executed: fatal("%s: Expected SSH2_FXP_HANDLE(%u) packet, got %u", errfmt == ((void *)0) ? __func__ : errmsg, 102, type); | 0 |
280 | | - |
281 | if ((r = sshbuf_get_string(msg, &handle, len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
282 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
283 | sshbuf_free(msg); | - |
284 | | - |
285 | return handle; never executed: return handle; | 0 |
286 | } | - |
287 | | - |
288 | static Attrib * | - |
289 | get_decode_stat(struct sftp_conn *conn, u_int expected_id, int quiet) | - |
290 | { | - |
291 | struct sshbuf *msg; | - |
292 | u_int id; | - |
293 | u_char type; | - |
294 | int r; | - |
295 | static Attrib a; | - |
296 | | - |
297 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
298 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
299 | get_msg(conn, msg); | - |
300 | | - |
301 | if ((r = sshbuf_get_u8(msg, &type)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
302 | (r = sshbuf_get_u32(msg, &id)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
303 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
304 | | - |
305 | debug3("Received stat reply T:%u I:%u", type, id); | - |
306 | if (id != expected_id)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
307 | fatal("ID mismatch (%u != %u)", id, expected_id); never executed: fatal("ID mismatch (%u != %u)", id, expected_id); | 0 |
308 | if (type == SSH2_FXP_STATUS) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
309 | u_int status; | - |
310 | | - |
311 | if ((r = sshbuf_get_u32(msg, &status)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
312 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
313 | if (quiet)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
314 | debug("Couldn't stat remote file: %s", fx2txt(status)); never executed: debug("Couldn't stat remote file: %s", fx2txt(status)); | 0 |
315 | else | - |
316 | error("Couldn't stat remote file: %s", fx2txt(status)); never executed: error("Couldn't stat remote file: %s", fx2txt(status)); | 0 |
317 | sshbuf_free(msg); | - |
318 | return(NULL); never executed: return( ((void *)0) ); | 0 |
319 | } else if (type != SSH2_FXP_ATTRS) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
320 | fatal("Expected SSH2_FXP_ATTRS(%u) packet, got %u", | - |
321 | SSH2_FXP_ATTRS, type); | - |
322 | } never executed: end of block | 0 |
323 | if ((r = decode_attrib(msg, &a)) != 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
324 | error("%s: couldn't decode attrib: %s", __func__, ssh_err(r)); | - |
325 | sshbuf_free(msg); | - |
326 | return NULL; never executed: return ((void *)0) ; | 0 |
327 | } | - |
328 | sshbuf_free(msg); | - |
329 | | - |
330 | return &a; never executed: return &a; | 0 |
331 | } | - |
332 | | - |
333 | static int | - |
334 | get_decode_statvfs(struct sftp_conn *conn, struct sftp_statvfs *st, | - |
335 | u_int expected_id, int quiet) | - |
336 | { | - |
337 | struct sshbuf *msg; | - |
338 | u_char type; | - |
339 | u_int id; | - |
340 | u_int64_t flag; | - |
341 | int r; | - |
342 | | - |
343 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
344 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
345 | get_msg(conn, msg); | - |
346 | | - |
347 | if ((r = sshbuf_get_u8(msg, &type)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
348 | (r = sshbuf_get_u32(msg, &id)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
349 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
350 | | - |
351 | debug3("Received statvfs reply T:%u I:%u", type, id); | - |
352 | if (id != expected_id)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
353 | fatal("ID mismatch (%u != %u)", id, expected_id); never executed: fatal("ID mismatch (%u != %u)", id, expected_id); | 0 |
354 | if (type == SSH2_FXP_STATUS) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
355 | u_int status; | - |
356 | | - |
357 | if ((r = sshbuf_get_u32(msg, &status)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
358 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
359 | if (quiet)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
360 | debug("Couldn't statvfs: %s", fx2txt(status)); never executed: debug("Couldn't statvfs: %s", fx2txt(status)); | 0 |
361 | else | - |
362 | error("Couldn't statvfs: %s", fx2txt(status)); never executed: error("Couldn't statvfs: %s", fx2txt(status)); | 0 |
363 | sshbuf_free(msg); | - |
364 | return -1; never executed: return -1; | 0 |
365 | } else if (type != SSH2_FXP_EXTENDED_REPLY) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
366 | fatal("Expected SSH2_FXP_EXTENDED_REPLY(%u) packet, got %u", | - |
367 | SSH2_FXP_EXTENDED_REPLY, type); | - |
368 | } never executed: end of block | 0 |
369 | | - |
370 | memset(st, 0, sizeof(*st)); | - |
371 | if ((r = sshbuf_get_u64(msg, &st->f_bsize)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
372 | (r = sshbuf_get_u64(msg, &st->f_frsize)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
373 | (r = sshbuf_get_u64(msg, &st->f_blocks)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
374 | (r = sshbuf_get_u64(msg, &st->f_bfree)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
375 | (r = sshbuf_get_u64(msg, &st->f_bavail)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
376 | (r = sshbuf_get_u64(msg, &st->f_files)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
377 | (r = sshbuf_get_u64(msg, &st->f_ffree)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
378 | (r = sshbuf_get_u64(msg, &st->f_favail)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
379 | (r = sshbuf_get_u64(msg, &st->f_fsid)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
380 | (r = sshbuf_get_u64(msg, &flag)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
381 | (r = sshbuf_get_u64(msg, &st->f_namemax)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
382 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
383 | | - |
384 | st->f_flag = (flag & SSH2_FXE_STATVFS_ST_RDONLY) ? ST_RDONLY : 0;TRUE | never evaluated | FALSE | never evaluated |
| 0 |
385 | st->f_flag |= (flag & SSH2_FXE_STATVFS_ST_NOSUID) ? ST_NOSUID : 0;TRUE | never evaluated | FALSE | never evaluated |
| 0 |
386 | | - |
387 | sshbuf_free(msg); | - |
388 | | - |
389 | return 0; never executed: return 0; | 0 |
390 | } | - |
391 | | - |
392 | struct sftp_conn * | - |
393 | do_init(int fd_in, int fd_out, u_int transfer_buflen, u_int num_requests, | - |
394 | u_int64_t limit_kbps) | - |
395 | { | - |
396 | u_char type; | - |
397 | struct sshbuf *msg; | - |
398 | struct sftp_conn *ret; | - |
399 | int r; | - |
400 | | - |
401 | ret = xcalloc(1, sizeof(*ret)); | - |
402 | ret->msg_id = 1; | - |
403 | ret->fd_in = fd_in; | - |
404 | ret->fd_out = fd_out; | - |
405 | ret->transfer_buflen = transfer_buflen; | - |
406 | ret->num_requests = num_requests; | - |
407 | ret->exts = 0; | - |
408 | ret->limit_kbps = 0; | - |
409 | | - |
410 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
411 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
412 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_INIT)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
413 | (r = sshbuf_put_u32(msg, SSH2_FILEXFER_VERSION)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
414 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
415 | send_msg(ret, msg); | - |
416 | | - |
417 | sshbuf_reset(msg); | - |
418 | | - |
419 | get_msg_extended(ret, msg, 1); | - |
420 | | - |
421 | | - |
422 | if ((r = sshbuf_get_u8(msg, &type)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
423 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
424 | if (type != SSH2_FXP_VERSION) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
425 | error("Invalid packet back from SSH2_FXP_INIT (type %u)", | - |
426 | type); | - |
427 | sshbuf_free(msg); | - |
428 | free(ret); | - |
429 | return(NULL); never executed: return( ((void *)0) ); | 0 |
430 | } | - |
431 | if ((r = sshbuf_get_u32(msg, &ret->version)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
432 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
433 | | - |
434 | debug2("Remote version: %u", ret->version); | - |
435 | | - |
436 | | - |
437 | while (sshbuf_len(msg) > 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
438 | char *name; | - |
439 | u_char *value; | - |
440 | size_t vlen; | - |
441 | int known = 0; | - |
442 | | - |
443 | if ((r = sshbuf_get_cstring(msg, &name, NULL)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
444 | (r = sshbuf_get_string(msg, &value, &vlen)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
445 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
446 | if (strcmp(name, "posix-rename@openssh.com") == 0 && never executed: __result = (((const unsigned char *) (const char *) ( name ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "posix-rename@openssh.com" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
447 | strcmp((char *)value, "1") == 0) { never executed: __result = (((const unsigned char *) (const char *) ( (char *)value ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "1" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
448 | ret->exts |= SFTP_EXT_POSIX_RENAME; | - |
449 | known = 1; | - |
450 | } else if (strcmp(name, "statvfs@openssh.com") == 0 && never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( name ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "statvfs@openssh.com" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
451 | strcmp((char *)value, "2") == 0) { never executed: __result = (((const unsigned char *) (const char *) ( (char *)value ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "2" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
452 | ret->exts |= SFTP_EXT_STATVFS; | - |
453 | known = 1; | - |
454 | } else if (strcmp(name, "fstatvfs@openssh.com") == 0 && never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( name ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "fstatvfs@openssh.com" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
455 | strcmp((char *)value, "2") == 0) { never executed: __result = (((const unsigned char *) (const char *) ( (char *)value ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "2" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
456 | ret->exts |= SFTP_EXT_FSTATVFS; | - |
457 | known = 1; | - |
458 | } else if (strcmp(name, "hardlink@openssh.com") == 0 && never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( name ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "hardlink@openssh.com" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
459 | strcmp((char *)value, "1") == 0) { never executed: __result = (((const unsigned char *) (const char *) ( (char *)value ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "1" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
460 | ret->exts |= SFTP_EXT_HARDLINK; | - |
461 | known = 1; | - |
462 | } else if (strcmp(name, "fsync@openssh.com") == 0 && never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( name ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "fsync@openssh.com" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
463 | strcmp((char *)value, "1") == 0) { never executed: __result = (((const unsigned char *) (const char *) ( (char *)value ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "1" ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
464 | ret->exts |= SFTP_EXT_FSYNC; | - |
465 | known = 1; | - |
466 | } never executed: end of block | 0 |
467 | if (known) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
468 | debug2("Server supports extension \"%s\" revision %s", | - |
469 | name, value); | - |
470 | } else { never executed: end of block | 0 |
471 | debug2("Unrecognised server extension \"%s\"", name); | - |
472 | } never executed: end of block | 0 |
473 | free(name); | - |
474 | free(value); | - |
475 | } never executed: end of block | 0 |
476 | | - |
477 | sshbuf_free(msg); | - |
478 | | - |
479 | | - |
480 | if (ret->version == 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
481 | ret->transfer_buflen = MINIMUM(ret->transfer_buflen, 20480); never executed: ret->transfer_buflen = (((ret->transfer_buflen) < (20480)) ? (ret->transfer_buflen) : (20480)); TRUE | never evaluated | FALSE | never evaluated |
| 0 |
482 | | - |
483 | ret->limit_kbps = limit_kbps; | - |
484 | if (ret->limit_kbps > 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
485 | bandwidth_limit_init(&ret->bwlimit_in, ret->limit_kbps, | - |
486 | ret->transfer_buflen); | - |
487 | bandwidth_limit_init(&ret->bwlimit_out, ret->limit_kbps, | - |
488 | ret->transfer_buflen); | - |
489 | } never executed: end of block | 0 |
490 | | - |
491 | return ret; never executed: return ret; | 0 |
492 | } | - |
493 | | - |
494 | u_int | - |
495 | sftp_proto_version(struct sftp_conn *conn) | - |
496 | { | - |
497 | return conn->version; never executed: return conn->version; | 0 |
498 | } | - |
499 | | - |
500 | int | - |
501 | do_close(struct sftp_conn *conn, const u_char *handle, u_int handle_len) | - |
502 | { | - |
503 | u_int id, status; | - |
504 | struct sshbuf *msg; | - |
505 | int r; | - |
506 | | - |
507 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
508 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
509 | | - |
510 | id = conn->msg_id++; | - |
511 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_CLOSE)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
512 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
513 | (r = sshbuf_put_string(msg, handle, handle_len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
514 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
515 | send_msg(conn, msg); | - |
516 | debug3("Sent message SSH2_FXP_CLOSE I:%u", id); | - |
517 | | - |
518 | status = get_status(conn, id); | - |
519 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
520 | error("Couldn't close file: %s", fx2txt(status)); never executed: error("Couldn't close file: %s", fx2txt(status)); | 0 |
521 | | - |
522 | sshbuf_free(msg); | - |
523 | | - |
524 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
525 | } | - |
526 | | - |
527 | | - |
528 | static int | - |
529 | do_lsreaddir(struct sftp_conn *conn, const char *path, int print_flag, | - |
530 | SFTP_DIRENT ***dir) | - |
531 | { | - |
532 | struct sshbuf *msg; | - |
533 | u_int count, id, i, expected_id, ents = 0; | - |
534 | size_t handle_len; | - |
535 | u_char type, *handle; | - |
536 | int status = SSH2_FX_FAILURE; | - |
537 | int r; | - |
538 | | - |
539 | if (dir)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
540 | *dir = NULL; never executed: *dir = ((void *)0) ; | 0 |
541 | | - |
542 | id = conn->msg_id++; | - |
543 | | - |
544 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
545 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
546 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_OPENDIR)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
547 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
548 | (r = sshbuf_put_cstring(msg, path)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
549 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
550 | send_msg(conn, msg); | - |
551 | | - |
552 | handle = get_handle(conn, id, &handle_len, | - |
553 | "remote readdir(\"%s\")", path); | - |
554 | if (handle == NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
555 | sshbuf_free(msg); | - |
556 | return -1; never executed: return -1; | 0 |
557 | } | - |
558 | | - |
559 | if (dir) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
560 | ents = 0; | - |
561 | *dir = xcalloc(1, sizeof(**dir)); | - |
562 | (*dir)[0] = NULL; | - |
563 | } never executed: end of block | 0 |
564 | | - |
565 | for (; !interrupted;) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
566 | id = expected_id = conn->msg_id++; | - |
567 | | - |
568 | debug3("Sending SSH2_FXP_READDIR I:%u", id); | - |
569 | | - |
570 | sshbuf_reset(msg); | - |
571 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_READDIR)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
572 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
573 | (r = sshbuf_put_string(msg, handle, handle_len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
574 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
575 | send_msg(conn, msg); | - |
576 | | - |
577 | sshbuf_reset(msg); | - |
578 | | - |
579 | get_msg(conn, msg); | - |
580 | | - |
581 | if ((r = sshbuf_get_u8(msg, &type)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
582 | (r = sshbuf_get_u32(msg, &id)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
583 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
584 | | - |
585 | debug3("Received reply T:%u I:%u", type, id); | - |
586 | | - |
587 | if (id != expected_id)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
588 | fatal("ID mismatch (%u != %u)", id, expected_id); never executed: fatal("ID mismatch (%u != %u)", id, expected_id); | 0 |
589 | | - |
590 | if (type == SSH2_FXP_STATUS) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
591 | u_int rstatus; | - |
592 | | - |
593 | if ((r = sshbuf_get_u32(msg, &rstatus)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
594 | fatal("%s: buffer error: %s", never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
595 | __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
596 | debug3("Received SSH2_FXP_STATUS %d", rstatus); | - |
597 | if (rstatus == SSH2_FX_EOF)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
598 | break; never executed: break; | 0 |
599 | error("Couldn't read directory: %s", fx2txt(rstatus)); | - |
600 | goto out; never executed: goto out; | 0 |
601 | } else if (type != SSH2_FXP_NAME)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
602 | fatal("Expected SSH2_FXP_NAME(%u) packet, got %u", never executed: fatal("Expected SSH2_FXP_NAME(%u) packet, got %u", 104, type); | 0 |
603 | SSH2_FXP_NAME, type); never executed: fatal("Expected SSH2_FXP_NAME(%u) packet, got %u", 104, type); | 0 |
604 | | - |
605 | if ((r = sshbuf_get_u32(msg, &count)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
606 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
607 | if (count > SSHBUF_SIZE_MAX)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
608 | fatal("%s: nonsensical number of entries", __func__); never executed: fatal("%s: nonsensical number of entries", __func__); | 0 |
609 | if (count == 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
610 | break; never executed: break; | 0 |
611 | debug3("Received %d SSH2_FXP_NAME responses", count); | - |
612 | for (i = 0; i < count; i++) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
613 | char *filename, *longname; | - |
614 | Attrib a; | - |
615 | | - |
616 | if ((r = sshbuf_get_cstring(msg, &filename,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
617 | NULL)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
618 | (r = sshbuf_get_cstring(msg, &longname,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
619 | NULL)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
620 | fatal("%s: buffer error: %s", never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
621 | __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
622 | if ((r = decode_attrib(msg, &a)) != 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
623 | error("%s: couldn't decode attrib: %s", | - |
624 | __func__, ssh_err(r)); | - |
625 | free(filename); | - |
626 | free(longname); | - |
627 | sshbuf_free(msg); | - |
628 | return -1; never executed: return -1; | 0 |
629 | } | - |
630 | | - |
631 | if (print_flag)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
632 | mprintf("%s\n", longname); never executed: mprintf("%s\n", longname); | 0 |
633 | | - |
634 | | - |
635 | | - |
636 | | - |
637 | | - |
638 | | - |
639 | if (strpbrk(filename, SFTP_DIRECTORY_CHARS) != NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
640 | error("Server sent suspect path \"%s\" " | - |
641 | "during readdir of \"%s\"", filename, path); | - |
642 | } else if (dir) { never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
| 0 |
643 | *dir = xreallocarray(*dir, ents + 2, sizeof(**dir)); | - |
644 | (*dir)[ents] = xcalloc(1, sizeof(***dir)); | - |
645 | (*dir)[ents]->filename = xstrdup(filename); | - |
646 | (*dir)[ents]->longname = xstrdup(longname); | - |
647 | memcpy(&(*dir)[ents]->a, &a, sizeof(a)); | - |
648 | (*dir)[++ents] = NULL; | - |
649 | } never executed: end of block | 0 |
650 | free(filename); | - |
651 | free(longname); | - |
652 | } never executed: end of block | 0 |
653 | } never executed: end of block | 0 |
654 | status = 0; | - |
655 | | - |
656 | out: code before this statement never executed: out: | 0 |
657 | sshbuf_free(msg); | - |
658 | do_close(conn, handle, handle_len); | - |
659 | free(handle); | - |
660 | | - |
661 | if (status != 0 && dir != NULL) {TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
662 | | - |
663 | free_sftp_dirents(*dir); | - |
664 | *dir = NULL; | - |
665 | } else if (interrupted && dir != NULL && *dir != NULL) { never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
666 | | - |
667 | free_sftp_dirents(*dir); | - |
668 | *dir = xcalloc(1, sizeof(**dir)); | - |
669 | **dir = NULL; | - |
670 | } never executed: end of block | 0 |
671 | | - |
672 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
673 | } | - |
674 | | - |
675 | int | - |
676 | do_readdir(struct sftp_conn *conn, const char *path, SFTP_DIRENT ***dir) | - |
677 | { | - |
678 | return(do_lsreaddir(conn, path, 0, dir)); never executed: return(do_lsreaddir(conn, path, 0, dir)); | 0 |
679 | } | - |
680 | | - |
681 | void free_sftp_dirents(SFTP_DIRENT **s) | - |
682 | { | - |
683 | int i; | - |
684 | | - |
685 | if (s == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
686 | return; never executed: return; | 0 |
687 | for (i = 0; s[i]; i++) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
688 | free(s[i]->filename); | - |
689 | free(s[i]->longname); | - |
690 | free(s[i]); | - |
691 | } never executed: end of block | 0 |
692 | free(s); | - |
693 | } never executed: end of block | 0 |
694 | | - |
695 | int | - |
696 | do_rm(struct sftp_conn *conn, const char *path) | - |
697 | { | - |
698 | u_int status, id; | - |
699 | | - |
700 | debug2("Sending SSH2_FXP_REMOVE \"%s\"", path); | - |
701 | | - |
702 | id = conn->msg_id++; | - |
703 | send_string_request(conn, id, SSH2_FXP_REMOVE, path, strlen(path)); | - |
704 | status = get_status(conn, id); | - |
705 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
706 | error("Couldn't delete file: %s", fx2txt(status)); never executed: error("Couldn't delete file: %s", fx2txt(status)); | 0 |
707 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
708 | } | - |
709 | | - |
710 | int | - |
711 | do_mkdir(struct sftp_conn *conn, const char *path, Attrib *a, int print_flag) | - |
712 | { | - |
713 | u_int status, id; | - |
714 | | - |
715 | id = conn->msg_id++; | - |
716 | send_string_attrs_request(conn, id, SSH2_FXP_MKDIR, path, | - |
717 | strlen(path), a); | - |
718 | | - |
719 | status = get_status(conn, id); | - |
720 | if (status != SSH2_FX_OK && print_flag)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
721 | error("Couldn't create directory: %s", fx2txt(status)); never executed: error("Couldn't create directory: %s", fx2txt(status)); | 0 |
722 | | - |
723 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
724 | } | - |
725 | | - |
726 | int | - |
727 | do_rmdir(struct sftp_conn *conn, const char *path) | - |
728 | { | - |
729 | u_int status, id; | - |
730 | | - |
731 | id = conn->msg_id++; | - |
732 | send_string_request(conn, id, SSH2_FXP_RMDIR, path, | - |
733 | strlen(path)); | - |
734 | | - |
735 | status = get_status(conn, id); | - |
736 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
737 | error("Couldn't remove directory: %s", fx2txt(status)); never executed: error("Couldn't remove directory: %s", fx2txt(status)); | 0 |
738 | | - |
739 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
740 | } | - |
741 | | - |
742 | Attrib * | - |
743 | do_stat(struct sftp_conn *conn, const char *path, int quiet) | - |
744 | { | - |
745 | u_int id; | - |
746 | | - |
747 | id = conn->msg_id++; | - |
748 | | - |
749 | send_string_request(conn, id, | - |
750 | conn->version == 0 ? SSH2_FXP_STAT_VERSION_0 : SSH2_FXP_STAT, | - |
751 | path, strlen(path)); | - |
752 | | - |
753 | return(get_decode_stat(conn, id, quiet)); never executed: return(get_decode_stat(conn, id, quiet)); | 0 |
754 | } | - |
755 | | - |
756 | Attrib * | - |
757 | do_lstat(struct sftp_conn *conn, const char *path, int quiet) | - |
758 | { | - |
759 | u_int id; | - |
760 | | - |
761 | if (conn->version == 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
762 | if (quiet)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
763 | debug("Server version does not support lstat operation"); never executed: debug("Server version does not support lstat operation"); | 0 |
764 | else | - |
765 | logit("Server version does not support lstat operation"); never executed: logit("Server version does not support lstat operation"); | 0 |
766 | return(do_stat(conn, path, quiet)); never executed: return(do_stat(conn, path, quiet)); | 0 |
767 | } | - |
768 | | - |
769 | id = conn->msg_id++; | - |
770 | send_string_request(conn, id, SSH2_FXP_LSTAT, path, | - |
771 | strlen(path)); | - |
772 | | - |
773 | return(get_decode_stat(conn, id, quiet)); never executed: return(get_decode_stat(conn, id, quiet)); | 0 |
774 | } | - |
775 | | - |
776 | #ifdef notyet | - |
777 | Attrib * | - |
778 | do_fstat(struct sftp_conn *conn, const u_char *handle, u_int handle_len, | - |
779 | int quiet) | - |
780 | { | - |
781 | u_int id; | - |
782 | | - |
783 | id = conn->msg_id++; | - |
784 | send_string_request(conn, id, SSH2_FXP_FSTAT, handle, | - |
785 | handle_len); | - |
786 | | - |
787 | return(get_decode_stat(conn, id, quiet)); | - |
788 | } | - |
789 | #endif | - |
790 | | - |
791 | int | - |
792 | do_setstat(struct sftp_conn *conn, const char *path, Attrib *a) | - |
793 | { | - |
794 | u_int status, id; | - |
795 | | - |
796 | id = conn->msg_id++; | - |
797 | send_string_attrs_request(conn, id, SSH2_FXP_SETSTAT, path, | - |
798 | strlen(path), a); | - |
799 | | - |
800 | status = get_status(conn, id); | - |
801 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
802 | error("Couldn't setstat on \"%s\": %s", path, never executed: error("Couldn't setstat on \"%s\": %s", path, fx2txt(status)); | 0 |
803 | fx2txt(status)); never executed: error("Couldn't setstat on \"%s\": %s", path, fx2txt(status)); | 0 |
804 | | - |
805 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
806 | } | - |
807 | | - |
808 | int | - |
809 | do_fsetstat(struct sftp_conn *conn, const u_char *handle, u_int handle_len, | - |
810 | Attrib *a) | - |
811 | { | - |
812 | u_int status, id; | - |
813 | | - |
814 | id = conn->msg_id++; | - |
815 | send_string_attrs_request(conn, id, SSH2_FXP_FSETSTAT, handle, | - |
816 | handle_len, a); | - |
817 | | - |
818 | status = get_status(conn, id); | - |
819 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
820 | error("Couldn't fsetstat: %s", fx2txt(status)); never executed: error("Couldn't fsetstat: %s", fx2txt(status)); | 0 |
821 | | - |
822 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
823 | } | - |
824 | | - |
825 | char * | - |
826 | do_realpath(struct sftp_conn *conn, const char *path) | - |
827 | { | - |
828 | struct sshbuf *msg; | - |
829 | u_int expected_id, count, id; | - |
830 | char *filename, *longname; | - |
831 | Attrib a; | - |
832 | u_char type; | - |
833 | int r; | - |
834 | | - |
835 | expected_id = id = conn->msg_id++; | - |
836 | send_string_request(conn, id, SSH2_FXP_REALPATH, path, | - |
837 | strlen(path)); | - |
838 | | - |
839 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
840 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
841 | | - |
842 | get_msg(conn, msg); | - |
843 | if ((r = sshbuf_get_u8(msg, &type)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
844 | (r = sshbuf_get_u32(msg, &id)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
845 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
846 | | - |
847 | if (id != expected_id)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
848 | fatal("ID mismatch (%u != %u)", id, expected_id); never executed: fatal("ID mismatch (%u != %u)", id, expected_id); | 0 |
849 | | - |
850 | if (type == SSH2_FXP_STATUS) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
851 | u_int status; | - |
852 | | - |
853 | if ((r = sshbuf_get_u32(msg, &status)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
854 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
855 | error("Couldn't canonicalize: %s", fx2txt(status)); | - |
856 | sshbuf_free(msg); | - |
857 | return NULL; never executed: return ((void *)0) ; | 0 |
858 | } else if (type != SSH2_FXP_NAME)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
859 | fatal("Expected SSH2_FXP_NAME(%u) packet, got %u", never executed: fatal("Expected SSH2_FXP_NAME(%u) packet, got %u", 104, type); | 0 |
860 | SSH2_FXP_NAME, type); never executed: fatal("Expected SSH2_FXP_NAME(%u) packet, got %u", 104, type); | 0 |
861 | | - |
862 | if ((r = sshbuf_get_u32(msg, &count)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
863 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
864 | if (count != 1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
865 | fatal("Got multiple names (%d) from SSH_FXP_REALPATH", count); never executed: fatal("Got multiple names (%d) from SSH_FXP_REALPATH", count); | 0 |
866 | | - |
867 | if ((r = sshbuf_get_cstring(msg, &filename, NULL)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
868 | (r = sshbuf_get_cstring(msg, &longname, NULL)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
869 | (r = decode_attrib(msg, &a)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
870 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
871 | | - |
872 | debug3("SSH_FXP_REALPATH %s -> %s size %lu", path, filename, | - |
873 | (unsigned long)a.size); | - |
874 | | - |
875 | free(longname); | - |
876 | | - |
877 | sshbuf_free(msg); | - |
878 | | - |
879 | return(filename); never executed: return(filename); | 0 |
880 | } | - |
881 | | - |
882 | int | - |
883 | do_rename(struct sftp_conn *conn, const char *oldpath, const char *newpath, | - |
884 | int force_legacy) | - |
885 | { | - |
886 | struct sshbuf *msg; | - |
887 | u_int status, id; | - |
888 | int r, use_ext = (conn->exts & SFTP_EXT_POSIX_RENAME) && !force_legacy;TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
889 | | - |
890 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
891 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
892 | | - |
893 | | - |
894 | id = conn->msg_id++; | - |
895 | if (use_ext) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
896 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_EXTENDED)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
897 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
898 | (r = sshbuf_put_cstring(msg,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
899 | "posix-rename@openssh.com")) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
900 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
901 | } else { never executed: end of block | 0 |
902 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_RENAME)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
903 | (r = sshbuf_put_u32(msg, id)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
904 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
905 | } never executed: end of block | 0 |
906 | if ((r = sshbuf_put_cstring(msg, oldpath)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
907 | (r = sshbuf_put_cstring(msg, newpath)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
908 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
909 | send_msg(conn, msg); | - |
910 | debug3("Sent message %s \"%s\" -> \"%s\"", | - |
911 | use_ext ? "posix-rename@openssh.com" : | - |
912 | "SSH2_FXP_RENAME", oldpath, newpath); | - |
913 | sshbuf_free(msg); | - |
914 | | - |
915 | status = get_status(conn, id); | - |
916 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
917 | error("Couldn't rename file \"%s\" to \"%s\": %s", oldpath, never executed: error("Couldn't rename file \"%s\" to \"%s\": %s", oldpath, newpath, fx2txt(status)); | 0 |
918 | newpath, fx2txt(status)); never executed: error("Couldn't rename file \"%s\" to \"%s\": %s", oldpath, newpath, fx2txt(status)); | 0 |
919 | | - |
920 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
921 | } | - |
922 | | - |
923 | int | - |
924 | do_hardlink(struct sftp_conn *conn, const char *oldpath, const char *newpath) | - |
925 | { | - |
926 | struct sshbuf *msg; | - |
927 | u_int status, id; | - |
928 | int r; | - |
929 | | - |
930 | if ((conn->exts & SFTP_EXT_HARDLINK) == 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
931 | error("Server does not support hardlink@openssh.com extension"); | - |
932 | return -1; never executed: return -1; | 0 |
933 | } | - |
934 | | - |
935 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
936 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
937 | | - |
938 | | - |
939 | id = conn->msg_id++; | - |
940 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_EXTENDED)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
941 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
942 | (r = sshbuf_put_cstring(msg, "hardlink@openssh.com")) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
943 | (r = sshbuf_put_cstring(msg, oldpath)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
944 | (r = sshbuf_put_cstring(msg, newpath)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
945 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
946 | send_msg(conn, msg); | - |
947 | debug3("Sent message hardlink@openssh.com \"%s\" -> \"%s\"", | - |
948 | oldpath, newpath); | - |
949 | sshbuf_free(msg); | - |
950 | | - |
951 | status = get_status(conn, id); | - |
952 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
953 | error("Couldn't link file \"%s\" to \"%s\": %s", oldpath, never executed: error("Couldn't link file \"%s\" to \"%s\": %s", oldpath, newpath, fx2txt(status)); | 0 |
954 | newpath, fx2txt(status)); never executed: error("Couldn't link file \"%s\" to \"%s\": %s", oldpath, newpath, fx2txt(status)); | 0 |
955 | | - |
956 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
957 | } | - |
958 | | - |
959 | int | - |
960 | do_symlink(struct sftp_conn *conn, const char *oldpath, const char *newpath) | - |
961 | { | - |
962 | struct sshbuf *msg; | - |
963 | u_int status, id; | - |
964 | int r; | - |
965 | | - |
966 | if (conn->version < 3) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
967 | error("This server does not support the symlink operation"); | - |
968 | return(SSH2_FX_OP_UNSUPPORTED); never executed: return(8); | 0 |
969 | } | - |
970 | | - |
971 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
972 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
973 | | - |
974 | | - |
975 | id = conn->msg_id++; | - |
976 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_SYMLINK)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
977 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
978 | (r = sshbuf_put_cstring(msg, oldpath)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
979 | (r = sshbuf_put_cstring(msg, newpath)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
980 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
981 | send_msg(conn, msg); | - |
982 | debug3("Sent message SSH2_FXP_SYMLINK \"%s\" -> \"%s\"", oldpath, | - |
983 | newpath); | - |
984 | sshbuf_free(msg); | - |
985 | | - |
986 | status = get_status(conn, id); | - |
987 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
988 | error("Couldn't symlink file \"%s\" to \"%s\": %s", oldpath, never executed: error("Couldn't symlink file \"%s\" to \"%s\": %s", oldpath, newpath, fx2txt(status)); | 0 |
989 | newpath, fx2txt(status)); never executed: error("Couldn't symlink file \"%s\" to \"%s\": %s", oldpath, newpath, fx2txt(status)); | 0 |
990 | | - |
991 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
992 | } | - |
993 | | - |
994 | int | - |
995 | do_fsync(struct sftp_conn *conn, u_char *handle, u_int handle_len) | - |
996 | { | - |
997 | struct sshbuf *msg; | - |
998 | u_int status, id; | - |
999 | int r; | - |
1000 | | - |
1001 | | - |
1002 | if ((conn->exts & SFTP_EXT_FSYNC) == 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1003 | return -1; never executed: return -1; | 0 |
1004 | | - |
1005 | | - |
1006 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1007 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
1008 | id = conn->msg_id++; | - |
1009 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_EXTENDED)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1010 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1011 | (r = sshbuf_put_cstring(msg, "fsync@openssh.com")) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1012 | (r = sshbuf_put_string(msg, handle, handle_len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1013 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1014 | send_msg(conn, msg); | - |
1015 | debug3("Sent message fsync@openssh.com I:%u", id); | - |
1016 | sshbuf_free(msg); | - |
1017 | | - |
1018 | status = get_status(conn, id); | - |
1019 | if (status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1020 | error("Couldn't sync file: %s", fx2txt(status)); never executed: error("Couldn't sync file: %s", fx2txt(status)); | 0 |
1021 | | - |
1022 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1023 | } | - |
1024 | | - |
1025 | #ifdef notyet | - |
1026 | char * | - |
1027 | do_readlink(struct sftp_conn *conn, const char *path) | - |
1028 | { | - |
1029 | struct sshbuf *msg; | - |
1030 | u_int expected_id, count, id; | - |
1031 | char *filename, *longname; | - |
1032 | Attrib a; | - |
1033 | u_char type; | - |
1034 | int r; | - |
1035 | | - |
1036 | expected_id = id = conn->msg_id++; | - |
1037 | send_string_request(conn, id, SSH2_FXP_READLINK, path, strlen(path)); | - |
1038 | | - |
1039 | if ((msg = sshbuf_new()) == NULL) | - |
1040 | fatal("%s: sshbuf_new failed", __func__); | - |
1041 | | - |
1042 | get_msg(conn, msg); | - |
1043 | if ((r = sshbuf_get_u8(msg, &type)) != 0 || | - |
1044 | (r = sshbuf_get_u32(msg, &id)) != 0) | - |
1045 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); | - |
1046 | | - |
1047 | if (id != expected_id) | - |
1048 | fatal("ID mismatch (%u != %u)", id, expected_id); | - |
1049 | | - |
1050 | if (type == SSH2_FXP_STATUS) { | - |
1051 | u_int status; | - |
1052 | | - |
1053 | if ((r = sshbuf_get_u32(msg, &status)) != 0) | - |
1054 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); | - |
1055 | error("Couldn't readlink: %s", fx2txt(status)); | - |
1056 | sshbuf_free(msg); | - |
1057 | return(NULL); | - |
1058 | } else if (type != SSH2_FXP_NAME) | - |
1059 | fatal("Expected SSH2_FXP_NAME(%u) packet, got %u", | - |
1060 | SSH2_FXP_NAME, type); | - |
1061 | | - |
1062 | if ((r = sshbuf_get_u32(msg, &count)) != 0) | - |
1063 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); | - |
1064 | if (count != 1) | - |
1065 | fatal("Got multiple names (%d) from SSH_FXP_READLINK", count); | - |
1066 | | - |
1067 | if ((r = sshbuf_get_cstring(msg, &filename, NULL)) != 0 || | - |
1068 | (r = sshbuf_get_cstring(msg, &longname, NULL)) != 0 || | - |
1069 | (r = decode_attrib(msg, &a)) != 0) | - |
1070 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); | - |
1071 | | - |
1072 | debug3("SSH_FXP_READLINK %s -> %s", path, filename); | - |
1073 | | - |
1074 | free(longname); | - |
1075 | | - |
1076 | sshbuf_free(msg); | - |
1077 | | - |
1078 | return filename; | - |
1079 | } | - |
1080 | #endif | - |
1081 | | - |
1082 | int | - |
1083 | do_statvfs(struct sftp_conn *conn, const char *path, struct sftp_statvfs *st, | - |
1084 | int quiet) | - |
1085 | { | - |
1086 | struct sshbuf *msg; | - |
1087 | u_int id; | - |
1088 | int r; | - |
1089 | | - |
1090 | if ((conn->exts & SFTP_EXT_STATVFS) == 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1091 | error("Server does not support statvfs@openssh.com extension"); | - |
1092 | return -1; never executed: return -1; | 0 |
1093 | } | - |
1094 | | - |
1095 | id = conn->msg_id++; | - |
1096 | | - |
1097 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1098 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
1099 | sshbuf_reset(msg); | - |
1100 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_EXTENDED)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1101 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1102 | (r = sshbuf_put_cstring(msg, "statvfs@openssh.com")) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1103 | (r = sshbuf_put_cstring(msg, path)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1104 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1105 | send_msg(conn, msg); | - |
1106 | sshbuf_free(msg); | - |
1107 | | - |
1108 | return get_decode_statvfs(conn, st, id, quiet); never executed: return get_decode_statvfs(conn, st, id, quiet); | 0 |
1109 | } | - |
1110 | | - |
1111 | #ifdef notyet | - |
1112 | int | - |
1113 | do_fstatvfs(struct sftp_conn *conn, const u_char *handle, u_int handle_len, | - |
1114 | struct sftp_statvfs *st, int quiet) | - |
1115 | { | - |
1116 | struct sshbuf *msg; | - |
1117 | u_int id; | - |
1118 | | - |
1119 | if ((conn->exts & SFTP_EXT_FSTATVFS) == 0) { | - |
1120 | error("Server does not support fstatvfs@openssh.com extension"); | - |
1121 | return -1; | - |
1122 | } | - |
1123 | | - |
1124 | id = conn->msg_id++; | - |
1125 | | - |
1126 | if ((msg = sshbuf_new()) == NULL) | - |
1127 | fatal("%s: sshbuf_new failed", __func__); | - |
1128 | sshbuf_reset(msg); | - |
1129 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_EXTENDED)) != 0 || | - |
1130 | (r = sshbuf_put_u32(msg, id)) != 0 || | - |
1131 | (r = sshbuf_put_cstring(msg, "fstatvfs@openssh.com")) != 0 || | - |
1132 | (r = sshbuf_put_string(msg, handle, handle_len)) != 0) | - |
1133 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); | - |
1134 | send_msg(conn, msg); | - |
1135 | sshbuf_free(msg); | - |
1136 | | - |
1137 | return get_decode_statvfs(conn, st, id, quiet); | - |
1138 | } | - |
1139 | #endif | - |
1140 | | - |
1141 | static void | - |
1142 | send_read_request(struct sftp_conn *conn, u_int id, u_int64_t offset, | - |
1143 | u_int len, const u_char *handle, u_int handle_len) | - |
1144 | { | - |
1145 | struct sshbuf *msg; | - |
1146 | int r; | - |
1147 | | - |
1148 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1149 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
1150 | sshbuf_reset(msg); | - |
1151 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_READ)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1152 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1153 | (r = sshbuf_put_string(msg, handle, handle_len)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1154 | (r = sshbuf_put_u64(msg, offset)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1155 | (r = sshbuf_put_u32(msg, len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1156 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1157 | send_msg(conn, msg); | - |
1158 | sshbuf_free(msg); | - |
1159 | } never executed: end of block | 0 |
1160 | | - |
1161 | int | - |
1162 | do_download(struct sftp_conn *conn, const char *remote_path, | - |
1163 | const char *local_path, Attrib *a, int preserve_flag, int resume_flag, | - |
1164 | int fsync_flag) | - |
1165 | { | - |
1166 | Attrib junk; | - |
1167 | struct sshbuf *msg; | - |
1168 | u_char *handle; | - |
1169 | int local_fd = -1, write_error; | - |
1170 | int read_error, write_errno, reordered = 0, r; | - |
1171 | u_int64_t offset = 0, size, highwater; | - |
1172 | u_int mode, id, buflen, num_req, max_req, status = SSH2_FX_OK; | - |
1173 | off_t progress_counter; | - |
1174 | size_t handle_len; | - |
1175 | struct stat st; | - |
1176 | struct request { | - |
1177 | u_int id; | - |
1178 | size_t len; | - |
1179 | u_int64_t offset; | - |
1180 | TAILQ_ENTRY(request) tq; | - |
1181 | }; | - |
1182 | TAILQ_HEAD(reqhead, request) requests; | - |
1183 | struct request *req; | - |
1184 | u_char type; | - |
1185 | | - |
1186 | TAILQ_INIT(&requests); | - |
1187 | | - |
1188 | if (a == NULL && (a = do_stat(conn, remote_path, 0)) == NULL)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1189 | return -1; never executed: return -1; | 0 |
1190 | | - |
1191 | | - |
1192 | if (a->flags & SSH2_FILEXFER_ATTR_PERMISSIONS)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1193 | mode = a->perm & 0777; never executed: mode = a->perm & 0777; | 0 |
1194 | else | - |
1195 | mode = 0666; never executed: mode = 0666; | 0 |
1196 | | - |
1197 | if ((a->flags & SSH2_FILEXFER_ATTR_PERMISSIONS) &&TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1198 | (!S_ISREG(a->perm))) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1199 | error("Cannot download non-regular file: %s", remote_path); | - |
1200 | return(-1); never executed: return(-1); | 0 |
1201 | } | - |
1202 | | - |
1203 | if (a->flags & SSH2_FILEXFER_ATTR_SIZE)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1204 | size = a->size; never executed: size = a->size; | 0 |
1205 | else | - |
1206 | size = 0; never executed: size = 0; | 0 |
1207 | | - |
1208 | buflen = conn->transfer_buflen; | - |
1209 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1210 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
1211 | | - |
1212 | attrib_clear(&junk); | - |
1213 | | - |
1214 | | - |
1215 | id = conn->msg_id++; | - |
1216 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_OPEN)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1217 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1218 | (r = sshbuf_put_cstring(msg, remote_path)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1219 | (r = sshbuf_put_u32(msg, SSH2_FXF_READ)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1220 | (r = encode_attrib(msg, &junk)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1221 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1222 | send_msg(conn, msg); | - |
1223 | debug3("Sent message SSH2_FXP_OPEN I:%u P:%s", id, remote_path); | - |
1224 | | - |
1225 | handle = get_handle(conn, id, &handle_len, | - |
1226 | "remote open(\"%s\")", remote_path); | - |
1227 | if (handle == NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1228 | sshbuf_free(msg); | - |
1229 | return(-1); never executed: return(-1); | 0 |
1230 | } | - |
1231 | | - |
1232 | local_fd = open(local_path, | - |
1233 | O_WRONLY | O_CREAT | (resume_flag ? 0 : O_TRUNC), mode | S_IWUSR); | - |
1234 | if (local_fd == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1235 | error("Couldn't open local file \"%s\" for writing: %s", | - |
1236 | local_path, strerror(errno)); | - |
1237 | goto fail; never executed: goto fail; | 0 |
1238 | } | - |
1239 | offset = highwater = 0; | - |
1240 | if (resume_flag) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1241 | if (fstat(local_fd, &st) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1242 | error("Unable to stat local file \"%s\": %s", | - |
1243 | local_path, strerror(errno)); | - |
1244 | goto fail; never executed: goto fail; | 0 |
1245 | } | - |
1246 | if (st.st_size < 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1247 | error("\"%s\" has negative size", local_path); | - |
1248 | goto fail; never executed: goto fail; | 0 |
1249 | } | - |
1250 | if ((u_int64_t)st.st_size > size) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1251 | error("Unable to resume download of \"%s\": " | - |
1252 | "local file is larger than remote", local_path); | - |
1253 | fail: code before this statement never executed: fail: | 0 |
1254 | do_close(conn, handle, handle_len); | - |
1255 | sshbuf_free(msg); | - |
1256 | free(handle); | - |
1257 | if (local_fd != -1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1258 | close(local_fd); never executed: close(local_fd); | 0 |
1259 | return -1; never executed: return -1; | 0 |
1260 | } | - |
1261 | offset = highwater = st.st_size; | - |
1262 | } never executed: end of block | 0 |
1263 | | - |
1264 | | - |
1265 | write_error = read_error = write_errno = num_req = 0; | - |
1266 | max_req = 1; | - |
1267 | progress_counter = offset; | - |
1268 | | - |
1269 | if (showprogress && size != 0)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1270 | start_progress_meter(remote_path, size, &progress_counter); never executed: start_progress_meter(remote_path, size, &progress_counter); | 0 |
1271 | | - |
1272 | while (num_req > 0 || max_req > 0) {TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1273 | u_char *data; | - |
1274 | size_t len; | - |
1275 | | - |
1276 | | - |
1277 | | - |
1278 | | - |
1279 | | - |
1280 | if (interrupted) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1281 | if (num_req == 0) TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1282 | break; never executed: break; | 0 |
1283 | max_req = 0; | - |
1284 | } never executed: end of block | 0 |
1285 | | - |
1286 | | - |
1287 | while (num_req < max_req) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1288 | debug3("Request range %llu -> %llu (%d/%d)", | - |
1289 | (unsigned long long)offset, | - |
1290 | (unsigned long long)offset + buflen - 1, | - |
1291 | num_req, max_req); | - |
1292 | req = xcalloc(1, sizeof(*req)); | - |
1293 | req->id = conn->msg_id++; | - |
1294 | req->len = buflen; | - |
1295 | req->offset = offset; | - |
1296 | offset += buflen; | - |
1297 | num_req++; | - |
1298 | TAILQ_INSERT_TAIL(&requests, req, tq); | - |
1299 | send_read_request(conn, req->id, req->offset, | - |
1300 | req->len, handle, handle_len); | - |
1301 | } never executed: end of block | 0 |
1302 | | - |
1303 | sshbuf_reset(msg); | - |
1304 | get_msg(conn, msg); | - |
1305 | if ((r = sshbuf_get_u8(msg, &type)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1306 | (r = sshbuf_get_u32(msg, &id)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1307 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1308 | debug3("Received reply T:%u I:%u R:%d", type, id, max_req); | - |
1309 | | - |
1310 | | - |
1311 | for (req = TAILQ_FIRST(&requests); | - |
1312 | req != NULL && req->id != id;TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1313 | req = TAILQ_NEXT(req, tq)) | - |
1314 | ; never executed: ; | 0 |
1315 | if (req == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1316 | fatal("Unexpected reply %u", id); never executed: fatal("Unexpected reply %u", id); | 0 |
1317 | | - |
1318 | switch (type) { | - |
1319 | case SSH2_FXP_STATUS: never executed: case 101: | 0 |
1320 | if ((r = sshbuf_get_u32(msg, &status)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1321 | fatal("%s: buffer error: %s", never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1322 | __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1323 | if (status != SSH2_FX_EOF)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1324 | read_error = 1; never executed: read_error = 1; | 0 |
1325 | max_req = 0; | - |
1326 | TAILQ_REMOVE(&requests, req, tq); never executed: (req)->tq.tqe_next->tq.tqe_prev = (req)->tq.tqe_prev; never executed: (&requests)->tqh_last = (req)->tq.tqe_prev; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1327 | free(req); | - |
1328 | num_req--; | - |
1329 | break; never executed: break; | 0 |
1330 | case SSH2_FXP_DATA: never executed: case 103: | 0 |
1331 | if ((r = sshbuf_get_string(msg, &data, &len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1332 | fatal("%s: buffer error: %s", never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1333 | __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1334 | debug3("Received data %llu -> %llu", | - |
1335 | (unsigned long long)req->offset, | - |
1336 | (unsigned long long)req->offset + len - 1); | - |
1337 | if (len > req->len)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1338 | fatal("Received more data than asked for " never executed: fatal("Received more data than asked for " "%zu > %zu", len, req->len); | 0 |
1339 | "%zu > %zu", len, req->len); never executed: fatal("Received more data than asked for " "%zu > %zu", len, req->len); | 0 |
1340 | if ((lseek(local_fd, req->offset, SEEK_SET) == -1 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1341 | atomicio(vwrite, local_fd, data, len) != len) &&TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1342 | !write_error) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1343 | write_errno = errno; | - |
1344 | write_error = 1; | - |
1345 | max_req = 0; | - |
1346 | } never executed: end of block | 0 |
1347 | else if (!reordered && req->offset <= highwater)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1348 | highwater = req->offset + len; never executed: highwater = req->offset + len; | 0 |
1349 | else if (!reordered && req->offset > highwater)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1350 | reordered = 1; never executed: reordered = 1; | 0 |
1351 | progress_counter += len; | - |
1352 | free(data); | - |
1353 | | - |
1354 | if (len == req->len) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1355 | TAILQ_REMOVE(&requests, req, tq); never executed: (req)->tq.tqe_next->tq.tqe_prev = (req)->tq.tqe_prev; never executed: (&requests)->tqh_last = (req)->tq.tqe_prev; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1356 | free(req); | - |
1357 | num_req--; | - |
1358 | } else { never executed: end of block | 0 |
1359 | | - |
1360 | debug3("Short data block, re-requesting " | - |
1361 | "%llu -> %llu (%2d)", | - |
1362 | (unsigned long long)req->offset + len, | - |
1363 | (unsigned long long)req->offset + | - |
1364 | req->len - 1, num_req); | - |
1365 | req->id = conn->msg_id++; | - |
1366 | req->len -= len; | - |
1367 | req->offset += len; | - |
1368 | send_read_request(conn, req->id, | - |
1369 | req->offset, req->len, handle, handle_len); | - |
1370 | | - |
1371 | if (len < buflen)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1372 | buflen = MAXIMUM(MIN_READ_SIZE, len); never executed: buflen = (((512) > (len)) ? (512) : (len)); TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1373 | } never executed: end of block | 0 |
1374 | if (max_req > 0) { TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1375 | if (size > 0 && offset > size) {TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1376 | | - |
1377 | | - |
1378 | debug3("Finish at %llu (%2d)", | - |
1379 | (unsigned long long)offset, | - |
1380 | num_req); | - |
1381 | max_req = 1; | - |
1382 | } else if (max_req <= conn->num_requests) { never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1383 | ++max_req; | - |
1384 | } never executed: end of block | 0 |
1385 | } never executed: end of block | 0 |
1386 | break; never executed: break; | 0 |
1387 | default: never executed: default: | 0 |
1388 | fatal("Expected SSH2_FXP_DATA(%u) packet, got %u", | - |
1389 | SSH2_FXP_DATA, type); | - |
1390 | } never executed: end of block | 0 |
1391 | } | - |
1392 | | - |
1393 | if (showprogress && size)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1394 | stop_progress_meter(); never executed: stop_progress_meter(); | 0 |
1395 | | - |
1396 | | - |
1397 | if (TAILQ_FIRST(&requests) != NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1398 | fatal("Transfer complete, but requests still in queue"); never executed: fatal("Transfer complete, but requests still in queue"); | 0 |
1399 | | - |
1400 | if (read_error || write_error || interrupted) {TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1401 | if (reordered && resume_flag) {TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1402 | error("Unable to resume download of \"%s\": " | - |
1403 | "server reordered requests", local_path); | - |
1404 | } never executed: end of block | 0 |
1405 | debug("truncating at %llu", (unsigned long long)highwater); | - |
1406 | if (ftruncate(local_fd, highwater) == -1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1407 | error("ftruncate \"%s\": %s", local_path, never executed: error("ftruncate \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1408 | strerror(errno)); never executed: error("ftruncate \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1409 | } never executed: end of block | 0 |
1410 | if (read_error) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1411 | error("Couldn't read from remote file \"%s\" : %s", | - |
1412 | remote_path, fx2txt(status)); | - |
1413 | status = -1; | - |
1414 | do_close(conn, handle, handle_len); | - |
1415 | } else if (write_error) { never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1416 | error("Couldn't write to \"%s\": %s", local_path, | - |
1417 | strerror(write_errno)); | - |
1418 | status = SSH2_FX_FAILURE; | - |
1419 | do_close(conn, handle, handle_len); | - |
1420 | } else { never executed: end of block | 0 |
1421 | if (do_close(conn, handle, handle_len) != 0 || interrupted)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1422 | status = SSH2_FX_FAILURE; never executed: status = 4; | 0 |
1423 | else | - |
1424 | status = SSH2_FX_OK; never executed: status = 0; | 0 |
1425 | | - |
1426 | #ifdef HAVE_FCHMOD | - |
1427 | if (preserve_flag && fchmod(local_fd, mode) == -1)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1428 | #else | - |
1429 | if (preserve_flag && chmod(local_path, mode) == -1) | - |
1430 | #endif /* HAVE_FCHMOD */ | - |
1431 | error("Couldn't set mode on \"%s\": %s", local_path, never executed: error("Couldn't set mode on \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1432 | strerror(errno)); never executed: error("Couldn't set mode on \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1433 | if (preserve_flag &&TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1434 | (a->flags & SSH2_FILEXFER_ATTR_ACMODTIME)) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1435 | struct timeval tv[2]; | - |
1436 | tv[0].tv_sec = a->atime; | - |
1437 | tv[1].tv_sec = a->mtime; | - |
1438 | tv[0].tv_usec = tv[1].tv_usec = 0; | - |
1439 | if (utimes(local_path, tv) == -1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1440 | error("Can't set times on \"%s\": %s", never executed: error("Can't set times on \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1441 | local_path, strerror(errno)); never executed: error("Can't set times on \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1442 | } never executed: end of block | 0 |
1443 | if (fsync_flag) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1444 | debug("syncing \"%s\"", local_path); | - |
1445 | if (fsync(local_fd) == -1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1446 | error("Couldn't sync file \"%s\": %s", never executed: error("Couldn't sync file \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1447 | local_path, strerror(errno)); never executed: error("Couldn't sync file \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1448 | } never executed: end of block | 0 |
1449 | } never executed: end of block | 0 |
1450 | close(local_fd); | - |
1451 | sshbuf_free(msg); | - |
1452 | free(handle); | - |
1453 | | - |
1454 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1455 | } | - |
1456 | | - |
1457 | static int | - |
1458 | download_dir_internal(struct sftp_conn *conn, const char *src, const char *dst, | - |
1459 | int depth, Attrib *dirattrib, int preserve_flag, int print_flag, | - |
1460 | int resume_flag, int fsync_flag) | - |
1461 | { | - |
1462 | int i, ret = 0; | - |
1463 | SFTP_DIRENT **dir_entries; | - |
1464 | char *filename, *new_src = NULL, *new_dst = NULL; | - |
1465 | mode_t mode = 0777; | - |
1466 | | - |
1467 | if (depth >= MAX_DIR_DEPTH) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1468 | error("Maximum directory depth exceeded: %d levels", depth); | - |
1469 | return -1; never executed: return -1; | 0 |
1470 | } | - |
1471 | | - |
1472 | if (dirattrib == NULL &&TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1473 | (dirattrib = do_stat(conn, src, 1)) == NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1474 | error("Unable to stat remote directory \"%s\"", src); | - |
1475 | return -1; never executed: return -1; | 0 |
1476 | } | - |
1477 | if (!S_ISDIR(dirattrib->perm)) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1478 | error("\"%s\" is not a directory", src); | - |
1479 | return -1; never executed: return -1; | 0 |
1480 | } | - |
1481 | if (print_flag)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1482 | mprintf("Retrieving %s\n", src); never executed: mprintf("Retrieving %s\n", src); | 0 |
1483 | | - |
1484 | if (dirattrib->flags & SSH2_FILEXFER_ATTR_PERMISSIONS)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1485 | mode = dirattrib->perm & 01777; never executed: mode = dirattrib->perm & 01777; | 0 |
1486 | else { | - |
1487 | debug("Server did not send permissions for " | - |
1488 | "directory \"%s\"", dst); | - |
1489 | } never executed: end of block | 0 |
1490 | | - |
1491 | if (mkdir(dst, mode) == -1 && errno != EEXIST) {TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1492 | error("mkdir %s: %s", dst, strerror(errno)); | - |
1493 | return -1; never executed: return -1; | 0 |
1494 | } | - |
1495 | | - |
1496 | if (do_readdir(conn, src, &dir_entries) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1497 | error("%s: Failed to get directory contents", src); | - |
1498 | return -1; never executed: return -1; | 0 |
1499 | } | - |
1500 | | - |
1501 | for (i = 0; dir_entries[i] != NULL && !interrupted; i++) {TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1502 | free(new_dst); | - |
1503 | free(new_src); | - |
1504 | | - |
1505 | filename = dir_entries[i]->filename; | - |
1506 | new_dst = path_append(dst, filename); | - |
1507 | new_src = path_append(src, filename); | - |
1508 | | - |
1509 | if (S_ISDIR(dir_entries[i]->a.perm)) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1510 | if (strcmp(filename, ".") == 0 || never executed: __result = (((const unsigned char *) (const char *) ( filename ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "." ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1511 | strcmp(filename, "..") == 0) never executed: __result = (((const unsigned char *) (const char *) ( filename ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( ".." ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1512 | continue; never executed: continue; | 0 |
1513 | if (download_dir_internal(conn, new_src, new_dst,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1514 | depth + 1, &(dir_entries[i]->a), preserve_flag,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1515 | print_flag, resume_flag, fsync_flag) == -1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1516 | ret = -1; never executed: ret = -1; | 0 |
1517 | } else if (S_ISREG(dir_entries[i]->a.perm) ) { never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1518 | if (do_download(conn, new_src, new_dst,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1519 | &(dir_entries[i]->a), preserve_flag,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1520 | resume_flag, fsync_flag) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1521 | error("Download of file %s to %s failed", | - |
1522 | new_src, new_dst); | - |
1523 | ret = -1; | - |
1524 | } never executed: end of block | 0 |
1525 | } else never executed: end of block | 0 |
1526 | logit("%s: not a regular file\n", new_src); never executed: logit("%s: not a regular file\n", new_src); | 0 |
1527 | | - |
1528 | } | - |
1529 | free(new_dst); | - |
1530 | free(new_src); | - |
1531 | | - |
1532 | if (preserve_flag) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1533 | if (dirattrib->flags & SSH2_FILEXFER_ATTR_ACMODTIME) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1534 | struct timeval tv[2]; | - |
1535 | tv[0].tv_sec = dirattrib->atime; | - |
1536 | tv[1].tv_sec = dirattrib->mtime; | - |
1537 | tv[0].tv_usec = tv[1].tv_usec = 0; | - |
1538 | if (utimes(dst, tv) == -1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1539 | error("Can't set times on \"%s\": %s", never executed: error("Can't set times on \"%s\": %s", dst, strerror( (*__errno_location ()) )); | 0 |
1540 | dst, strerror(errno)); never executed: error("Can't set times on \"%s\": %s", dst, strerror( (*__errno_location ()) )); | 0 |
1541 | } else never executed: end of block | 0 |
1542 | debug("Server did not send times for directory " never executed: debug("Server did not send times for directory " "\"%s\"", dst); | 0 |
1543 | "\"%s\"", dst); never executed: debug("Server did not send times for directory " "\"%s\"", dst); | 0 |
1544 | } | - |
1545 | | - |
1546 | free_sftp_dirents(dir_entries); | - |
1547 | | - |
1548 | return ret; never executed: return ret; | 0 |
1549 | } | - |
1550 | | - |
1551 | int | - |
1552 | download_dir(struct sftp_conn *conn, const char *src, const char *dst, | - |
1553 | Attrib *dirattrib, int preserve_flag, int print_flag, int resume_flag, | - |
1554 | int fsync_flag) | - |
1555 | { | - |
1556 | char *src_canon; | - |
1557 | int ret; | - |
1558 | | - |
1559 | if ((src_canon = do_realpath(conn, src)) == NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1560 | error("Unable to canonicalize path \"%s\"", src); | - |
1561 | return -1; never executed: return -1; | 0 |
1562 | } | - |
1563 | | - |
1564 | ret = download_dir_internal(conn, src_canon, dst, 0, | - |
1565 | dirattrib, preserve_flag, print_flag, resume_flag, fsync_flag); | - |
1566 | free(src_canon); | - |
1567 | return ret; never executed: return ret; | 0 |
1568 | } | - |
1569 | | - |
1570 | int | - |
1571 | do_upload(struct sftp_conn *conn, const char *local_path, | - |
1572 | const char *remote_path, int preserve_flag, int resume, int fsync_flag) | - |
1573 | { | - |
1574 | int r, local_fd; | - |
1575 | u_int status = SSH2_FX_OK; | - |
1576 | u_int id; | - |
1577 | u_char type; | - |
1578 | off_t offset, progress_counter; | - |
1579 | u_char *handle, *data; | - |
1580 | struct sshbuf *msg; | - |
1581 | struct stat sb; | - |
1582 | Attrib a, *c = NULL; | - |
1583 | u_int32_t startid; | - |
1584 | u_int32_t ackid; | - |
1585 | struct outstanding_ack { | - |
1586 | u_int id; | - |
1587 | u_int len; | - |
1588 | off_t offset; | - |
1589 | TAILQ_ENTRY(outstanding_ack) tq; | - |
1590 | }; | - |
1591 | TAILQ_HEAD(ackhead, outstanding_ack) acks; | - |
1592 | struct outstanding_ack *ack = NULL; | - |
1593 | size_t handle_len; | - |
1594 | | - |
1595 | TAILQ_INIT(&acks); | - |
1596 | | - |
1597 | if ((local_fd = open(local_path, O_RDONLY, 0)) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1598 | error("Couldn't open local file \"%s\" for reading: %s", | - |
1599 | local_path, strerror(errno)); | - |
1600 | return(-1); never executed: return(-1); | 0 |
1601 | } | - |
1602 | if (fstat(local_fd, &sb) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1603 | error("Couldn't fstat local file \"%s\": %s", | - |
1604 | local_path, strerror(errno)); | - |
1605 | close(local_fd); | - |
1606 | return(-1); never executed: return(-1); | 0 |
1607 | } | - |
1608 | if (!S_ISREG(sb.st_mode)) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1609 | error("%s is not a regular file", local_path); | - |
1610 | close(local_fd); | - |
1611 | return(-1); never executed: return(-1); | 0 |
1612 | } | - |
1613 | stat_to_attrib(&sb, &a); | - |
1614 | | - |
1615 | a.flags &= ~SSH2_FILEXFER_ATTR_SIZE; | - |
1616 | a.flags &= ~SSH2_FILEXFER_ATTR_UIDGID; | - |
1617 | a.perm &= 0777; | - |
1618 | if (!preserve_flag)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1619 | a.flags &= ~SSH2_FILEXFER_ATTR_ACMODTIME; never executed: a.flags &= ~0x00000008; | 0 |
1620 | | - |
1621 | if (resume) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1622 | | - |
1623 | if ((c = do_stat(conn, remote_path, 0)) == NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1624 | close(local_fd); | - |
1625 | return -1; never executed: return -1; | 0 |
1626 | } | - |
1627 | | - |
1628 | if ((off_t)c->size >= sb.st_size) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1629 | error("destination file bigger or same size as " | - |
1630 | "source file"); | - |
1631 | close(local_fd); | - |
1632 | return -1; never executed: return -1; | 0 |
1633 | } | - |
1634 | | - |
1635 | if (lseek(local_fd, (off_t)c->size, SEEK_SET) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1636 | close(local_fd); | - |
1637 | return -1; never executed: return -1; | 0 |
1638 | } | - |
1639 | } never executed: end of block | 0 |
1640 | | - |
1641 | if ((msg = sshbuf_new()) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1642 | fatal("%s: sshbuf_new failed", __func__); never executed: fatal("%s: sshbuf_new failed", __func__); | 0 |
1643 | | - |
1644 | | - |
1645 | id = conn->msg_id++; | - |
1646 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_OPEN)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1647 | (r = sshbuf_put_u32(msg, id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1648 | (r = sshbuf_put_cstring(msg, remote_path)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1649 | (r = sshbuf_put_u32(msg, SSH2_FXF_WRITE|SSH2_FXF_CREAT|TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1650 | (resume ? SSH2_FXF_APPEND : SSH2_FXF_TRUNC))) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1651 | (r = encode_attrib(msg, &a)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1652 | fatal("%s: buffer error: %s", __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1653 | send_msg(conn, msg); | - |
1654 | debug3("Sent message SSH2_FXP_OPEN I:%u P:%s", id, remote_path); | - |
1655 | | - |
1656 | sshbuf_reset(msg); | - |
1657 | | - |
1658 | handle = get_handle(conn, id, &handle_len, | - |
1659 | "remote open(\"%s\")", remote_path); | - |
1660 | if (handle == NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1661 | close(local_fd); | - |
1662 | sshbuf_free(msg); | - |
1663 | return -1; never executed: return -1; | 0 |
1664 | } | - |
1665 | | - |
1666 | startid = ackid = id + 1; | - |
1667 | data = xmalloc(conn->transfer_buflen); | - |
1668 | | - |
1669 | | - |
1670 | offset = progress_counter = (resume ? c->size : 0);TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1671 | if (showprogress)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1672 | start_progress_meter(local_path, sb.st_size, never executed: start_progress_meter(local_path, sb.st_size, &progress_counter); | 0 |
1673 | &progress_counter); never executed: start_progress_meter(local_path, sb.st_size, &progress_counter); | 0 |
1674 | | - |
1675 | for (;;) { | - |
1676 | int len; | - |
1677 | | - |
1678 | | - |
1679 | | - |
1680 | | - |
1681 | | - |
1682 | | - |
1683 | | - |
1684 | if (interrupted || status != SSH2_FX_OK)TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1685 | len = 0; never executed: len = 0; | 0 |
1686 | else do | - |
1687 | len = read(local_fd, data, conn->transfer_buflen); never executed: len = read(local_fd, data, conn->transfer_buflen); | 0 |
1688 | while ((len == -1) &&TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1689 | (errno == EINTR || errno == EAGAIN || errno == EWOULDBLOCK));TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1690 | | - |
1691 | if (len == -1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1692 | fatal("Couldn't read from \"%s\": %s", local_path, never executed: fatal("Couldn't read from \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1693 | strerror(errno)); never executed: fatal("Couldn't read from \"%s\": %s", local_path, strerror( (*__errno_location ()) )); | 0 |
1694 | | - |
1695 | if (len != 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1696 | ack = xcalloc(1, sizeof(*ack)); | - |
1697 | ack->id = ++id; | - |
1698 | ack->offset = offset; | - |
1699 | ack->len = len; | - |
1700 | TAILQ_INSERT_TAIL(&acks, ack, tq); | - |
1701 | | - |
1702 | sshbuf_reset(msg); | - |
1703 | if ((r = sshbuf_put_u8(msg, SSH2_FXP_WRITE)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1704 | (r = sshbuf_put_u32(msg, ack->id)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1705 | (r = sshbuf_put_string(msg, handle,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1706 | handle_len)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1707 | (r = sshbuf_put_u64(msg, offset)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1708 | (r = sshbuf_put_string(msg, data, len)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1709 | fatal("%s: buffer error: %s", never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1710 | __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1711 | send_msg(conn, msg); | - |
1712 | debug3("Sent message SSH2_FXP_WRITE I:%u O:%llu S:%u", | - |
1713 | id, (unsigned long long)offset, len); | - |
1714 | } else if (TAILQ_FIRST(&acks) == NULL) never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1715 | break; never executed: break; | 0 |
1716 | | - |
1717 | if (ack == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1718 | fatal("Unexpected ACK %u", id); never executed: fatal("Unexpected ACK %u", id); | 0 |
1719 | | - |
1720 | if (id == startid || len == 0 ||TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1721 | id - ackid >= conn->num_requests) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1722 | u_int rid; | - |
1723 | | - |
1724 | sshbuf_reset(msg); | - |
1725 | get_msg(conn, msg); | - |
1726 | if ((r = sshbuf_get_u8(msg, &type)) != 0 ||TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1727 | (r = sshbuf_get_u32(msg, &rid)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1728 | fatal("%s: buffer error: %s", never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1729 | __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1730 | | - |
1731 | if (type != SSH2_FXP_STATUS)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1732 | fatal("Expected SSH2_FXP_STATUS(%d) packet, " never executed: fatal("Expected SSH2_FXP_STATUS(%d) packet, " "got %d", 101, type); | 0 |
1733 | "got %d", SSH2_FXP_STATUS, type); never executed: fatal("Expected SSH2_FXP_STATUS(%d) packet, " "got %d", 101, type); | 0 |
1734 | | - |
1735 | if ((r = sshbuf_get_u32(msg, &status)) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1736 | fatal("%s: buffer error: %s", never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1737 | __func__, ssh_err(r)); never executed: fatal("%s: buffer error: %s", __func__, ssh_err(r)); | 0 |
1738 | debug3("SSH2_FXP_STATUS %u", status); | - |
1739 | | - |
1740 | | - |
1741 | for (ack = TAILQ_FIRST(&acks); | - |
1742 | ack != NULL && ack->id != rid;TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1743 | ack = TAILQ_NEXT(ack, tq)) | - |
1744 | ; never executed: ; | 0 |
1745 | if (ack == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1746 | fatal("Can't find request for ID %u", rid); never executed: fatal("Can't find request for ID %u", rid); | 0 |
1747 | TAILQ_REMOVE(&acks, ack, tq); never executed: (ack)->tq.tqe_next->tq.tqe_prev = (ack)->tq.tqe_prev; never executed: (&acks)->tqh_last = (ack)->tq.tqe_prev; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1748 | debug3("In write loop, ack for %u %u bytes at %lld", | - |
1749 | ack->id, ack->len, (long long)ack->offset); | - |
1750 | ++ackid; | - |
1751 | progress_counter += ack->len; | - |
1752 | free(ack); | - |
1753 | } never executed: end of block | 0 |
1754 | offset += len; | - |
1755 | if (offset < 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1756 | fatal("%s: offset < 0", __func__); never executed: fatal("%s: offset < 0", __func__); | 0 |
1757 | } never executed: end of block | 0 |
1758 | sshbuf_free(msg); | - |
1759 | | - |
1760 | if (showprogress)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1761 | stop_progress_meter(); never executed: stop_progress_meter(); | 0 |
1762 | free(data); | - |
1763 | | - |
1764 | if (status != SSH2_FX_OK) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1765 | error("Couldn't write to remote file \"%s\": %s", | - |
1766 | remote_path, fx2txt(status)); | - |
1767 | status = SSH2_FX_FAILURE; | - |
1768 | } never executed: end of block | 0 |
1769 | | - |
1770 | if (close(local_fd) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1771 | error("Couldn't close local file \"%s\": %s", local_path, | - |
1772 | strerror(errno)); | - |
1773 | status = SSH2_FX_FAILURE; | - |
1774 | } never executed: end of block | 0 |
1775 | | - |
1776 | | - |
1777 | if (preserve_flag)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1778 | do_fsetstat(conn, handle, handle_len, &a); never executed: do_fsetstat(conn, handle, handle_len, &a); | 0 |
1779 | | - |
1780 | if (fsync_flag)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1781 | (void)do_fsync(conn, handle, handle_len); never executed: (void)do_fsync(conn, handle, handle_len); | 0 |
1782 | | - |
1783 | if (do_close(conn, handle, handle_len) != 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1784 | status = SSH2_FX_FAILURE; never executed: status = 4; | 0 |
1785 | | - |
1786 | free(handle); | - |
1787 | | - |
1788 | return status == SSH2_FX_OK ? 0 : -1; never executed: return status == 0 ? 0 : -1; TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1789 | } | - |
1790 | | - |
1791 | static int | - |
1792 | upload_dir_internal(struct sftp_conn *conn, const char *src, const char *dst, | - |
1793 | int depth, int preserve_flag, int print_flag, int resume, int fsync_flag) | - |
1794 | { | - |
1795 | int ret = 0; | - |
1796 | DIR *dirp; | - |
1797 | struct dirent *dp; | - |
1798 | char *filename, *new_src = NULL, *new_dst = NULL; | - |
1799 | struct stat sb; | - |
1800 | Attrib a, *dirattrib; | - |
1801 | | - |
1802 | if (depth >= MAX_DIR_DEPTH) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1803 | error("Maximum directory depth exceeded: %d levels", depth); | - |
1804 | return -1; never executed: return -1; | 0 |
1805 | } | - |
1806 | | - |
1807 | if (stat(src, &sb) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1808 | error("Couldn't stat directory \"%s\": %s", | - |
1809 | src, strerror(errno)); | - |
1810 | return -1; never executed: return -1; | 0 |
1811 | } | - |
1812 | if (!S_ISDIR(sb.st_mode)) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1813 | error("\"%s\" is not a directory", src); | - |
1814 | return -1; never executed: return -1; | 0 |
1815 | } | - |
1816 | if (print_flag)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1817 | mprintf("Entering %s\n", src); never executed: mprintf("Entering %s\n", src); | 0 |
1818 | | - |
1819 | attrib_clear(&a); | - |
1820 | stat_to_attrib(&sb, &a); | - |
1821 | a.flags &= ~SSH2_FILEXFER_ATTR_SIZE; | - |
1822 | a.flags &= ~SSH2_FILEXFER_ATTR_UIDGID; | - |
1823 | a.perm &= 01777; | - |
1824 | if (!preserve_flag)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1825 | a.flags &= ~SSH2_FILEXFER_ATTR_ACMODTIME; never executed: a.flags &= ~0x00000008; | 0 |
1826 | | - |
1827 | | - |
1828 | | - |
1829 | | - |
1830 | | - |
1831 | | - |
1832 | if (do_mkdir(conn, dst, &a, 0) != 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1833 | if ((dirattrib = do_stat(conn, dst, 0)) == NULL)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1834 | return -1; never executed: return -1; | 0 |
1835 | if (!S_ISDIR(dirattrib->perm)) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1836 | error("\"%s\" exists but is not a directory", dst); | - |
1837 | return -1; never executed: return -1; | 0 |
1838 | } | - |
1839 | } never executed: end of block | 0 |
1840 | | - |
1841 | if ((dirp = opendir(src)) == NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1842 | error("Failed to open dir \"%s\": %s", src, strerror(errno)); | - |
1843 | return -1; never executed: return -1; | 0 |
1844 | } | - |
1845 | | - |
1846 | while (((dp = readdir(dirp)) != NULL) && !interrupted) {TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1847 | if (dp->d_ino == 0)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1848 | continue; never executed: continue; | 0 |
1849 | free(new_dst); | - |
1850 | free(new_src); | - |
1851 | filename = dp->d_name; | - |
1852 | new_dst = path_append(dst, filename); | - |
1853 | new_src = path_append(src, filename); | - |
1854 | | - |
1855 | if (lstat(new_src, &sb) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1856 | logit("%s: lstat failed: %s", filename, | - |
1857 | strerror(errno)); | - |
1858 | ret = -1; | - |
1859 | } else if (S_ISDIR(sb.st_mode)) { never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1860 | if (strcmp(filename, ".") == 0 || never executed: __result = (((const unsigned char *) (const char *) ( filename ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( "." ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1861 | strcmp(filename, "..") == 0) never executed: __result = (((const unsigned char *) (const char *) ( filename ))[3] - __s2[3]); never executed: end of block never executed: end of block never executed: __result = (((const unsigned char *) (const char *) ( ".." ))[3] - __s2[3]); never executed: end of block never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1862 | continue; never executed: continue; | 0 |
1863 | | - |
1864 | if (upload_dir_internal(conn, new_src, new_dst,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1865 | depth + 1, preserve_flag, print_flag, resume,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1866 | fsync_flag) == -1)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1867 | ret = -1; never executed: ret = -1; | 0 |
1868 | } else if (S_ISREG(sb.st_mode)) { never executed: end of block TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1869 | if (do_upload(conn, new_src, new_dst,TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1870 | preserve_flag, resume, fsync_flag) == -1) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1871 | error("Uploading of file %s to %s failed!", | - |
1872 | new_src, new_dst); | - |
1873 | ret = -1; | - |
1874 | } never executed: end of block | 0 |
1875 | } else never executed: end of block | 0 |
1876 | logit("%s: not a regular file\n", filename); never executed: logit("%s: not a regular file\n", filename); | 0 |
1877 | } | - |
1878 | free(new_dst); | - |
1879 | free(new_src); | - |
1880 | | - |
1881 | do_setstat(conn, dst, &a); | - |
1882 | | - |
1883 | (void) closedir(dirp); | - |
1884 | return ret; never executed: return ret; | 0 |
1885 | } | - |
1886 | | - |
1887 | int | - |
1888 | upload_dir(struct sftp_conn *conn, const char *src, const char *dst, | - |
1889 | int preserve_flag, int print_flag, int resume, int fsync_flag) | - |
1890 | { | - |
1891 | char *dst_canon; | - |
1892 | int ret; | - |
1893 | | - |
1894 | if ((dst_canon = do_realpath(conn, dst)) == NULL) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1895 | error("Unable to canonicalize path \"%s\"", dst); | - |
1896 | return -1; never executed: return -1; | 0 |
1897 | } | - |
1898 | | - |
1899 | ret = upload_dir_internal(conn, src, dst_canon, 0, preserve_flag, | - |
1900 | print_flag, resume, fsync_flag); | - |
1901 | | - |
1902 | free(dst_canon); | - |
1903 | return ret; never executed: return ret; | 0 |
1904 | } | - |
1905 | | - |
1906 | char * | - |
1907 | path_append(const char *p1, const char *p2) | - |
1908 | { | - |
1909 | char *ret; | - |
1910 | size_t len = strlen(p1) + strlen(p2) + 2; | - |
1911 | | - |
1912 | ret = xmalloc(len); | - |
1913 | strlcpy(ret, p1, len); | - |
1914 | if (p1[0] != '\0' && p1[strlen(p1) - 1] != '/')TRUE | never evaluated | FALSE | never evaluated |
TRUE | never evaluated | FALSE | never evaluated |
| 0 |
1915 | strlcat(ret, "/", len); never executed: strlcat(ret, "/", len); | 0 |
1916 | strlcat(ret, p2, len); | - |
1917 | | - |
1918 | return(ret); never executed: return(ret); | 0 |
1919 | } | - |
1920 | | - |
| | |