6 #include <sys/socket.h>
7 #include <netinet/in.h>
12 * Read all the refs from the other end
14 struct ref
**get_remote_heads(int in
, struct ref
**list
,
15 int nr_match
, char **match
, int ignore_funny
)
20 unsigned char old_sha1
[20];
21 static char buffer
[1000];
25 len
= packet_read_line(in
, buffer
, sizeof(buffer
));
28 if (buffer
[len
-1] == '\n')
31 if (len
< 42 || get_sha1_hex(buffer
, old_sha1
) || buffer
[40] != ' ')
32 die("protocol error: expected sha/ref, got '%s'", buffer
);
35 if (ignore_funny
&& 45 < len
&& !memcmp(name
, "refs/", 5) &&
36 check_ref_format(name
+ 5))
39 if (nr_match
&& !path_match(name
, nr_match
, match
))
41 ref
= xcalloc(1, sizeof(*ref
) + len
- 40);
42 memcpy(ref
->old_sha1
, old_sha1
, 20);
43 memcpy(ref
->name
, buffer
+ 41, len
- 40);
50 int get_ack(int fd
, unsigned char *result_sha1
)
52 static char line
[1000];
53 int len
= packet_read_line(fd
, line
, sizeof(line
));
56 die("git-fetch-pack: expected ACK/NAK, got EOF");
57 if (line
[len
-1] == '\n')
59 if (!strcmp(line
, "NAK"))
61 if (!strncmp(line
, "ACK ", 3)) {
62 if (!get_sha1_hex(line
+4, result_sha1
)) {
63 if (strstr(line
+45, "continue"))
68 die("git-fetch_pack: expected ACK/NAK, got '%s'", line
);
71 int path_match(const char *path
, int nr
, char **match
)
74 int pathlen
= strlen(path
);
76 for (i
= 0; i
< nr
; i
++) {
80 if (!len
|| len
> pathlen
)
82 if (memcmp(path
+ pathlen
- len
, s
, len
))
84 if (pathlen
> len
&& path
[pathlen
- len
- 1] != '/')
99 * A:B means fast forward remote B with local A.
100 * +A:B means overwrite remote B with local A.
101 * +A is a shorthand for +A:A.
102 * A is a shorthand for A:A.
104 static struct refspec
*parse_ref_spec(int nr_refspec
, char **refspec
)
107 struct refspec
*rs
= xcalloc(sizeof(*rs
), (nr_refspec
+ 1));
108 for (i
= 0; i
< nr_refspec
; i
++) {
115 ep
= strchr(sp
, ':');
125 rs
[nr_refspec
].src
= rs
[nr_refspec
].dst
= NULL
;
129 static int count_refspec_match(const char *pattern
,
131 struct ref
**matched_ref
)
134 int patlen
= strlen(pattern
);
136 for (match
= 0; refs
; refs
= refs
->next
) {
137 char *name
= refs
->name
;
138 int namelen
= strlen(name
);
139 if (namelen
< patlen
||
140 memcmp(name
+ namelen
- patlen
, pattern
, patlen
))
142 if (namelen
!= patlen
&& name
[namelen
- patlen
- 1] != '/')
150 static void link_dst_tail(struct ref
*ref
, struct ref
***tail
)
157 static struct ref
*try_explicit_object_name(const char *name
)
159 unsigned char sha1
[20];
162 if (get_sha1(name
, sha1
))
164 len
= strlen(name
) + 1;
165 ref
= xcalloc(1, sizeof(*ref
) + len
);
166 memcpy(ref
->name
, name
, len
);
167 memcpy(ref
->new_sha1
, sha1
, 20);
171 static int match_explicit_refs(struct ref
*src
, struct ref
*dst
,
172 struct ref
***dst_tail
, struct refspec
*rs
)
175 for (i
= errs
= 0; rs
[i
].src
; i
++) {
176 struct ref
*matched_src
, *matched_dst
;
178 matched_src
= matched_dst
= NULL
;
179 switch (count_refspec_match(rs
[i
].src
, src
, &matched_src
)) {
183 /* The source could be in the get_sha1() format
184 * not a reference name.
186 matched_src
= try_explicit_object_name(rs
[i
].src
);
190 error("src refspec %s does not match any.",
195 error("src refspec %s matches more than one.",
199 switch (count_refspec_match(rs
[i
].dst
, dst
, &matched_dst
)) {
203 if (!memcmp(rs
[i
].dst
, "refs/", 5)) {
204 int len
= strlen(rs
[i
].dst
) + 1;
205 matched_dst
= xcalloc(1, sizeof(*dst
) + len
);
206 memcpy(matched_dst
->name
, rs
[i
].dst
, len
);
207 link_dst_tail(matched_dst
, dst_tail
);
209 else if (!strcmp(rs
[i
].src
, rs
[i
].dst
) &&
211 /* pushing "master:master" when
212 * remote does not have master yet.
214 int len
= strlen(matched_src
->name
) + 1;
215 matched_dst
= xcalloc(1, sizeof(*dst
) + len
);
216 memcpy(matched_dst
->name
, matched_src
->name
,
218 link_dst_tail(matched_dst
, dst_tail
);
222 error("dst refspec %s does not match any "
223 "existing ref on the remote and does "
224 "not start with refs/.", rs
[i
].dst
);
229 error("dst refspec %s matches more than one.",
235 if (matched_dst
->peer_ref
) {
237 error("dst ref %s receives from more than one src.",
241 matched_dst
->peer_ref
= matched_src
;
242 matched_dst
->force
= rs
[i
].force
;
248 static struct ref
*find_ref_by_name(struct ref
*list
, const char *name
)
250 for ( ; list
; list
= list
->next
)
251 if (!strcmp(list
->name
, name
))
256 int match_refs(struct ref
*src
, struct ref
*dst
, struct ref
***dst_tail
,
257 int nr_refspec
, char **refspec
, int all
)
259 struct refspec
*rs
= parse_ref_spec(nr_refspec
, refspec
);
262 return match_explicit_refs(src
, dst
, dst_tail
, rs
);
264 /* pick the remainder */
265 for ( ; src
; src
= src
->next
) {
266 struct ref
*dst_peer
;
269 dst_peer
= find_ref_by_name(dst
, src
->name
);
270 if ((dst_peer
&& dst_peer
->peer_ref
) || (!dst_peer
&& !all
))
273 /* Create a new one and link it */
274 int len
= strlen(src
->name
) + 1;
275 dst_peer
= xcalloc(1, sizeof(*dst_peer
) + len
);
276 memcpy(dst_peer
->name
, src
->name
, len
);
277 memcpy(dst_peer
->new_sha1
, src
->new_sha1
, 20);
278 link_dst_tail(dst_peer
, dst_tail
);
280 dst_peer
->peer_ref
= src
;
291 static enum protocol
get_protocol(const char *name
)
293 if (!strcmp(name
, "ssh"))
295 if (!strcmp(name
, "git"))
297 if (!strcmp(name
, "git+ssh"))
299 if (!strcmp(name
, "ssh+git"))
301 die("I don't handle protocol '%s'", name
);
305 #define STR(s) STR_(s)
309 static int git_tcp_connect(int fd
[2], const char *prog
, char *host
, char *path
)
313 char *port
= STR(DEFAULT_GIT_PORT
);
314 struct addrinfo hints
, *ai0
, *ai
;
317 if (host
[0] == '[') {
318 end
= strchr(host
+ 1, ']');
327 colon
= strchr(end
, ':');
334 memset(&hints
, 0, sizeof(hints
));
335 hints
.ai_socktype
= SOCK_STREAM
;
336 hints
.ai_protocol
= IPPROTO_TCP
;
338 gai
= getaddrinfo(host
, port
, &hints
, &ai
);
340 die("Unable to look up %s (%s)", host
, gai_strerror(gai
));
342 for (ai0
= ai
; ai
; ai
= ai
->ai_next
) {
343 sockfd
= socket(ai
->ai_family
, ai
->ai_socktype
, ai
->ai_protocol
);
346 if (connect(sockfd
, ai
->ai_addr
, ai
->ai_addrlen
) < 0) {
357 die("unable to connect a socket (%s)", strerror(errno
));
361 packet_write(sockfd
, "%s %s\n", prog
, path
);
367 static int git_tcp_connect(int fd
[2], const char *prog
, char *host
, char *path
)
371 char *port
= STR(DEFAULT_GIT_PORT
), *ep
;
373 struct sockaddr_in sa
;
377 if (host
[0] == '[') {
378 end
= strchr(host
+ 1, ']');
387 colon
= strchr(end
, ':');
395 he
= gethostbyname(host
);
397 die("Unable to look up %s (%s)", host
, hstrerror(h_errno
));
398 nport
= strtoul(port
, &ep
, 10);
399 if ( ep
== port
|| *ep
) {
401 struct servent
*se
= getservbyname(port
,"tcp");
403 die("Unknown port %s\n", port
);
407 for (ap
= he
->h_addr_list
; *ap
; ap
++) {
408 sockfd
= socket(he
->h_addrtype
, SOCK_STREAM
, 0);
412 memset(&sa
, 0, sizeof sa
);
413 sa
.sin_family
= he
->h_addrtype
;
414 sa
.sin_port
= htons(nport
);
415 memcpy(&sa
.sin_addr
, ap
, he
->h_length
);
417 if (connect(sockfd
, (struct sockaddr
*)&sa
, sizeof sa
) < 0) {
426 die("unable to connect a socket (%s)", strerror(errno
));
430 packet_write(sockfd
, "%s %s\n", prog
, path
);
437 * Yeah, yeah, fixme. Need to pass in the heads etc.
439 int git_connect(int fd
[2], char *url
, const char *prog
)
446 enum protocol protocol
;
450 colon
= strchr(url
, ':');
451 protocol
= PROTO_LOCAL
;
456 protocol
= PROTO_SSH
;
457 if (!memcmp(path
, "//", 2)) {
458 char *slash
= strchr(path
+ 2, '/');
460 int nr
= slash
- path
- 2;
461 memmove(path
, path
+2, nr
);
463 protocol
= get_protocol(url
);
470 if (protocol
== PROTO_GIT
)
471 return git_tcp_connect(fd
, prog
, host
, path
);
473 if (pipe(pipefd
[0]) < 0 || pipe(pipefd
[1]) < 0)
474 die("unable to create pipe pair for communication");
477 snprintf(command
, sizeof(command
), "%s %s", prog
,
479 dup2(pipefd
[1][0], 0);
480 dup2(pipefd
[0][1], 1);
485 if (protocol
== PROTO_SSH
) {
486 const char *ssh
, *ssh_basename
;
487 ssh
= getenv("GIT_SSH");
488 if (!ssh
) ssh
= "ssh";
489 ssh_basename
= strrchr(ssh
, '/');
494 execlp(ssh
, ssh_basename
, host
, command
, NULL
);
497 execlp("sh", "sh", "-c", command
, NULL
);
500 fd
[0] = pipefd
[0][0];
501 fd
[1] = pipefd
[1][1];
507 int finish_connect(pid_t pid
)
512 ret
= waitpid(pid
, NULL
, 0);