|
krh@74
|
1 |
#include <stdio.h>
|
|
krh@84
|
2 |
#include <stddef.h>
|
|
krh@74
|
3 |
#include <string.h>
|
|
krh@74
|
4 |
#include <sys/stat.h>
|
|
krh@74
|
5 |
#include <sys/mman.h>
|
|
krh@85
|
6 |
#include <sys/types.h>
|
|
krh@85
|
7 |
#include <sys/wait.h>
|
|
krh@74
|
8 |
#include <fcntl.h>
|
|
krh@74
|
9 |
#include <unistd.h>
|
|
krh@74
|
10 |
#include <arpa/inet.h>
|
|
krh@74
|
11 |
#include <rpm/rpmlib.h>
|
|
krh@77
|
12 |
#include <zlib.h>
|
|
krh@74
|
13 |
|
|
krh@75
|
14 |
#include "razor.h"
|
|
krh@75
|
15 |
|
|
krh@74
|
16 |
#define RPM_LEAD_SIZE 96
|
|
krh@74
|
17 |
|
|
krh@74
|
18 |
struct rpm_header {
|
|
krh@74
|
19 |
unsigned char magic[4];
|
|
krh@74
|
20 |
unsigned char reserved[4];
|
|
krh@74
|
21 |
int nindex;
|
|
krh@74
|
22 |
int hsize;
|
|
krh@74
|
23 |
};
|
|
krh@74
|
24 |
|
|
krh@74
|
25 |
struct rpm_header_index {
|
|
krh@74
|
26 |
int tag;
|
|
krh@74
|
27 |
int type;
|
|
krh@74
|
28 |
int offset;
|
|
krh@74
|
29 |
int count;
|
|
krh@74
|
30 |
};
|
|
krh@74
|
31 |
|
|
krh@77
|
32 |
struct razor_rpm {
|
|
krh@75
|
33 |
struct rpm_header *signature;
|
|
krh@75
|
34 |
struct rpm_header *header;
|
|
krh@77
|
35 |
const char **dirs;
|
|
krh@75
|
36 |
const char *pool;
|
|
krh@75
|
37 |
void *map;
|
|
krh@75
|
38 |
size_t size;
|
|
krh@77
|
39 |
void *payload;
|
|
krh@75
|
40 |
};
|
|
krh@75
|
41 |
|
|
krh@74
|
42 |
#define ALIGN(value, base) (((value) + (base - 1)) & ~((base) - 1))
|
|
krh@74
|
43 |
|
|
krh@85
|
44 |
static struct rpm_header_index *
|
|
krh@85
|
45 |
razor_rpm_get_header(struct razor_rpm *rpm, unsigned int tag)
|
|
krh@85
|
46 |
{
|
|
krh@85
|
47 |
struct rpm_header_index *index, *end;
|
|
krh@85
|
48 |
|
|
krh@85
|
49 |
index = (struct rpm_header_index *) (rpm->header + 1);
|
|
krh@85
|
50 |
end = index + ntohl(rpm->header->nindex);
|
|
krh@85
|
51 |
while (index < end) {
|
|
krh@85
|
52 |
if (ntohl(index->tag) == tag)
|
|
krh@85
|
53 |
return index;
|
|
krh@85
|
54 |
index++;
|
|
krh@85
|
55 |
}
|
|
krh@85
|
56 |
|
|
krh@85
|
57 |
return NULL;
|
|
krh@85
|
58 |
}
|
|
krh@85
|
59 |
|
|
krh@87
|
60 |
static const void *
|
|
krh@87
|
61 |
razor_rpm_get_indirect(struct razor_rpm *rpm,
|
|
krh@87
|
62 |
unsigned int tag, unsigned int *count)
|
|
krh@87
|
63 |
{
|
|
krh@87
|
64 |
struct rpm_header_index *index;
|
|
krh@87
|
65 |
|
|
krh@87
|
66 |
index = razor_rpm_get_header(rpm, tag);
|
|
krh@87
|
67 |
if (index != NULL) {
|
|
krh@87
|
68 |
if (count)
|
|
krh@87
|
69 |
*count = ntohl(index->count);
|
|
krh@87
|
70 |
|
|
krh@87
|
71 |
return rpm->pool + ntohl(index->offset);
|
|
krh@87
|
72 |
}
|
|
krh@87
|
73 |
|
|
krh@87
|
74 |
return NULL;
|
|
krh@87
|
75 |
}
|
|
krh@87
|
76 |
|
|
krh@87
|
77 |
static void
|
|
krh@87
|
78 |
import_properties(struct razor_importer *importer, unsigned long type,
|
|
krh@87
|
79 |
struct razor_rpm *rpm,
|
|
krh@87
|
80 |
int name_tag, int version_tag, int flags_tag)
|
|
krh@87
|
81 |
{
|
|
krh@87
|
82 |
const char *name, *version;
|
|
krh@87
|
83 |
unsigned int i, count;
|
|
krh@87
|
84 |
|
|
krh@87
|
85 |
name = razor_rpm_get_indirect(rpm, name_tag, &count);
|
|
krh@87
|
86 |
if (name == NULL)
|
|
krh@87
|
87 |
return;
|
|
krh@87
|
88 |
|
|
krh@87
|
89 |
/* FIXME: Concat version and release. */
|
|
krh@87
|
90 |
version = razor_rpm_get_indirect(rpm, version_tag, &count);
|
|
krh@87
|
91 |
for (i = 0; i < count; i++) {
|
|
krh@87
|
92 |
razor_importer_add_property(importer, name, version, type);
|
|
krh@87
|
93 |
name += strlen(name) + 1;
|
|
krh@87
|
94 |
version += strlen(version) + 1;
|
|
krh@87
|
95 |
}
|
|
krh@87
|
96 |
}
|
|
krh@87
|
97 |
|
|
krh@87
|
98 |
static void
|
|
krh@87
|
99 |
import_files(struct razor_importer *importer, struct razor_rpm *rpm)
|
|
krh@87
|
100 |
{
|
|
krh@87
|
101 |
const char *name;
|
|
krh@87
|
102 |
const unsigned long *index;
|
|
krh@87
|
103 |
unsigned int i, count;
|
|
krh@87
|
104 |
char buffer[256];
|
|
krh@87
|
105 |
|
|
krh@87
|
106 |
/* assert: count is the same for all arrays */
|
|
krh@87
|
107 |
|
|
krh@87
|
108 |
index = razor_rpm_get_indirect(rpm, RPMTAG_DIRINDEXES, &count);
|
|
krh@87
|
109 |
name = razor_rpm_get_indirect(rpm, RPMTAG_BASENAMES, &count);
|
|
krh@87
|
110 |
for (i = 0; i < count; i++) {
|
|
krh@87
|
111 |
snprintf(buffer, sizeof buffer,
|
|
krh@87
|
112 |
"%s%s", rpm->dirs[ntohl(*index)], name);
|
|
krh@87
|
113 |
razor_importer_add_file(importer, buffer);
|
|
krh@87
|
114 |
name += strlen(name) + 1;
|
|
krh@87
|
115 |
index++;
|
|
krh@87
|
116 |
}
|
|
krh@87
|
117 |
}
|
|
krh@87
|
118 |
|
|
krh@77
|
119 |
struct razor_rpm *
|
|
krh@77
|
120 |
razor_rpm_open(const char *filename)
|
|
krh@74
|
121 |
{
|
|
krh@77
|
122 |
struct razor_rpm *rpm;
|
|
krh@74
|
123 |
struct rpm_header_index *base, *index;
|
|
krh@75
|
124 |
struct stat buf;
|
|
krh@87
|
125 |
unsigned int count, i, nindex, hsize;
|
|
krh@77
|
126 |
const char *name;
|
|
krh@87
|
127 |
int fd;
|
|
krh@74
|
128 |
|
|
krh@77
|
129 |
rpm = malloc(sizeof *rpm);
|
|
krh@75
|
130 |
memset(rpm, 0, sizeof *rpm);
|
|
krh@75
|
131 |
if (stat(filename, &buf) < 0) {
|
|
krh@75
|
132 |
fprintf(stderr, "no such file %s (%m)\n", filename);
|
|
krh@77
|
133 |
return NULL;
|
|
krh@75
|
134 |
}
|
|
krh@74
|
135 |
|
|
krh@75
|
136 |
fd = open(filename, O_RDONLY);
|
|
krh@75
|
137 |
if (fd < 0) {
|
|
krh@75
|
138 |
fprintf(stderr, "couldn't open %s\n", filename);
|
|
krh@77
|
139 |
return NULL;
|
|
krh@75
|
140 |
}
|
|
krh@75
|
141 |
rpm->size = buf.st_size;
|
|
krh@75
|
142 |
rpm->map = mmap(NULL, rpm->size, PROT_READ, MAP_PRIVATE, fd, 0);
|
|
krh@75
|
143 |
if (rpm->map == MAP_FAILED) {
|
|
krh@75
|
144 |
fprintf(stderr, "couldn't mmap %s\n", filename);
|
|
krh@77
|
145 |
return NULL;
|
|
krh@75
|
146 |
}
|
|
krh@75
|
147 |
close(fd);
|
|
krh@75
|
148 |
|
|
krh@75
|
149 |
rpm->signature = rpm->map + RPM_LEAD_SIZE;
|
|
krh@75
|
150 |
nindex = ntohl(rpm->signature->nindex);
|
|
krh@75
|
151 |
hsize = ntohl(rpm->signature->hsize);
|
|
krh@75
|
152 |
rpm->header = (void *) (rpm->signature + 1) +
|
|
krh@75
|
153 |
ALIGN(nindex * sizeof *index + hsize, 8);
|
|
krh@77
|
154 |
nindex = ntohl(rpm->header->nindex);
|
|
krh@77
|
155 |
hsize = ntohl(rpm->header->hsize);
|
|
krh@77
|
156 |
rpm->payload = (void *) (rpm->header + 1) +
|
|
krh@77
|
157 |
nindex * sizeof *index + hsize;
|
|
krh@75
|
158 |
|
|
krh@75
|
159 |
base = (struct rpm_header_index *) (rpm->header + 1);
|
|
krh@75
|
160 |
rpm->pool = (void *) base + nindex * sizeof *index;
|
|
krh@75
|
161 |
|
|
krh@87
|
162 |
/* Look up dir names now so we can index them directly. */
|
|
krh@87
|
163 |
name = razor_rpm_get_indirect(rpm, RPMTAG_DIRNAMES, &count);
|
|
krh@87
|
164 |
if (name == NULL) {
|
|
krh@87
|
165 |
fprintf(stderr, "old filename style not handled\n");
|
|
krh@87
|
166 |
return NULL;
|
|
krh@74
|
167 |
}
|
|
krh@75
|
168 |
|
|
krh@87
|
169 |
rpm->dirs = calloc(count, sizeof *rpm->dirs);
|
|
krh@87
|
170 |
for (i = 0; i < count; i++) {
|
|
krh@87
|
171 |
rpm->dirs[i] = name;
|
|
krh@87
|
172 |
name += strlen(name) + 1;
|
|
krh@77
|
173 |
}
|
|
krh@77
|
174 |
|
|
krh@77
|
175 |
return rpm;
|
|
krh@77
|
176 |
}
|
|
krh@77
|
177 |
|
|
krh@77
|
178 |
struct cpio_file_header {
|
|
krh@77
|
179 |
char magic[6];
|
|
krh@77
|
180 |
char inode[8];
|
|
krh@77
|
181 |
char mode[8];
|
|
krh@77
|
182 |
char uid[8];
|
|
krh@77
|
183 |
char gid[8];
|
|
krh@77
|
184 |
char nlink[8];
|
|
krh@77
|
185 |
char mtime[8];
|
|
krh@77
|
186 |
char filesize[8];
|
|
krh@77
|
187 |
char devmajor[8];
|
|
krh@77
|
188 |
char devminor[8];
|
|
krh@77
|
189 |
char rdevmajor[8];
|
|
krh@77
|
190 |
char rdevminor[8];
|
|
krh@77
|
191 |
char namesize[8];
|
|
krh@77
|
192 |
char checksum[8];
|
|
krh@77
|
193 |
char filename[0];
|
|
krh@77
|
194 |
};
|
|
krh@77
|
195 |
|
|
krh@77
|
196 |
/* gzip flags */
|
|
krh@77
|
197 |
#define ASCII_FLAG 0x01 /* bit 0 set: file probably ascii text */
|
|
krh@77
|
198 |
#define HEAD_CRC 0x02 /* bit 1 set: header CRC present */
|
|
krh@77
|
199 |
#define EXTRA_FIELD 0x04 /* bit 2 set: extra field present */
|
|
krh@77
|
200 |
#define ORIG_NAME 0x08 /* bit 3 set: original file name present */
|
|
krh@77
|
201 |
#define COMMENT 0x10 /* bit 4 set: file comment present */
|
|
krh@77
|
202 |
#define RESERVED 0xE0 /* bits 5..7: reserved */
|
|
krh@77
|
203 |
|
|
krh@86
|
204 |
struct installer {
|
|
krh@86
|
205 |
const char *root;
|
|
krh@86
|
206 |
struct razor_rpm *rpm;
|
|
krh@86
|
207 |
z_stream stream;
|
|
krh@86
|
208 |
unsigned char buffer[32768];
|
|
krh@86
|
209 |
size_t rest, length;
|
|
krh@86
|
210 |
};
|
|
krh@86
|
211 |
|
|
krh@77
|
212 |
static int
|
|
krh@86
|
213 |
installer_inflate(struct installer *installer)
|
|
krh@86
|
214 |
{
|
|
krh@86
|
215 |
size_t length;
|
|
krh@86
|
216 |
int err;
|
|
krh@86
|
217 |
|
|
krh@86
|
218 |
if (ALIGN(installer->rest, 4) > sizeof installer->buffer)
|
|
krh@86
|
219 |
length = sizeof installer->buffer;
|
|
krh@86
|
220 |
else
|
|
krh@86
|
221 |
length = installer->rest;
|
|
krh@86
|
222 |
|
|
krh@86
|
223 |
installer->stream.next_out = installer->buffer;
|
|
krh@86
|
224 |
installer->stream.avail_out = ALIGN(length, 4);
|
|
krh@86
|
225 |
err = inflate(&installer->stream, Z_SYNC_FLUSH);
|
|
krh@86
|
226 |
if (err != Z_OK && err != Z_STREAM_END) {
|
|
krh@86
|
227 |
fprintf(stderr, "inflate error: %d (%m)\n", err);
|
|
krh@86
|
228 |
return -1;
|
|
krh@86
|
229 |
}
|
|
krh@86
|
230 |
|
|
krh@86
|
231 |
installer->rest -= length;
|
|
krh@86
|
232 |
installer->length = length;
|
|
krh@86
|
233 |
|
|
krh@86
|
234 |
return 0;
|
|
krh@86
|
235 |
}
|
|
krh@86
|
236 |
|
|
krh@86
|
237 |
static int
|
|
krh@86
|
238 |
xwrite(int fd, const void *data, size_t size)
|
|
krh@86
|
239 |
{
|
|
krh@86
|
240 |
size_t rest;
|
|
krh@86
|
241 |
ssize_t written;
|
|
krh@86
|
242 |
const unsigned char *p;
|
|
krh@86
|
243 |
|
|
krh@86
|
244 |
rest = size;
|
|
krh@86
|
245 |
p = data;
|
|
krh@86
|
246 |
while (rest > 0) {
|
|
krh@86
|
247 |
written = write(fd, p, rest);
|
|
krh@86
|
248 |
if (written < 0) {
|
|
krh@86
|
249 |
fprintf(stderr, "write error: %m\n");
|
|
krh@86
|
250 |
return -1;
|
|
krh@86
|
251 |
}
|
|
krh@86
|
252 |
rest -= written;
|
|
krh@86
|
253 |
p += written;
|
|
krh@86
|
254 |
}
|
|
krh@86
|
255 |
|
|
krh@86
|
256 |
return 0;
|
|
krh@86
|
257 |
}
|
|
krh@86
|
258 |
|
|
krh@86
|
259 |
static int
|
|
krh@86
|
260 |
create_path(struct installer *installer,
|
|
krh@86
|
261 |
const char *path, const char *name, unsigned int mode)
|
|
krh@77
|
262 |
{
|
|
krh@77
|
263 |
char buffer[256], *p;
|
|
krh@77
|
264 |
const char *slash, *next;
|
|
krh@77
|
265 |
struct stat buf;
|
|
krh@86
|
266 |
int fd;
|
|
krh@77
|
267 |
|
|
krh@77
|
268 |
/* Create all sub-directories in dir and then create name. We
|
|
krh@77
|
269 |
* know root exists and is a dir, root does not end in a '/',
|
|
krh@77
|
270 |
* and path has a leading '/'. */
|
|
krh@77
|
271 |
|
|
krh@86
|
272 |
strcpy(buffer, installer->root);
|
|
krh@77
|
273 |
p = buffer + strlen(buffer);
|
|
krh@77
|
274 |
slash = path;
|
|
krh@77
|
275 |
for (slash = path; slash[1] != '\0'; slash = next) {
|
|
krh@77
|
276 |
next = strchr(slash + 1, '/');
|
|
krh@77
|
277 |
memcpy(p, slash, next - slash);
|
|
krh@77
|
278 |
p += next - slash;
|
|
krh@77
|
279 |
*p = '\0';
|
|
krh@77
|
280 |
|
|
krh@77
|
281 |
if (stat(buffer, &buf) == 0) {
|
|
krh@77
|
282 |
if (!S_ISDIR(buf.st_mode)) {
|
|
krh@77
|
283 |
fprintf(stderr,
|
|
krh@77
|
284 |
"%s exists but is not a directory\n",
|
|
krh@77
|
285 |
buffer);
|
|
krh@77
|
286 |
return -1;
|
|
krh@77
|
287 |
}
|
|
krh@77
|
288 |
} else if (mkdir(buffer, 0777) < 0) {
|
|
krh@77
|
289 |
fprintf(stderr, "failed to make directory %s: %m\n",
|
|
krh@77
|
290 |
buffer);
|
|
krh@77
|
291 |
return -1;
|
|
krh@77
|
292 |
}
|
|
krh@77
|
293 |
/* FIXME: permissions */
|
|
krh@77
|
294 |
}
|
|
krh@77
|
295 |
|
|
krh@77
|
296 |
*p++ = '/';
|
|
krh@77
|
297 |
strcpy(p, name);
|
|
krh@77
|
298 |
|
|
krh@77
|
299 |
switch (mode >> 12) {
|
|
krh@77
|
300 |
case REG:
|
|
krh@86
|
301 |
fd = open(buffer, O_WRONLY | O_CREAT | O_TRUNC, mode & 0x1ff);
|
|
krh@86
|
302 |
if (fd < 0){
|
|
krh@86
|
303 |
fprintf(stderr, "failed to create file %s\n", buffer);
|
|
krh@86
|
304 |
return -1;
|
|
krh@86
|
305 |
}
|
|
krh@86
|
306 |
while (installer->rest > 0) {
|
|
krh@86
|
307 |
if (installer_inflate(installer)) {
|
|
krh@86
|
308 |
fprintf(stderr, "failed to inflate\n");
|
|
krh@86
|
309 |
return -1;
|
|
krh@86
|
310 |
}
|
|
krh@86
|
311 |
if (xwrite(fd, installer->buffer, installer->length)) {
|
|
krh@86
|
312 |
fprintf(stderr, "failed to write payload\n");
|
|
krh@86
|
313 |
return -1;
|
|
krh@86
|
314 |
}
|
|
krh@86
|
315 |
}
|
|
krh@86
|
316 |
if (close(fd) < 0) {
|
|
krh@86
|
317 |
fprintf(stderr, "failed to close %s: %m\n", buffer);
|
|
krh@86
|
318 |
return -1;
|
|
krh@86
|
319 |
}
|
|
krh@86
|
320 |
return 0;
|
|
krh@86
|
321 |
case XDIR:
|
|
krh@86
|
322 |
return mkdir(buffer, mode & 0x1ff);
|
|
krh@86
|
323 |
case PIPE:
|
|
krh@86
|
324 |
case CDEV:
|
|
krh@86
|
325 |
case BDEV:
|
|
krh@86
|
326 |
case SOCK:
|
|
krh@86
|
327 |
printf("%s: unhandled file type %d\n", buffer, mode >> 12);
|
|
krh@86
|
328 |
return 0;
|
|
krh@86
|
329 |
case LINK:
|
|
krh@86
|
330 |
if (installer_inflate(installer)) {
|
|
krh@86
|
331 |
fprintf(stderr, "failed to inflate\n");
|
|
krh@86
|
332 |
return -1;
|
|
krh@86
|
333 |
}
|
|
krh@86
|
334 |
if (installer->length >= sizeof installer->buffer) {
|
|
krh@86
|
335 |
fprintf(stderr, "link name too long\n");
|
|
krh@86
|
336 |
return -1;
|
|
krh@86
|
337 |
}
|
|
krh@86
|
338 |
installer->buffer[installer->length] = '\0';
|
|
krh@86
|
339 |
if (symlink((const char *) installer->buffer, buffer)) {
|
|
krh@86
|
340 |
fprintf(stderr, "failed to create symlink, %m\n");
|
|
krh@86
|
341 |
return -1;
|
|
krh@86
|
342 |
}
|
|
krh@86
|
343 |
return 0;
|
|
krh@77
|
344 |
default:
|
|
krh@86
|
345 |
printf("%s: unknown file type %d\n", buffer, mode >> 12);
|
|
krh@86
|
346 |
return 0;
|
|
krh@77
|
347 |
}
|
|
krh@77
|
348 |
}
|
|
krh@77
|
349 |
|
|
krh@85
|
350 |
static int
|
|
krh@86
|
351 |
run_script(struct installer *installer,
|
|
krh@86
|
352 |
unsigned int program_tag, unsigned int script_tag)
|
|
krh@85
|
353 |
{
|
|
krh@85
|
354 |
int pid, status, fd[2];
|
|
krh@86
|
355 |
const char *script = NULL, *program = NULL;
|
|
krh@85
|
356 |
|
|
krh@87
|
357 |
program = razor_rpm_get_indirect(installer->rpm, program_tag, NULL);
|
|
krh@87
|
358 |
script = razor_rpm_get_indirect(installer->rpm, script_tag, NULL);
|
|
krh@86
|
359 |
if (program == NULL && script == NULL) {
|
|
krh@86
|
360 |
printf("no script or program for tags %d and %d\n",
|
|
krh@86
|
361 |
program_tag, script_tag);
|
|
krh@86
|
362 |
return -1;
|
|
krh@86
|
363 |
} else if (program == NULL) {
|
|
krh@86
|
364 |
program = "/bin/sh";
|
|
krh@85
|
365 |
}
|
|
krh@85
|
366 |
|
|
krh@85
|
367 |
if (pipe(fd) < 0) {
|
|
krh@85
|
368 |
fprintf(stderr, "failed to create pipe\n");
|
|
krh@85
|
369 |
return -1;
|
|
krh@85
|
370 |
}
|
|
krh@85
|
371 |
pid = fork();
|
|
krh@85
|
372 |
if (pid < 0) {
|
|
krh@85
|
373 |
fprintf(stderr, "failed to fork, %m\n");
|
|
krh@85
|
374 |
} else if (pid == 0) {
|
|
krh@85
|
375 |
if (dup2(fd[0], STDIN_FILENO) < 0) {
|
|
krh@85
|
376 |
fprintf(stderr, "failed redirect stdin, %m\n");
|
|
krh@85
|
377 |
return -1;
|
|
krh@85
|
378 |
}
|
|
krh@85
|
379 |
if (close(fd[0]) < 0 || close(fd[1]) < 0) {
|
|
krh@85
|
380 |
fprintf(stderr, "failed to close pipe, %m\n");
|
|
krh@85
|
381 |
exit(-1);
|
|
krh@85
|
382 |
}
|
|
krh@86
|
383 |
if (chroot(installer->root) < 0) {
|
|
krh@86
|
384 |
fprintf(stderr, "failed to chroot to %s, %m\n",
|
|
krh@86
|
385 |
installer->root);
|
|
krh@85
|
386 |
return -1;
|
|
krh@85
|
387 |
}
|
|
krh@86
|
388 |
printf("executing program %s in chroot %s\n",
|
|
krh@86
|
389 |
program, installer->root);
|
|
krh@86
|
390 |
if (execl(program, program, NULL)) {
|
|
krh@86
|
391 |
fprintf(stderr, "failed to exec %s, %m\n", program);
|
|
krh@85
|
392 |
return -1;
|
|
krh@85
|
393 |
}
|
|
krh@85
|
394 |
} else {
|
|
krh@86
|
395 |
if (script && write(fd[1], script, strlen(script)) < 0) {
|
|
krh@85
|
396 |
fprintf(stderr, "failed to pipe script, %m\n");
|
|
krh@85
|
397 |
return -1;
|
|
krh@85
|
398 |
}
|
|
krh@85
|
399 |
if (close(fd[0]) || close(fd[1])) {
|
|
krh@85
|
400 |
fprintf(stderr, "failed to close pipe, %m\n");
|
|
krh@85
|
401 |
return -1;
|
|
krh@85
|
402 |
}
|
|
krh@85
|
403 |
if (wait(&status) < 0) {
|
|
krh@85
|
404 |
fprintf(stderr, "wait for child failed, %m");
|
|
krh@85
|
405 |
return -1;
|
|
krh@85
|
406 |
}
|
|
krh@85
|
407 |
printf("script exited with status %d\n", status);
|
|
krh@85
|
408 |
}
|
|
krh@85
|
409 |
|
|
krh@85
|
410 |
return 0;
|
|
krh@85
|
411 |
}
|
|
krh@85
|
412 |
|
|
krh@86
|
413 |
static int
|
|
krh@86
|
414 |
installer_init(struct installer *installer)
|
|
krh@77
|
415 |
{
|
|
krh@86
|
416 |
unsigned char *gz_header;
|
|
krh@86
|
417 |
int method, flags, err;
|
|
krh@77
|
418 |
|
|
krh@86
|
419 |
gz_header = installer->rpm->payload;
|
|
krh@77
|
420 |
if (gz_header[0] != 0x1f || gz_header[1] != 0x8b) {
|
|
krh@77
|
421 |
fprintf(stderr, "payload section doesn't have gz header\n");
|
|
krh@77
|
422 |
return -1;
|
|
krh@77
|
423 |
}
|
|
krh@77
|
424 |
|
|
krh@77
|
425 |
method = gz_header[2];
|
|
krh@77
|
426 |
flags = gz_header[3];
|
|
krh@77
|
427 |
|
|
krh@77
|
428 |
if (method != Z_DEFLATED || flags != 0) {
|
|
krh@77
|
429 |
fprintf(stderr,
|
|
krh@77
|
430 |
"unknown payload compression method or flags set\n");
|
|
krh@77
|
431 |
return -1;
|
|
krh@77
|
432 |
}
|
|
krh@77
|
433 |
|
|
krh@86
|
434 |
installer->stream.zalloc = NULL;
|
|
krh@86
|
435 |
installer->stream.zfree = NULL;
|
|
krh@86
|
436 |
installer->stream.opaque = NULL;
|
|
krh@85
|
437 |
|
|
krh@86
|
438 |
installer->stream.next_in = gz_header + 10;
|
|
krh@86
|
439 |
installer->stream.avail_in =
|
|
krh@86
|
440 |
(installer->rpm->map + installer->rpm->size) -
|
|
krh@86
|
441 |
(void *) installer->stream.next_in;
|
|
krh@86
|
442 |
installer->stream.next_out = NULL;
|
|
krh@86
|
443 |
installer->stream.avail_out = 0;
|
|
krh@77
|
444 |
|
|
krh@86
|
445 |
err = inflateInit2(&installer->stream, -MAX_WBITS);
|
|
krh@77
|
446 |
if (err != Z_OK) {
|
|
krh@77
|
447 |
fprintf(stderr, "inflateInit error: %d\n", err);
|
|
krh@77
|
448 |
return -1;
|
|
krh@77
|
449 |
}
|
|
krh@77
|
450 |
|
|
krh@86
|
451 |
return 0;
|
|
krh@86
|
452 |
}
|
|
krh@77
|
453 |
|
|
krh@86
|
454 |
static int
|
|
krh@86
|
455 |
installer_finish(struct installer *installer)
|
|
krh@86
|
456 |
{
|
|
krh@86
|
457 |
int err;
|
|
krh@77
|
458 |
|
|
krh@86
|
459 |
err = inflateEnd(&installer->stream);
|
|
krh@77
|
460 |
|
|
krh@77
|
461 |
if (err != Z_OK) {
|
|
krh@77
|
462 |
fprintf(stderr, "inflateEnd error: %d\n", err);
|
|
krh@77
|
463 |
return -1;
|
|
krh@77
|
464 |
}
|
|
krh@77
|
465 |
|
|
krh@86
|
466 |
return 0;
|
|
krh@86
|
467 |
}
|
|
krh@86
|
468 |
|
|
krh@86
|
469 |
int
|
|
krh@86
|
470 |
razor_rpm_install(struct razor_rpm *rpm, const char *root)
|
|
krh@86
|
471 |
{
|
|
krh@86
|
472 |
struct installer installer;
|
|
krh@87
|
473 |
unsigned int count, i, length;
|
|
krh@86
|
474 |
struct cpio_file_header *header;
|
|
krh@87
|
475 |
const unsigned long *size, *index, *flags;
|
|
krh@87
|
476 |
const unsigned short *mode;
|
|
krh@86
|
477 |
const char *name, *dir;
|
|
krh@86
|
478 |
struct stat buf;
|
|
krh@86
|
479 |
|
|
krh@86
|
480 |
installer.rpm = rpm;
|
|
krh@86
|
481 |
installer.root = root;
|
|
krh@86
|
482 |
|
|
krh@86
|
483 |
/* FIXME: Only do this before a transaction, not per rpm. */
|
|
krh@86
|
484 |
if (stat(root, &buf) < 0 || !S_ISDIR(buf.st_mode)) {
|
|
krh@86
|
485 |
fprintf(stderr,
|
|
krh@86
|
486 |
"root installation directory \"%s\" does not exist\n",
|
|
krh@86
|
487 |
root);
|
|
krh@86
|
488 |
return -1;
|
|
krh@86
|
489 |
}
|
|
krh@86
|
490 |
|
|
krh@86
|
491 |
if (installer_init(&installer))
|
|
krh@86
|
492 |
return -1;
|
|
krh@86
|
493 |
|
|
krh@86
|
494 |
run_script(&installer, RPMTAG_PREINPROG, RPMTAG_PREIN);
|
|
krh@86
|
495 |
|
|
krh@87
|
496 |
name = razor_rpm_get_indirect(rpm, RPMTAG_BASENAMES, &count);
|
|
krh@87
|
497 |
size = razor_rpm_get_indirect(rpm, RPMTAG_FILESIZES, &count);
|
|
krh@87
|
498 |
index = razor_rpm_get_indirect(rpm, RPMTAG_DIRINDEXES, &count);
|
|
krh@87
|
499 |
mode = razor_rpm_get_indirect(rpm, RPMTAG_FILEMODES, &count);
|
|
krh@87
|
500 |
flags = razor_rpm_get_indirect(rpm, RPMTAG_FILEFLAGS, &count);
|
|
krh@86
|
501 |
|
|
krh@86
|
502 |
for (i = 0; i < count; i++) {
|
|
krh@86
|
503 |
dir = rpm->dirs[ntohl(*index)];
|
|
krh@86
|
504 |
|
|
krh@86
|
505 |
/* Skip past the cpio header block unless it's a ghost file,
|
|
krh@86
|
506 |
* in which case doesn't appear in the cpio archive. */
|
|
krh@86
|
507 |
if (!(ntohl(*flags) & RPMFILE_GHOST)) {
|
|
krh@86
|
508 |
/* Plus two for the leading '.' and the terminating NUL. */
|
|
krh@86
|
509 |
length = sizeof *header + strlen(dir) + strlen(name) + 2;
|
|
krh@86
|
510 |
installer.rest = ALIGN(length, 4);
|
|
krh@86
|
511 |
if (installer_inflate(&installer))
|
|
krh@86
|
512 |
return -1;
|
|
krh@86
|
513 |
}
|
|
krh@86
|
514 |
|
|
krh@86
|
515 |
installer.rest = ntohl(*size);
|
|
krh@86
|
516 |
if (create_path(&installer, dir, name, ntohs(*mode)) < 0)
|
|
krh@86
|
517 |
return -1;
|
|
krh@86
|
518 |
|
|
krh@86
|
519 |
name += strlen(name) + 1;
|
|
krh@86
|
520 |
index++;
|
|
krh@86
|
521 |
size++;
|
|
krh@86
|
522 |
mode++;
|
|
krh@86
|
523 |
flags++;
|
|
krh@86
|
524 |
}
|
|
krh@86
|
525 |
|
|
krh@86
|
526 |
if (installer_finish(&installer))
|
|
krh@86
|
527 |
return -1;
|
|
krh@86
|
528 |
|
|
krh@86
|
529 |
run_script(&installer, RPMTAG_POSTINPROG, RPMTAG_POSTIN);
|
|
krh@85
|
530 |
|
|
krh@75
|
531 |
return 0;
|
|
krh@74
|
532 |
}
|
|
krh@74
|
533 |
|
|
krh@77
|
534 |
int
|
|
krh@77
|
535 |
razor_rpm_close(struct razor_rpm *rpm)
|
|
krh@74
|
536 |
{
|
|
krh@77
|
537 |
int err;
|
|
krh@77
|
538 |
|
|
krh@77
|
539 |
free(rpm->dirs);
|
|
krh@77
|
540 |
err = munmap(rpm->map, rpm->size);
|
|
krh@77
|
541 |
free(rpm);
|
|
krh@77
|
542 |
|
|
krh@77
|
543 |
return err;
|
|
krh@75
|
544 |
}
|
|
krh@74
|
545 |
|
|
krh@75
|
546 |
int
|
|
krh@77
|
547 |
razor_importer_add_rpm(struct razor_importer *importer, struct razor_rpm *rpm)
|
|
krh@75
|
548 |
{
|
|
krh@87
|
549 |
const char *name, *version, *release;
|
|
krh@75
|
550 |
|
|
krh@87
|
551 |
name = razor_rpm_get_indirect(rpm, RPMTAG_NAME, NULL);
|
|
krh@87
|
552 |
version = razor_rpm_get_indirect(rpm, RPMTAG_VERSION, NULL);
|
|
krh@87
|
553 |
release = razor_rpm_get_indirect(rpm, RPMTAG_RELEASE, NULL);
|
|
krh@87
|
554 |
|
|
krh@87
|
555 |
/* FIXME: Concatenate version and release. */
|
|
krh@87
|
556 |
razor_importer_begin_package(importer, name, version);
|
|
krh@87
|
557 |
|
|
krh@87
|
558 |
import_properties(importer, RAZOR_PROPERTY_REQUIRES, rpm,
|
|
krh@87
|
559 |
RPMTAG_REQUIRENAME,
|
|
krh@87
|
560 |
RPMTAG_REQUIREVERSION,
|
|
krh@87
|
561 |
RPMTAG_REQUIREFLAGS);
|
|
krh@87
|
562 |
|
|
krh@87
|
563 |
import_properties(importer, RAZOR_PROPERTY_PROVIDES, rpm,
|
|
krh@87
|
564 |
RPMTAG_PROVIDENAME,
|
|
krh@87
|
565 |
RPMTAG_PROVIDEVERSION,
|
|
krh@87
|
566 |
RPMTAG_PROVIDEFLAGS);
|
|
krh@87
|
567 |
|
|
krh@87
|
568 |
import_properties(importer, RAZOR_PROPERTY_OBSOLETES, rpm,
|
|
krh@87
|
569 |
RPMTAG_OBSOLETENAME,
|
|
krh@87
|
570 |
RPMTAG_OBSOLETEVERSION,
|
|
krh@87
|
571 |
RPMTAG_OBSOLETEFLAGS);
|
|
krh@87
|
572 |
|
|
krh@87
|
573 |
import_properties(importer, RAZOR_PROPERTY_CONFLICTS, rpm,
|
|
krh@87
|
574 |
RPMTAG_CONFLICTNAME,
|
|
krh@87
|
575 |
RPMTAG_CONFLICTVERSION,
|
|
krh@87
|
576 |
RPMTAG_CONFLICTFLAGS);
|
|
krh@87
|
577 |
|
|
krh@77
|
578 |
import_files(importer, rpm);
|
|
krh@74
|
579 |
|
|
krh@75
|
580 |
razor_importer_finish_package(importer);
|
|
krh@74
|
581 |
|
|
krh@75
|
582 |
return 0;
|
|
krh@74
|
583 |
}
|