8 static const char send_pack_usage
[] =
9 "git-send-pack [--all] [--force] [--receive-pack=<git-receive-pack>] [--verbose] [--thin] [<host>:]<directory> [<ref>...]\n"
10 " --all and explicit <ref> specification are mutually exclusive.";
11 static const char *receivepack
= "git-receive-pack";
14 static int force_update
;
15 static int use_thin_pack
;
18 * Make a pack stream and spit it out into file descriptor fd
20 static int pack_objects(int fd
, struct ref
*refs
)
23 int pack_fd
[2] = { -1, fd
};
27 * The child becomes pack-objects --revs; we feed
28 * the revision parameters to it via its stdin and
29 * let its stdout go back to the other end.
31 static const char *args
[] = {
42 if (pipe(pipe_fd
) < 0)
43 return error("send-pack: pipe failed");
44 pid
= spawnv_git_cmd(args
, pipe_fd
, pack_fd
);
46 return error("send-pack: unable to fork git-pack-objects");
49 * We feed the pack-objects we just spawned with revision
50 * parameters by writing to the pipe.
56 if (!is_null_sha1(refs
->old_sha1
) &&
57 has_sha1_file(refs
->old_sha1
)) {
58 memcpy(buf
+ 1, sha1_to_hex(refs
->old_sha1
), 40);
61 if (!write_or_whine(pipe_fd
[1], buf
, 42,
62 "send-pack: send refs"))
65 if (!is_null_sha1(refs
->new_sha1
)) {
66 memcpy(buf
, sha1_to_hex(refs
->new_sha1
), 40);
68 if (!write_or_whine(pipe_fd
[1], buf
, 41,
69 "send-pack: send refs"))
78 pid_t waiting
= waitpid(pid
, &status
, 0);
83 return error("waitpid failed (%s)", strerror(errno
));
85 if ((waiting
!= pid
) || WIFSIGNALED(status
) ||
87 return error("pack-objects died with strange error");
88 code
= WEXITSTATUS(status
);
95 static void unmark_and_free(struct commit_list
*list
, unsigned int mark
)
98 struct commit_list
*temp
= list
;
99 temp
->item
->object
.flags
&= ~mark
;
105 static int ref_newer(const unsigned char *new_sha1
,
106 const unsigned char *old_sha1
)
109 struct commit
*old
, *new;
110 struct commit_list
*list
, *used
;
113 /* Both new and old must be commit-ish and new is descendant of
114 * old. Otherwise we require --force.
116 o
= deref_tag(parse_object(old_sha1
), NULL
, 0);
117 if (!o
|| o
->type
!= OBJ_COMMIT
)
119 old
= (struct commit
*) o
;
121 o
= deref_tag(parse_object(new_sha1
), NULL
, 0);
122 if (!o
|| o
->type
!= OBJ_COMMIT
)
124 new = (struct commit
*) o
;
126 if (parse_commit(new) < 0)
130 commit_list_insert(new, &list
);
132 new = pop_most_recent_commit(&list
, 1);
133 commit_list_insert(new, &used
);
139 unmark_and_free(list
, 1);
140 unmark_and_free(used
, 1);
144 static struct ref
*local_refs
, **local_tail
;
145 static struct ref
*remote_refs
, **remote_tail
;
147 static int one_local_ref(const char *refname
, const unsigned char *sha1
, int flag
, void *cb_data
)
150 int len
= strlen(refname
) + 1;
151 ref
= xcalloc(1, sizeof(*ref
) + len
);
152 hashcpy(ref
->new_sha1
, sha1
);
153 memcpy(ref
->name
, refname
, len
);
155 local_tail
= &ref
->next
;
159 static void get_local_heads(void)
161 local_tail
= &local_refs
;
162 for_each_ref(one_local_ref
, NULL
);
165 static int receive_status(int in
)
169 int len
= packet_read_line(in
, line
, sizeof(line
));
170 if (len
< 10 || memcmp(line
, "unpack ", 7)) {
171 fprintf(stderr
, "did not receive status back\n");
174 if (memcmp(line
, "unpack ok\n", 10)) {
179 len
= packet_read_line(in
, line
, sizeof(line
));
183 (memcmp(line
, "ok", 2) && memcmp(line
, "ng", 2))) {
184 fprintf(stderr
, "protocol error: %s\n", line
);
188 if (!memcmp(line
, "ok", 2))
196 static int send_pack(int in
, int out
, int nr_refspec
, char **refspec
)
201 int ask_for_status_report
= 0;
202 int allow_deleting_refs
= 0;
203 int expect_status_report
= 0;
205 /* No funny business with the matcher */
206 remote_tail
= get_remote_heads(in
, &remote_refs
, 0, NULL
, REF_NORMAL
);
209 /* Does the other end support the reporting? */
210 if (server_supports("report-status"))
211 ask_for_status_report
= 1;
212 if (server_supports("delete-refs"))
213 allow_deleting_refs
= 1;
217 remote_tail
= &remote_refs
;
218 if (match_refs(local_refs
, remote_refs
, &remote_tail
,
219 nr_refspec
, refspec
, send_all
))
223 fprintf(stderr
, "No refs in common and none specified; doing nothing.\n");
228 * Finally, tell the other end!
231 for (ref
= remote_refs
; ref
; ref
= ref
->next
) {
232 char old_hex
[60], *new_hex
;
238 delete_ref
= is_null_sha1(ref
->peer_ref
->new_sha1
);
239 if (delete_ref
&& !allow_deleting_refs
) {
240 error("remote does not support deleting refs");
245 !hashcmp(ref
->old_sha1
, ref
->peer_ref
->new_sha1
)) {
247 fprintf(stderr
, "'%s': up-to-date\n", ref
->name
);
251 /* This part determines what can overwrite what.
254 * (0) you can always use --force or +A:B notation to
255 * selectively force individual ref pairs.
257 * (1) if the old thing does not exist, it is OK.
259 * (2) if you do not have the old thing, you are not allowed
260 * to overwrite it; you would not know what you are losing
263 * (3) if both new and old are commit-ish, and new is a
264 * descendant of old, it is OK.
266 * (4) regardless of all of the above, removing :B is
272 !is_null_sha1(ref
->old_sha1
) &&
274 if (!has_sha1_file(ref
->old_sha1
) ||
275 !ref_newer(ref
->peer_ref
->new_sha1
,
277 /* We do not have the remote ref, or
278 * we know that the remote ref is not
279 * an ancestor of what we are trying to
280 * push. Either way this can be losing
281 * commits at the remote end and likely
282 * we were not up to date to begin with.
284 error("remote '%s' is not a strict "
285 "subset of local ref '%s'. "
286 "maybe you are not up-to-date and "
287 "need to pull first?",
289 ref
->peer_ref
->name
);
294 hashcpy(ref
->new_sha1
, ref
->peer_ref
->new_sha1
);
297 strcpy(old_hex
, sha1_to_hex(ref
->old_sha1
));
298 new_hex
= sha1_to_hex(ref
->new_sha1
);
300 if (ask_for_status_report
) {
301 packet_write(out
, "%s %s %s%c%s",
302 old_hex
, new_hex
, ref
->name
, 0,
304 ask_for_status_report
= 0;
305 expect_status_report
= 1;
308 packet_write(out
, "%s %s %s",
309 old_hex
, new_hex
, ref
->name
);
311 fprintf(stderr
, "deleting '%s'\n", ref
->name
);
313 fprintf(stderr
, "updating '%s'", ref
->name
);
314 if (strcmp(ref
->name
, ref
->peer_ref
->name
))
315 fprintf(stderr
, " using '%s'",
316 ref
->peer_ref
->name
);
317 fprintf(stderr
, "\n from %s\n to %s\n",
324 ret
= pack_objects(out
, remote_refs
);
327 if (expect_status_report
) {
328 if (receive_status(in
))
332 if (!new_refs
&& ret
== 0)
333 fprintf(stderr
, "Everything up-to-date\n");
337 static void verify_remote_names(int nr_heads
, char **heads
)
341 for (i
= 0; i
< nr_heads
; i
++) {
342 const char *remote
= strchr(heads
[i
], ':');
344 remote
= remote
? (remote
+ 1) : heads
[i
];
345 switch (check_ref_format(remote
)) {
347 case -2: /* ok but a single level -- that is fine for
352 die("remote part of refspec is not a valid name in %s",
357 int main(int argc
, char **argv
)
365 setup_git_directory();
366 git_config(git_default_config
);
369 for (i
= 1; i
< argc
; i
++, argv
++) {
373 if (!strncmp(arg
, "--receive-pack=", 15)) {
374 receivepack
= arg
+ 15;
377 if (!strncmp(arg
, "--exec=", 7)) {
378 receivepack
= arg
+ 7;
381 if (!strcmp(arg
, "--all")) {
385 if (!strcmp(arg
, "--force")) {
389 if (!strcmp(arg
, "--verbose")) {
393 if (!strcmp(arg
, "--thin")) {
397 usage(send_pack_usage
);
408 usage(send_pack_usage
);
409 if (heads
&& send_all
)
410 usage(send_pack_usage
);
411 verify_remote_names(nr_heads
, heads
);
413 pid
= git_connect(fd
, dest
, receivepack
);
416 ret
= send_pack(fd
[0], fd
[1], nr_heads
, heads
);
419 ret
|= finish_connect(pid
);