crypto/openssh/sftp-client.c

167 send_string_request(struct sftp_conn *conn, u_int id, u_int code, const char *s,
176 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
180 	debug3("Sent message fd %d T:%u I:%u", conn->fd_out, code, id);
185 send_string_attrs_request(struct sftp_conn *conn, u_int id, u_int code,
194 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
199 	debug3("Sent message fd %d T:%u I:%u", conn->fd_out, code, id);
208 	u_int id, status;
215 	    (r = sshbuf_get_u32(msg, &id)) != 0)
218 	if (id != expected_id)
219 		fatal("ID mismatch (%u != %u)", id, expected_id);
238 	u_int id, status;
254 	    (r = sshbuf_get_u32(msg, &id)) != 0)
257 	if (id != expected_id)
259 		    errfmt == NULL ? __func__ : errmsg, id, expected_id);
282 	u_int id;
292 	    (r = sshbuf_get_u32(msg, &id)) != 0)
295 	debug3("Received stat reply T:%u I:%u", type, id);
296 	if (id != expected_id)
297 		fatal("ID mismatch (%u != %u)", id, expected_id);
329 	u_int id;
338 	    (r = sshbuf_get_u32(msg, &id)) != 0)
341 	debug3("Received statvfs reply T:%u I:%u", type, id);
342 	if (id != expected_id)
343 		fatal("ID mismatch (%u != %u)", id, expected_id);
493 	u_int id, status;
500 	id = conn->msg_id++;
502 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
506 	debug3("Sent message SSH2_FXP_CLOSE I:%u", id);
508 	status = get_status(conn, id);
523 	u_int count, id, i, expected_id, ents = 0;
532 	id = conn->msg_id++;
537 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
542 	handle = get_handle(conn, id, &handle_len,
556 		id = expected_id = conn->msg_id++;
558 		debug3("Sending SSH2_FXP_READDIR I:%u", id);
562 		    (r = sshbuf_put_u32(msg, id)) != 0 ||
572 		    (r = sshbuf_get_u32(msg, &id)) != 0)
575 		debug3("Received reply T:%u I:%u", type, id);
577 		if (id != expected_id)
578 			fatal("ID mismatch (%u != %u)", id, expected_id);
688 	u_int status, id;
692 	id = conn->msg_id++;
693 	send_string_request(conn, id, SSH2_FXP_REMOVE, path, strlen(path));
694 	status = get_status(conn, id);
703 	u_int status, id;
705 	id = conn->msg_id++;
706 	send_string_attrs_request(conn, id, SSH2_FXP_MKDIR, path,
709 	status = get_status(conn, id);
719 	u_int status, id;
721 	id = conn->msg_id++;
722 	send_string_request(conn, id, SSH2_FXP_RMDIR, path,
725 	status = get_status(conn, id);
735 	u_int id;
737 	id = conn->msg_id++;
739 	send_string_request(conn, id,
743 	return(get_decode_stat(conn, id, quiet));
749 	u_int id;
759 	id = conn->msg_id++;
760 	send_string_request(conn, id, SSH2_FXP_LSTAT, path,
763 	return(get_decode_stat(conn, id, quiet));
771 	u_int id;
773 	id = conn->msg_id++;
774 	send_string_request(conn, id, SSH2_FXP_FSTAT, handle,
777 	return(get_decode_stat(conn, id, quiet));
784 	u_int status, id;
786 	id = conn->msg_id++;
787 	send_string_attrs_request(conn, id, SSH2_FXP_SETSTAT, path,
790 	status = get_status(conn, id);
802 	u_int status, id;
804 	id = conn->msg_id++;
805 	send_string_attrs_request(conn, id, SSH2_FXP_FSETSTAT, handle,
808 	status = get_status(conn, id);
819 	u_int expected_id, count, id;
825 	expected_id = id = conn->msg_id++;
826 	send_string_request(conn, id, SSH2_FXP_REALPATH, path,
834 	    (r = sshbuf_get_u32(msg, &id)) != 0)
837 	if (id != expected_id)
838 		fatal("ID mismatch (%u != %u)", id, expected_id);
877 	u_int status, id;
884 	id = conn->msg_id++;
887 		    (r = sshbuf_put_u32(msg, id)) != 0 ||
893 		    (r = sshbuf_put_u32(msg, id)) != 0)
905 	status = get_status(conn, id);
917 	u_int status, id;
929 	id = conn->msg_id++;
931 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
941 	status = get_status(conn, id);
953 	u_int status, id;
965 	id = conn->msg_id++;
967 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
976 	status = get_status(conn, id);
988 	u_int status, id;
998 	id = conn->msg_id++;
1000 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
1005 	debug3("Sent message fsync@openssh.com I:%u", id);
1008 	status = get_status(conn, id);
1020 	u_int expected_id, count, id;
1026 	expected_id = id = conn->msg_id++;
1027 	send_string_request(conn, id, SSH2_FXP_READLINK, path, strlen(path));
1034 	    (r = sshbuf_get_u32(msg, &id)) != 0)
1037 	if (id != expected_id)
1038 		fatal("ID mismatch (%u != %u)", id, expected_id);
1077 	u_int id;
1085 	id = conn->msg_id++;
1091 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
1098 	return get_decode_statvfs(conn, st, id, quiet);
1107 	u_int id;
1114 	id = conn->msg_id++;
1120 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
1127 	return get_decode_statvfs(conn, st, id, quiet);
1132 send_read_request(struct sftp_conn *conn, u_int id, u_int64_t offset,
1142 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
1162 	u_int mode, id, buflen, num_req, max_req, status = SSH2_FX_OK;
1167 		u_int id;
1181 	/* Do not preserve set[ug]id here, as we do not preserve ownership */
1205 	id = conn->msg_id++;
1207 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
1213 	debug3("Sent message SSH2_FXP_OPEN I:%u P:%s", id, remote_path);
1215 	handle = get_handle(conn, id, &handle_len,
1283 			req->id = conn->msg_id++;
1289 			send_read_request(conn, req->id, req->offset,
1296 		    (r = sshbuf_get_u32(msg, &id)) != 0)
1298 		debug3("Received reply T:%u I:%u R:%d", type, id, max_req);
1302 		    req != NULL && req->id != id;
1306 			fatal("Unexpected reply %u", id);
1355 				req->id = conn->msg_id++;
1358 				send_read_request(conn, req->id,
1564 	u_int id;
1574 		u_int id;
1633 	id = conn->msg_id++;
1635 	    (r = sshbuf_put_u32(msg, id)) != 0 ||
1642 	debug3("Sent message SSH2_FXP_OPEN I:%u P:%s", id, remote_path);
1646 	handle = get_handle(conn, id, &handle_len,
1654 	startid = ackid = id + 1;
1685 			ack->id = ++id;
1692 			    (r = sshbuf_put_u32(msg, ack->id)) != 0 ||
1701 			    id, (unsigned long long)offset, len);
1706 			fatal("Unexpected ACK %u", id);
1708 		if (id == startid || len == 0 ||
1709 		    id - ackid >= conn->num_requests) {
1730 			    ack != NULL && ack->id != rid;
1737 			    ack->id, ack->len, (long long)ack->offset);