]>
Commit | Line | Data |
---|---|---|
4df096a5 FBH |
1 | /* |
2 | * Copyright (c) 2006 Franck Bui-Huu | |
3 | * Copyright (c) 2006 Rene Scharfe | |
4 | */ | |
4df096a5 FBH |
5 | #include "cache.h" |
6 | #include "builtin.h" | |
7 | #include "archive.h" | |
4df096a5 | 8 | #include "pkt-line.h" |
23d6d112 | 9 | #include "sideband.h" |
4df096a5 | 10 | |
37f94436 | 11 | static int run_remote_archiver(const char *remote, int argc, |
4df096a5 FBH |
12 | const char **argv) |
13 | { | |
23d6d112 | 14 | char *url, buf[LARGE_PACKET_MAX]; |
4df096a5 | 15 | int fd[2], i, len, rv; |
98158e9c | 16 | struct child_process *conn; |
fe5ab763 | 17 | const char *exec = "git-upload-archive"; |
819b2b58 | 18 | int exec_at = 0, exec_value_at = 0; |
4df096a5 | 19 | |
fe5ab763 JH |
20 | for (i = 1; i < argc; i++) { |
21 | const char *arg = argv[i]; | |
599065a3 | 22 | if (!prefixcmp(arg, "--exec=")) { |
fe5ab763 JH |
23 | if (exec_at) |
24 | die("multiple --exec specified"); | |
25 | exec = arg + 7; | |
26 | exec_at = i; | |
819b2b58 RS |
27 | } else if (!strcmp(arg, "--exec")) { |
28 | if (exec_at) | |
29 | die("multiple --exec specified"); | |
30 | if (i + 1 >= argc) | |
31 | die("option --exec requires a value"); | |
32 | exec = argv[i + 1]; | |
33 | exec_at = i; | |
34 | exec_value_at = ++i; | |
fe5ab763 JH |
35 | } |
36 | } | |
4df096a5 | 37 | |
37f94436 | 38 | url = xstrdup(remote); |
98158e9c | 39 | conn = git_connect(fd, url, exec, 0); |
4df096a5 | 40 | |
fe5ab763 | 41 | for (i = 1; i < argc; i++) { |
819b2b58 | 42 | if (i == exec_at || i == exec_value_at) |
fe5ab763 | 43 | continue; |
4df096a5 | 44 | packet_write(fd[1], "argument %s\n", argv[i]); |
fe5ab763 | 45 | } |
4df096a5 FBH |
46 | packet_flush(fd[1]); |
47 | ||
48 | len = packet_read_line(fd[0], buf, sizeof(buf)); | |
49 | if (!len) | |
34baebce | 50 | die("git archive: expected ACK/NAK, got EOF"); |
4df096a5 FBH |
51 | if (buf[len-1] == '\n') |
52 | buf[--len] = 0; | |
53 | if (strcmp(buf, "ACK")) { | |
cc44c765 | 54 | if (len > 5 && !prefixcmp(buf, "NACK ")) |
34baebce HO |
55 | die("git archive: NACK %s", buf + 5); |
56 | die("git archive: protocol error"); | |
4df096a5 FBH |
57 | } |
58 | ||
59 | len = packet_read_line(fd[0], buf, sizeof(buf)); | |
60 | if (len) | |
34baebce | 61 | die("git archive: expected a flush"); |
4df096a5 FBH |
62 | |
63 | /* Now, start reading from fd[0] and spit it out to stdout */ | |
9ac13ec9 | 64 | rv = recv_sideband("archive", fd[0], 1, 2); |
4df096a5 | 65 | close(fd[0]); |
ec587fde | 66 | close(fd[1]); |
98158e9c | 67 | rv |= finish_connect(conn); |
4df096a5 FBH |
68 | |
69 | return !!rv; | |
70 | } | |
71 | ||
d751864c | 72 | static const char *extract_remote_arg(int *ac, const char **av) |
37f94436 JH |
73 | { |
74 | int ix, iy, cnt = *ac; | |
75 | int no_more_options = 0; | |
76 | const char *remote = NULL; | |
77 | ||
78 | for (ix = iy = 1; ix < cnt; ix++) { | |
79 | const char *arg = av[ix]; | |
80 | if (!strcmp(arg, "--")) | |
81 | no_more_options = 1; | |
82 | if (!no_more_options) { | |
cc44c765 | 83 | if (!prefixcmp(arg, "--remote=")) { |
37f94436 JH |
84 | if (remote) |
85 | die("Multiple --remote specified"); | |
86 | remote = arg + 9; | |
87 | continue; | |
819b2b58 RS |
88 | } else if (!strcmp(arg, "--remote")) { |
89 | if (remote) | |
90 | die("Multiple --remote specified"); | |
91 | if (++ix >= cnt) | |
92 | die("option --remote requires a value"); | |
93 | remote = av[ix]; | |
94 | continue; | |
37f94436 JH |
95 | } |
96 | if (arg[0] != '-') | |
97 | no_more_options = 1; | |
98 | } | |
99 | if (ix != iy) | |
100 | av[iy] = arg; | |
101 | iy++; | |
102 | } | |
103 | if (remote) { | |
104 | av[--cnt] = NULL; | |
105 | *ac = cnt; | |
106 | } | |
107 | return remote; | |
108 | } | |
109 | ||
4df096a5 FBH |
110 | int cmd_archive(int argc, const char **argv, const char *prefix) |
111 | { | |
37f94436 | 112 | const char *remote = NULL; |
4df096a5 | 113 | |
d751864c | 114 | remote = extract_remote_arg(&argc, argv); |
37f94436 JH |
115 | if (remote) |
116 | return run_remote_archiver(remote, argc, argv); | |
4df096a5 | 117 | |
aa909861 | 118 | setvbuf(stderr, NULL, _IOLBF, BUFSIZ); |
8142f603 | 119 | |
6e94e683 | 120 | return write_archive(argc, argv, prefix, 1); |
4df096a5 | 121 | } |