Browse Source

upload-pack: convert to a builtin

In order to allow for code sharing with the server-side of fetch in
protocol-v2 convert upload-pack to be a builtin.

Signed-off-by: Brandon Williams <bmwill@google.com>
Signed-off-by: Junio C Hamano <gitster@pobox.com>
maint
Brandon Williams 7 years ago committed by Junio C Hamano
parent
commit
a3d6b53e92
  1. 3
      Makefile
  2. 1
      builtin.h
  3. 67
      builtin/upload-pack.c
  4. 1
      git.c
  5. 107
      upload-pack.c
  6. 13
      upload-pack.h

3
Makefile

@ -636,7 +636,6 @@ PROGRAM_OBJS += imap-send.o
PROGRAM_OBJS += sh-i18n--envsubst.o PROGRAM_OBJS += sh-i18n--envsubst.o
PROGRAM_OBJS += shell.o PROGRAM_OBJS += shell.o
PROGRAM_OBJS += show-index.o PROGRAM_OBJS += show-index.o
PROGRAM_OBJS += upload-pack.o
PROGRAM_OBJS += remote-testsvn.o PROGRAM_OBJS += remote-testsvn.o


# Binary suffix, set to .exe for Windows builds # Binary suffix, set to .exe for Windows builds
@ -904,6 +903,7 @@ LIB_OBJS += tree-diff.o
LIB_OBJS += tree.o LIB_OBJS += tree.o
LIB_OBJS += tree-walk.o LIB_OBJS += tree-walk.o
LIB_OBJS += unpack-trees.o LIB_OBJS += unpack-trees.o
LIB_OBJS += upload-pack.o
LIB_OBJS += url.o LIB_OBJS += url.o
LIB_OBJS += urlmatch.o LIB_OBJS += urlmatch.o
LIB_OBJS += usage.o LIB_OBJS += usage.o
@ -1021,6 +1021,7 @@ BUILTIN_OBJS += builtin/update-index.o
BUILTIN_OBJS += builtin/update-ref.o BUILTIN_OBJS += builtin/update-ref.o
BUILTIN_OBJS += builtin/update-server-info.o BUILTIN_OBJS += builtin/update-server-info.o
BUILTIN_OBJS += builtin/upload-archive.o BUILTIN_OBJS += builtin/upload-archive.o
BUILTIN_OBJS += builtin/upload-pack.o
BUILTIN_OBJS += builtin/var.o BUILTIN_OBJS += builtin/var.o
BUILTIN_OBJS += builtin/verify-commit.o BUILTIN_OBJS += builtin/verify-commit.o
BUILTIN_OBJS += builtin/verify-pack.o BUILTIN_OBJS += builtin/verify-pack.o

1
builtin.h

@ -231,6 +231,7 @@ extern int cmd_update_ref(int argc, const char **argv, const char *prefix);
extern int cmd_update_server_info(int argc, const char **argv, const char *prefix); extern int cmd_update_server_info(int argc, const char **argv, const char *prefix);
extern int cmd_upload_archive(int argc, const char **argv, const char *prefix); extern int cmd_upload_archive(int argc, const char **argv, const char *prefix);
extern int cmd_upload_archive_writer(int argc, const char **argv, const char *prefix); extern int cmd_upload_archive_writer(int argc, const char **argv, const char *prefix);
extern int cmd_upload_pack(int argc, const char **argv, const char *prefix);
extern int cmd_var(int argc, const char **argv, const char *prefix); extern int cmd_var(int argc, const char **argv, const char *prefix);
extern int cmd_verify_commit(int argc, const char **argv, const char *prefix); extern int cmd_verify_commit(int argc, const char **argv, const char *prefix);
extern int cmd_verify_tag(int argc, const char **argv, const char *prefix); extern int cmd_verify_tag(int argc, const char **argv, const char *prefix);

67
builtin/upload-pack.c

@ -0,0 +1,67 @@
#include "cache.h"
#include "builtin.h"
#include "exec_cmd.h"
#include "pkt-line.h"
#include "parse-options.h"
#include "protocol.h"
#include "upload-pack.h"

