6 #include "run-command.h"
11 #include "transport.h"
13 #include "sha1-array.h"
15 static int feed_object(const unsigned char *sha1
, int fd
, int negative
)
19 if (negative
&& !has_sha1_file(sha1
))
22 memcpy(buf
+ negative
, sha1_to_hex(sha1
), 40);
25 buf
[40 + negative
] = '\n';
26 return write_or_whine(fd
, buf
, 41 + negative
, "send-pack: send refs");
30 * Make a pack stream and spit it out into file descriptor fd
32 static int pack_objects(int fd
, struct ref
*refs
, struct sha1_array
*extra
, struct send_pack_args
*args
)
35 * The child becomes pack-objects --revs; we feed
36 * the revision parameters to it via its stdin and
37 * let its stdout go back to the other end.
39 const char *argv
[] = {
41 "--all-progress-implied",
50 struct child_process po
;
54 if (args
->use_thin_pack
)
56 if (args
->use_ofs_delta
)
57 argv
[i
++] = "--delta-base-offset";
58 if (args
->quiet
|| !args
->progress
)
61 argv
[i
++] = "--progress";
62 memset(&po
, 0, sizeof(po
));
65 po
.out
= args
->stateless_rpc
? -1 : fd
;
67 if (start_command(&po
))
68 die_errno("git pack-objects failed");
71 * We feed the pack-objects we just spawned with revision
72 * parameters by writing to the pipe.
74 for (i
= 0; i
< extra
->nr
; i
++)
75 if (!feed_object(extra
->sha1
[i
], po
.in
, 1))
79 if (!is_null_sha1(refs
->old_sha1
) &&
80 !feed_object(refs
->old_sha1
, po
.in
, 1))
82 if (!is_null_sha1(refs
->new_sha1
) &&
83 !feed_object(refs
->new_sha1
, po
.in
, 0))
90 if (args
->stateless_rpc
) {
91 char *buf
= xmalloc(LARGE_PACKET_MAX
);
93 ssize_t n
= xread(po
.out
, buf
, LARGE_PACKET_MAX
);
96 send_sideband(fd
, -1, buf
, n
, LARGE_PACKET_MAX
);
103 if (finish_command(&po
))
108 static int receive_status(int in
, struct ref
*refs
)
112 char *line
= packet_read_line(in
, NULL
);
113 if (!starts_with(line
, "unpack "))
114 return error("did not receive remote status");
115 if (strcmp(line
, "unpack ok")) {
116 error("unpack failed: %s", line
+ 7);
123 line
= packet_read_line(in
, NULL
);
126 if (!starts_with(line
, "ok ") && !starts_with(line
, "ng ")) {
127 error("invalid ref status from remote: %s", line
);
133 msg
= strchr(refname
, ' ');
137 /* first try searching at our hint, falling back to all refs */
139 hint
= find_ref_by_name(hint
, refname
);
141 hint
= find_ref_by_name(refs
, refname
);
143 warning("remote reported status on unknown ref: %s",
147 if (hint
->status
!= REF_STATUS_EXPECTING_REPORT
) {
148 warning("remote reported status on unexpected ref: %s",
153 if (line
[0] == 'o' && line
[1] == 'k')
154 hint
->status
= REF_STATUS_OK
;
156 hint
->status
= REF_STATUS_REMOTE_REJECT
;
160 hint
->remote_status
= xstrdup(msg
);
161 /* start our next search from the next ref */
167 static int sideband_demux(int in
, int out
, void *data
)
173 ret
= recv_sideband("send-pack", fd
[0], out
);
178 static int advertise_shallow_grafts_cb(const struct commit_graft
*graft
, void *cb
)
180 struct strbuf
*sb
= cb
;
181 if (graft
->nr_parent
== -1)
182 packet_buf_write(sb
, "shallow %s\n", sha1_to_hex(graft
->sha1
));
186 static void advertise_shallow_grafts_buf(struct strbuf
*sb
)
188 if (!is_repository_shallow())
190 for_each_commit_graft(advertise_shallow_grafts_cb
, sb
);
193 int send_pack(struct send_pack_args
*args
,
194 int fd
[], struct child_process
*conn
,
195 struct ref
*remote_refs
,
196 struct sha1_array
*extra_have
)
200 struct strbuf req_buf
= STRBUF_INIT
;
203 int allow_deleting_refs
= 0;
204 int status_report
= 0;
205 int use_sideband
= 0;
206 int quiet_supported
= 0;
207 int agent_supported
= 0;
208 unsigned cmds_sent
= 0;
212 /* Does the other end support the reporting? */
213 if (server_supports("report-status"))
215 if (server_supports("delete-refs"))
216 allow_deleting_refs
= 1;
217 if (server_supports("ofs-delta"))
218 args
->use_ofs_delta
= 1;
219 if (server_supports("side-band-64k"))
221 if (server_supports("quiet"))
223 if (server_supports("agent"))
225 if (server_supports("no-thin"))
226 args
->use_thin_pack
= 0;
229 fprintf(stderr
, "No refs in common and none specified; doing nothing.\n"
230 "Perhaps you should specify a branch such as 'master'.\n");
235 * NEEDSWORK: why is delete-refs so specific to send-pack
236 * machinery that set_ref_status_for_push() cannot set this
239 for (ref
= remote_refs
; ref
; ref
= ref
->next
)
240 if (ref
->deletion
&& !allow_deleting_refs
)
241 ref
->status
= REF_STATUS_REJECT_NODELETE
;
244 advertise_shallow_grafts_buf(&req_buf
);
247 * Finally, tell the other end!
250 for (ref
= remote_refs
; ref
; ref
= ref
->next
) {
251 if (!ref
->peer_ref
&& !args
->send_mirror
)
254 /* Check for statuses set by set_ref_status_for_push() */
255 switch (ref
->status
) {
256 case REF_STATUS_REJECT_NONFASTFORWARD
:
257 case REF_STATUS_REJECT_ALREADY_EXISTS
:
258 case REF_STATUS_REJECT_FETCH_FIRST
:
259 case REF_STATUS_REJECT_NEEDS_FORCE
:
260 case REF_STATUS_REJECT_STALE
:
261 case REF_STATUS_REJECT_NODELETE
:
262 case REF_STATUS_UPTODATE
:
272 ref
->status
= REF_STATUS_OK
;
274 char *old_hex
= sha1_to_hex(ref
->old_sha1
);
275 char *new_hex
= sha1_to_hex(ref
->new_sha1
);
276 int quiet
= quiet_supported
&& (args
->quiet
|| !args
->progress
);
278 if (!cmds_sent
&& (status_report
|| use_sideband
||
279 quiet
|| agent_supported
)) {
280 packet_buf_write(&req_buf
,
281 "%s %s %s%c%s%s%s%s%s",
282 old_hex
, new_hex
, ref
->name
, 0,
283 status_report
? " report-status" : "",
284 use_sideband
? " side-band-64k" : "",
285 quiet
? " quiet" : "",
286 agent_supported
? " agent=" : "",
287 agent_supported
? git_user_agent_sanitized() : ""
291 packet_buf_write(&req_buf
, "%s %s %s",
292 old_hex
, new_hex
, ref
->name
);
293 ref
->status
= status_report
?
294 REF_STATUS_EXPECTING_REPORT
:
300 if (args
->stateless_rpc
) {
301 if (!args
->dry_run
&& (cmds_sent
|| is_repository_shallow())) {
302 packet_buf_flush(&req_buf
);
303 send_sideband(out
, -1, req_buf
.buf
, req_buf
.len
, LARGE_PACKET_MAX
);
306 write_or_die(out
, req_buf
.buf
, req_buf
.len
);
309 strbuf_release(&req_buf
);
311 if (use_sideband
&& cmds_sent
) {
312 memset(&demux
, 0, sizeof(demux
));
313 demux
.proc
= sideband_demux
;
316 if (start_async(&demux
))
317 die("send-pack: unable to fork off sideband demultiplexer");
321 if (new_refs
&& cmds_sent
) {
322 if (pack_objects(out
, remote_refs
, extra_have
, args
) < 0) {
323 for (ref
= remote_refs
; ref
; ref
= ref
->next
)
324 ref
->status
= REF_STATUS_NONE
;
325 if (args
->stateless_rpc
)
327 if (git_connection_is_socket(conn
))
328 shutdown(fd
[0], SHUT_WR
);
330 finish_async(&demux
);
334 if (!args
->stateless_rpc
)
335 /* Closed by pack_objects() via start_command() */
338 if (args
->stateless_rpc
&& cmds_sent
)
341 if (status_report
&& cmds_sent
)
342 ret
= receive_status(in
, remote_refs
);
345 if (args
->stateless_rpc
)
348 if (use_sideband
&& cmds_sent
) {
349 if (finish_async(&demux
)) {
350 error("error in sideband demultiplexer");
362 for (ref
= remote_refs
; ref
; ref
= ref
->next
) {
363 switch (ref
->status
) {
364 case REF_STATUS_NONE
:
365 case REF_STATUS_UPTODATE
: