fetch.c 3.15 KB
Newer Older
1
#include "common.h"
2

Ben Straub committed
3
static int progress_cb(const char *str, int len, void *data)
4
{
5
	(void)data;
6 7
	printf("remote: %.*s", len, str);
	fflush(stdout); /* We don't have the \n to force the flush */
Ben Straub committed
8
	return 0;
9 10
}

11
/**
Ben Straub committed
12
 * This function gets called for each remote-tracking branch that gets
13 14 15
 * updated. The message we output depends on whether it's a new one or
 * an update.
 */
16
static int update_cb(const char *refname, const git_oid *a, const git_oid *b, void *data)
17 18
{
	char a_str[GIT_OID_HEXSZ+1], b_str[GIT_OID_HEXSZ+1];
19
	(void)data;
20 21 22 23

	git_oid_fmt(b_str, b);
	b_str[GIT_OID_HEXSZ] = '\0';

24
	if (git_oid_is_zero(a)) {
25 26 27 28 29 30 31 32 33 34
		printf("[new]     %.20s %s\n", b_str, refname);
	} else {
		git_oid_fmt(a_str, a);
		a_str[GIT_OID_HEXSZ] = '\0';
		printf("[updated] %.10s..%.10s %s\n", a_str, b_str, refname);
	}

	return 0;
}

35 36 37 38 39 40
/**
 * This gets called during the download and indexing. Here we show
 * processed and total objects in the pack and the amount of received
 * data. Most frontends will probably want to show a percentage and
 * the download rate.
 */
41
static int transfer_progress_cb(const git_indexer_progress *stats, void *payload)
42
{
43 44
	(void)payload;

45
	if (stats->received_objects == stats->total_objects) {
46
		printf("Resolving deltas %u/%u\r",
47 48
		       stats->indexed_deltas, stats->total_deltas);
	} else if (stats->total_objects > 0) {
49
		printf("Received %u/%u objects (%u) in %" PRIuZ " bytes\r",
50 51 52
		       stats->received_objects, stats->total_objects,
		       stats->indexed_objects, stats->received_bytes);
	}
Eun committed
53
	return 0;
54 55
}

56
/** Entry point for this command */
57
int lg2_fetch(git_repository *repo, int argc, char **argv)
58
{
59
	git_remote *remote = NULL;
60
	const git_indexer_progress *stats;
61
	git_fetch_options fetch_opts = GIT_FETCH_OPTIONS_INIT;
62

63 64 65 66 67
	if (argc < 2) {
		fprintf(stderr, "usage: %s fetch <repo>\n", argv[-1]);
		return EXIT_FAILURE;
	}

68
	/* Figure out whether it's a named remote or a URL */
69
	printf("Fetching %s for repo %p\n", argv[1], repo);
70
	if (git_remote_lookup(&remote, repo, argv[1]) < 0)
71
		if (git_remote_create_anonymous(&remote, repo, argv[1]) < 0)
72
			goto on_error;
73

74
	/* Set up the callbacks (only update_tips for now) */
75 76
	fetch_opts.callbacks.update_tips = &update_cb;
	fetch_opts.callbacks.sideband_progress = &progress_cb;
77
	fetch_opts.callbacks.transfer_progress = transfer_progress_cb;
78
	fetch_opts.callbacks.credentials = cred_acquire_cb;
79

80 81 82 83 84 85
	/**
	 * Perform the fetch with the configured refspecs from the
	 * config. Update the reflog for the updated references with
	 * "fetch".
	 */
	if (git_remote_fetch(remote, NULL, &fetch_opts, "fetch") < 0)
86
		goto on_error;
87

88 89
	/**
	 * If there are local objects (we got a thin pack), then tell
Ben Straub committed
90
	 * the user how many objects we saved from having to cross the
91 92
	 * network.
	 */
93
	stats = git_remote_stats(remote);
94
	if (stats->local_objects > 0) {
95
		printf("\rReceived %u/%u objects in %" PRIuZ " bytes (used %u local objects)\n",
96 97
		       stats->indexed_objects, stats->total_objects, stats->received_bytes, stats->local_objects);
	} else{
98
		printf("\rReceived %u/%u objects in %" PRIuZ "bytes\n",
99
			stats->indexed_objects, stats->total_objects, stats->received_bytes);
100
	}
101 102 103 104 105 106 107 108

	git_remote_free(remote);

	return 0;

 on_error:
	git_remote_free(remote);
	return -1;
109
}