ref: refs/heads/master
commit 12468ba6fa286f4e35dc2328af1a65ce9e5bc9c2
Author: Michael Schroeder
Date: Mon Jun 29 17:49:11 2009 +0200
- add repo_deb.[ch], needed for build service code
---
ext/repo_deb.c | 253 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
ext/repo_deb.h | 10 ++
src/chksum.c | 9 ++-
src/chksum.h | 2 +-
4 files changed, 272 insertions(+), 2 deletions(-)
diff --git a/ext/repo_deb.c b/ext/repo_deb.c
new file mode 100644
index 0000000..3ed362b
--- /dev/null
+++ b/ext/repo_deb.c
@@ -0,0 +1,253 @@
+/*
+ * Copyright (c) 2009, Novell Inc.
+ *
+ * This program is licensed under the BSD license, read LICENSE.BSD
+ * for further information
+ */
+
+#include
+#include
+#include
+#include
+#include
+#include
+#include
+
+#include "pool.h"
+#include "repo.h"
+#include "util.h"
+#include "chksum.h"
+#include "repo_deb.h"
+
+static unsigned char *
+decompress(unsigned char *in, int inl, int *outlp)
+{
+ z_stream strm;
+ int outl, ret;
+ unsigned char *out;
+
+ memset(&strm, 0, sizeof(strm));
+ strm.next_in = in;
+ strm.avail_in = inl;
+ out = sat_malloc(4096);
+ strm.next_out = out;
+ strm.avail_out = 4096;
+ outl = 0;
+ ret = inflateInit2(&strm, -MAX_WBITS);
+ if (ret != Z_OK)
+ {
+ free(out);
+ return 0;
+ }
+ for (;;)
+ {
+ if (strm.avail_out == 0)
+ {
+ outl += 4096;
+ out = sat_realloc(out, outl + 4096);
+ strm.next_out = out + outl;
+ strm.avail_out = 4096;
+ }
+ ret = inflate(&strm, Z_NO_FLUSH);
+ if (ret == Z_STREAM_END)
+ break;
+ if (ret != Z_OK)
+ {
+ free(out);
+ return 0;
+ }
+ }
+ outl += 4096 - strm.avail_out;
+ inflateEnd(&strm);
+ *outlp = outl;
+ return out;
+}
+
+static void
+control2solvable(Solvable *s, char *control)
+{
+}
+
+void
+repo_add_debs(Repo *repo, const char **debs, int ndebs, int flags)
+{
+ Pool *pool = repo->pool;
+ Repodata *data;
+ unsigned char buf[4096], *bp;
+ int i, l, l2, vlen, clen, ctarlen;
+ unsigned char *ctgz;
+ unsigned char pkgid[16];
+ unsigned char *ctar;
+ int gotpkgid;
+ FILE *fp;
+ Solvable *s;
+ struct stat stb;
+
+ if (!(flags & REPO_REUSE_REPODATA))
+ data = repo_add_repodata(repo, 0);
+ else
+ data = repo_last_repodata(repo);
+ for (i = 0; i < ndebs; i++)
+ {
+ if ((fp = fopen(debs[i], "r")) == 0)
+ {
+ perror(debs[i]);
+ continue;
+ }
+ if (fstat(fileno(fp), &stb))
+ {
+ perror("stat");
+ continue;
+ }
+ l = fread(buf, 1, sizeof(buf), fp);
+ if (l < 8 + 60 || strncmp(buf, "!<arch>\ndebian-binary ", 8 + 16) != 0)
+ {
+ fprintf(stderr, "%s: not a deb package\n", debs[i]);
+ fclose(fp);
+ continue;
+ }
+ vlen = atoi(buf + 8 + 48);
+ if (vlen < 0 || vlen > l)
+ {
+ fprintf(stderr, "%s: not a deb package\n", debs[i]);
+ fclose(fp);
+ continue;
+ }
+ vlen += vlen & 1;
+ if (l < 8 + 60 + vlen + 60)
+ {
+ fprintf(stderr, "%s: unhandled deb package\n", debs[i]);
+ fclose(fp);
+ continue;
+ }
+ if (strncmp(buf + 8 + 60 + vlen, "control.tar.gz ", 16) != 0)
+ {
+ fprintf(stderr, "%s: control.tar.gz is not second entry\n", debs[i]);
+ fclose(fp);
+ continue;
+ }
+ clen = atoi(buf + 8 + 60 + vlen + 48);
+ if (clen <= 0)
+ {
+ fprintf(stderr, "%s: control.tar.gz has illegal size\n", debs[i]);
+ fclose(fp);
+ continue;
+ }
+ ctgz = sat_calloc(1, clen + 4);
+ bp = buf + 8 + 60 + vlen + 60;
+ l -= 8 + 60 + vlen + 60;
+ if (l > clen)
+ l = clen;
+ if (l)
+ memcpy(ctgz, bp, l);
+ if (l < clen)
+ {
+ if (fread(ctgz + l, clen - l, 1, fp) != 1)
+ {
+ fprintf(stderr, "%s: unexpected EOF\n", debs[i]);
+ sat_free(ctgz);
+ fclose(fp);
+ continue;
+ }
+ }
+ fclose(fp);
+ gotpkgid = 0;
+ if (flags & DEBS_ADD_WITH_PKGID)
+ {
+ void *handle = sat_chksum_create(REPOKEY_TYPE_MD5);
+ sat_chksum_add(handle, ctgz, clen);
+ sat_chksum_free(handle, pkgid);
+ gotpkgid = 1;
+ }
+ if (ctgz[0] != 0x1f || ctgz[1] != 0x8b)
+ {
+ fprintf(stderr, "%s: control.tar.gz is not gzipped\n", debs[i]);
+ sat_free(ctgz);
+ continue;
+ }
+ if (ctgz[2] != 8 || (ctgz[3] & 0xe0) != 0)
+ {
+ fprintf(stderr, "%s: control.tar.gz is compressed in a strange way\n", debs[i]);
+ sat_free(ctgz);
+ continue;
+ }
+ bp = ctgz + 4;
+ bp += 6; /* skip time, xflags and OS code */
+ if (ctgz[3] & 0x04)
+ {
+ /* skip extra field */
+ l = bp[0] | bp[1] << 8;
+ bp += l + 2;
+ if (bp >= ctgz + clen)
+ {
+ fprintf(stderr, "%s: corrupt gzip\n", debs[i]);
+ sat_free(ctgz);
+ continue;
+ }
+ }
+ if (ctgz[3] & 0x08) /* orig filename */
+ while (*bp)
+ bp++;
+ if (ctgz[3] & 0x10) /* file comment */
+ while (*bp)
+ bp++;
+ if (ctgz[3] & 0x02) /* header crc */
+ bp += 2;
+ if (bp >= ctgz + clen)
+ {
+ fprintf(stderr, "%s: corrupt control.tar.gz\n", debs[i]);
+ sat_free(ctgz);
+ continue;
+ }
+ ctar = decompress(bp, ctgz + clen - bp, &ctarlen);
+ sat_free(ctgz);
+ if (!ctar)
+ {
+ fprintf(stderr, "%s: corrupt control.tar.gz\n", debs[i]);
+ continue;
+ }
+ bp = ctar;
+ l = ctarlen;
+ while (l > 512)
+ {
+ int j;
+ l2 = 0;
+ for (j = 124; j < 124 + 12; j++)
+ if (bp[j] >= '0' && bp[j] <= '7')
+ l2 = l2 * 8 + (bp[j] - '0');
+ if (!strcmp(bp, "./control"))
+ break;
+ l2 = 512 + ((l2 + 511) & ~511);
+ l -= l2;
+ bp += l2;
+ }
+ if (l <= 512 || l - 512 - l2 <= 0 || l2 <= 0)
+ {
+ fprintf(stderr, "%s: control.tar.gz contains no ./control file\n", debs[i]);
+ free(ctar);
+ continue;
+ }
+ memmove(ctar, bp + 512, l2);
+ ctar = sat_realloc(ctar, l2 + 1);
+ ctar[l2] = 0;
+ s = pool_id2solvable(pool, repo_add_solvable(repo));
+ control2solvable(s, (char *)ctar);
+ repodata_set_location(data, s - pool->solvables, 0, 0, debs[i]);
+ repodata_set_num(data, s - pool->solvables, SOLVABLE_DOWNLOADSIZE, (unsigned int)((stb.st_size + 1023) / 1024));
+ if (gotpkgid)
+ repodata_set_bin_checksum(data, s - pool->solvables, SOLVABLE_PKGID, REPOKEY_TYPE_MD5, pkgid);
+ sat_free(ctar);
+ }
+ if (!(flags & REPO_NO_INTERNALIZE))
+ repodata_internalize(data);
+}
+
+int
+main(int argc, const char **argv)
+{
+ Pool *pool = pool_create();
+ Repo *repo = repo_create(pool, "debs2solv");
+ repo_add_debs(repo, argv + 1, argc - 1, DEBS_ADD_WITH_PKGID);
+ repo_write(repo, stdout, 0, 0, 0);
+ pool_free(pool);
+}
diff --git a/ext/repo_deb.h b/ext/repo_deb.h
new file mode 100644
index 0000000..d06dbeb
--- /dev/null
+++ b/ext/repo_deb.h
@@ -0,0 +1,10 @@
+/*
+ * Copyright (c) 2009, Novell Inc.
+ *
+ * This program is licensed under the BSD license, read LICENSE.BSD
+ * for further information
+ */
+
+extern void repo_add_debs(Repo *repo, const char **debs, int ndebs, int flags);
+
+#define DEBS_ADD_WITH_PKGID (1 << 8)
diff --git a/src/chksum.c b/src/chksum.c
index e2043f3..a66de46 100644
--- a/src/chksum.c
+++ b/src/chksum.c
@@ -99,8 +99,15 @@ sat_chksum_get(void *handle, int *lenp)
}
void *
-sat_chksum_free(void *handle)
+sat_chksum_free(void *handle, unsigned char *cp)
{
+ if (cp)
+ {
+ unsigned char *res;
+ int l;
+ res = sat_chksum_get(handle, &l);
+ memcpy(cp, res, l);
+ }
sat_free(handle);
return 0;
}
diff --git a/src/chksum.h b/src/chksum.h
index 0b3a289..89bdf86 100644
--- a/src/chksum.h
+++ b/src/chksum.h
@@ -3,7 +3,7 @@
void *sat_chksum_create(Id type);
void sat_chksum_add(void *handle, const void *data, int len);
unsigned char *sat_chksum_get(void *handle, int *lenp);
-void *sat_chksum_free(void *handle);
+void *sat_chksum_free(void *handle, unsigned char *cp);
static inline int sat_chksum_len(Id type)
{
--
To unsubscribe, e-mail: zypp-commit+unsubscribe@opensuse.org
For additional commands, e-mail: zypp-commit+help@opensuse.org
