зеркало из https://github.com/microsoft/git.git
http-push: refactor request url creation
Introduce two helper functions append_remote_object_url() and get_remote_object_url() and use them to remove various places that allocate and format the URL by hand. These functions generate a URL that point at the fan-out directory inside the remote object store (e.g. http://host/path/to/repo/objects/a1/) or at an individual loose object file. Signed-off-by: Tay Ray Chuan <rctay89@gmail.com> Signed-off-by: Junio C Hamano <gitster@pobox.com>
This commit is contained in:
Родитель
a34a9dbbce
Коммит
817d14a87a
64
http-push.c
64
http-push.c
|
@ -209,6 +209,22 @@ static struct curl_slist *get_dav_token_headers(struct remote_lock *lock, enum d
|
|||
return dav_headers;
|
||||
}
|
||||
|
||||
static void append_remote_object_url(struct strbuf *buf, const char *url,
|
||||
const char *hex,
|
||||
int only_two_digit_prefix)
|
||||
{
|
||||
strbuf_addf(buf, "%sobjects/%.*s/", url, 2, hex);
|
||||
if (!only_two_digit_prefix)
|
||||
strbuf_addf(buf, "%s", hex+2);
|
||||
}
|
||||
|
||||
static char *get_remote_object_url(const char *url, const char *hex, int only_two_digit_prefix)
|
||||
{
|
||||
struct strbuf buf = STRBUF_INIT;
|
||||
append_remote_object_url(&buf, url, hex, only_two_digit_prefix);
|
||||
return strbuf_detach(&buf, NULL);
|
||||
}
|
||||
|
||||
static void finish_request(struct transfer_request *request);
|
||||
static void release_request(struct transfer_request *request);
|
||||
|
||||
|
@ -255,7 +271,6 @@ static void start_fetch_loose(struct transfer_request *request)
|
|||
char *filename;
|
||||
char prevfile[PATH_MAX];
|
||||
char *url;
|
||||
char *posn;
|
||||
int prevlocal;
|
||||
unsigned char prev_buf[PREV_BUF_SIZE];
|
||||
ssize_t prev_read = 0;
|
||||
|
@ -305,17 +320,8 @@ static void start_fetch_loose(struct transfer_request *request)
|
|||
|
||||
git_SHA1_Init(&request->c);
|
||||
|
||||
url = xmalloc(strlen(remote->url) + 50);
|
||||
request->url = xmalloc(strlen(remote->url) + 50);
|
||||
strcpy(url, remote->url);
|
||||
posn = url + strlen(remote->url);
|
||||
strcpy(posn, "objects/");
|
||||
posn += 8;
|
||||
memcpy(posn, hex, 2);
|
||||
posn += 2;
|
||||
*(posn++) = '/';
|
||||
strcpy(posn, hex + 2);
|
||||
strcpy(request->url, url);
|
||||
url = get_remote_object_url(remote->url, hex, 0);
|
||||
request->url = xstrdup(url);
|
||||
|
||||
/* If a previous temp file is present, process what was already
|
||||
fetched. */
|
||||
|
@ -388,16 +394,8 @@ static void start_mkcol(struct transfer_request *request)
|
|||
{
|
||||
char *hex = sha1_to_hex(request->obj->sha1);
|
||||
struct active_request_slot *slot;
|
||||
char *posn;
|
||||
|
||||
request->url = xmalloc(strlen(remote->url) + 13);
|
||||
strcpy(request->url, remote->url);
|
||||
posn = request->url + strlen(remote->url);
|
||||
strcpy(posn, "objects/");
|
||||
posn += 8;
|
||||
memcpy(posn, hex, 2);
|
||||
posn += 2;
|
||||
strcpy(posn, "/");
|
||||
request->url = get_remote_object_url(remote->url, hex, 1);
|
||||
|
||||
slot = get_active_slot();
|
||||
slot->callback_func = process_response;
|
||||
|
@ -512,7 +510,7 @@ static void start_put(struct transfer_request *request)
|
|||
{
|
||||
char *hex = sha1_to_hex(request->obj->sha1);
|
||||
struct active_request_slot *slot;
|
||||
char *posn;
|
||||
struct strbuf buf = STRBUF_INIT;
|
||||
enum object_type type;
|
||||
char hdr[50];
|
||||
void *unpacked;
|
||||
|
@ -551,21 +549,13 @@ static void start_put(struct transfer_request *request)
|
|||
|
||||
request->buffer.buf.len = stream.total_out;
|
||||
|
||||
request->url = xmalloc(strlen(remote->url) +
|
||||
strlen(request->lock->token) + 51);
|
||||
strcpy(request->url, remote->url);
|
||||
posn = request->url + strlen(remote->url);
|
||||
strcpy(posn, "objects/");
|
||||
posn += 8;
|
||||
memcpy(posn, hex, 2);
|
||||
posn += 2;
|
||||
*(posn++) = '/';
|
||||
strcpy(posn, hex + 2);
|
||||
request->dest = xmalloc(strlen(request->url) + 14);
|
||||
sprintf(request->dest, "Destination: %s", request->url);
|
||||
posn += 38;
|
||||
*(posn++) = '_';
|
||||
strcpy(posn, request->lock->token);
|
||||
strbuf_addstr(&buf, "Destination: ");
|
||||
append_remote_object_url(&buf, remote->url, hex, 0);
|
||||
request->dest = strbuf_detach(&buf, NULL);
|
||||
|
||||
append_remote_object_url(&buf, remote->url, hex, 0);
|
||||
strbuf_addstr(&buf, request->lock->token);
|
||||
request->url = strbuf_detach(&buf, NULL);
|
||||
|
||||
slot = get_active_slot();
|
||||
slot->callback_func = process_response;
|
||||
|
|
Загрузка…
Ссылка в новой задаче