thodg/libgit2/examples/network/fetch.c

• Show log

  Commit

• Hash : b3aaa7a7
  Author :
  Date : 2012-07-21T17:52:51
  

  Add a struct for network callbacks Currently only update_tips is used, but it prepares the way for progress output during download.

Download

• examples/network/fetch.c

• #include "common.h"
  #include <git2.h>
  #include <stdio.h>
  #include <stdlib.h>
  #include <string.h>
  #include <pthread.h>
  #include <unistd.h>
  
  struct dl_data {
  	git_remote *remote;
  	git_off_t *bytes;
  	git_indexer_stats *stats;
  	int ret;
  	int finished;
  };
  
  static void *download(void *ptr)
  {
  	struct dl_data *data = (struct dl_data *)ptr;
  
  	// Connect to the remote end specifying that we want to fetch
  	// information from it.
  	if (git_remote_connect(data->remote, GIT_DIR_FETCH) < 0) {
  		data->ret = -1;
  		goto exit;
  	}
  
  	// Download the packfile and index it. This function updates the
  	// amount of received data and the indexer stats which lets you
  	// inform the user about progress.
  	if (git_remote_download(data->remote, data->bytes, data->stats) < 0) {
  		data->ret = -1;
  		goto exit;
  	}
  
  	data->ret = 0;
  
  exit:
  	data->finished = 1;
  	pthread_exit(&data->ret);
  }
  
  int update_cb(const char *refname, const git_oid *a, const git_oid *b, void *data)
  {
  	const char *action;
  	char a_str[GIT_OID_HEXSZ+1], b_str[GIT_OID_HEXSZ+1];
  
  	git_oid_fmt(b_str, b);
  	b_str[GIT_OID_HEXSZ] = '\0';
  
  	if (git_oid_iszero(a)) {
  		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;
  }
  
  int fetch(git_repository *repo, int argc, char **argv)
  {
  	git_remote *remote = NULL;
  	git_off_t bytes = 0;
  	git_indexer_stats stats;
  	pthread_t worker;
  	struct dl_data data;
  	git_remote_callbacks callbacks;
  
  	// Figure out whether it's a named remote or a URL
  	printf("Fetching %s\n", argv[1]);
  	if (git_remote_load(&remote, repo, argv[1]) < 0) {
  		if (git_remote_new(&remote, repo, NULL, argv[1], NULL) < 0)
  			return -1;
  	}
  
  	// Set up the callbacks (only update_tips for now)
  	memset(&callbacks, 0, sizeof(callbacks));
  	callbacks.update_tips = &update_cb;
  	git_remote_set_callbacks(remote, &callbacks);
  
  	// Set up the information for the background worker thread
  	data.remote = remote;
  	data.bytes = &bytes;
  	data.stats = &stats;
  	data.ret = 0;
  	data.finished = 0;
  	memset(&stats, 0, sizeof(stats));
  
  	pthread_create(&worker, NULL, download, &data);
  
  	// Loop while the worker thread is still running. 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.
  	do {
  		usleep(10000);
  		printf("\rReceived %d/%d objects in %d bytes", stats.processed, stats.total, bytes);
  	} while (!data.finished);
  
  	printf("\rReceived %d/%d objects in %d bytes\n", stats.processed, stats.total, bytes);
  
  	// Disconnect the underlying connection to prevent from idling.
  	git_remote_disconnect(remote);
  
  	// Update the references in the remote's namespace to point to the
  	// right commits. This may be needed even if there was no packfile
  	// to download, which can happen e.g. when the branches have been
  	// changed but all the neede objects are available locally.
  	if (git_remote_update_tips(remote) < 0)
  		return -1;
  
  	git_remote_free(remote);
  
  	return 0;
  
   on_error:
  	git_remote_free(remote);
  	return -1;
  }
  

Download