crypto/openssh/sftp-client.c

154 send_string_request(struct sftp_conn *conn, u_int id, u_int code, char *s,
161 	buffer_put_int(&msg, id);
164 	debug3("Sent message fd %d T:%u I:%u", conn->fd_out, code, id);
169 send_string_attrs_request(struct sftp_conn *conn, u_int id, u_int code,
176 	buffer_put_int(&msg, id);
180 	debug3("Sent message fd %d T:%u I:%u", conn->fd_out, code, id);
188 	u_int type, id, status;
193 	id = buffer_get_int(&msg);
195 	if (id != expected_id)
196 		fatal("ID mismatch (%u != %u)", id, expected_id);
214 	u_int type, id;
227 	id = buffer_get_int(&msg);
229 	if (id != expected_id)
231 		    errfmt == NULL ? __func__ : errmsg, id, expected_id);
252 	u_int type, id;
259 	id = buffer_get_int(&msg);
261 	debug3("Received stat reply T:%u I:%u", type, id);
262 	if (id != expected_id)
263 		fatal("ID mismatch (%u != %u)", id, expected_id);
288 	u_int type, id, flag;
294 	id = buffer_get_int(&msg);
296 	debug3("Received statvfs reply T:%u I:%u", type, id);
297 	if (id != expected_id)
298 		fatal("ID mismatch (%u != %u)", id, expected_id);
434 	u_int id, status;
439 	id = conn->msg_id++;
441 	buffer_put_int(&msg, id);
444 	debug3("Sent message SSH2_FXP_CLOSE I:%u", id);
446 	status = get_status(conn, id);
461 	u_int count, type, id, handle_len, i, expected_id, ents = 0;
468 	id = conn->msg_id++;
472 	buffer_put_int(&msg, id);
476 	handle = get_handle(conn, id, &handle_len,
490 		id = expected_id = conn->msg_id++;
492 		debug3("Sending SSH2_FXP_READDIR I:%u", id);
496 		buffer_put_int(&msg, id);
505 		id = buffer_get_int(&msg);
507 		debug3("Received reply T:%u I:%u", type, id);
509 		if (id != expected_id)
510 			fatal("ID mismatch (%u != %u)", id, expected_id);
602 	u_int status, id;
606 	id = conn->msg_id++;
607 	send_string_request(conn, id, SSH2_FXP_REMOVE, path, strlen(path));
608 	status = get_status(conn, id);
617 	u_int status, id;
619 	id = conn->msg_id++;
620 	send_string_attrs_request(conn, id, SSH2_FXP_MKDIR, path,
623 	status = get_status(conn, id);
633 	u_int status, id;
635 	id = conn->msg_id++;
636 	send_string_request(conn, id, SSH2_FXP_RMDIR, path,
639 	status = get_status(conn, id);
649 	u_int id;
651 	id = conn->msg_id++;
653 	send_string_request(conn, id,
657 	return(get_decode_stat(conn, id, quiet));
663 	u_int id;
673 	id = conn->msg_id++;
674 	send_string_request(conn, id, SSH2_FXP_LSTAT, path,
677 	return(get_decode_stat(conn, id, quiet));
684 	u_int id;
686 	id = conn->msg_id++;
687 	send_string_request(conn, id, SSH2_FXP_FSTAT, handle,
690 	return(get_decode_stat(conn, id, quiet));
697 	u_int status, id;
699 	id = conn->msg_id++;
700 	send_string_attrs_request(conn, id, SSH2_FXP_SETSTAT, path,
703 	status = get_status(conn, id);
715 	u_int status, id;
717 	id = conn->msg_id++;
718 	send_string_attrs_request(conn, id, SSH2_FXP_FSETSTAT, handle,
721 	status = get_status(conn, id);
732 	u_int type, expected_id, count, id;
736 	expected_id = id = conn->msg_id++;
737 	send_string_request(conn, id, SSH2_FXP_REALPATH, path,
744 	id = buffer_get_int(&msg);
746 	if (id != expected_id)
747 		fatal("ID mismatch (%u != %u)", id, expected_id);
782 	u_int status, id;
788 	id = conn->msg_id++;
791 		buffer_put_int(&msg, id);
795 		buffer_put_int(&msg, id);
805 	status = get_status(conn, id);
817 	u_int status, id;
827 	id = conn->msg_id++;
829 	buffer_put_int(&msg, id);
838 	status = get_status(conn, id);
850 	u_int status, id;
860 	id = conn->msg_id++;
862 	buffer_put_int(&msg, id);
870 	status = get_status(conn, id);
882 	u_int status, id;
891 	id = conn->msg_id++;
894 	buffer_put_int(&msg, id);
898 	debug3("Sent message fsync@openssh.com I:%u", id);
901 	status = get_status(conn, id);
913 	u_int type, expected_id, count, id;
917 	expected_id = id = conn->msg_id++;
918 	send_string_request(conn, id, SSH2_FXP_READLINK, path, strlen(path));
924 	id = buffer_get_int(&msg);
926 	if (id != expected_id)
927 		fatal("ID mismatch (%u != %u)", id, expected_id);
962 	u_int id;
969 	id = conn->msg_id++;
974 	buffer_put_int(&msg, id);
980 	return get_decode_statvfs(conn, st, id, quiet);
989 	u_int id;
996 	id = conn->msg_id++;
1001 	buffer_put_int(&msg, id);
1007 	return get_decode_statvfs(conn, st, id, quiet);
1012 send_read_request(struct sftp_conn *conn, u_int id, u_int64_t offset,
1020 	buffer_put_int(&msg, id);
1038 	u_int handle_len, mode, type, id, buflen, num_req, max_req;
1042 		u_int id;
1055 	/* Do not preserve set[ug]id here, as we do not preserve ownership */
1076 	id = conn->msg_id++;
1078 	buffer_put_int(&msg, id);
1084 	debug3("Sent message SSH2_FXP_OPEN I:%u P:%s", id, remote_path);
1086 	handle = get_handle(conn, id, &handle_len,
1154 			req->id = conn->msg_id++;
1160 			send_read_request(conn, req->id, req->offset,
1167 		id = buffer_get_int(&msg);
1168 		debug3("Received reply T:%u I:%u R:%d", type, id, max_req);
1172 		    req != NULL && req->id != id;
1176 			fatal("Unexpected reply %u", id);
1221 				req->id = conn->msg_id++;
1224 				send_read_request(conn, req->id,
1427 	u_int handle_len, id, type;
1436 		u_int id;
1473 	id = conn->msg_id++;
1475 	buffer_put_int(&msg, id);
1480 	debug3("Sent message SSH2_FXP_OPEN I:%u P:%s", id, remote_path);
1484 	handle = get_handle(conn, id, &handle_len,
1492 	startid = ackid = id + 1;
1523 			ack->id = ++id;
1530 			buffer_put_int(&msg, ack->id);
1536 			    id, (unsigned long long)offset, len);
1541 			fatal("Unexpected ACK %u", id);
1543 		if (id == startid || len == 0 ||
1544 		    id - ackid >= conn->num_requests) {
1561 			    ack != NULL && ack->id != r_id;
1568 			    ack->id, ack->len, (long long)ack->offset);