4 #include "run-command.h"
12 struct child_process
*helper
;
17 static struct child_process
*get_helper(struct transport
*transport
)
19 struct helper_data
*data
= transport
->data
;
20 struct strbuf buf
= STRBUF_INIT
;
21 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 data
->out
= xfdopen(helper
->out
, "r");
44 if (strbuf_getline(&buf
, data
->out
, '\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
);
62 finish_command(data
->helper
);
63 free((char *)data
->helper
->argv
[0]);
64 free(data
->helper
->argv
);
71 static int fetch_with_fetch(struct transport
*transport
,
72 int nr_heads
, const struct ref
**to_fetch
)
74 struct helper_data
*data
= transport
->data
;
76 struct strbuf buf
= STRBUF_INIT
;
78 for (i
= 0; i
< nr_heads
; i
++) {
79 const struct ref
*posn
= to_fetch
[i
];
80 if (posn
->status
& REF_STATUS_UPTODATE
)
83 strbuf_addf(&buf
, "fetch %s %s\n",
84 sha1_to_hex(posn
->old_sha1
), posn
->name
);
87 strbuf_addch(&buf
, '\n');
88 if (write_in_full(data
->helper
->in
, buf
.buf
, buf
.len
) != buf
.len
)
89 die_errno("cannot send fetch to %s", data
->name
);
93 if (strbuf_getline(&buf
, data
->out
, '\n') == EOF
)
94 exit(128); /* child died, message supplied already */
96 if (!prefixcmp(buf
.buf
, "lock ")) {
97 const char *name
= buf
.buf
+ 5;
98 if (transport
->pack_lockfile
)
99 warning("%s also locked %s", data
->name
, name
);
101 transport
->pack_lockfile
= xstrdup(name
);
106 warning("%s unexpectedly said: '%s'", data
->name
, buf
.buf
);
108 strbuf_release(&buf
);
112 static int fetch(struct transport
*transport
,
113 int nr_heads
, const struct ref
**to_fetch
)
115 struct helper_data
*data
= transport
->data
;
119 for (i
= 0; i
< nr_heads
; i
++)
120 if (!(to_fetch
[i
]->status
& REF_STATUS_UPTODATE
))
127 return fetch_with_fetch(transport
, nr_heads
, to_fetch
);
132 static struct ref
*get_refs_list(struct transport
*transport
, int for_push
)
134 struct helper_data
*data
= transport
->data
;
135 struct child_process
*helper
;
136 struct ref
*ret
= NULL
;
137 struct ref
**tail
= &ret
;
139 struct strbuf buf
= STRBUF_INIT
;
141 helper
= get_helper(transport
);
143 write_str_in_full(helper
->in
, "list\n");
147 if (strbuf_getline(&buf
, data
->out
, '\n') == EOF
)
148 exit(128); /* child died, message supplied already */
153 eov
= strchr(buf
.buf
, ' ');
155 die("Malformed response in ref list: %s", buf
.buf
);
156 eon
= strchr(eov
+ 1, ' ');
160 *tail
= alloc_ref(eov
+ 1);
161 if (buf
.buf
[0] == '@')
162 (*tail
)->symref
= xstrdup(buf
.buf
+ 1);
163 else if (buf
.buf
[0] != '?')
164 get_sha1_hex(buf
.buf
, (*tail
)->old_sha1
);
165 tail
= &((*tail
)->next
);
167 strbuf_release(&buf
);
169 for (posn
= ret
; posn
; posn
= posn
->next
)
170 resolve_remote_symref(posn
, ret
);
175 int transport_helper_init(struct transport
*transport
, const char *name
)
177 struct helper_data
*data
= xcalloc(sizeof(*data
), 1);
180 transport
->data
= data
;
181 transport
->get_refs_list
= get_refs_list
;
182 transport
->fetch
= fetch
;
183 transport
->disconnect
= disconnect_helper
;