1 module clone; 2 3 import git.c; 4 5 import core.thread; 6 import std.concurrency; 7 import std.string; 8 import std.stdio; 9 10 import common; 11 12 void clone_thread() 13 { 14 git_repository* repo = null; 15 16 // Kick off the clone 17 clone_data.ret = git_clone(&repo, toStringz(clone_data.url), toStringz(clone_data.path), 18 &clone_data.fetch_stats, &clone_data.checkout_stats, 19 &clone_data.opts); 20 21 if (repo) 22 git_repository_free(repo); 23 24 clone_data.finished = 1; 25 } 26 27 int do_clone(git_repository* repo, int argc, string[] args) 28 { 29 // Validate args 30 if (argc < 3) 31 { 32 writefln("USAGE: %s <url> <path>\n", args[0]); 33 return -1; 34 } 35 36 // Data for background thread 37 clone_data.url = args[1]; 38 clone_data.path = args[2]; 39 clone_data.opts.disable_filters = 1; 40 writefln("Cloning '%s' to '%s'", clone_data.url, clone_data.path); 41 42 // Create the worker thread 43 spawn(&clone_thread); 44 45 // Watch for progress information 46 do { 47 Thread.sleep(dur!("msecs")(100)); 48 writefln("Fetch %s/%s – Checkout %s/%s", 49 clone_data.fetch_stats.processed, clone_data.fetch_stats.total, 50 clone_data.checkout_stats.processed, clone_data.checkout_stats.total); 51 } while (!clone_data.finished); 52 53 writefln("Fetch %s/%s – Checkout %s/%s", 54 clone_data.fetch_stats.processed, clone_data.fetch_stats.total, 55 clone_data.checkout_stats.processed, clone_data.checkout_stats.total); 56 57 return clone_data.ret; 58 }