[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 "connect.h"
#include "send-pack.h"
#include "quote.h"
#include "transport.h"
#include "version.h"
#include "sha1-array.h"
#include "gpg-interface.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 sha1_array *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,
		NULL,
	};
	struct child_process po = CHILD_PROCESS_INIT;
	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";
	if (is_repository_shallow())
		argv[i++] = "--shallow";
	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->sha1[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;
	int ret = 0;
	char *line = packet_read_line(in, NULL);
	if (!starts_with(line, "unpack "))
		return error("did not receive remote status");
	if (strcmp(line, "unpack ok")) {
		error("unpack failed: %s", line + 7);
		ret = -1;
	}
	hint = NULL;
	while (1) {
		char *refname;
		char *msg;
		line = packet_read_line(in, NULL);
		if (!line)
			break;
		if (!starts_with(line, "ok ") && !starts_with(line, "ng ")) {
			error("invalid ref status from remote: %s", line);
			ret = -1;
			break;
		}

		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;
}

static int advertise_shallow_grafts_cb(const struct commit_graft *graft, void *cb)
{
	struct strbuf *sb = cb;
	if (graft->nr_parent == -1)
		packet_buf_write(sb, "shallow %s\n", sha1_to_hex(graft->sha1));
	return 0;
}

static void advertise_shallow_grafts_buf(struct strbuf *sb)
{
	if (!is_repository_shallow())
		return;
	for_each_commit_graft(advertise_shallow_grafts_cb, sb);
}

static int ref_update_to_be_sent(const struct ref *ref, const struct send_pack_args *args)
{
	if (!ref->peer_ref && !args->send_mirror)
		return 0;

	/* 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_REJECT_STALE:
	case REF_STATUS_REJECT_NODELETE:
	case REF_STATUS_UPTODATE:
		return 0;
	default:
		return 1;
	}
}

/*
 * the beginning of the next line, or the end of buffer.
 *
 * NEEDSWORK: perhaps move this to git-compat-util.h or somewhere and
 * convert many similar uses found by "git grep -A4 memchr".
 */
static const char *next_line(const char *line, size_t len)
{
	const char *nl = memchr(line, '\n', len);
	if (!nl)
		return line + len; /* incomplete line */
	return nl + 1;
}

static int generate_push_cert(struct strbuf *req_buf,
			      const struct ref *remote_refs,
			      struct send_pack_args *args,
			      const char *cap_string,
			      const char *push_cert_nonce)
{
	const struct ref *ref;
	char *signing_key = xstrdup(get_signing_key());
	const char *cp, *np;
	struct strbuf cert = STRBUF_INIT;
	int update_seen = 0;

	strbuf_addf(&cert, "certificate version 0.1\n");
	strbuf_addf(&cert, "pusher %s ", signing_key);
	datestamp(&cert);
	strbuf_addch(&cert, '\n');
	if (args->url && *args->url) {
		char *anon_url = transport_anonymize_url(args->url);
		strbuf_addf(&cert, "pushee %s\n", anon_url);
		free(anon_url);
	}
	if (push_cert_nonce[0])
		strbuf_addf(&cert, "nonce %s\n", push_cert_nonce);
	strbuf_addstr(&cert, "\n");

	for (ref = remote_refs; ref; ref = ref->next) {
		if (!ref_update_to_be_sent(ref, args))
			continue;
		update_seen = 1;
		strbuf_addf(&cert, "%s %s %s\n",
			    sha1_to_hex(ref->old_sha1),
			    sha1_to_hex(ref->new_sha1),
			    ref->name);
	}
	if (!update_seen)
		goto free_return;

	if (sign_buffer(&cert, &cert, signing_key))
		die(_("failed to sign the push certificate"));

	packet_buf_write(req_buf, "push-cert%c%s", 0, cap_string);
	for (cp = cert.buf; cp < cert.buf + cert.len; cp = np) {
		np = next_line(cp, cert.buf + cert.len - cp);
		packet_buf_write(req_buf,
				 "%.*s", (int)(np - cp), cp);
	}
	packet_buf_write(req_buf, "push-cert-end\n");

free_return:
	free(signing_key);
	strbuf_release(&cert);
	return update_seen;
}

int send_pack(struct send_pack_args *args,
	      int fd[], struct child_process *conn,
	      struct ref *remote_refs,
	      struct sha1_array *extra_have)
{
	int in = fd[0];
	int out = fd[1];
	struct strbuf req_buf = STRBUF_INIT;
	struct strbuf cap_buf = STRBUF_INIT;
	struct ref *ref;
	int need_pack_data = 0;
	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;
	const char *push_cert_nonce = NULL;

	/* 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 (server_supports("no-thin"))
		args->use_thin_pack = 0;
	if (args->push_cert) {
		int len;

		push_cert_nonce = server_feature_value("push-cert", &len);
		if (!push_cert_nonce)
			die(_("the receiving end does not support --signed push"));
		push_cert_nonce = xmemdupz(push_cert_nonce, len);
	}

	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;
	}

	if (status_report)
		strbuf_addstr(&cap_buf, " report-status");
	if (use_sideband)
		strbuf_addstr(&cap_buf, " side-band-64k");
	if (quiet_supported && (args->quiet || !args->progress))
		strbuf_addstr(&cap_buf, " quiet");
	if (agent_supported)
		strbuf_addf(&cap_buf, " agent=%s", git_user_agent_sanitized());

	/*
	 * NEEDSWORK: why does delete-refs have to be so specific to
	 * send-pack machinery that set_ref_status_for_push() cannot
	 * set this bit for us???
	 */
	for (ref = remote_refs; ref; ref = ref->next)
		if (ref->deletion && !allow_deleting_refs)
			ref->status = REF_STATUS_REJECT_NODELETE;

	if (!args->dry_run)
		advertise_shallow_grafts_buf(&req_buf);

	if (!args->dry_run && args->push_cert)
		cmds_sent = generate_push_cert(&req_buf, remote_refs, args,
					       cap_buf.buf, push_cert_nonce);

	/*
	 * Clear the status for each ref and see if we need to send
	 * the pack data.
	 */
	for (ref = remote_refs; ref; ref = ref->next) {
		if (!ref_update_to_be_sent(ref, args))
			continue;

		if (!ref->deletion)
			need_pack_data = 1;

		if (args->dry_run || !status_report)
			ref->status = REF_STATUS_OK;
		else
			ref->status = REF_STATUS_EXPECTING_REPORT;
	}

	/*
	 * Finally, tell the other end!
	 */
	for (ref = remote_refs; ref; ref = ref->next) {
		char *old_hex, *new_hex;

		if (args->dry_run || args->push_cert)
			continue;

		if (!ref_update_to_be_sent(ref, args))
			continue;

		old_hex = sha1_to_hex(ref->old_sha1);
		new_hex = sha1_to_hex(ref->new_sha1);
		if (!cmds_sent) {
			packet_buf_write(&req_buf,
					 "%s %s %s%c%s",
					 old_hex, new_hex, ref->name, 0,
					 cap_buf.buf);
			cmds_sent = 1;
		} else {
			packet_buf_write(&req_buf, "%s %s %s",
					 old_hex, new_hex, ref->name);
		}
	}

	if (args->stateless_rpc) {
		if (!args->dry_run && (cmds_sent || is_repository_shallow())) {
			packet_buf_flush(&req_buf);
			send_sideband(out, -1, req_buf.buf, req_buf.len, LARGE_PACKET_MAX);
		}
	} else {
		write_or_die(out, req_buf.buf, req_buf.len);
		packet_flush(out);
	}
	strbuf_release(&req_buf);
	strbuf_release(&cap_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 (need_pack_data && 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);
			fd[1] = -1;
			return -1;
		}
		if (!args->stateless_rpc)
			/* Closed by pack_objects() via start_command() */
			fd[1] = -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"
47a59185	8	#include "connect.h"
f5d942e1 NTND	9	#include "send-pack.h"
	10	#include "quote.h"
	11	#include "transport.h"
	12	#include "version.h"
13eb4626	13	#include "sha1-array.h"
a85b377d	14	#include "gpg-interface.h"
f5d942e1 NTND	15
	16	static int feed_object(const unsigned char *sha1, int fd, int negative)
	17	{
	18	char buf[42];
	19
	20	if (negative && !has_sha1_file(sha1))
	21	return 1;
	22
	23	memcpy(buf + negative, sha1_to_hex(sha1), 40);
	24	if (negative)
	25	buf[0] = '^';
	26	buf[40 + negative] = '\n';
	27	return write_or_whine(fd, buf, 41 + negative, "send-pack: send refs");
	28	}
	29
	30	/*
	31	* Make a pack stream and spit it out into file descriptor fd
	32	*/
13eb4626	33	static int pack_objects(int fd, struct ref refs, struct sha1_array extra, struct send_pack_args *args)
f5d942e1 NTND	34	{
	35	/*
	36	* The child becomes pack-objects --revs; we feed
	37	* the revision parameters to it via its stdin and
	38	* let its stdout go back to the other end.
	39	*/
	40	const char *argv[] = {
	41	"pack-objects",
	42	"--all-progress-implied",
	43	"--revs",
	44	"--stdout",
	45	NULL,
	46	NULL,
	47	NULL,
	48	NULL,
	49	NULL,
2dacf26d	50	NULL,
f5d942e1	51	};
d3180279	52	struct child_process po = CHILD_PROCESS_INIT;
f5d942e1 NTND	53	int i;
	54
	55	i = 4;
	56	if (args->use_thin_pack)
	57	argv[i++] = "--thin";
	58	if (args->use_ofs_delta)
	59	argv[i++] = "--delta-base-offset";
	60	if (args->quiet \|\| !args->progress)
	61	argv[i++] = "-q";
	62	if (args->progress)
	63	argv[i++] = "--progress";
2dacf26d	64	if (is_repository_shallow())
2dacf26d	65	argv[i++] = "--shallow";
f5d942e1 NTND	66	po.argv = argv;
	67	po.in = -1;
	68	po.out = args->stateless_rpc ? -1 : fd;
	69	po.git_cmd = 1;
	70	if (start_command(&po))
	71	die_errno("git pack-objects failed");
	72
	73	/*
	74	* We feed the pack-objects we just spawned with revision
	75	* parameters by writing to the pipe.
	76	*/
	77	for (i = 0; i < extra->nr; i++)
13eb4626	78	if (!feed_object(extra->sha1[i], po.in, 1))
f5d942e1 NTND	79	break;
	80
	81	while (refs) {
	82	if (!is_null_sha1(refs->old_sha1) &&
	83	!feed_object(refs->old_sha1, po.in, 1))
	84	break;
	85	if (!is_null_sha1(refs->new_sha1) &&
	86	!feed_object(refs->new_sha1, po.in, 0))
	87	break;
	88	refs = refs->next;
	89	}
	90
	91	close(po.in);
	92
	93	if (args->stateless_rpc) {
	94	char *buf = xmalloc(LARGE_PACKET_MAX);
	95	while (1) {
	96	ssize_t n = xread(po.out, buf, LARGE_PACKET_MAX);
	97	if (n <= 0)
	98	break;
	99	send_sideband(fd, -1, buf, n, LARGE_PACKET_MAX);
	100	}
	101	free(buf);
	102	close(po.out);
	103	po.out = -1;
	104	}
	105
	106	if (finish_command(&po))
	107	return -1;
	108	return 0;
	109	}
	110
	111	static int receive_status(int in, struct ref *refs)
	112	{
	113	struct ref *hint;
f5d942e1	114	int ret = 0;
74543a04	115	char *line = packet_read_line(in, NULL);
59556548	116	if (!starts_with(line, "unpack "))
f5d942e1	117	return error("did not receive remote status");
819b929d	118	if (strcmp(line, "unpack ok")) {
f5d942e1 NTND	119	error("unpack failed: %s", line + 7);
	120	ret = -1;
	121	}
	122	hint = NULL;
	123	while (1) {
	124	char *refname;
	125	char *msg;
74543a04 JK	126	line = packet_read_line(in, NULL);
74543a04 JK	127	if (!line)
f5d942e1	128	break;
59556548	129	if (!starts_with(line, "ok ") && !starts_with(line, "ng ")) {
8f9e3e49	130	error("invalid ref status from remote: %s", line);
f5d942e1 NTND	131	ret = -1;
	132	break;
	133	}
	134
f5d942e1 NTND	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
f2c681cf NTND	181	static int advertise_shallow_grafts_cb(const struct commit_graft graft, void cb)
	182	{
	183	struct strbuf *sb = cb;
	184	if (graft->nr_parent == -1)
	185	packet_buf_write(sb, "shallow %s\n", sha1_to_hex(graft->sha1));
	186	return 0;
	187	}
	188
16a2743c	189	static void advertise_shallow_grafts_buf(struct strbuf *sb)
f2c681cf NTND	190	{
	191	if (!is_repository_shallow())
	192	return;
	193	for_each_commit_graft(advertise_shallow_grafts_cb, sb);
	194	}
	195
e40671a3 JH	196	static int ref_update_to_be_sent(const struct ref ref, const struct send_pack_args args)
	197	{
	198	if (!ref->peer_ref && !args->send_mirror)
	199	return 0;
	200
	201	/* Check for statuses set by set_ref_status_for_push() */
	202	switch (ref->status) {
	203	case REF_STATUS_REJECT_NONFASTFORWARD:
	204	case REF_STATUS_REJECT_ALREADY_EXISTS:
	205	case REF_STATUS_REJECT_FETCH_FIRST:
	206	case REF_STATUS_REJECT_NEEDS_FORCE:
	207	case REF_STATUS_REJECT_STALE:
	208	case REF_STATUS_REJECT_NODELETE:
	209	case REF_STATUS_UPTODATE:
	210	return 0;
	211	default:
	212	return 1;
	213	}
	214	}
	215
a85b377d JH	216	/*
	217	* the beginning of the next line, or the end of buffer.
	218	*
	219	* NEEDSWORK: perhaps move this to git-compat-util.h or somewhere and
	220	* convert many similar uses found by "git grep -A4 memchr".
	221	*/
	222	static const char next_line(const char line, size_t len)
	223	{
	224	const char *nl = memchr(line, '\n', len);
	225	if (!nl)
	226	return line + len; /* incomplete line */
	227	return nl + 1;
	228	}
	229
20a7558f JH	230	static int generate_push_cert(struct strbuf *req_buf,
	231	const struct ref *remote_refs,
	232	struct send_pack_args *args,
b89363e4 JH	233	const char *cap_string,
b89363e4 JH	234	const char *push_cert_nonce)
a85b377d JH	235	{
a85b377d JH	236	const struct ref *ref;
a85b377d JH	237	char *signing_key = xstrdup(get_signing_key());
	238	const char cp, np;
	239	struct strbuf cert = STRBUF_INIT;
	240	int update_seen = 0;
	241
a85b377d	242	strbuf_addf(&cert, "certificate version 0.1\n");
fb06b528 JH	243	strbuf_addf(&cert, "pusher %s ", signing_key);
	244	datestamp(&cert);
	245	strbuf_addch(&cert, '\n');
9be89160 JH	246	if (args->url && *args->url) {
	247	char *anon_url = transport_anonymize_url(args->url);
	248	strbuf_addf(&cert, "pushee %s\n", anon_url);
	249	free(anon_url);
	250	}
b89363e4 JH	251	if (push_cert_nonce[0])
b89363e4 JH	252	strbuf_addf(&cert, "nonce %s\n", push_cert_nonce);
a85b377d JH	253	strbuf_addstr(&cert, "\n");
	254
	255	for (ref = remote_refs; ref; ref = ref->next) {
	256	if (!ref_update_to_be_sent(ref, args))
	257	continue;
	258	update_seen = 1;
	259	strbuf_addf(&cert, "%s %s %s\n",
	260	sha1_to_hex(ref->old_sha1),
	261	sha1_to_hex(ref->new_sha1),
	262	ref->name);
	263	}
	264	if (!update_seen)
	265	goto free_return;
	266
	267	if (sign_buffer(&cert, &cert, signing_key))
	268	die(_("failed to sign the push certificate"));
	269
20a7558f	270	packet_buf_write(req_buf, "push-cert%c%s", 0, cap_string);
a85b377d JH	271	for (cp = cert.buf; cp < cert.buf + cert.len; cp = np) {
	272	np = next_line(cp, cert.buf + cert.len - cp);
	273	packet_buf_write(req_buf,
	274	"%.*s", (int)(np - cp), cp);
	275	}
	276	packet_buf_write(req_buf, "push-cert-end\n");
	277
	278	free_return:
	279	free(signing_key);
	280	strbuf_release(&cert);
20a7558f	281	return update_seen;
a85b377d JH	282	}
a85b377d JH	283
f5d942e1 NTND	284	int send_pack(struct send_pack_args *args,
	285	int fd[], struct child_process *conn,
	286	struct ref *remote_refs,
13eb4626	287	struct sha1_array *extra_have)
f5d942e1 NTND	288	{
	289	int in = fd[0];
	290	int out = fd[1];
	291	struct strbuf req_buf = STRBUF_INIT;
887f3533	292	struct strbuf cap_buf = STRBUF_INIT;
f5d942e1	293	struct ref *ref;
ab2b0c90	294	int need_pack_data = 0;
f5d942e1 NTND	295	int allow_deleting_refs = 0;
	296	int status_report = 0;
	297	int use_sideband = 0;
	298	int quiet_supported = 0;
	299	int agent_supported = 0;
	300	unsigned cmds_sent = 0;
	301	int ret;
	302	struct async demux;
b89363e4	303	const char *push_cert_nonce = NULL;
f5d942e1 NTND	304
	305	/* Does the other end support the reporting? */
	306	if (server_supports("report-status"))
	307	status_report = 1;
	308	if (server_supports("delete-refs"))
	309	allow_deleting_refs = 1;
	310	if (server_supports("ofs-delta"))
	311	args->use_ofs_delta = 1;
	312	if (server_supports("side-band-64k"))
	313	use_sideband = 1;
	314	if (server_supports("quiet"))
	315	quiet_supported = 1;
	316	if (server_supports("agent"))
	317	agent_supported = 1;
1ba98a79 CMN	318	if (server_supports("no-thin"))
1ba98a79 CMN	319	args->use_thin_pack = 0;
b89363e4 JH	320	if (args->push_cert) {
	321	int len;
	322
	323	push_cert_nonce = server_feature_value("push-cert", &len);
	324	if (!push_cert_nonce)
	325	die(_("the receiving end does not support --signed push"));
	326	push_cert_nonce = xmemdupz(push_cert_nonce, len);
	327	}
f5d942e1 NTND	328
	329	if (!remote_refs) {
	330	fprintf(stderr, "No refs in common and none specified; doing nothing.\n"
	331	"Perhaps you should specify a branch such as 'master'.\n");
	332	return 0;
	333	}
	334
887f3533 JH	335	if (status_report)
	336	strbuf_addstr(&cap_buf, " report-status");
	337	if (use_sideband)
	338	strbuf_addstr(&cap_buf, " side-band-64k");
	339	if (quiet_supported && (args->quiet \|\| !args->progress))
	340	strbuf_addstr(&cap_buf, " quiet");
	341	if (agent_supported)
	342	strbuf_addf(&cap_buf, " agent=%s", git_user_agent_sanitized());
	343
621b0599 JH	344	/*
	345	* NEEDSWORK: why does delete-refs have to be so specific to
	346	* send-pack machinery that set_ref_status_for_push() cannot
	347	* set this bit for us???
	348	*/
	349	for (ref = remote_refs; ref; ref = ref->next)
	350	if (ref->deletion && !allow_deleting_refs)
	351	ref->status = REF_STATUS_REJECT_NODELETE;
	352
5dbd7676	353	if (!args->dry_run)
f2c681cf	354	advertise_shallow_grafts_buf(&req_buf);
5dbd7676	355
a85b377d	356	if (!args->dry_run && args->push_cert)
20a7558f	357	cmds_sent = generate_push_cert(&req_buf, remote_refs, args,
b89363e4	358	cap_buf.buf, push_cert_nonce);
a85b377d	359
f5d942e1	360	/*
b783aa71 JH	361	* Clear the status for each ref and see if we need to send
b783aa71 JH	362	* the pack data.
f5d942e1	363	*/
f5d942e1	364	for (ref = remote_refs; ref; ref = ref->next) {
e40671a3	365	if (!ref_update_to_be_sent(ref, args))
f5d942e1 NTND	366	continue;
f5d942e1 NTND	367
f5d942e1	368	if (!ref->deletion)
ab2b0c90	369	need_pack_data = 1;
f5d942e1	370
b783aa71	371	if (args->dry_run \|\| !status_report)
f5d942e1	372	ref->status = REF_STATUS_OK;
b783aa71 JH	373	else
	374	ref->status = REF_STATUS_EXPECTING_REPORT;
	375	}
	376
	377	/*
	378	* Finally, tell the other end!
	379	*/
	380	for (ref = remote_refs; ref; ref = ref->next) {
	381	char old_hex, new_hex;
	382
4adf569d	383	if (args->dry_run \|\| args->push_cert)
f5d942e1	384	continue;
f5d942e1	385
b783aa71 JH	386	if (!ref_update_to_be_sent(ref, args))
b783aa71 JH	387	continue;
f5d942e1	388
b783aa71 JH	389	old_hex = sha1_to_hex(ref->old_sha1);
b783aa71 JH	390	new_hex = sha1_to_hex(ref->new_sha1);
c67072b9	391	if (!cmds_sent) {
b783aa71 JH	392	packet_buf_write(&req_buf,
	393	"%s %s %s%c%s",
	394	old_hex, new_hex, ref->name, 0,
	395	cap_buf.buf);
c67072b9	396	cmds_sent = 1;
f5d942e1	397	} else {
b783aa71 JH	398	packet_buf_write(&req_buf, "%s %s %s",
b783aa71 JH	399	old_hex, new_hex, ref->name);
f5d942e1 NTND	400	}
	401	}
	402
	403	if (args->stateless_rpc) {
f2c681cf	404	if (!args->dry_run && (cmds_sent \|\| is_repository_shallow())) {
f5d942e1 NTND	405	packet_buf_flush(&req_buf);
	406	send_sideband(out, -1, req_buf.buf, req_buf.len, LARGE_PACKET_MAX);
	407	}
	408	} else {
cdf4fb8e	409	write_or_die(out, req_buf.buf, req_buf.len);
f5d942e1 NTND	410	packet_flush(out);
	411	}
	412	strbuf_release(&req_buf);
887f3533	413	strbuf_release(&cap_buf);
f5d942e1 NTND	414
	415	if (use_sideband && cmds_sent) {
	416	memset(&demux, 0, sizeof(demux));
	417	demux.proc = sideband_demux;
	418	demux.data = fd;
	419	demux.out = -1;
	420	if (start_async(&demux))
	421	die("send-pack: unable to fork off sideband demultiplexer");
	422	in = demux.out;
	423	}
	424
ab2b0c90	425	if (need_pack_data && cmds_sent) {
f5d942e1 NTND	426	if (pack_objects(out, remote_refs, extra_have, args) < 0) {
	427	for (ref = remote_refs; ref; ref = ref->next)
	428	ref->status = REF_STATUS_NONE;
	429	if (args->stateless_rpc)
	430	close(out);
	431	if (git_connection_is_socket(conn))
	432	shutdown(fd[0], SHUT_WR);
	433	if (use_sideband)
	434	finish_async(&demux);
37cb1dd6	435	fd[1] = -1;
f5d942e1 NTND	436	return -1;
f5d942e1 NTND	437	}
37cb1dd6 JL	438	if (!args->stateless_rpc)
	439	/* Closed by pack_objects() via start_command() */
	440	fd[1] = -1;
f5d942e1 NTND	441	}
	442	if (args->stateless_rpc && cmds_sent)
	443	packet_flush(out);
	444
	445	if (status_report && cmds_sent)
	446	ret = receive_status(in, remote_refs);
	447	else
	448	ret = 0;
	449	if (args->stateless_rpc)
	450	packet_flush(out);
	451
	452	if (use_sideband && cmds_sent) {
	453	if (finish_async(&demux)) {
	454	error("error in sideband demultiplexer");
	455	ret = -1;
	456	}
	457	close(demux.out);
	458	}
	459
	460	if (ret < 0)
	461	return ret;
	462
	463	if (args->porcelain)
	464	return 0;
	465
	466	for (ref = remote_refs; ref; ref = ref->next) {
	467	switch (ref->status) {
	468	case REF_STATUS_NONE:
	469	case REF_STATUS_UPTODATE:
	470	case REF_STATUS_OK:
	471	break;
	472	default:
	473	return -1;
	474	}
	475	}
	476	return 0;
	477	}