]>
git.ipfire.org Git - thirdparty/git.git/blob - transport-helper.c
4 #include "run-command.h"
12 struct child_process
*helper
;
16 static struct child_process
*get_helper(struct transport
*transport
)
18 struct helper_data
*data
= transport
->data
;
19 struct strbuf buf
= STRBUF_INIT
;
20 struct child_process
*helper
;
26 helper
= xcalloc(1, sizeof(*helper
));
30 helper
->argv
= xcalloc(4, sizeof(*helper
->argv
));
31 strbuf_addf(&buf
, "remote-%s", data
->name
);
32 helper
->argv
[0] = strbuf_detach(&buf
, NULL
);
33 helper
->argv
[1] = transport
->remote
->name
;
34 helper
->argv
[2] = transport
->url
;
36 if (start_command(helper
))
37 die("Unable to run helper: git %s", helper
->argv
[0]);
38 data
->helper
= helper
;
40 write_str_in_full(helper
->in
, "capabilities\n");
42 file
= xfdopen(helper
->out
, "r");
44 if (strbuf_getline(&buf
, file
, '\n') == EOF
)
45 exit(128); /* child died, message supplied already */
49 if (!strcmp(buf
.buf
, "fetch"))
55 static int disconnect_helper(struct transport
*transport
)
57 struct helper_data
*data
= transport
->data
;
59 write_str_in_full(data
->helper
->in
, "\n");
60 close(data
->helper
->in
);
61 finish_command(data
->helper
);
62 free((char *)data
->helper
->argv
[0]);
63 free(data
->helper
->argv
);
70 static int release_helper(struct transport
*transport
)
72 disconnect_helper(transport
);
73 free(transport
->data
);
77 static int fetch_with_fetch(struct transport
*transport
,
78 int nr_heads
, struct ref
**to_fetch
)
80 struct child_process
*helper
= get_helper(transport
);
81 FILE *file
= xfdopen(helper
->out
, "r");
83 struct strbuf buf
= STRBUF_INIT
;
85 for (i
= 0; i
< nr_heads
; i
++) {
86 const struct ref
*posn
= to_fetch
[i
];
87 if (posn
->status
& REF_STATUS_UPTODATE
)
90 strbuf_addf(&buf
, "fetch %s %s\n",
91 sha1_to_hex(posn
->old_sha1
), posn
->name
);
92 write_in_full(helper
->in
, buf
.buf
, buf
.len
);
95 if (strbuf_getline(&buf
, file
, '\n') == EOF
)
96 exit(128); /* child died, message supplied already */
101 static int fetch(struct transport
*transport
,
102 int nr_heads
, struct ref
**to_fetch
)
104 struct helper_data
*data
= transport
->data
;
108 for (i
= 0; i
< nr_heads
; i
++)
109 if (!(to_fetch
[i
]->status
& REF_STATUS_UPTODATE
))
116 return fetch_with_fetch(transport
, nr_heads
, to_fetch
);
121 static struct ref
*get_refs_list(struct transport
*transport
, int for_push
)
123 struct child_process
*helper
;
124 struct ref
*ret
= NULL
;
125 struct ref
**tail
= &ret
;
127 struct strbuf buf
= STRBUF_INIT
;
130 helper
= get_helper(transport
);
132 write_str_in_full(helper
->in
, "list\n");
134 file
= xfdopen(helper
->out
, "r");
137 if (strbuf_getline(&buf
, file
, '\n') == EOF
)
138 exit(128); /* child died, message supplied already */
143 eov
= strchr(buf
.buf
, ' ');
145 die("Malformed response in ref list: %s", buf
.buf
);
146 eon
= strchr(eov
+ 1, ' ');
150 *tail
= alloc_ref(eov
+ 1);
151 if (buf
.buf
[0] == '@')
152 (*tail
)->symref
= xstrdup(buf
.buf
+ 1);
153 else if (buf
.buf
[0] != '?')
154 get_sha1_hex(buf
.buf
, (*tail
)->old_sha1
);
155 tail
= &((*tail
)->next
);
157 strbuf_release(&buf
);
159 for (posn
= ret
; posn
; posn
= posn
->next
)
160 resolve_remote_symref(posn
, ret
);
165 int transport_helper_init(struct transport
*transport
, const char *name
)
167 struct helper_data
*data
= xcalloc(sizeof(*data
), 1);
170 transport
->data
= data
;
171 transport
->get_refs_list
= get_refs_list
;
172 transport
->fetch
= fetch
;
173 transport
->disconnect
= release_helper
;