static const char * const upload_pack_usage[] = {
N_("git upload-pack [<options>] <dir>"),
NULL
};

int cmd_upload_pack(int argc, const char **argv, const char *prefix)
{
const char *dir;
int strict = 0;
struct upload_pack_options opts = { 0 };
struct option options[] = {
OPT_BOOL(0, "stateless-rpc", &opts.stateless_rpc,
N_("quit after a single request/response exchange")),
OPT_BOOL(0, "advertise-refs", &opts.advertise_refs,
N_("exit immediately after initial ref advertisement")),
OPT_BOOL(0, "strict", &strict,
N_("do not try <directory>/.git/ if <directory> is no Git directory")),
OPT_INTEGER(0, "timeout", &opts.timeout,
N_("interrupt transfer after <n> seconds of inactivity")),
OPT_END()
};

packet_trace_identity("upload-pack");
check_replace_refs = 0;

argc = parse_options(argc, argv, NULL, options, upload_pack_usage, 0);

if (argc != 1)
usage_with_options(upload_pack_usage, options);

if (opts.timeout)
opts.daemon_mode = 1;

setup_path();

dir = argv[0];

if (!enter_repo(dir, strict))
die("'%s' does not appear to be a git repository", dir);

switch (determine_protocol_version_server()) {
case protocol_v1:
/*
* v1 is just the original protocol with a version string,
* so just fall through after writing the version string.
*/
if (opts.advertise_refs || !opts.stateless_rpc)
packet_write_fmt(1, "version 1\n");

/* fallthrough */
case protocol_v0:
upload_pack(&opts);
break;
case protocol_unknown_version:
BUG("unknown protocol version");
}

return 0;
}

1
git.c

@ -478,6 +478,7 @@ static struct cmd_struct commands[] = {
{ "update-server-info", cmd_update_server_info, RUN_SETUP }, { "update-server-info", cmd_update_server_info, RUN_SETUP },
{ "upload-archive", cmd_upload_archive }, { "upload-archive", cmd_upload_archive },
{ "upload-archive--writer", cmd_upload_archive_writer }, { "upload-archive--writer", cmd_upload_archive_writer },
{ "upload-pack", cmd_upload_pack },
{ "var", cmd_var, RUN_SETUP_GENTLY }, { "var", cmd_var, RUN_SETUP_GENTLY },
{ "verify-commit", cmd_verify_commit, RUN_SETUP }, { "verify-commit", cmd_verify_commit, RUN_SETUP },
{ "verify-pack", cmd_verify_pack }, { "verify-pack", cmd_verify_pack },

107
upload-pack.c

@ -6,7 +6,6 @@
#include "tag.h" #include "tag.h"
#include "object.h" #include "object.h"
#include "commit.h" #include "commit.h"
#include "exec_cmd.h"
#include "diff.h" #include "diff.h"
#include "revision.h" #include "revision.h"
#include "list-objects.h" #include "list-objects.h"
@ -15,15 +14,10 @@
#include "sigchain.h" #include "sigchain.h"
#include "version.h" #include "version.h"
#include "string-list.h" #include "string-list.h"
#include "parse-options.h"
#include "argv-array.h" #include "argv-array.h"
#include "prio-queue.h" #include "prio-queue.h"
#include "protocol.h" #include "protocol.h"

#include "upload-pack.h"
static const char * const upload_pack_usage[] = {
N_("git upload-pack [<options>] <dir>"),
NULL
};


/* Remember to update object flag allocation in object.h */ /* Remember to update object flag allocation in object.h */
#define THEY_HAVE (1u << 11) #define THEY_HAVE (1u << 11)
@ -61,7 +55,6 @@ static int keepalive = 5;
* otherwise maximum packet size (up to 65520 bytes). * otherwise maximum packet size (up to 65520 bytes).
*/ */
static int use_sideband; static int use_sideband;
static int advertise_refs;
static int stateless_rpc; static int stateless_rpc;
static const char *pack_objects_hook; static const char *pack_objects_hook;


@ -977,33 +970,6 @@ static int find_symref(const char *refname, const struct object_id *oid,
return 0; return 0;
} }


