[thirdparty/git.git] / send-pack.c

#include "builtin.h"
#include "commit.h"
#include "refs.h"
#include "pkt-line.h"
#include "sideband.h"
#include "run-command.h"
#include "remote.h"
#include "send-pack.h"
#include "quote.h"
#include "transport.h"
#include "version.h"

static int feed_object(const unsigned char *sha1, int fd, int negative)
{
	char buf[42];

	if (negative && !has_sha1_file(sha1))
		return 1;

	memcpy(buf + negative, sha1_to_hex(sha1), 40);
	if (negative)
		buf[0] = '^';
	buf[40 + negative] = '\n';
	return write_or_whine(fd, buf, 41 + negative, "send-pack: send refs");
}

/*
 * Make a pack stream and spit it out into file descriptor fd
 */
static int pack_objects(int fd, struct ref *refs, struct extra_have_objects *extra, struct send_pack_args *args)
{
	/*
	 * The child becomes pack-objects --revs; we feed
	 * the revision parameters to it via its stdin and
	 * let its stdout go back to the other end.
	 */
	const char *argv[] = {
		"pack-objects",
		"--all-progress-implied",
		"--revs",
		"--stdout",
		NULL,
		NULL,
		NULL,
		NULL,
		NULL,
	};
	struct child_process po;
	int i;

	i = 4;
	if (args->use_thin_pack)
		argv[i++] = "--thin";
	if (args->use_ofs_delta)
		argv[i++] = "--delta-base-offset";
	if (args->quiet || !args->progress)
		argv[i++] = "-q";
	if (args->progress)
		argv[i++] = "--progress";
	memset(&po, 0, sizeof(po));
	po.argv = argv;
	po.in = -1;
	po.out = args->stateless_rpc ? -1 : fd;
	po.git_cmd = 1;
	if (start_command(&po))
		die_errno("git pack-objects failed");

	/*
	 * We feed the pack-objects we just spawned with revision
	 * parameters by writing to the pipe.
	 */
	for (i = 0; i < extra->nr; i++)
		if (!feed_object(extra->array[i], po.in, 1))
			break;

	while (refs) {
		if (!is_null_sha1(refs->old_sha1) &&
		    !feed_object(refs->old_sha1, po.in, 1))
			break;
		if (!is_null_sha1(refs->new_sha1) &&
		    !feed_object(refs->new_sha1, po.in, 0))
			break;
		refs = refs->next;
	}

	close(po.in);

	if (args->stateless_rpc) {
		char *buf = xmalloc(LARGE_PACKET_MAX);
		while (1) {
			ssize_t n = xread(po.out, buf, LARGE_PACKET_MAX);
			if (n <= 0)
				break;
			send_sideband(fd, -1, buf, n, LARGE_PACKET_MAX);
		}
		free(buf);
		close(po.out);
		po.out = -1;
	}

	if (finish_command(&po))
		return -1;
	return 0;
}

static int receive_status(int in, struct ref *refs)
{
	struct ref *hint;
	char line[1000];
	int ret = 0;
	int len = packet_read_line(in, line, sizeof(line));
	if (prefixcmp(line, "unpack "))
		return error("did not receive remote status");
	if (strcmp(line, "unpack ok\n")) {
		char *p = line + strlen(line) - 1;
		if (*p == '\n')
			*p = '\0';
		error("unpack failed: %s", line + 7);
		ret = -1;
	}
	hint = NULL;
	while (1) {
		char *refname;
		char *msg;
		len = packet_read_line(in, line, sizeof(line));
		if (!len)
			break;
		if (prefixcmp(line, "ok ") && prefixcmp(line, "ng ")) {
			error("invalid ref status from remote: %s", line);
			ret = -1;
			break;
		}

		line[strlen(line)-1] = '\0';
		refname = line + 3;
		msg = strchr(refname, ' ');
		if (msg)
			*msg++ = '\0';

		/* first try searching at our hint, falling back to all refs */
		if (hint)
			hint = find_ref_by_name(hint, refname);
		if (!hint)
			hint = find_ref_by_name(refs, refname);
		if (!hint) {
			warning("remote reported status on unknown ref: %s",
					refname);
			continue;
		}
		if (hint->status != REF_STATUS_EXPECTING_REPORT) {
			warning("remote reported status on unexpected ref: %s",
					refname);
			continue;
		}

		if (line[0] == 'o' && line[1] == 'k')
			hint->status = REF_STATUS_OK;
		else {
			hint->status = REF_STATUS_REMOTE_REJECT;
			ret = -1;
		}
		if (msg)
			hint->remote_status = xstrdup(msg);
		/* start our next search from the next ref */
		hint = hint->next;
	}
	return ret;
}

