6 #include "run-command.h"
10 #include "transport.h"
13 static int feed_object(const unsigned char *sha1
, int fd
, int negative
)
17 if (negative
&& !has_sha1_file(sha1
))
20 memcpy(buf
+ negative
, sha1_to_hex(sha1
), 40);
23 buf
[40 + negative
] = '\n';
24 return write_or_whine(fd
, buf
, 41 + negative
, "send-pack: send refs");
28 * Make a pack stream and spit it out into file descriptor fd
30 static int pack_objects(int fd
, struct ref
*refs
, struct extra_have_objects
*extra
, struct send_pack_args
*args
)
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.
37 const char *argv
[] = {
39 "--all-progress-implied",
48 struct child_process po
;
52 if (args
->use_thin_pack
)
54 if (args
->use_ofs_delta
)
55 argv
[i
++] = "--delta-base-offset";
56 if (args
->quiet
|| !args
->progress
)
59 argv
[i
++] = "--progress";
60 memset(&po
, 0, sizeof(po
));
63 po
.out
= args
->stateless_rpc
? -1 : fd
;
65 if (start_command(&po
))
66 die_errno("git pack-objects failed");
69 * We feed the pack-objects we just spawned with revision
70 * parameters by writing to the pipe.
72 for (i
= 0; i
< extra
->nr
; i
++)
73 if (!feed_object(extra
->array
[i
], po
.in
, 1))
77 if (!is_null_sha1(refs
->old_sha1
) &&
78 !feed_object(refs
->old_sha1
, po
.in
, 1))
80 if (!is_null_sha1(refs
->new_sha1
) &&
81 !feed_object(refs
->new_sha1
, po
.in
, 0))
88 if (args
->stateless_rpc
) {
89 char *buf
= xmalloc(LARGE_PACKET_MAX
);
91 ssize_t n
= xread(po
.out
, buf
, LARGE_PACKET_MAX
);
94 send_sideband(fd
, -1, buf
, n
, LARGE_PACKET_MAX
);
101 if (finish_command(&po
))
106 static int receive_status(int in
, struct ref
*refs
)
111 int len
= packet_read_line(in
, line
, sizeof(line
));
112 if (prefixcmp(line
, "unpack "))
113 return error("did not receive remote status");
114 if (strcmp(line
, "unpack ok\n")) {
115 char *p
= line
+ strlen(line
) - 1;
118 error("unpack failed: %s", line
+ 7);
125 len
= packet_read_line(in
, line
, sizeof(line
));
128 if (prefixcmp(line
, "ok ") && prefixcmp(line
, "ng ")) {
129 error("invalid ref status from remote: %s", line
);
134 line
[strlen(line
)-1] = '\0';
136 msg
= strchr(refname
, ' ');
140 /* first try searching at our hint, falling back to all refs */
142 hint
= find_ref_by_name(hint
, refname
);
144 hint
= find_ref_by_name(refs
, refname
);
146 warning("remote reported status on unknown ref: %s",
150 if (hint
->status
!= REF_STATUS_EXPECTING_REPORT
) {
151 warning("remote reported status on unexpected ref: %s",
156 if (line
[0] == 'o' && line
[1] == 'k')
157 hint
->status
= REF_STATUS_OK
;
159 hint
->status
= REF_STATUS_REMOTE_REJECT
;
163 hint
->remote_status
= xstrdup(msg
);
164 /* start our next search from the next ref */
170 static int sideband_demux(int in
, int out
, void *data
)
176 ret
= recv_sideband("send-pack", fd
[0], out
);
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
)
188 struct strbuf req_buf
= STRBUF_INIT
;
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;
200 /* Does the other end support the reporting? */
201 if (server_supports("report-status"))
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"))
209 if (server_supports("quiet"))
211 if (server_supports("agent"))
215 fprintf(stderr
, "No refs in common and none specified; doing nothing.\n"
216 "Perhaps you should specify a branch such as 'master'.\n");
221 * Finally, tell the other end!
224 for (ref
= remote_refs
; ref
; ref
= ref
->next
) {
225 if (!ref
->peer_ref
&& !args
->send_mirror
)
228 /* Check for statuses set by set_ref_status_for_push() */
229 switch (ref
->status
) {
230 case REF_STATUS_REJECT_NONFASTFORWARD
:
231 case REF_STATUS_REJECT_ALREADY_EXISTS
:
232 case REF_STATUS_REJECT_FETCH_FIRST
:
233 case REF_STATUS_REJECT_NEEDS_FORCE
:
234 case REF_STATUS_UPTODATE
:
240 if (ref
->deletion
&& !allow_deleting_refs
) {
241 ref
->status
= REF_STATUS_REJECT_NODELETE
;
249 ref
->status
= REF_STATUS_OK
;
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
);
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() : ""
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
:
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
);
283 safe_write(out
, req_buf
.buf
, req_buf
.len
);
286 strbuf_release(&req_buf
);
288 if (use_sideband
&& cmds_sent
) {
289 memset(&demux
, 0, sizeof(demux
));
290 demux
.proc
= sideband_demux
;
293 if (start_async(&demux
))
294 die("send-pack: unable to fork off sideband demultiplexer");
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
)
304 if (git_connection_is_socket(conn
))
305 shutdown(fd
[0], SHUT_WR
);
307 finish_async(&demux
);
311 if (args
->stateless_rpc
&& cmds_sent
)
314 if (status_report
&& cmds_sent
)
315 ret
= receive_status(in
, remote_refs
);
318 if (args
->stateless_rpc
)
321 if (use_sideband
&& cmds_sent
) {
322 if (finish_async(&demux
)) {
323 error("error in sideband demultiplexer");
335 for (ref
= remote_refs
; ref
; ref
= ref
->next
) {
336 switch (ref
->status
) {
337 case REF_STATUS_NONE
:
338 case REF_STATUS_UPTODATE
: