9 #include "fetch-pack.h"
11 #include "run-command.h"
12 #include "transport.h"
14 static int transfer_unpack_limit
= -1;
15 static int fetch_unpack_limit
= -1;
16 static int unpack_limit
= 100;
17 static int prefer_ofs_delta
= 1;
18 static int no_done
= 0;
19 static struct fetch_pack_args args
= {
20 /* .uploadpack = */ "git-upload-pack",
23 static const char fetch_pack_usage
[] =
24 "git fetch-pack [--all] [--quiet|-q] [--keep|-k] [--thin] [--include-tag] [--upload-pack=<git-upload-pack>] [--depth=<n>] [--no-progress] [-v] [<host>:]<directory> [<refs>...]";
26 #define COMPLETE (1U << 0)
27 #define COMMON (1U << 1)
28 #define COMMON_REF (1U << 2)
29 #define SEEN (1U << 3)
30 #define POPPED (1U << 4)
35 * After sending this many "have"s if we do not get any new ACK , we
36 * give up traversing our history.
38 #define MAX_IN_VAIN 256
40 static struct commit_list
*rev_list
;
41 static int non_common_revs
, multi_ack
, use_sideband
;
43 static void rev_list_push(struct commit
*commit
, int mark
)
45 if (!(commit
->object
.flags
& mark
)) {
46 commit
->object
.flags
|= mark
;
48 if (!(commit
->object
.parsed
))
49 if (parse_commit(commit
))
52 commit_list_insert_by_date(commit
, &rev_list
);
54 if (!(commit
->object
.flags
& COMMON
))
59 static int rev_list_insert_ref(const char *path
, const unsigned char *sha1
, int flag
, void *cb_data
)
61 struct object
*o
= deref_tag(parse_object(sha1
), path
, 0);
63 if (o
&& o
->type
== OBJ_COMMIT
)
64 rev_list_push((struct commit
*)o
, SEEN
);
69 static int clear_marks(const char *path
, const unsigned char *sha1
, int flag
, void *cb_data
)
71 struct object
*o
= deref_tag(parse_object(sha1
), path
, 0);
73 if (o
&& o
->type
== OBJ_COMMIT
)
74 clear_commit_marks((struct commit
*)o
,
75 COMMON
| COMMON_REF
| SEEN
| POPPED
);
80 This function marks a rev and its ancestors as common.
81 In some cases, it is desirable to mark only the ancestors (for example
82 when only the server does not yet know that they are common).
85 static void mark_common(struct commit
*commit
,
86 int ancestors_only
, int dont_parse
)
88 if (commit
!= NULL
&& !(commit
->object
.flags
& COMMON
)) {
89 struct object
*o
= (struct object
*)commit
;
94 if (!(o
->flags
& SEEN
))
95 rev_list_push(commit
, SEEN
);
97 struct commit_list
*parents
;
99 if (!ancestors_only
&& !(o
->flags
& POPPED
))
101 if (!o
->parsed
&& !dont_parse
)
102 if (parse_commit(commit
))
105 for (parents
= commit
->parents
;
107 parents
= parents
->next
)
108 mark_common(parents
->item
, 0, dont_parse
);
114 Get the next rev to send, ignoring the common.
117 static const unsigned char *get_rev(void)
119 struct commit
*commit
= NULL
;
121 while (commit
== NULL
) {
123 struct commit_list
*parents
;
125 if (rev_list
== NULL
|| non_common_revs
== 0)
128 commit
= rev_list
->item
;
129 if (!commit
->object
.parsed
)
130 parse_commit(commit
);
131 parents
= commit
->parents
;
133 commit
->object
.flags
|= POPPED
;
134 if (!(commit
->object
.flags
& COMMON
))
137 if (commit
->object
.flags
& COMMON
) {
138 /* do not send "have", and ignore ancestors */
140 mark
= COMMON
| SEEN
;
141 } else if (commit
->object
.flags
& COMMON_REF
)
142 /* send "have", and ignore ancestors */
143 mark
= COMMON
| SEEN
;
145 /* send "have", also for its ancestors */
149 if (!(parents
->item
->object
.flags
& SEEN
))
150 rev_list_push(parents
->item
, mark
);
152 mark_common(parents
->item
, 1, 0);
153 parents
= parents
->next
;
156 rev_list
= rev_list
->next
;
159 return commit
->object
.sha1
;
170 static void consume_shallow_list(int fd
)
172 if (args
.stateless_rpc
&& args
.depth
> 0) {
173 /* If we sent a depth we will get back "duplicate"
174 * shallow and unshallow commands every time there
175 * is a block of have lines exchanged.
178 while (packet_read_line(fd
, line
, sizeof(line
))) {
179 if (!prefixcmp(line
, "shallow "))
181 if (!prefixcmp(line
, "unshallow "))
183 die("git fetch-pack: expected shallow list");
188 static enum ack_type
get_ack(int fd
, unsigned char *result_sha1
)
190 static char line
[1000];
191 int len
= packet_read_line(fd
, line
, sizeof(line
));
194 die("git fetch-pack: expected ACK/NAK, got EOF");
195 if (line
[len
-1] == '\n')
197 if (!strcmp(line
, "NAK"))
199 if (!prefixcmp(line
, "ACK ")) {
200 if (!get_sha1_hex(line
+4, result_sha1
)) {
201 if (strstr(line
+45, "continue"))
203 if (strstr(line
+45, "common"))
205 if (strstr(line
+45, "ready"))
210 die("git fetch_pack: expected ACK/NAK, got '%s'", line
);
213 static void send_request(int fd
, struct strbuf
*buf
)
215 if (args
.stateless_rpc
) {
216 send_sideband(fd
, -1, buf
->buf
, buf
->len
, LARGE_PACKET_MAX
);
219 safe_write(fd
, buf
->buf
, buf
->len
);
222 static void insert_one_alternate_ref(const struct ref
*ref
, void *unused
)
224 rev_list_insert_ref(NULL
, ref
->old_sha1
, 0, NULL
);
227 static void insert_alternate_refs(void)
229 foreach_alt_odb(refs_from_alternate_cb
, insert_one_alternate_ref
);
232 #define INITIAL_FLUSH 16
233 #define LARGE_FLUSH 1024
235 static int next_flush(int count
)
237 if (count
< INITIAL_FLUSH
* 2)
238 count
+= INITIAL_FLUSH
;
239 else if (count
< LARGE_FLUSH
)
242 count
+= LARGE_FLUSH
;
246 static int find_common(int fd
[2], unsigned char *result_sha1
,
250 int count
= 0, flushes
= 0, flush_at
= INITIAL_FLUSH
, retval
;
251 const unsigned char *sha1
;
252 unsigned in_vain
= 0;
253 int got_continue
= 0;
255 struct strbuf req_buf
= STRBUF_INIT
;
256 size_t state_len
= 0;
258 if (args
.stateless_rpc
&& multi_ack
== 1)
259 die("--stateless-rpc requires multi_ack_detailed");
261 for_each_ref(clear_marks
, NULL
);
264 for_each_ref(rev_list_insert_ref
, NULL
);
265 insert_alternate_refs();
268 for ( ; refs
; refs
= refs
->next
) {
269 unsigned char *remote
= refs
->old_sha1
;
270 const char *remote_hex
;
274 * If that object is complete (i.e. it is an ancestor of a
275 * local ref), we tell them we have it but do not have to
276 * tell them about its ancestors, which they already know
279 * We use lookup_object here because we are only
280 * interested in the case we *know* the object is
281 * reachable and we have already scanned it.
283 if (((o
= lookup_object(remote
)) != NULL
) &&
284 (o
->flags
& COMPLETE
)) {
288 remote_hex
= sha1_to_hex(remote
);
290 struct strbuf c
= STRBUF_INIT
;
291 if (multi_ack
== 2) strbuf_addstr(&c
, " multi_ack_detailed");
292 if (multi_ack
== 1) strbuf_addstr(&c
, " multi_ack");
293 if (no_done
) strbuf_addstr(&c
, " no-done");
294 if (use_sideband
== 2) strbuf_addstr(&c
, " side-band-64k");
295 if (use_sideband
== 1) strbuf_addstr(&c
, " side-band");
296 if (args
.use_thin_pack
) strbuf_addstr(&c
, " thin-pack");
297 if (args
.no_progress
) strbuf_addstr(&c
, " no-progress");
298 if (args
.include_tag
) strbuf_addstr(&c
, " include-tag");
299 if (prefer_ofs_delta
) strbuf_addstr(&c
, " ofs-delta");
300 packet_buf_write(&req_buf
, "want %s%s\n", remote_hex
, c
.buf
);
303 packet_buf_write(&req_buf
, "want %s\n", remote_hex
);
308 strbuf_release(&req_buf
);
313 if (is_repository_shallow())
314 write_shallow_commits(&req_buf
, 1);
316 packet_buf_write(&req_buf
, "deepen %d", args
.depth
);
317 packet_buf_flush(&req_buf
);
318 state_len
= req_buf
.len
;
320 if (args
.depth
> 0) {
322 unsigned char sha1
[20];
324 send_request(fd
[1], &req_buf
);
325 while (packet_read_line(fd
[0], line
, sizeof(line
))) {
326 if (!prefixcmp(line
, "shallow ")) {
327 if (get_sha1_hex(line
+ 8, sha1
))
328 die("invalid shallow line: %s", line
);
329 register_shallow(sha1
);
332 if (!prefixcmp(line
, "unshallow ")) {
333 if (get_sha1_hex(line
+ 10, sha1
))
334 die("invalid unshallow line: %s", line
);
335 if (!lookup_object(sha1
))
336 die("object not found: %s", line
);
337 /* make sure that it is parsed as shallow */
338 if (!parse_object(sha1
))
339 die("error in object: %s", line
);
340 if (unregister_shallow(sha1
))
341 die("no shallow found: %s", line
);
344 die("expected shallow/unshallow, got %s", line
);
346 } else if (!args
.stateless_rpc
)
347 send_request(fd
[1], &req_buf
);
349 if (!args
.stateless_rpc
) {
350 /* If we aren't using the stateless-rpc interface
351 * we don't need to retain the headers.
353 strbuf_setlen(&req_buf
, 0);
359 while ((sha1
= get_rev())) {
360 packet_buf_write(&req_buf
, "have %s\n", sha1_to_hex(sha1
));
362 fprintf(stderr
, "have %s\n", sha1_to_hex(sha1
));
364 if (flush_at
<= ++count
) {
367 packet_buf_flush(&req_buf
);
368 send_request(fd
[1], &req_buf
);
369 strbuf_setlen(&req_buf
, state_len
);
371 flush_at
= next_flush(count
);
374 * We keep one window "ahead" of the other side, and
375 * will wait for an ACK only on the next one
377 if (!args
.stateless_rpc
&& count
== INITIAL_FLUSH
)
380 consume_shallow_list(fd
[0]);
382 ack
= get_ack(fd
[0], result_sha1
);
383 if (args
.verbose
&& ack
)
384 fprintf(stderr
, "got ack %d %s\n", ack
,
385 sha1_to_hex(result_sha1
));
395 struct commit
*commit
=
396 lookup_commit(result_sha1
);
397 if (args
.stateless_rpc
399 && !(commit
->object
.flags
& COMMON
)) {
400 /* We need to replay the have for this object
401 * on the next RPC request so the peer knows
402 * it is in common with us.
404 const char *hex
= sha1_to_hex(result_sha1
);
405 packet_buf_write(&req_buf
, "have %s\n", hex
);
406 state_len
= req_buf
.len
;
408 mark_common(commit
, 0, 1);
412 if (ack
== ACK_ready
) {
421 if (got_continue
&& MAX_IN_VAIN
< in_vain
) {
423 fprintf(stderr
, "giving up\n");
429 if (!got_ready
|| !no_done
) {
430 packet_buf_write(&req_buf
, "done\n");
431 send_request(fd
[1], &req_buf
);
434 fprintf(stderr
, "done\n");
439 strbuf_release(&req_buf
);
441 consume_shallow_list(fd
[0]);
442 while (flushes
|| multi_ack
) {
443 int ack
= get_ack(fd
[0], result_sha1
);
446 fprintf(stderr
, "got ack (%d) %s\n", ack
,
447 sha1_to_hex(result_sha1
));
455 /* it is no error to fetch into a completely empty repo */
456 return count
? retval
: 0;
459 static struct commit_list
*complete
;
461 static int mark_complete(const char *path
, const unsigned char *sha1
, int flag
, void *cb_data
)
463 struct object
*o
= parse_object(sha1
);
465 while (o
&& o
->type
== OBJ_TAG
) {
466 struct tag
*t
= (struct tag
*) o
;
468 break; /* broken repository */
469 o
->flags
|= COMPLETE
;
470 o
= parse_object(t
->tagged
->sha1
);
472 if (o
&& o
->type
== OBJ_COMMIT
) {
473 struct commit
*commit
= (struct commit
*)o
;
474 commit
->object
.flags
|= COMPLETE
;
475 commit_list_insert_by_date(commit
, &complete
);
480 static void mark_recent_complete_commits(unsigned long cutoff
)
482 while (complete
&& cutoff
<= complete
->item
->date
) {
484 fprintf(stderr
, "Marking %s as complete\n",
485 sha1_to_hex(complete
->item
->object
.sha1
));
486 pop_most_recent_commit(&complete
, COMPLETE
);
490 static void filter_refs(struct ref
**refs
, int nr_match
, char **match
)
492 struct ref
**return_refs
;
493 struct ref
*newlist
= NULL
;
494 struct ref
**newtail
= &newlist
;
495 struct ref
*ref
, *next
;
496 struct ref
*fastarray
[32];
498 if (nr_match
&& !args
.fetch_all
) {
499 if (ARRAY_SIZE(fastarray
) < nr_match
)
500 return_refs
= xcalloc(nr_match
, sizeof(struct ref
*));
502 return_refs
= fastarray
;
503 memset(return_refs
, 0, sizeof(struct ref
*) * nr_match
);
509 for (ref
= *refs
; ref
; ref
= next
) {
511 if (!memcmp(ref
->name
, "refs/", 5) &&
512 check_ref_format(ref
->name
+ 5))
514 else if (args
.fetch_all
&&
515 (!args
.depth
|| prefixcmp(ref
->name
, "refs/tags/") )) {
518 newtail
= &ref
->next
;
522 int order
= path_match(ref
->name
, nr_match
, match
);
524 return_refs
[order
-1] = ref
;
525 continue; /* we will link it later */
531 if (!args
.fetch_all
) {
533 for (i
= 0; i
< nr_match
; i
++) {
534 ref
= return_refs
[i
];
538 newtail
= &ref
->next
;
541 if (return_refs
!= fastarray
)
547 static int everything_local(struct ref
**refs
, int nr_match
, char **match
)
551 unsigned long cutoff
= 0;
553 save_commit_buffer
= 0;
555 for (ref
= *refs
; ref
; ref
= ref
->next
) {
558 o
= parse_object(ref
->old_sha1
);
562 /* We already have it -- which may mean that we were
563 * in sync with the other side at some time after
564 * that (it is OK if we guess wrong here).
566 if (o
->type
== OBJ_COMMIT
) {
567 struct commit
*commit
= (struct commit
*)o
;
568 if (!cutoff
|| cutoff
< commit
->date
)
569 cutoff
= commit
->date
;
574 for_each_ref(mark_complete
, NULL
);
576 mark_recent_complete_commits(cutoff
);
580 * Mark all complete remote refs as common refs.
581 * Don't mark them common yet; the server has to be told so first.
583 for (ref
= *refs
; ref
; ref
= ref
->next
) {
584 struct object
*o
= deref_tag(lookup_object(ref
->old_sha1
),
587 if (!o
|| o
->type
!= OBJ_COMMIT
|| !(o
->flags
& COMPLETE
))
590 if (!(o
->flags
& SEEN
)) {
591 rev_list_push((struct commit
*)o
, COMMON_REF
| SEEN
);
593 mark_common((struct commit
*)o
, 1, 1);
597 filter_refs(refs
, nr_match
, match
);
599 for (retval
= 1, ref
= *refs
; ref
; ref
= ref
->next
) {
600 const unsigned char *remote
= ref
->old_sha1
;
601 unsigned char local
[20];
604 o
= lookup_object(remote
);
605 if (!o
|| !(o
->flags
& COMPLETE
)) {
610 "want %s (%s)\n", sha1_to_hex(remote
),
615 hashcpy(ref
->new_sha1
, local
);
619 "already have %s (%s)\n", sha1_to_hex(remote
),
625 static int sideband_demux(int in
, int out
, void *data
)
629 int ret
= recv_sideband("fetch-pack", xd
[0], out
);
634 static int get_pack(int xd
[2], char **pack_lockfile
)
637 const char *argv
[20];
641 int do_keep
= args
.keep_pack
;
642 struct child_process cmd
;
644 memset(&demux
, 0, sizeof(demux
));
646 /* xd[] is talking with upload-pack; subprocess reads from
647 * xd[0], spits out band#2 to stderr, and feeds us band#1
648 * through demux->out.
650 demux
.proc
= sideband_demux
;
653 if (start_async(&demux
))
654 die("fetch-pack: unable to fork off sideband"
660 memset(&cmd
, 0, sizeof(cmd
));
664 if (!args
.keep_pack
&& unpack_limit
) {
665 struct pack_header header
;
667 if (read_pack_header(demux
.out
, &header
))
668 die("protocol error: bad pack header");
669 snprintf(hdr_arg
, sizeof(hdr_arg
),
670 "--pack_header=%"PRIu32
",%"PRIu32
,
671 ntohl(header
.hdr_version
), ntohl(header
.hdr_entries
));
672 if (ntohl(header
.hdr_entries
) < unpack_limit
)
681 *av
++ = "index-pack";
683 if (!args
.quiet
&& !args
.no_progress
)
685 if (args
.use_thin_pack
)
686 *av
++ = "--fix-thin";
687 if (args
.lock_pack
|| unpack_limit
) {
688 int s
= sprintf(keep_arg
,
689 "--keep=fetch-pack %"PRIuMAX
" on ", (uintmax_t) getpid());
690 if (gethostname(keep_arg
+ s
, sizeof(keep_arg
) - s
))
691 strcpy(keep_arg
+ s
, "localhost");
696 *av
++ = "unpack-objects";
706 if (start_command(&cmd
))
707 die("fetch-pack: unable to fork off %s", argv
[0]);
708 if (do_keep
&& pack_lockfile
) {
709 *pack_lockfile
= index_pack_lockfile(cmd
.out
);
713 if (finish_command(&cmd
))
714 die("%s failed", argv
[0]);
715 if (use_sideband
&& finish_async(&demux
))
716 die("error in sideband demultiplexer");
720 static struct ref
*do_fetch_pack(int fd
[2],
721 const struct ref
*orig_ref
,
724 char **pack_lockfile
)
726 struct ref
*ref
= copy_ref_list(orig_ref
);
727 unsigned char sha1
[20];
729 if (is_repository_shallow() && !server_supports("shallow"))
730 die("Server does not support shallow clients");
731 if (server_supports("multi_ack_detailed")) {
733 fprintf(stderr
, "Server supports multi_ack_detailed\n");
735 if (server_supports("no-done")) {
737 fprintf(stderr
, "Server supports no-done\n");
738 if (args
.stateless_rpc
)
742 else if (server_supports("multi_ack")) {
744 fprintf(stderr
, "Server supports multi_ack\n");
747 if (server_supports("side-band-64k")) {
749 fprintf(stderr
, "Server supports side-band-64k\n");
752 else if (server_supports("side-band")) {
754 fprintf(stderr
, "Server supports side-band\n");
757 if (server_supports("ofs-delta")) {
759 fprintf(stderr
, "Server supports ofs-delta\n");
761 prefer_ofs_delta
= 0;
762 if (everything_local(&ref
, nr_match
, match
)) {
766 if (find_common(fd
, sha1
, ref
) < 0)
768 /* When cloning, it is not unusual to have
771 warning("no common commits");
773 if (args
.stateless_rpc
)
775 if (get_pack(fd
, pack_lockfile
))
776 die("git fetch-pack: fetch failed.");
782 static int remove_duplicates(int nr_heads
, char **heads
)
786 for (src
= dst
= 0; src
< nr_heads
; src
++) {
787 /* If heads[src] is different from any of
788 * heads[0..dst], push it in.
791 for (i
= 0; i
< dst
; i
++) {
792 if (!strcmp(heads
[i
], heads
[src
]))
798 heads
[dst
] = heads
[src
];
804 static int fetch_pack_config(const char *var
, const char *value
, void *cb
)
806 if (strcmp(var
, "fetch.unpacklimit") == 0) {
807 fetch_unpack_limit
= git_config_int(var
, value
);
811 if (strcmp(var
, "transfer.unpacklimit") == 0) {
812 transfer_unpack_limit
= git_config_int(var
, value
);
816 if (strcmp(var
, "repack.usedeltabaseoffset") == 0) {
817 prefer_ofs_delta
= git_config_bool(var
, value
);
821 return git_default_config(var
, value
, cb
);
824 static struct lock_file lock
;
826 static void fetch_pack_setup(void)
828 static int did_setup
;
831 git_config(fetch_pack_config
, NULL
);
832 if (0 <= transfer_unpack_limit
)
833 unpack_limit
= transfer_unpack_limit
;
834 else if (0 <= fetch_unpack_limit
)
835 unpack_limit
= fetch_unpack_limit
;
839 int cmd_fetch_pack(int argc
, const char **argv
, const char *prefix
)
841 int i
, ret
, nr_heads
;
842 struct ref
*ref
= NULL
;
843 char *dest
= NULL
, **heads
;
845 char *pack_lockfile
= NULL
;
846 char **pack_lockfile_ptr
= NULL
;
847 struct child_process
*conn
;
849 packet_trace_identity("fetch-pack");
853 for (i
= 1; i
< argc
; i
++) {
854 const char *arg
= argv
[i
];
857 if (!prefixcmp(arg
, "--upload-pack=")) {
858 args
.uploadpack
= arg
+ 14;
861 if (!prefixcmp(arg
, "--exec=")) {
862 args
.uploadpack
= arg
+ 7;
865 if (!strcmp("--quiet", arg
) || !strcmp("-q", arg
)) {
869 if (!strcmp("--keep", arg
) || !strcmp("-k", arg
)) {
870 args
.lock_pack
= args
.keep_pack
;
874 if (!strcmp("--thin", arg
)) {
875 args
.use_thin_pack
= 1;
878 if (!strcmp("--include-tag", arg
)) {
879 args
.include_tag
= 1;
882 if (!strcmp("--all", arg
)) {
886 if (!strcmp("-v", arg
)) {
890 if (!prefixcmp(arg
, "--depth=")) {
891 args
.depth
= strtol(arg
+ 8, NULL
, 0);
894 if (!strcmp("--no-progress", arg
)) {
895 args
.no_progress
= 1;
898 if (!strcmp("--stateless-rpc", arg
)) {
899 args
.stateless_rpc
= 1;
902 if (!strcmp("--lock-pack", arg
)) {
904 pack_lockfile_ptr
= &pack_lockfile
;
907 usage(fetch_pack_usage
);
910 heads
= (char **)(argv
+ i
+ 1);
911 nr_heads
= argc
- i
- 1;
915 usage(fetch_pack_usage
);
917 if (args
.stateless_rpc
) {
922 conn
= git_connect(fd
, (char *)dest
, args
.uploadpack
,
923 args
.verbose
? CONNECT_VERBOSE
: 0);
926 get_remote_heads(fd
[0], &ref
, 0, NULL
, 0, NULL
);
928 ref
= fetch_pack(&args
, fd
, conn
, ref
, dest
,
929 nr_heads
, heads
, pack_lockfile_ptr
);
931 printf("lock %s\n", pack_lockfile
);
936 if (finish_connect(conn
))
940 if (!ret
&& nr_heads
) {
941 /* If the heads to pull were given, we should have
942 * consumed all of them by matching the remote.
943 * Otherwise, 'git fetch remote no-such-ref' would
944 * silently succeed without issuing an error.
946 for (i
= 0; i
< nr_heads
; i
++)
947 if (heads
[i
] && heads
[i
][0]) {
948 error("no such remote ref %s", heads
[i
]);
954 sha1_to_hex(ref
->old_sha1
), ref
->name
);
961 struct ref
*fetch_pack(struct fetch_pack_args
*my_args
,
962 int fd
[], struct child_process
*conn
,
963 const struct ref
*ref
,
967 char **pack_lockfile
)
973 if (&args
!= my_args
)
974 memcpy(&args
, my_args
, sizeof(args
));
975 if (args
.depth
> 0) {
976 if (stat(git_path("shallow"), &st
))
980 if (heads
&& nr_heads
)
981 nr_heads
= remove_duplicates(nr_heads
, heads
);
984 die("no matching remote head");
986 ref_cpy
= do_fetch_pack(fd
, ref
, nr_heads
, heads
, pack_lockfile
);
988 if (args
.depth
> 0) {
989 struct cache_time mtime
;
990 struct strbuf sb
= STRBUF_INIT
;
991 char *shallow
= git_path("shallow");
994 mtime
.sec
= st
.st_mtime
;
995 mtime
.nsec
= ST_MTIME_NSEC(st
);
996 if (stat(shallow
, &st
)) {
998 die("shallow file was removed during fetch");
999 } else if (st
.st_mtime
!= mtime
.sec
1001 || ST_MTIME_NSEC(st
) != mtime
.nsec
1004 die("shallow file was changed during fetch");
1006 fd
= hold_lock_file_for_update(&lock
, shallow
,
1008 if (!write_shallow_commits(&sb
, 0)
1009 || write_in_full(fd
, sb
.buf
, sb
.len
) != sb
.len
) {
1010 unlink_or_warn(shallow
);
1011 rollback_lock_file(&lock
);
1013 commit_lock_file(&lock
);
1015 strbuf_release(&sb
);
1018 reprepare_packed_git();