summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDavid Turner <dturner@twopensource.com>2016-04-15 15:19:06 -0400
committerJunio C Hamano <gitster@pobox.com>2016-04-18 11:36:30 -0700
commit196aa7af8e4518212f49511a709583f42fea9a7b (patch)
treeba383170697422d225371815c36eb6a12fe4bfcf
parent2aec98f9cf9e1307b7eac05e671922c522591051 (diff)
downloadgit-196aa7af8e4518212f49511a709583f42fea9a7b.tar.gz
http-backend: handle refspec argument
Allow clients to pass a "refspec" parameter through to upload-pack; upload-pack will only advertise refs which match that refspec. Signed-off-by: David Turner <dturner@twopensource.com> Signed-off-by: Junio C Hamano <gitster@pobox.com>
-rw-r--r--http-backend.c9
-rw-r--r--upload-pack.c81
2 files changed, 88 insertions, 2 deletions
diff --git a/http-backend.c b/http-backend.c
index a4f0066687..9731391903 100644
--- a/http-backend.c
+++ b/http-backend.c
@@ -452,6 +452,7 @@ static void get_info_refs(char *arg)
if (service_name) {
struct argv_array argv = ARGV_ARRAY_INIT;
struct rpc_service *svc = select_service(service_name);
+ const char *refspec;
strbuf_addf(&buf, "application/x-git-%s-advertisement",
svc->name);
@@ -465,6 +466,14 @@ static void get_info_refs(char *arg)
argv_array_push(&argv, "--stateless-rpc");
argv_array_push(&argv, "--advertise-refs");
+ refspec = get_parameter("refspec");
+ if (refspec) {
+ struct strbuf interesting_refs = STRBUF_INIT;
+ strbuf_addstr(&interesting_refs, "--interesting-refs=");
+ strbuf_addstr(&interesting_refs, refspec);
+ argv_array_push(&argv, interesting_refs.buf);
+ strbuf_release(&interesting_refs);
+ }
argv_array_push(&argv, ".");
run_service(argv.argv, 0);
argv_array_clear(&argv);
diff --git a/upload-pack.c b/upload-pack.c
index dc802a07c2..c846061ee9 100644
--- a/upload-pack.c
+++ b/upload-pack.c
@@ -52,6 +52,7 @@ static int keepalive = 5;
static int use_sideband;
static int advertise_refs;
static int stateless_rpc;
+static struct string_list interesting_refspecs = STRING_LIST_INIT_DUP;
static void reset_timeout(void)
{
@@ -684,16 +685,61 @@ static void receive_needs(void)
free(shallows.objects);
}
-/* return non-zero if the ref is hidden, otherwise 0 */
+struct refspec_data {
+ int has_star;
+ size_t prefixlen;
+ size_t suffixlen;
+};
+
+static int matches_refspec(const char *refspec, struct refspec_data *data,
+ const char *ref)
+{
+ size_t len;
+
+ if (!data->has_star)
+ return !strcmp(refspec, ref);
+
+ if (strncmp(refspec, ref, data->prefixlen))
+ return -1;
+
+ len = strlen(refspec);
+ if (len < data->prefixlen + data->suffixlen)
+ return -1;
+
+ return strcmp(ref + (len - data->suffixlen),
+ refspec + data->prefixlen + 1);
+}
+
+/*
+ * return non-zero if the ref is hidden or outside the provided
+ * refspecs, otherwise 0
+*/
static int mark_our_ref(const char *refname, const char *refname_full,
const struct object_id *oid)
{
struct object *o = lookup_unknown_object(oid->hash);
+ struct string_list_item *item;
if (ref_is_hidden(refname, refname_full)) {
o->flags |= HIDDEN_REF;
return 1;
}
+
+ if (interesting_refspecs.nr) {
+ int found = 0;
+ /*
+ * TODO: this could be faster for large numbers of
+ * refspecs by using tries or a DFA.
+ */
+ for_each_string_list_item(item, &interesting_refspecs)
+ if (matches_refspec(item->string, item->util, refname)) {
+ found = 1;
+ break;
+ }
+ if (!found)
+ return 1;
+
+ }
o->flags |= OUR_REF;
return 0;
}
@@ -722,7 +768,7 @@ static int send_ref(const char *refname, const struct object_id *oid,
{
static const char *capabilities = "multi_ack thin-pack side-band"
" side-band-64k ofs-delta shallow no-progress"
- " include-tag multi_ack_detailed";
+ " include-tag multi_ack_detailed interesting-refs";
const char *refname_nons = strip_namespace(refname);
struct object_id peeled;
@@ -817,6 +863,24 @@ static int upload_pack_config(const char *var, const char *value, void *unused)
return parse_hide_refs_config(var, value, "uploadpack");
}
+static struct refspec_data *make_refspec_data(const char *refspec)
+{
+ struct refspec_data *data;
+ const char *star;
+
+ data = xmalloc(sizeof(struct refspec_data));
+ star = strchr(refspec, '*');
+ if (star) {
+ data->has_star = 1;
+ data->prefixlen = star - refspec;
+ data->suffixlen = strlen(refspec) - (data->prefixlen + 1);
+ } else {
+ data->has_star = 0;
+ }
+
+ return data;
+}
+
int main(int argc, char **argv)
{
char *dir;
@@ -838,6 +902,19 @@ int main(int argc, char **argv)
advertise_refs = 1;
continue;
}
+ if (starts_with(arg, "--interesting-refs=")) {
+ struct string_list_item *item;
+
+ string_list_split(&interesting_refspecs, arg + 19,
+ ' ', -1);
+ for_each_string_list_item(item, &interesting_refspecs) {
+ if (check_refname_format(item->string,
+ REFNAME_REFSPEC_PATTERN))
+ die("invalid refspec %s", item->string);
+ item->util = make_refspec_data(item->string);
+ }
+ continue;
+ }
if (!strcmp(arg, "--stateless-rpc")) {
stateless_rpc = 1;
continue;