static int sideband_demux(int in, int out, void *data)
{
	int *fd = data, ret;
#ifdef NO_PTHREADS
	close(fd[1]);
#endif
	ret = recv_sideband("send-pack", fd[0], out);
	close(out);
	return ret;
}

int send_pack(struct send_pack_args *args,
	      int fd[], struct child_process *conn,
	      struct ref *remote_refs,
	      struct extra_have_objects *extra_have)
{
	int in = fd[0];
	int out = fd[1];
	struct strbuf req_buf = STRBUF_INIT;
	struct ref *ref;
	int new_refs;
	int allow_deleting_refs = 0;
	int status_report = 0;
	int use_sideband = 0;
	int quiet_supported = 0;
	int agent_supported = 0;
	unsigned cmds_sent = 0;
	int ret;
	struct async demux;

	/* Does the other end support the reporting? */
	if (server_supports("report-status"))
		status_report = 1;
	if (server_supports("delete-refs"))
		allow_deleting_refs = 1;
	if (server_supports("ofs-delta"))
		args->use_ofs_delta = 1;
	if (server_supports("side-band-64k"))
		use_sideband = 1;
	if (server_supports("quiet"))
		quiet_supported = 1;
	if (server_supports("agent"))
		agent_supported = 1;

	if (!remote_refs) {
		fprintf(stderr, "No refs in common and none specified; doing nothing.\n"
			"Perhaps you should specify a branch such as 'master'.\n");
		return 0;
	}

	/*
	 * Finally, tell the other end!
	 */
	new_refs = 0;
	for (ref = remote_refs; ref; ref = ref->next) {
		if (!ref->peer_ref && !args->send_mirror)
			continue;

		/* Check for statuses set by set_ref_status_for_push() */
		switch (ref->status) {
		case REF_STATUS_REJECT_NONFASTFORWARD:
		case REF_STATUS_REJECT_ALREADY_EXISTS:
		case REF_STATUS_REJECT_FETCH_FIRST:
		case REF_STATUS_REJECT_NEEDS_FORCE:
		case REF_STATUS_UPTODATE:
			continue;
		default:
			; /* do nothing */
		}

		if (ref->deletion && !allow_deleting_refs) {
			ref->status = REF_STATUS_REJECT_NODELETE;
			continue;
		}

		if (!ref->deletion)
			new_refs++;

		if (args->dry_run) {
			ref->status = REF_STATUS_OK;
		} else {
			char *old_hex = sha1_to_hex(ref->old_sha1);
			char *new_hex = sha1_to_hex(ref->new_sha1);
			int quiet = quiet_supported && (args->quiet || !args->progress);

			if (!cmds_sent && (status_report || use_sideband ||
					   quiet || agent_supported)) {
				packet_buf_write(&req_buf,
						 "%s %s %s%c%s%s%s%s%s",
						 old_hex, new_hex, ref->name, 0,
						 status_report ? " report-status" : "",
						 use_sideband ? " side-band-64k" : "",
						 quiet ? " quiet" : "",
						 agent_supported ? " agent=" : "",
						 agent_supported ? git_user_agent_sanitized() : ""
						);
			}
			else
				packet_buf_write(&req_buf, "%s %s %s",
						 old_hex, new_hex, ref->name);
			ref->status = status_report ?
				REF_STATUS_EXPECTING_REPORT :
				REF_STATUS_OK;
			cmds_sent++;
		}
	}

	if (args->stateless_rpc) {
		if (!args->dry_run && cmds_sent) {
			packet_buf_flush(&req_buf);
			send_sideband(out, -1, req_buf.buf, req_buf.len, LARGE_PACKET_MAX);
		}
	} else {
		safe_write(out, req_buf.buf, req_buf.len);
		packet_flush(out);
	}
	strbuf_release(&req_buf);

	if (use_sideband && cmds_sent) {
		memset(&demux, 0, sizeof(demux));
		demux.proc = sideband_demux;
		demux.data = fd;
		demux.out = -1;
		if (start_async(&demux))
			die("send-pack: unable to fork off sideband demultiplexer");
		in = demux.out;
	}

