提交 8736a848 编写于 作者: J Jeff King 提交者: Junio C Hamano

send-pack: track errors for each ref

Instead of keeping the 'ret' variable, we instead have a
status flag for each ref that tracks what happened to it.
We then print the ref status after all of the refs have
been examined.

This paves the way for three improvements:
  - updating tracking refs only for non-error refs
  - incorporating remote rejection into the printed status
  - printing errors in a different order than we processed
    (e.g., consolidating non-ff errors near the end with
    a special message)
Signed-off-by: NJeff King <peff@peff.net>
Acked-by: NAlex Riesen <raa.lkml@gmail.com>
Acked-by: NDaniel Barkalow <barkalow@iabervon.org>
Signed-off-by: NJunio C Hamano <gitster@pobox.com>
上级 bcd2e266
...@@ -207,8 +207,9 @@ static void update_tracking_ref(struct remote *remote, struct ref *ref) ...@@ -207,8 +207,9 @@ static void update_tracking_ref(struct remote *remote, struct ref *ref)
} }
} }
static const char *prettify_ref(const char *name) static const char *prettify_ref(const struct ref *ref)
{ {
const char *name = ref->name;
return name + ( return name + (
!prefixcmp(name, "refs/heads/") ? 11 : !prefixcmp(name, "refs/heads/") ? 11 :
!prefixcmp(name, "refs/tags/") ? 10 : !prefixcmp(name, "refs/tags/") ? 10 :
...@@ -218,15 +219,104 @@ static const char *prettify_ref(const char *name) ...@@ -218,15 +219,104 @@ static const char *prettify_ref(const char *name)
#define SUMMARY_WIDTH (2 * DEFAULT_ABBREV + 3) #define SUMMARY_WIDTH (2 * DEFAULT_ABBREV + 3)
static void print_ref_status(char flag, const char *summary, struct ref *to, struct ref *from, const char *msg)
{
fprintf(stderr, " %c %-*s ", flag, SUMMARY_WIDTH, summary);
if (from)
fprintf(stderr, "%s -> %s", prettify_ref(from), prettify_ref(to));
else
fputs(prettify_ref(to), stderr);
if (msg) {
fputs(" (", stderr);
fputs(msg, stderr);
fputc(')', stderr);
}
fputc('\n', stderr);
}
static const char *status_abbrev(unsigned char sha1[20])
{
const char *abbrev;
abbrev = find_unique_abbrev(sha1, DEFAULT_ABBREV);
return abbrev ? abbrev : sha1_to_hex(sha1);
}
static void print_ok_ref_status(struct ref *ref)
{
if (ref->deletion)
print_ref_status('-', "[deleted]", ref, NULL, NULL);
else if (is_null_sha1(ref->old_sha1))
print_ref_status('*',
(!prefixcmp(ref->name, "refs/tags/") ? "[new tag]" :
"[new branch]"),
ref, ref->peer_ref, NULL);
else {
char quickref[84];
char type;
const char *msg;
strcpy(quickref, status_abbrev(ref->old_sha1));
if (ref->nonfastforward) {
strcat(quickref, "...");
type = '+';
msg = "forced update";
} else {
strcat(quickref, "..");
type = ' ';
msg = NULL;
}
strcat(quickref, status_abbrev(ref->new_sha1));
print_ref_status(type, quickref, ref, ref->peer_ref, msg);
}
}
static void print_push_status(const char *dest, struct ref *refs)
{
struct ref *ref;
int shown_dest = 0;
for (ref = refs; ref; ref = ref->next) {
if (!ref->status)
continue;
if (ref->status == REF_STATUS_UPTODATE && !args.verbose)
continue;
if (!shown_dest) {
fprintf(stderr, "To %s\n", dest);
shown_dest = 1;
}
switch(ref->status) {
case REF_STATUS_NONE:
print_ref_status('X', "[no match]", ref, NULL, NULL);
break;
case REF_STATUS_REJECT_NODELETE:
print_ref_status('!', "[rejected]", ref, NULL,
"remote does not support deleting refs");
break;
case REF_STATUS_UPTODATE:
print_ref_status('=', "[up to date]", ref,
ref->peer_ref, NULL);
break;
case REF_STATUS_REJECT_NONFASTFORWARD:
print_ref_status('!', "[rejected]", ref, ref->peer_ref,
"non-fast forward");
break;
case REF_STATUS_OK:
print_ok_ref_status(ref);
break;
}
}
}
static int do_send_pack(int in, int out, struct remote *remote, const char *dest, int nr_refspec, const char **refspec) static int do_send_pack(int in, int out, struct remote *remote, const char *dest, int nr_refspec, const char **refspec)
{ {
struct ref *ref; struct ref *ref;
int new_refs; int new_refs;
int ret = 0;
int ask_for_status_report = 0; int ask_for_status_report = 0;
int allow_deleting_refs = 0; int allow_deleting_refs = 0;
int expect_status_report = 0; int expect_status_report = 0;
int shown_dest = 0;
int flags = MATCH_REFS_NONE; int flags = MATCH_REFS_NONE;
if (args.send_all) if (args.send_all)
...@@ -262,10 +352,6 @@ static int do_send_pack(int in, int out, struct remote *remote, const char *dest ...@@ -262,10 +352,6 @@ static int do_send_pack(int in, int out, struct remote *remote, const char *dest
*/ */
new_refs = 0; new_refs = 0;
for (ref = remote_refs; ref; ref = ref->next) { for (ref = remote_refs; ref; ref = ref->next) {
char old_hex[60], *new_hex;
int will_delete_ref;
const char *pretty_ref;
const char *pretty_peer = NULL; /* only used when not deleting */
const unsigned char *new_sha1; const unsigned char *new_sha1;
if (!ref->peer_ref) { if (!ref->peer_ref) {
...@@ -276,29 +362,15 @@ static int do_send_pack(int in, int out, struct remote *remote, const char *dest ...@@ -276,29 +362,15 @@ static int do_send_pack(int in, int out, struct remote *remote, const char *dest
else else
new_sha1 = ref->peer_ref->new_sha1; new_sha1 = ref->peer_ref->new_sha1;
if (!shown_dest) {
fprintf(stderr, "To %s\n", dest);
shown_dest = 1;
}
will_delete_ref = is_null_sha1(new_sha1);
pretty_ref = prettify_ref(ref->name); ref->deletion = is_null_sha1(new_sha1);
if (!will_delete_ref) if (ref->deletion && !allow_deleting_refs) {
pretty_peer = prettify_ref(ref->peer_ref->name); ref->status = REF_STATUS_REJECT_NODELETE;
if (will_delete_ref && !allow_deleting_refs) {
fprintf(stderr, " ! %-*s %s (remote does not support deleting refs)\n",
SUMMARY_WIDTH, "[rejected]", pretty_ref);
ret = -2;
continue; continue;
} }
if (!will_delete_ref && if (!ref->deletion &&
!hashcmp(ref->old_sha1, new_sha1)) { !hashcmp(ref->old_sha1, new_sha1)) {
if (args.verbose) ref->status = REF_STATUS_UPTODATE;
fprintf(stderr, " = %-*s %s -> %s\n",
SUMMARY_WIDTH, "[up to date]",
pretty_peer, pretty_ref);
continue; continue;
} }
...@@ -321,33 +393,26 @@ static int do_send_pack(int in, int out, struct remote *remote, const char *dest ...@@ -321,33 +393,26 @@ static int do_send_pack(int in, int out, struct remote *remote, const char *dest
* always allowed. * always allowed.
*/ */
if (!args.force_update && ref->nonfastforward =
!will_delete_ref && !ref->deletion &&
!is_null_sha1(ref->old_sha1) && !is_null_sha1(ref->old_sha1) &&
!ref->force) { (!has_sha1_file(ref->old_sha1)
if (!has_sha1_file(ref->old_sha1) || || !ref_newer(new_sha1, ref->old_sha1));
!ref_newer(new_sha1, ref->old_sha1)) {
/* We do not have the remote ref, or if (ref->nonfastforward && !ref->force && !args.force_update) {
* we know that the remote ref is not ref->status = REF_STATUS_REJECT_NONFASTFORWARD;
* an ancestor of what we are trying to continue;
* push. Either way this can be losing
* commits at the remote end and likely
* we were not up to date to begin with.
*/
fprintf(stderr, " ! %-*s %s -> %s (non-fast forward)\n",
SUMMARY_WIDTH, "[rejected]",
pretty_peer, pretty_ref);
ret = -2;
continue;
}
} }
hashcpy(ref->new_sha1, new_sha1); hashcpy(ref->new_sha1, new_sha1);
if (!will_delete_ref) if (!ref->deletion)
new_refs++; new_refs++;
strcpy(old_hex, sha1_to_hex(ref->old_sha1)); ref->status = REF_STATUS_OK;
new_hex = sha1_to_hex(ref->new_sha1);
if (!args.dry_run) { if (!args.dry_run) {
char *old_hex = sha1_to_hex(ref->old_sha1);
char *new_hex = sha1_to_hex(ref->new_sha1);
if (ask_for_status_report) { if (ask_for_status_report) {
packet_write(out, "%s %s %s%c%s", packet_write(out, "%s %s %s%c%s",
old_hex, new_hex, ref->name, 0, old_hex, new_hex, ref->name, 0,
...@@ -359,64 +424,43 @@ static int do_send_pack(int in, int out, struct remote *remote, const char *dest ...@@ -359,64 +424,43 @@ static int do_send_pack(int in, int out, struct remote *remote, const char *dest
packet_write(out, "%s %s %s", packet_write(out, "%s %s %s",
old_hex, new_hex, ref->name); old_hex, new_hex, ref->name);
} }
if (will_delete_ref)
fprintf(stderr, " - %-*s %s\n",
SUMMARY_WIDTH, "[deleting]",
pretty_ref);
else if (is_null_sha1(ref->old_sha1)) {
const char *msg;
if (!prefixcmp(ref->name, "refs/tags/"))
msg = "[new tag]";
else
msg = "[new branch]";
fprintf(stderr, " * %-*s %s -> %s\n",
SUMMARY_WIDTH, msg,
pretty_peer, pretty_ref);
}
else {
char quickref[83];
char type = ' ';
const char *msg = "";
const char *old_abb;
old_abb = find_unique_abbrev(ref->old_sha1, DEFAULT_ABBREV);
strcpy(quickref, old_abb ? old_abb : old_hex);
if (ref_newer(ref->peer_ref->new_sha1, ref->old_sha1))
strcat(quickref, "..");
else {
strcat(quickref, "...");
type = '+';
msg = " (forced update)";
}
strcat(quickref, find_unique_abbrev(ref->new_sha1, DEFAULT_ABBREV));
fprintf(stderr, " %c %-*s %s -> %s%s\n",
type,
SUMMARY_WIDTH, quickref,
pretty_peer, pretty_ref,
msg);
}
} }
packet_flush(out); packet_flush(out);
if (new_refs && !args.dry_run) if (new_refs && !args.dry_run) {
ret = pack_objects(out, remote_refs); if (pack_objects(out, remote_refs) < 0) {
close(out);
return -1;
}
}
close(out); close(out);
print_push_status(dest, remote_refs);
if (expect_status_report) { if (expect_status_report) {
if (receive_status(in)) if (receive_status(in))
ret = -4; return -1;
} }
if (!args.dry_run && remote && ret == 0) { if (!args.dry_run && remote) {
for (ref = remote_refs; ref; ref = ref->next) for (ref = remote_refs; ref; ref = ref->next)
if (!is_null_sha1(ref->new_sha1)) if (!is_null_sha1(ref->new_sha1))
update_tracking_ref(remote, ref); update_tracking_ref(remote, ref);
} }
if (!new_refs && ret == 0) if (!new_refs)
fprintf(stderr, "Everything up-to-date\n"); fprintf(stderr, "Everything up-to-date\n");
return ret; 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;
} }
static void verify_remote_names(int nr_heads, const char **heads) static void verify_remote_names(int nr_heads, const char **heads)
......
...@@ -493,8 +493,17 @@ struct ref { ...@@ -493,8 +493,17 @@ struct ref {
struct ref *next; struct ref *next;
unsigned char old_sha1[20]; unsigned char old_sha1[20];
unsigned char new_sha1[20]; unsigned char new_sha1[20];
unsigned char force; unsigned char force : 1;
unsigned char merge; unsigned char merge : 1;
unsigned char nonfastforward : 1;
unsigned char deletion : 1;
enum {
REF_STATUS_NONE = 0,
REF_STATUS_OK,
REF_STATUS_REJECT_NONFASTFORWARD,
REF_STATUS_REJECT_NODELETE,
REF_STATUS_UPTODATE,
} status;
struct ref *peer_ref; /* when renaming */ struct ref *peer_ref; /* when renaming */
char name[FLEX_ARRAY]; /* more */ char name[FLEX_ARRAY]; /* more */
}; };
......
...@@ -19,7 +19,7 @@ test_expect_success 'setup' ' ...@@ -19,7 +19,7 @@ test_expect_success 'setup' '
git commit -a -m b2 git commit -a -m b2
' '
test_expect_success 'check tracking branches updated correctly after push' ' test_expect_success 'prepare pushable branches' '
cd aa && cd aa &&
b1=$(git rev-parse origin/b1) && b1=$(git rev-parse origin/b1) &&
b2=$(git rev-parse origin/b2) && b2=$(git rev-parse origin/b2) &&
...@@ -31,8 +31,16 @@ test_expect_success 'check tracking branches updated correctly after push' ' ...@@ -31,8 +31,16 @@ test_expect_success 'check tracking branches updated correctly after push' '
git commit -a -m aa-b2 && git commit -a -m aa-b2 &&
git checkout master && git checkout master &&
echo aa-master >>file && echo aa-master >>file &&
git commit -a -m aa-master && git commit -a -m aa-master
git push && '
test_expect_success 'mixed-success push returns error' '! git push'
test_expect_success 'check tracking branches updated correctly after push' '
test "$(git rev-parse origin/master)" = "$(git rev-parse master)"
'
test_expect_success 'check tracking branches not updated for failed refs' '
test "$(git rev-parse origin/b1)" = "$b1" && test "$(git rev-parse origin/b1)" = "$b1" &&
test "$(git rev-parse origin/b2)" = "$b2" test "$(git rev-parse origin/b2)" = "$b2"
' '
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册