]>
git.ipfire.org Git - thirdparty/git.git/blob - builtin-bundle.c
6 #include "list-objects.h"
10 * Basic handler for bundle files to connect repositories via sneakernet.
11 * Invocation must include action.
12 * This function can create a bundle or provide information on an existing
13 * bundle supporting git-fetch, git-pull, and git-ls-remote
16 static const char *bundle_usage
="git-bundle (create <bundle> <git-rev-list args> | verify <bundle> | list-heads <bundle> [refname]... | unbundle <bundle> [refname]... )";
18 static const char bundle_signature
[] = "# v2 git bundle\n";
21 unsigned int nr
, alloc
;
22 struct ref_list_entry
{
23 unsigned char sha1
[20];
28 static void add_to_ref_list(const unsigned char *sha1
, const char *name
,
29 struct ref_list
*list
)
31 if (list
->nr
+ 1 >= list
->alloc
) {
32 list
->alloc
= alloc_nr(list
->nr
+ 1);
33 list
->list
= xrealloc(list
->list
,
34 list
->alloc
* sizeof(list
->list
[0]));
36 memcpy(list
->list
[list
->nr
].sha1
, sha1
, 20);
37 list
->list
[list
->nr
].name
= xstrdup(name
);
41 struct bundle_header
{
42 struct ref_list prerequisites
;
43 struct ref_list references
;
46 /* this function returns the length of the string */
47 static int read_string(int fd
, char *buffer
, int size
)
50 for (i
= 0; i
< size
- 1; i
++) {
51 int count
= xread(fd
, buffer
+ i
, 1);
53 return error("Read error: %s", strerror(errno
));
58 if (buffer
[i
] == '\n')
66 static int read_header(const char *path
, struct bundle_header
*header
) {
68 int fd
= open(path
, O_RDONLY
);
71 return error("could not open '%s'", path
);
72 if (read_string(fd
, buffer
, sizeof(buffer
)) < 0 ||
73 strcmp(buffer
, bundle_signature
)) {
75 return error("'%s' does not look like a v2 bundle file", path
);
77 while (read_string(fd
, buffer
, sizeof(buffer
)) > 0
78 && buffer
[0] != '\n') {
79 int is_prereq
= buffer
[0] == '-';
80 int offset
= is_prereq
? 1 : 0;
81 int len
= strlen(buffer
);
82 unsigned char sha1
[20];
83 struct ref_list
*list
= is_prereq
? &header
->prerequisites
84 : &header
->references
;
87 if (buffer
[len
- 1] == '\n')
88 buffer
[len
- 1] = '\0';
89 if (get_sha1_hex(buffer
+ offset
, sha1
)) {
90 warn("unrecognized header: %s", buffer
);
93 delim
= buffer
[40 + offset
];
94 if (!isspace(delim
) && (delim
!= '\0' || !is_prereq
))
95 die ("invalid header: %s", buffer
);
96 add_to_ref_list(sha1
, isspace(delim
) ?
97 buffer
+ 41 + offset
: "", list
);
102 /* if in && *in >= 0, take that as input file descriptor instead */
103 static int fork_with_pipe(const char **argv
, int *in
, int *out
)
105 int needs_in
, needs_out
;
106 int fdin
[2], fdout
[2], pid
;
108 needs_in
= in
&& *in
< 0;
111 return error("could not setup pipe");
115 needs_out
= out
&& *out
< 0;
118 return error("could not setup pipe");
122 if ((pid
= fork()) < 0) {
131 return error("could not fork");
150 exit(execv_git_cmd(argv
));
163 static int verify_bundle(struct bundle_header
*header
)
166 * Do fast check, then if any prereqs are missing then go line by line
167 * to be verbose about the errors
169 struct ref_list
*p
= &header
->prerequisites
;
170 struct rev_info revs
;
171 const char *argv
[] = {NULL
, "--all"};
172 struct object_array refs
;
173 struct commit
*commit
;
174 int i
, ret
= 0, req_nr
;
175 const char *message
= "The bundle requires these lacking revs:";
177 init_revisions(&revs
, NULL
);
178 for (i
= 0; i
< p
->nr
; i
++) {
179 struct ref_list_entry
*e
= p
->list
+ i
;
180 struct object
*o
= parse_object(e
->sha1
);
182 o
->flags
|= BOUNDARY_SHOW
;
183 add_pending_object(&revs
, o
, e
->name
);
188 error("%s %s", sha1_to_hex(e
->sha1
), e
->name
);
190 if (revs
.pending
.nr
== 0)
192 req_nr
= revs
.pending
.nr
;
193 setup_revisions(2, argv
, &revs
, NULL
);
195 memset(&refs
, 0, sizeof(struct object_array
));
196 for (i
= 0; i
< revs
.pending
.nr
; i
++) {
197 struct object_array_entry
*e
= revs
.pending
.objects
+ i
;
198 add_object_array(e
->item
, e
->name
, &refs
);
201 prepare_revision_walk(&revs
);
204 while (i
&& (commit
= get_revision(&revs
)))
205 if (commit
->object
.flags
& BOUNDARY_SHOW
)
208 for (i
= 0; i
< req_nr
; i
++)
209 if (!(refs
.objects
[i
].item
->flags
& SHOWN
)) {
212 error("%s %s", sha1_to_hex(refs
.objects
[i
].item
->sha1
),
213 refs
.objects
[i
].name
);
216 for (i
= 0; i
< refs
.nr
; i
++)
217 clear_commit_marks((struct commit
*)refs
.objects
[i
].item
, -1);
222 static int list_heads(struct bundle_header
*header
, int argc
, const char **argv
)
225 struct ref_list
*r
= &header
->references
;
227 for (i
= 0; i
< r
->nr
; i
++) {
230 for (j
= 1; j
< argc
; j
++)
231 if (!strcmp(r
->list
[i
].name
, argv
[j
]))
236 printf("%s %s\n", sha1_to_hex(r
->list
[i
].sha1
),
242 static void show_commit(struct commit
*commit
)
244 write_or_die(1, sha1_to_hex(commit
->object
.sha1
), 40);
245 write_or_die(1, "\n", 1);
246 if (commit
->parents
) {
247 free_commit_list(commit
->parents
);
248 commit
->parents
= NULL
;
252 static void show_object(struct object_array_entry
*p
)
254 /* An object with name "foo\n0000000..." can be used to
255 * confuse downstream git-pack-objects very badly.
257 const char *ep
= strchr(p
->name
, '\n');
258 int len
= ep
? ep
- p
->name
: strlen(p
->name
);
259 write_or_die(1, sha1_to_hex(p
->item
->sha1
), 40);
260 write_or_die(1, " ", 1);
262 write_or_die(1, p
->name
, len
);
263 write_or_die(1, "\n", 1);
266 static int create_bundle(struct bundle_header
*header
, const char *path
,
267 int argc
, const char **argv
)
270 const char **argv_boundary
= xmalloc((argc
+ 3) * sizeof(const char *));
271 const char **argv_pack
= xmalloc(4 * sizeof(const char *));
272 int pid
, in
, out
, i
, status
;
274 struct rev_info revs
;
276 bundle_fd
= (!strcmp(path
, "-") ? 1 :
277 open(path
, O_CREAT
| O_WRONLY
, 0666));
279 return error("Could not write to '%s'", path
);
281 /* write signature */
282 write_or_die(bundle_fd
, bundle_signature
, strlen(bundle_signature
));
284 /* write prerequisites */
285 memcpy(argv_boundary
+ 2, argv
+ 1, argc
* sizeof(const char *));
286 argv_boundary
[0] = "rev-list";
287 argv_boundary
[1] = "--boundary";
288 argv_boundary
[argc
+ 1] = NULL
;
290 pid
= fork_with_pipe(argv_boundary
, NULL
, &out
);
293 while ((i
= read_string(out
, buffer
, sizeof(buffer
))) > 0)
294 if (buffer
[0] == '-')
295 write_or_die(bundle_fd
, buffer
, i
);
296 while ((i
= waitpid(pid
, &status
, 0)) < 0)
298 return error("rev-list died");
299 if (!WIFEXITED(status
) || WEXITSTATUS(status
))
300 return error("rev-list died %d", WEXITSTATUS(status
));
302 /* write references */
303 save_commit_buffer
= 0;
304 init_revisions(&revs
, NULL
);
305 revs
.tag_objects
= 1;
306 revs
.tree_objects
= 1;
307 revs
.blob_objects
= 1;
308 argc
= setup_revisions(argc
, argv
, &revs
, NULL
);
310 return error("unrecognized argument: %s'", argv
[1]);
311 for (i
= 0; i
< revs
.pending
.nr
; i
++) {
312 struct object_array_entry
*e
= revs
.pending
.objects
+ i
;
313 if (!(e
->item
->flags
& UNINTERESTING
)) {
314 unsigned char sha1
[20];
316 if (dwim_ref(e
->name
, strlen(e
->name
), sha1
, &ref
) != 1)
318 write_or_die(bundle_fd
, sha1_to_hex(e
->item
->sha1
), 40);
319 write_or_die(bundle_fd
, " ", 1);
320 write_or_die(bundle_fd
, ref
, strlen(ref
));
321 write_or_die(bundle_fd
, "\n", 1);
327 write_or_die(bundle_fd
, "\n", 1);
330 argv_pack
[0] = "pack-objects";
331 argv_pack
[1] = "--all-progress";
332 argv_pack
[2] = "--stdout";
336 pid
= fork_with_pipe(argv_pack
, &in
, &out
);
338 return error("Could not spawn pack-objects");
342 prepare_revision_walk(&revs
);
343 traverse_commit_list(&revs
, show_commit
, show_object
);
345 while (waitpid(pid
, &status
, 0) < 0)
348 if (!WIFEXITED(status
) || WEXITSTATUS(status
))
349 return error ("pack-objects died");
353 static int unbundle(struct bundle_header
*header
, int bundle_fd
,
354 int argc
, const char **argv
)
356 const char *argv_index_pack
[] = {"index-pack", "--stdin", NULL
};
357 int pid
, status
, dev_null
;
359 if (verify_bundle(header
))
361 dev_null
= open("/dev/null", O_WRONLY
);
362 pid
= fork_with_pipe(argv_index_pack
, &bundle_fd
, &dev_null
);
364 return error("Could not spawn index-pack");
365 while (waitpid(pid
, &status
, 0) < 0)
367 return error("index-pack died");
368 if (!WIFEXITED(status
) || WEXITSTATUS(status
))
369 return error("index-pack exited with status %d",
370 WEXITSTATUS(status
));
371 return list_heads(header
, argc
, argv
);
374 int cmd_bundle(int argc
, const char **argv
, const char *prefix
)
376 struct bundle_header header
;
378 const char *cmd
, *bundle_file
;
380 char buffer
[PATH_MAX
];
386 bundle_file
= argv
[2];
390 prefix
= setup_git_directory_gently(&nongit
);
391 if (prefix
&& bundle_file
[0] != '/') {
392 snprintf(buffer
, sizeof(buffer
), "%s/%s", prefix
, bundle_file
);
393 bundle_file
= buffer
;
396 memset(&header
, 0, sizeof(header
));
397 if (strcmp(cmd
, "create") &&
398 !(bundle_fd
= read_header(bundle_file
, &header
)))
401 if (!strcmp(cmd
, "verify")) {
403 if (verify_bundle(&header
))
405 fprintf(stderr
, "%s is okay\n", bundle_file
);
408 if (!strcmp(cmd
, "list-heads")) {
410 return !!list_heads(&header
, argc
, argv
);
412 if (!strcmp(cmd
, "create")) {
414 die("Need a repository to create a bundle.");
415 return !!create_bundle(&header
, bundle_file
, argc
, argv
);
416 } else if (!strcmp(cmd
, "unbundle")) {
418 die("Need a repository to unbundle.");
419 return !!unbundle(&header
, bundle_fd
, argc
, argv
);