	if (new_refs && cmds_sent) {
		if (pack_objects(out, remote_refs, extra_have, args) < 0) {
			for (ref = remote_refs; ref; ref = ref->next)
				ref->status = REF_STATUS_NONE;
			if (args->stateless_rpc)
				close(out);
			if (git_connection_is_socket(conn))
				shutdown(fd[0], SHUT_WR);
			if (use_sideband)
				finish_async(&demux);
			return -1;
		}
	}
	if (args->stateless_rpc && cmds_sent)
		packet_flush(out);

	if (status_report && cmds_sent)
		ret = receive_status(in, remote_refs);
	else
		ret = 0;
	if (args->stateless_rpc)
		packet_flush(out);

	if (use_sideband && cmds_sent) {
		if (finish_async(&demux)) {
			error("error in sideband demultiplexer");
			ret = -1;
		}
		close(demux.out);
	}

	if (ret < 0)
		return ret;

	if (args->porcelain)
		return 0;

	for (ref = remote_refs; ref; ref = ref->next) {
		switch (ref->status) {
		case REF_STATUS_NONE:
		case REF_STATUS_UPTODATE:
		case REF_STATUS_OK:
			break;
		default:
			return -1;
		}
	}
	return 0;
}
Commit	Line	Data
f5d942e1 NTND	1	#include "builtin.h"
	2	#include "commit.h"
	3	#include "refs.h"
	4	#include "pkt-line.h"
	5	#include "sideband.h"
	6	#include "run-command.h"
	7	#include "remote.h"
	8	#include "send-pack.h"
	9	#include "quote.h"
	10	#include "transport.h"
	11	#include "version.h"
	12
	13	static int feed_object(const unsigned char *sha1, int fd, int negative)
	14	{
	15	char buf[42];
	16
	17	if (negative && !has_sha1_file(sha1))
	18	return 1;
	19
	20	memcpy(buf + negative, sha1_to_hex(sha1), 40);
	21	if (negative)
	22	buf[0] = '^';
	23	buf[40 + negative] = '\n';
	24	return write_or_whine(fd, buf, 41 + negative, "send-pack: send refs");
	25	}
	26
	27	/*
	28	* Make a pack stream and spit it out into file descriptor fd
	29	*/
	30	static int pack_objects(int fd, struct ref refs, struct extra_have_objects extra, struct send_pack_args *args)
	31	{
	32	/*
	33	* The child becomes pack-objects --revs; we feed
	34	* the revision parameters to it via its stdin and
	35	* let its stdout go back to the other end.
	36	*/
	37	const char *argv[] = {
	38	"pack-objects",
	39	"--all-progress-implied",
	40	"--revs",
	41	"--stdout",
	42	NULL,
	43	NULL,
	44	NULL,
	45	NULL,
	46	NULL,
	47	};
	48	struct child_process po;
	49	int i;
	50
	51	i = 4;
	52	if (args->use_thin_pack)
	53	argv[i++] = "--thin";
	54	if (args->use_ofs_delta)
	55	argv[i++] = "--delta-base-offset";
	56	if (args->quiet \|\| !args->progress)
	57	argv[i++] = "-q";
	58	if (args->progress)
	59	argv[i++] = "--progress";
	60	memset(&po, 0, sizeof(po));
	61	po.argv = argv;
	62	po.in = -1;
	63	po.out = args->stateless_rpc ? -1 : fd;
	64	po.git_cmd = 1;
65	if (start_command(&po))
66	die_errno("git pack-objects failed");
67
68	/*
69	* We feed the pack-objects we just spawned with revision
70	* parameters by writing to the pipe.
71	*/
72	for (i = 0; i < extra->nr; i++)
73	if (!feed_object(extra->array[i], po.in, 1))
74	break;
75
76	while (refs) {
77	if (!is_null_sha1(refs->old_sha1) &&
78	!feed_object(refs->old_sha1, po.in, 1))
79	break;
80	if (!is_null_sha1(refs->new_sha1) &&
81	!feed_object(refs->new_sha1, po.in, 0))
82	break;
83	refs = refs->next;
84	}
85
86	close(po.in);
87
88	if (args->stateless_rpc) {
89	char *buf = xmalloc(LARGE_PACKET_MAX);
90	while (1) {
91	ssize_t n = xread(po.out, buf, LARGE_PACKET_MAX);
92	if (n <= 0)
93	break;
94	send_sideband(fd, -1, buf, n, LARGE_PACKET_MAX);
95	}
96	free(buf);
97	close(po.out);
98	po.out = -1;
99	}
100
101	if (finish_command(&po))
102	return -1;
103	return 0;
104	}
105
106	static int receive_status(int in, struct ref *refs)
107	{
108	struct ref *hint;
109	char line[1000];
110	int ret = 0;
111	int len = packet_read_line(in, line, sizeof(line));
8f9e3e49	112	if (prefixcmp(line, "unpack "))
f5d942e1	113	return error("did not receive remote status");
8f9e3e49	114	if (strcmp(line, "unpack ok\n")) {
f5d942e1 NTND	115	char *p = line + strlen(line) - 1;
	116	if (*p == '\n')
	117	*p = '\0';
	118	error("unpack failed: %s", line + 7);
	119	ret = -1;
	120	}
	121	hint = NULL;
	122	while (1) {
	123	char *refname;
	124	char *msg;
	125	len = packet_read_line(in, line, sizeof(line));
	126	if (!len)
	127	break;
8f9e3e49 JK	128	if (prefixcmp(line, "ok ") && prefixcmp(line, "ng ")) {
8f9e3e49 JK	129	error("invalid ref status from remote: %s", line);
f5d942e1 NTND	130	ret = -1;
	131	break;
	132	}
	133
	134	line[strlen(line)-1] = '\0';
	135	refname = line + 3;
	136	msg = strchr(refname, ' ');
	137	if (msg)
	138	*msg++ = '\0';
	139
	140	/* first try searching at our hint, falling back to all refs */
	141	if (hint)
	142	hint = find_ref_by_name(hint, refname);
	143	if (!hint)
	144	hint = find_ref_by_name(refs, refname);
	145	if (!hint) {
	146	warning("remote reported status on unknown ref: %s",
	147	refname);
	148	continue;
	149	}
	150	if (hint->status != REF_STATUS_EXPECTING_REPORT) {
	151	warning("remote reported status on unexpected ref: %s",
	152	refname);
	153	continue;
	154	}
	155
	156	if (line[0] == 'o' && line[1] == 'k')
	157	hint->status = REF_STATUS_OK;
	158	else {
	159	hint->status = REF_STATUS_REMOTE_REJECT;
	160	ret = -1;
	161	}
	162	if (msg)
	163	hint->remote_status = xstrdup(msg);
	164	/* start our next search from the next ref */
	165	hint = hint->next;
	166	}
	167	return ret;
	168	}
	169
	170	static int sideband_demux(int in, int out, void *data)
	171	{
	172	int *fd = data, ret;
	173	#ifdef NO_PTHREADS
	174	close(fd[1]);
	175	#endif
	176	ret = recv_sideband("send-pack", fd[0], out);
	177	close(out);
	178	return ret;
	179	}
	180
	181	int send_pack(struct send_pack_args *args,
	182	int fd[], struct child_process *conn,
	183	struct ref *remote_refs,
	184	struct extra_have_objects *extra_have)
	185	{
	186	int in = fd[0];
	187	int out = fd[1];
	188	struct strbuf req_buf = STRBUF_INIT;
	189	struct ref *ref;
	190	int new_refs;
	191	int allow_deleting_refs = 0;
	192	int status_report = 0;
	193	int use_sideband = 0;
194	int quiet_supported = 0;
195	int agent_supported = 0;
196	unsigned cmds_sent = 0;
197	int ret;
198	struct async demux;
199
200	/* Does the other end support the reporting? */
201	if (server_supports("report-status"))
202	status_report = 1;
203	if (server_supports("delete-refs"))
204	allow_deleting_refs = 1;
205	if (server_supports("ofs-delta"))
206	args->use_ofs_delta = 1;
207	if (server_supports("side-band-64k"))
208	use_sideband = 1;
209	if (server_supports("quiet"))
210	quiet_supported = 1;
211	if (server_supports("agent"))
212	agent_supported = 1;
213
214	if (!remote_refs) {
215	fprintf(stderr, "No refs in common and none specified; doing nothing.\n"
216	"Perhaps you should specify a branch such as 'master'.\n");
217	return 0;
218	}
219
220	/*
221	* Finally, tell the other end!
222	*/
223	new_refs = 0;
224	for (ref = remote_refs; ref; ref = ref->next) {
225	if (!ref->peer_ref && !args->send_mirror)
226	continue;
227
228	/* Check for statuses set by set_ref_status_for_push() */
229	switch (ref->status) {
230	case REF_STATUS_REJECT_NONFASTFORWARD:
dbfeddb1	231	case REF_STATUS_REJECT_ALREADY_EXISTS:
75e5c0dc JH	232	case REF_STATUS_REJECT_FETCH_FIRST:
75e5c0dc JH	233	case REF_STATUS_REJECT_NEEDS_FORCE:
f5d942e1 NTND	234	case REF_STATUS_UPTODATE:
	235	continue;
	236	default:
	237	; /* do nothing */
	238	}
	239
	240	if (ref->deletion && !allow_deleting_refs) {
	241	ref->status = REF_STATUS_REJECT_NODELETE;
	242	continue;
	243	}
	244
	245	if (!ref->deletion)
	246	new_refs++;
	247
	248	if (args->dry_run) {
	249	ref->status = REF_STATUS_OK;
	250	} else {
	251	char *old_hex = sha1_to_hex(ref->old_sha1);
	252	char *new_hex = sha1_to_hex(ref->new_sha1);
	253	int quiet = quiet_supported && (args->quiet \|\| !args->progress);
	254
	255	if (!cmds_sent && (status_report \|\| use_sideband \|\|
	256	quiet \|\| agent_supported)) {
	257	packet_buf_write(&req_buf,
	258	"%s %s %s%c%s%s%s%s%s",
	259	old_hex, new_hex, ref->name, 0,
	260	status_report ? " report-status" : "",
	261	use_sideband ? " side-band-64k" : "",
	262	quiet ? " quiet" : "",
	263	agent_supported ? " agent=" : "",
	264	agent_supported ? git_user_agent_sanitized() : ""
	265	);
	266	}
	267	else
	268	packet_buf_write(&req_buf, "%s %s %s",
	269	old_hex, new_hex, ref->name);
	270	ref->status = status_report ?
	271	REF_STATUS_EXPECTING_REPORT :
	272	REF_STATUS_OK;
	273	cmds_sent++;
	274	}
	275	}
	276
	277	if (args->stateless_rpc) {
	278	if (!args->dry_run && cmds_sent) {
	279	packet_buf_flush(&req_buf);
	280	send_sideband(out, -1, req_buf.buf, req_buf.len, LARGE_PACKET_MAX);
	281	}
	282	} else {
	283	safe_write(out, req_buf.buf, req_buf.len);
	284	packet_flush(out);
	285	}
	286	strbuf_release(&req_buf);
	287
	288	if (use_sideband && cmds_sent) {
	289	memset(&demux, 0, sizeof(demux));
	290	demux.proc = sideband_demux;
	291	demux.data = fd;
	292	demux.out = -1;
	293	if (start_async(&demux))
	294	die("send-pack: unable to fork off sideband demultiplexer");
	295	in = demux.out;
	296	}
	297
298	if (new_refs && cmds_sent) {
299	if (pack_objects(out, remote_refs, extra_have, args) < 0) {
300	for (ref = remote_refs; ref; ref = ref->next)
301	ref->status = REF_STATUS_NONE;
302	if (args->stateless_rpc)
303	close(out);
304	if (git_connection_is_socket(conn))
305	shutdown(fd[0], SHUT_WR);
306	if (use_sideband)
307	finish_async(&demux);
308	return -1;
309	}
310	}
311	if (args->stateless_rpc && cmds_sent)
312	packet_flush(out);
313
314	if (status_report && cmds_sent)
315	ret = receive_status(in, remote_refs);
316	else
317	ret = 0;
318	if (args->stateless_rpc)
319	packet_flush(out);
320
321	if (use_sideband && cmds_sent) {
322	if (finish_async(&demux)) {
323	error("error in sideband demultiplexer");
324	ret = -1;
325	}
326	close(demux.out);
327	}
328
329	if (ret < 0)
330	return ret;
331
332	if (args->porcelain)
333	return 0;
334
335	for (ref = remote_refs; ref; ref = ref->next) {
336	switch (ref->status) {
337	case REF_STATUS_NONE:
338	case REF_STATUS_UPTODATE:
339	case REF_STATUS_OK:
340	break;
341	default:
342	return -1;
343	}
344	}
345	return 0;
346	}