9 #if LIBCURL_VERSION_NUM >= 0x070908
10 #define USE_CURL_MULTI
11 #define DEFAULT_MAX_REQUESTS 5
14 #if LIBCURL_VERSION_NUM < 0x070704
15 #define curl_global_cleanup() do { /* nothing */ } while(0)
17 #if LIBCURL_VERSION_NUM < 0x070800
18 #define curl_global_init(a) do { /* nothing */ } while(0)
21 #define PREV_BUF_SIZE 4096
22 #define RANGE_HEADER_SIZE 30
24 static int active_requests = 0;
25 static int data_received;
28 static int max_requests = DEFAULT_MAX_REQUESTS;
31 static CURL *curl_default;
32 static struct curl_slist *no_pragma_header;
33 static struct curl_slist *no_range_header;
34 static char curl_errorstr[CURL_ERROR_SIZE];
40 struct packed_git *packs;
41 struct alt_base *next;
44 static struct alt_base *alt = NULL;
53 struct transfer_request
55 unsigned char sha1[20];
56 struct alt_base *repo;
58 char filename[PATH_MAX];
59 char tmpfile[PATH_MAX];
61 enum transfer_state state;
63 char errorstr[CURL_ERROR_SIZE];
65 unsigned char real_sha1[20];
70 struct active_request_slot *slot;
71 struct transfer_request *next;
74 struct active_request_slot
81 struct active_request_slot *next;
84 static struct transfer_request *request_queue_head = NULL;
85 static struct active_request_slot *active_queue_head = NULL;
87 static int curl_ssl_verify;
88 static char *ssl_cert;
90 static char *ssl_capath;
91 static char *ssl_cainfo;
100 static size_t fwrite_buffer(void *ptr, size_t eltsize, size_t nmemb,
101 struct buffer *buffer)
103 size_t size = eltsize * nmemb;
104 if (size > buffer->size - buffer->posn)
105 size = buffer->size - buffer->posn;
106 memcpy(buffer->buffer + buffer->posn, ptr, size);
107 buffer->posn += size;
112 static size_t fwrite_sha1_file(void *ptr, size_t eltsize, size_t nmemb,
115 unsigned char expn[4096];
116 size_t size = eltsize * nmemb;
118 struct transfer_request *request = (struct transfer_request *)data;
120 ssize_t retval = write(request->local,
121 ptr + posn, size - posn);
125 } while (posn < size);
127 request->stream.avail_in = size;
128 request->stream.next_in = ptr;
130 request->stream.next_out = expn;
131 request->stream.avail_out = sizeof(expn);
132 request->zret = inflate(&request->stream, Z_SYNC_FLUSH);
133 SHA1_Update(&request->c, expn,
134 sizeof(expn) - request->stream.avail_out);
135 } while (request->stream.avail_in && request->zret == Z_OK);
140 int relink_or_rename(char *old, char *new) {
143 ret = link(old, new);
145 /* Same Coda hack as in write_sha1_file(sha1_file.c) */
147 if (ret == EXDEV && !rename(old, new))
159 #ifdef USE_CURL_MULTI
160 void process_curl_messages();
161 void process_request_queue();
164 struct active_request_slot *get_active_slot()
166 struct active_request_slot *slot = active_queue_head;
167 struct active_request_slot *newslot;
169 #ifdef USE_CURL_MULTI
172 /* Wait for a slot to open up if the queue is full */
173 while (active_requests >= max_requests) {
174 curl_multi_perform(curlm, &num_transfers);
175 if (num_transfers < active_requests) {
176 process_curl_messages();
181 while (slot != NULL && slot->in_use) {
185 newslot = xmalloc(sizeof(*newslot));
186 newslot->curl = curl_easy_duphandle(curl_default);
188 newslot->next = NULL;
190 slot = active_queue_head;
192 active_queue_head = newslot;
194 while (slot->next != NULL) {
197 slot->next = newslot;
206 curl_easy_setopt(slot->curl, CURLOPT_HTTPHEADER, no_pragma_header);
207 curl_easy_setopt(slot->curl, CURLOPT_HTTPHEADER, no_range_header);
208 curl_easy_setopt(slot->curl, CURLOPT_ERRORBUFFER, curl_errorstr);
213 int start_active_slot(struct active_request_slot *slot)
215 #ifdef USE_CURL_MULTI
216 CURLMcode curlm_result = curl_multi_add_handle(curlm, slot->curl);
218 if (curlm_result != CURLM_OK &&
219 curlm_result != CURLM_CALL_MULTI_PERFORM) {
228 void run_active_slot(struct active_request_slot *slot)
230 #ifdef USE_CURL_MULTI
238 struct timeval select_timeout;
239 CURLMcode curlm_result;
241 while (!slot->done) {
244 curlm_result = curl_multi_perform(curlm,
246 } while (curlm_result == CURLM_CALL_MULTI_PERFORM);
247 if (num_transfers < active_requests) {
248 process_curl_messages();
249 process_request_queue();
252 if (!data_received && slot->local != NULL) {
253 current_pos = ftell(slot->local);
254 if (current_pos > last_pos)
256 last_pos = current_pos;
259 if (!slot->done && !data_received) {
264 select_timeout.tv_sec = 0;
265 select_timeout.tv_usec = 50000;
266 select(max_fd, &readfds, &writefds,
267 &excfds, &select_timeout);
271 slot->curl_result = curl_easy_perform(slot->curl);
276 void start_request(struct transfer_request *request)
278 char *hex = sha1_to_hex(request->sha1);
279 char prevfile[PATH_MAX];
283 unsigned char prev_buf[PREV_BUF_SIZE];
284 ssize_t prev_read = 0;
286 char range[RANGE_HEADER_SIZE];
287 struct curl_slist *range_header = NULL;
288 struct active_request_slot *slot;
290 snprintf(prevfile, sizeof(prevfile), "%s.prev", request->filename);
292 rename(request->tmpfile, prevfile);
293 unlink(request->tmpfile);
295 request->local = open(request->tmpfile,
296 O_WRONLY | O_CREAT | O_EXCL, 0666);
297 if (request->local < 0) {
298 request->state = ABORTED;
299 error("Couldn't create temporary file %s for %s: %s\n",
300 request->tmpfile, request->filename, strerror(errno));
304 memset(&request->stream, 0, sizeof(request->stream));
306 inflateInit(&request->stream);
308 SHA1_Init(&request->c);
310 url = xmalloc(strlen(request->repo->base) + 50);
311 request->url = xmalloc(strlen(request->repo->base) + 50);
312 strcpy(url, request->repo->base);
313 posn = url + strlen(request->repo->base);
314 strcpy(posn, "objects/");
316 memcpy(posn, hex, 2);
319 strcpy(posn, hex + 2);
320 strcpy(request->url, url);
322 /* If a previous temp file is present, process what was already
324 prevlocal = open(prevfile, O_RDONLY);
325 if (prevlocal != -1) {
327 prev_read = read(prevlocal, prev_buf, PREV_BUF_SIZE);
329 if (fwrite_sha1_file(prev_buf,
332 request) == prev_read) {
333 prev_posn += prev_read;
338 } while (prev_read > 0);
343 /* Reset inflate/SHA1 if there was an error reading the previous temp
344 file; also rewind to the beginning of the local file. */
345 if (prev_read == -1) {
346 memset(&request->stream, 0, sizeof(request->stream));
347 inflateInit(&request->stream);
348 SHA1_Init(&request->c);
351 lseek(request->local, SEEK_SET, 0);
352 ftruncate(request->local, 0);
356 slot = get_active_slot();
357 curl_easy_setopt(slot->curl, CURLOPT_FILE, request);
358 curl_easy_setopt(slot->curl, CURLOPT_WRITEFUNCTION, fwrite_sha1_file);
359 curl_easy_setopt(slot->curl, CURLOPT_ERRORBUFFER, request->errorstr);
360 curl_easy_setopt(slot->curl, CURLOPT_URL, url);
362 /* If we have successfully processed data from a previous fetch
363 attempt, only fetch the data we don't already have. */
367 "Resuming fetch of object %s at byte %ld\n",
369 sprintf(range, "Range: bytes=%ld-", prev_posn);
370 range_header = curl_slist_append(range_header, range);
371 curl_easy_setopt(slot->curl,
372 CURLOPT_HTTPHEADER, range_header);
375 /* Try to get the request started, abort the request on error */
376 if (!start_active_slot(slot)) {
377 request->state = ABORTED;
378 close(request->local);
383 request->slot = slot;
384 request->state = ACTIVE;
387 void finish_request(struct transfer_request *request)
389 fchmod(request->local, 0444);
390 close(request->local);
392 if (request->http_code == 416) {
393 fprintf(stderr, "Warning: requested range invalid; we may already have all the data.\n");
394 } else if (request->curl_result != CURLE_OK) {
398 inflateEnd(&request->stream);
399 SHA1_Final(request->real_sha1, &request->c);
400 if (request->zret != Z_STREAM_END) {
401 unlink(request->tmpfile);
404 if (memcmp(request->sha1, request->real_sha1, 20)) {
405 unlink(request->tmpfile);
409 relink_or_rename(request->tmpfile, request->filename);
411 if (request->rename == 0)
412 pull_say("got %s\n", sha1_to_hex(request->sha1));
415 void release_request(struct transfer_request *request)
417 struct transfer_request *entry = request_queue_head;
419 if (request == request_queue_head) {
420 request_queue_head = request->next;
422 while (entry->next != NULL && entry->next != request)
424 if (entry->next == request)
425 entry->next = entry->next->next;
432 #ifdef USE_CURL_MULTI
433 void process_curl_messages()
436 struct active_request_slot *slot;
437 struct transfer_request *request = NULL;
438 CURLMsg *curl_message = curl_multi_info_read(curlm, &num_messages);
440 while (curl_message != NULL) {
441 if (curl_message->msg == CURLMSG_DONE) {
442 slot = active_queue_head;
443 while (slot != NULL &&
444 slot->curl != curl_message->easy_handle)
447 curl_multi_remove_handle(curlm, slot->curl);
451 slot->curl_result = curl_message->data.result;
452 request = request_queue_head;
453 while (request != NULL &&
454 request->slot != slot)
455 request = request->next;
457 fprintf(stderr, "Received DONE message for unknown request!\n");
459 if (request != NULL) {
460 request->curl_result =
461 curl_message->data.result;
462 curl_easy_getinfo(slot->curl,
464 &request->http_code);
465 request->slot = NULL;
467 /* Use alternates if necessary */
468 if (request->http_code == 404 &&
469 request->repo->next != NULL) {
470 request->repo = request->repo->next;
471 start_request(request);
473 finish_request(request);
474 request->state = COMPLETE;
478 fprintf(stderr, "Unknown CURL message received: %d\n",
479 (int)curl_message->msg);
481 curl_message = curl_multi_info_read(curlm, &num_messages);
485 void process_request_queue()
487 struct transfer_request *request = request_queue_head;
490 while (active_requests < max_requests && request != NULL) {
491 if (request->state == WAITING) {
492 if (has_sha1_file(request->sha1))
493 release_request(request);
495 start_request(request);
496 curl_multi_perform(curlm, &num_transfers);
498 request = request->next;
503 void prefetch(unsigned char *sha1)
505 struct transfer_request *newreq;
506 struct transfer_request *tail;
507 char *filename = sha1_file_name(sha1);
509 newreq = xmalloc(sizeof(*newreq));
510 memcpy(newreq->sha1, sha1, 20);
514 newreq->state = WAITING;
515 snprintf(newreq->filename, sizeof(newreq->filename), "%s", filename);
516 snprintf(newreq->tmpfile, sizeof(newreq->tmpfile),
517 "%s.temp", filename);
520 if (request_queue_head == NULL) {
521 request_queue_head = newreq;
523 tail = request_queue_head;
524 while (tail->next != NULL) {
529 #ifdef USE_CURL_MULTI
530 process_request_queue();
531 process_curl_messages();
535 static int got_alternates = 0;
537 static int fetch_index(struct alt_base *repo, unsigned char *sha1)
539 char *hex = sha1_to_hex(sha1);
542 char tmpfile[PATH_MAX];
545 char range[RANGE_HEADER_SIZE];
546 struct curl_slist *range_header = NULL;
549 struct active_request_slot *slot;
551 if (has_pack_index(sha1))
555 fprintf(stderr, "Getting index for pack %s\n", hex);
557 url = xmalloc(strlen(repo->base) + 64);
558 sprintf(url, "%s/objects/pack/pack-%s.idx", repo->base, hex);
560 filename = sha1_pack_index_name(sha1);
561 snprintf(tmpfile, sizeof(tmpfile), "%s.temp", filename);
562 indexfile = fopen(tmpfile, "a");
564 return error("Unable to open local file %s for pack index",
567 slot = get_active_slot();
568 curl_easy_setopt(slot->curl, CURLOPT_FILE, indexfile);
569 curl_easy_setopt(slot->curl, CURLOPT_WRITEFUNCTION, fwrite);
570 curl_easy_setopt(slot->curl, CURLOPT_URL, url);
571 slot->local = indexfile;
573 /* If there is data present from a previous transfer attempt,
574 resume where it left off */
575 prev_posn = ftell(indexfile);
579 "Resuming fetch of index for pack %s at byte %ld\n",
581 sprintf(range, "Range: bytes=%ld-", prev_posn);
582 range_header = curl_slist_append(range_header, range);
583 curl_easy_setopt(slot->curl, CURLOPT_HTTPHEADER, range_header);
586 if (start_active_slot(slot)) {
587 run_active_slot(slot);
588 if (slot->curl_result != CURLE_OK) {
590 return error("Unable to get pack index %s\n%s", url,
594 return error("Unable to start request");
599 ret = relink_or_rename(tmpfile, filename);
601 return error("unable to write index filename %s: %s",
602 filename, strerror(ret));
607 static int setup_index(struct alt_base *repo, unsigned char *sha1)
609 struct packed_git *new_pack;
610 if (has_pack_file(sha1))
611 return 0; // don't list this as something we can get
613 if (fetch_index(repo, sha1))
616 new_pack = parse_pack_index(sha1);
617 new_pack->next = repo->packs;
618 repo->packs = new_pack;
622 static int fetch_alternates(char *base)
625 struct buffer buffer;
629 int http_specific = 1;
630 struct alt_base *tail = alt;
632 struct active_request_slot *slot;
635 data = xmalloc(4096);
638 buffer.buffer = data;
641 fprintf(stderr, "Getting alternates list\n");
643 url = xmalloc(strlen(base) + 31);
644 sprintf(url, "%s/objects/info/http-alternates", base);
646 slot = get_active_slot();
647 curl_easy_setopt(slot->curl, CURLOPT_FILE, &buffer);
648 curl_easy_setopt(slot->curl, CURLOPT_WRITEFUNCTION, fwrite_buffer);
649 curl_easy_setopt(slot->curl, CURLOPT_URL, url);
650 if (start_active_slot(slot)) {
651 run_active_slot(slot);
652 if (slot->curl_result != CURLE_OK || !buffer.posn) {
655 sprintf(url, "%s/objects/info/alternates", base);
657 slot = get_active_slot();
658 curl_easy_setopt(slot->curl, CURLOPT_FILE, &buffer);
659 curl_easy_setopt(slot->curl, CURLOPT_WRITEFUNCTION,
661 curl_easy_setopt(slot->curl, CURLOPT_URL, url);
662 if (start_active_slot(slot)) {
663 run_active_slot(slot);
664 if (slot->curl_result != CURLE_OK) {
673 data[buffer.posn] = '\0';
675 while (i < buffer.posn) {
677 while (posn < buffer.posn && data[posn] != '\n')
679 if (data[posn] == '\n') {
682 struct alt_base *newalt;
684 if (data[i] == '/') {
685 serverlen = strchr(base + 8, '/') - base;
687 } else if (!memcmp(data + i, "../", 3)) {
689 serverlen = strlen(base);
690 while (i + 2 < posn &&
691 !memcmp(data + i, "../", 3)) {
694 } while (serverlen &&
695 base[serverlen - 1] != '/');
698 // If the server got removed, give up.
699 okay = strchr(base, ':') - base + 3 <
701 } else if (http_specific) {
702 char *colon = strchr(data + i, ':');
703 char *slash = strchr(data + i, '/');
704 if (colon && slash && colon < data + posn &&
705 slash < data + posn && colon < slash) {
709 // skip 'objects' at end
711 target = xmalloc(serverlen + posn - i - 6);
712 strncpy(target, base, serverlen);
713 strncpy(target + serverlen, data + i,
715 target[serverlen + posn - i - 7] = '\0';
718 "Also look at %s\n", target);
719 newalt = xmalloc(sizeof(*newalt));
721 newalt->base = target;
722 newalt->got_indices = 0;
723 newalt->packs = NULL;
724 while (tail->next != NULL)
737 static int fetch_indices(struct alt_base *repo)
739 unsigned char sha1[20];
741 struct buffer buffer;
745 struct active_request_slot *slot;
747 if (repo->got_indices)
750 data = xmalloc(4096);
753 buffer.buffer = data;
756 fprintf(stderr, "Getting pack list\n");
758 url = xmalloc(strlen(repo->base) + 21);
759 sprintf(url, "%s/objects/info/packs", repo->base);
761 slot = get_active_slot();
762 curl_easy_setopt(slot->curl, CURLOPT_FILE, &buffer);
763 curl_easy_setopt(slot->curl, CURLOPT_WRITEFUNCTION, fwrite_buffer);
764 curl_easy_setopt(slot->curl, CURLOPT_URL, url);
765 curl_easy_setopt(slot->curl, CURLOPT_HTTPHEADER, NULL);
766 if (start_active_slot(slot)) {
767 run_active_slot(slot);
768 if (slot->curl_result != CURLE_OK)
769 return error("%s", curl_errorstr);
771 return error("Unable to start request");
774 while (i < buffer.posn) {
778 if (i + 52 < buffer.posn &&
779 !strncmp(data + i, " pack-", 6) &&
780 !strncmp(data + i + 46, ".pack\n", 6)) {
781 get_sha1_hex(data + i + 6, sha1);
782 setup_index(repo, sha1);
787 while (data[i] != '\n')
793 repo->got_indices = 1;
797 static int fetch_pack(struct alt_base *repo, unsigned char *sha1)
800 struct packed_git *target;
801 struct packed_git **lst;
804 char tmpfile[PATH_MAX];
807 char range[RANGE_HEADER_SIZE];
808 struct curl_slist *range_header = NULL;
810 struct active_request_slot *slot;
812 if (fetch_indices(repo))
814 target = find_sha1_pack(sha1, repo->packs);
819 fprintf(stderr, "Getting pack %s\n",
820 sha1_to_hex(target->sha1));
821 fprintf(stderr, " which contains %s\n",
825 url = xmalloc(strlen(repo->base) + 65);
826 sprintf(url, "%s/objects/pack/pack-%s.pack",
827 repo->base, sha1_to_hex(target->sha1));
829 filename = sha1_pack_name(target->sha1);
830 snprintf(tmpfile, sizeof(tmpfile), "%s.temp", filename);
831 packfile = fopen(tmpfile, "a");
833 return error("Unable to open local file %s for pack",
836 slot = get_active_slot();
837 curl_easy_setopt(slot->curl, CURLOPT_FILE, packfile);
838 curl_easy_setopt(slot->curl, CURLOPT_WRITEFUNCTION, fwrite);
839 curl_easy_setopt(slot->curl, CURLOPT_URL, url);
840 slot->local = packfile;
842 /* If there is data present from a previous transfer attempt,
843 resume where it left off */
844 prev_posn = ftell(packfile);
848 "Resuming fetch of pack %s at byte %ld\n",
849 sha1_to_hex(target->sha1), prev_posn);
850 sprintf(range, "Range: bytes=%ld-", prev_posn);
851 range_header = curl_slist_append(range_header, range);
852 curl_easy_setopt(slot->curl, CURLOPT_HTTPHEADER, range_header);
855 if (start_active_slot(slot)) {
856 run_active_slot(slot);
857 if (slot->curl_result != CURLE_OK) {
859 return error("Unable to get pack file %s\n%s", url,
863 return error("Unable to start request");
868 ret = relink_or_rename(tmpfile, filename);
870 return error("unable to write pack filename %s: %s",
871 filename, strerror(ret));
874 while (*lst != target)
875 lst = &((*lst)->next);
878 if (verify_pack(target, 0))
880 install_packed_git(target);
885 static int fetch_object(struct alt_base *repo, unsigned char *sha1)
887 char *hex = sha1_to_hex(sha1);
889 struct transfer_request *request = request_queue_head;
891 while (request != NULL && memcmp(request->sha1, sha1, 20))
892 request = request->next;
894 return error("Couldn't find request for %s in the queue", hex);
896 if (has_sha1_file(request->sha1)) {
897 release_request(request);
901 #ifdef USE_CURL_MULTI
903 while (request->state == WAITING) {
904 curl_multi_perform(curlm, &num_transfers);
905 if (num_transfers < active_requests) {
906 process_curl_messages();
907 process_request_queue();
911 start_request(request);
914 while (request->state == ACTIVE) {
915 run_active_slot(request->slot);
916 #ifndef USE_CURL_MULTI
917 request->curl_result = request->slot->curl_result;
918 curl_easy_getinfo(request->slot->curl,
920 &request->http_code);
921 request->slot = NULL;
923 /* Use alternates if necessary */
924 if (request->http_code == 404 &&
925 request->repo->next != NULL) {
926 request->repo = request->repo->next;
927 start_request(request);
929 finish_request(request);
930 request->state = COMPLETE;
935 if (request->state == ABORTED) {
936 release_request(request);
937 return error("Request for %s aborted", hex);
940 if (request->curl_result != CURLE_OK && request->http_code != 416) {
941 ret = error("%s", request->errorstr);
942 release_request(request);
946 if (request->zret != Z_STREAM_END) {
947 ret = error("File %s (%s) corrupt\n", hex, request->url);
948 release_request(request);
952 if (memcmp(request->sha1, request->real_sha1, 20)) {
953 release_request(request);
954 return error("File %s has bad hash\n", hex);
957 if (request->rename < 0) {
958 ret = error("unable to write sha1 filename %s: %s",
960 strerror(request->rename));
961 release_request(request);
965 release_request(request);
969 int fetch(unsigned char *sha1)
971 struct alt_base *altbase = alt;
973 if (!fetch_object(altbase, sha1))
976 if (!fetch_pack(altbase, sha1))
978 altbase = altbase->next;
980 return error("Unable to find %s under %s\n", sha1_to_hex(sha1),
984 int fetch_ref(char *ref, unsigned char *sha1)
988 struct buffer buffer;
989 char *base = alt->base;
990 struct active_request_slot *slot;
996 url = xmalloc(strlen(base) + 6 + strlen(ref));
998 posn = url + strlen(base);
999 strcpy(posn, "refs/");
1003 slot = get_active_slot();
1004 curl_easy_setopt(slot->curl, CURLOPT_FILE, &buffer);
1005 curl_easy_setopt(slot->curl, CURLOPT_WRITEFUNCTION, fwrite_buffer);
1006 curl_easy_setopt(slot->curl, CURLOPT_HTTPHEADER, NULL);
1007 curl_easy_setopt(slot->curl, CURLOPT_URL, url);
1008 if (start_active_slot(slot)) {
1009 run_active_slot(slot);
1010 if (slot->curl_result != CURLE_OK)
1011 return error("Couldn't get %s for %s\n%s",
1012 url, ref, curl_errorstr);
1014 return error("Unable to start request");
1018 get_sha1_hex(hex, sha1);
1022 int main(int argc, char **argv)
1027 struct active_request_slot *slot;
1029 while (arg < argc && argv[arg][0] == '-') {
1030 if (argv[arg][1] == 't') {
1032 } else if (argv[arg][1] == 'c') {
1034 } else if (argv[arg][1] == 'a') {
1038 } else if (argv[arg][1] == 'v') {
1040 } else if (argv[arg][1] == 'w') {
1041 write_ref = argv[arg + 1];
1043 } else if (!strcmp(argv[arg], "--recover")) {
1048 if (argc < arg + 2) {
1049 usage("git-http-fetch [-c] [-t] [-a] [-d] [-v] [--recover] [-w ref] commit-id url");
1052 commit_id = argv[arg];
1053 url = argv[arg + 1];
1055 curl_global_init(CURL_GLOBAL_ALL);
1057 #ifdef USE_CURL_MULTI
1058 char *http_max_requests = getenv("GIT_HTTP_MAX_REQUESTS");
1059 if (http_max_requests != NULL)
1060 max_requests = atoi(http_max_requests);
1061 if (max_requests < 1)
1062 max_requests = DEFAULT_MAX_REQUESTS;
1064 curlm = curl_multi_init();
1065 if (curlm == NULL) {
1066 fprintf(stderr, "Error creating curl multi handle.\n");
1070 no_pragma_header = curl_slist_append(no_pragma_header, "Pragma:");
1071 no_range_header = curl_slist_append(no_range_header, "Range:");
1073 curl_default = curl_easy_init();
1075 curl_ssl_verify = getenv("GIT_SSL_NO_VERIFY") ? 0 : 1;
1076 curl_easy_setopt(curl_default, CURLOPT_SSL_VERIFYPEER, curl_ssl_verify);
1077 #if LIBCURL_VERSION_NUM >= 0x070907
1078 curl_easy_setopt(curl_default, CURLOPT_NETRC, CURL_NETRC_OPTIONAL);
1081 if ((ssl_cert = getenv("GIT_SSL_CERT")) != NULL) {
1082 curl_easy_setopt(curl_default, CURLOPT_SSLCERT, ssl_cert);
1084 #if LIBCURL_VERSION_NUM >= 0x070902
1085 if ((ssl_key = getenv("GIT_SSL_KEY")) != NULL) {
1086 curl_easy_setopt(curl_default, CURLOPT_SSLKEY, ssl_key);
1089 #if LIBCURL_VERSION_NUM >= 0x070908
1090 if ((ssl_capath = getenv("GIT_SSL_CAPATH")) != NULL) {
1091 curl_easy_setopt(curl_default, CURLOPT_CAPATH, ssl_capath);
1094 if ((ssl_cainfo = getenv("GIT_SSL_CAINFO")) != NULL) {
1095 curl_easy_setopt(curl_default, CURLOPT_CAINFO, ssl_cainfo);
1097 curl_easy_setopt(curl_default, CURLOPT_FAILONERROR, 1);
1099 alt = xmalloc(sizeof(*alt));
1101 alt->got_indices = 0;
1104 fetch_alternates(alt->base);
1106 if (pull(commit_id))
1109 curl_slist_free_all(no_pragma_header);
1110 curl_slist_free_all(no_range_header);
1111 curl_easy_cleanup(curl_default);
1112 slot = active_queue_head;
1113 while (slot != NULL) {
1114 curl_easy_cleanup(slot->curl);
1117 #ifdef USE_CURL_MULTI
1118 curl_multi_cleanup(curlm);
1120 curl_global_cleanup();