static void upload_pack(void)
{
struct string_list symref = STRING_LIST_INIT_DUP;

head_ref_namespaced(find_symref, &symref);

if (advertise_refs || !stateless_rpc) {
reset_timeout();
head_ref_namespaced(send_ref, &symref);
for_each_namespaced_ref(send_ref, &symref);
advertise_shallow_grafts(1);
packet_flush(1);
} else {
head_ref_namespaced(check_ref, NULL);
for_each_namespaced_ref(check_ref, NULL);
}
string_list_clear(&symref, 1);
if (advertise_refs)
return;

receive_needs();
if (want_obj.nr) {
get_common_commits();
create_pack_file();
}
}

static int upload_pack_config(const char *var, const char *value, void *unused) static int upload_pack_config(const char *var, const char *value, void *unused)
{ {
if (!strcmp("uploadpack.allowtipsha1inwant", var)) { if (!strcmp("uploadpack.allowtipsha1inwant", var)) {
@ -1032,58 +998,35 @@ static int upload_pack_config(const char *var, const char *value, void *unused)
return parse_hide_refs_config(var, value, "uploadpack"); return parse_hide_refs_config(var, value, "uploadpack");
} }


int cmd_main(int argc, const char **argv) void upload_pack(struct upload_pack_options *options)
{ {
const char *dir; struct string_list symref = STRING_LIST_INIT_DUP;
int strict = 0;
struct option options[] = {
OPT_BOOL(0, "stateless-rpc", &stateless_rpc,
N_("quit after a single request/response exchange")),
OPT_BOOL(0, "advertise-refs", &advertise_refs,
N_("exit immediately after initial ref advertisement")),
OPT_BOOL(0, "strict", &strict,
N_("do not try <directory>/.git/ if <directory> is no Git directory")),
OPT_INTEGER(0, "timeout", &timeout,
N_("interrupt transfer after <n> seconds of inactivity")),
OPT_END()
};

packet_trace_identity("upload-pack");
check_replace_refs = 0;

argc = parse_options(argc, argv, NULL, options, upload_pack_usage, 0);

if (argc != 1)
usage_with_options(upload_pack_usage, options);

if (timeout)
daemon_mode = 1;

setup_path();

dir = argv[0];


if (!enter_repo(dir, strict)) stateless_rpc = options->stateless_rpc;
die("'%s' does not appear to be a git repository", dir); timeout = options->timeout;
daemon_mode = options->daemon_mode;


git_config(upload_pack_config, NULL); git_config(upload_pack_config, NULL);


switch (determine_protocol_version_server()) { head_ref_namespaced(find_symref, &symref);
case protocol_v1:
/* if (options->advertise_refs || !stateless_rpc) {
* v1 is just the original protocol with a version string, reset_timeout();
* so just fall through after writing the version string. head_ref_namespaced(send_ref, &symref);
*/ for_each_namespaced_ref(send_ref, &symref);
if (advertise_refs || !stateless_rpc) advertise_shallow_grafts(1);
packet_write_fmt(1, "version 1\n"); packet_flush(1);

} else {
/* fallthrough */ head_ref_namespaced(check_ref, NULL);
case protocol_v0: for_each_namespaced_ref(check_ref, NULL);
upload_pack();
break;
case protocol_unknown_version:
BUG("unknown protocol version");
} }
string_list_clear(&symref, 1);
if (options->advertise_refs)
return;


return 0; receive_needs();
if (want_obj.nr) {
get_common_commits();
create_pack_file();
}
} }

13
upload-pack.h

@ -0,0 +1,13 @@
#ifndef UPLOAD_PACK_H
#define UPLOAD_PACK_H

struct upload_pack_options {
int stateless_rpc;
int advertise_refs;
unsigned int timeout;
int daemon_mode;
};

void upload_pack(struct upload_pack_options *options);

#endif /* UPLOAD_PACK_H */
Loading…
Cancel
Save