libbb/unarchive.c

   1 /*
   2  *  Copyright (C) 2000 by Glenn McGrath
   3  *  Copyright (C) 2001 by Laurence Anderson
   4  *
   5  *  Based on previous work by busybox developers and others.
   6  *
   7  *  This program is free software; you can redistribute it and/or modify
   8  *  it under the terms of the GNU General Public License as published by
   9  *  the Free Software Foundation; either version 2 of the License, or
  10  *  (at your option) any later version.
  11  *
  12  *  This program is distributed in the hope that it will be useful,
  13  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  14  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15  *  GNU Library General Public License for more details.
  16  *
  17  *  You should have received a copy of the GNU General Public License
  18  *  along with this program; if not, write to the Free Software
  19  *  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  20  */
  21
  22 #include <stdio.h>
  23 #include <errno.h>
  24 #include <stdlib.h>
  25 #include <string.h>
  26 #include <unistd.h>
  27 #include <utime.h>
  28 #include <libgen.h>
  29
  30 #include "libbb.h"
  31
  32 #define CONFIG_FEATURE_TAR_OLDGNU_COMPATABILITY 1
  33 #define CONFIG_FEATURE_TAR_GNU_EXTENSIONS
  34
  35 #ifdef CONFIG_FEATURE_TAR_GNU_EXTENSIONS
  36 static char *longname = NULL;
  37 static char *linkname = NULL;
  38 #endif
  39
  40 off_t archive_offset;
  41
  42 #define SEEK_BUF 4096
  43 static ssize_t
  44 seek_by_read(FILE* fd, size_t len)
  45 {
  46         ssize_t cc, total = 0;
  47         char buf[SEEK_BUF];
  48
  49         while (len) {
  50                 cc = fread(buf, sizeof(buf[0]),
  51                                 len > SEEK_BUF ? SEEK_BUF : len,
  52                                 fd);
  53
  54                 total += cc;
  55                 len -= cc;
  56
  57                 if(feof(fd) || ferror(fd))
  58                         break;
  59         }
  60         return total;
  61 }
  62
  63 static void
  64 seek_sub_file(FILE *fd, const int count)
  65 {
  66         archive_offset += count;
  67
  68         /* Do not use fseek() on a pipe. It may fail with ESPIPE, leaving the
  69          * stream at an undefined location.
  70          */
  71         seek_by_read(fd, count);
  72
  73         return;
  74 }
  75
  76
  77 /* Extract the data postioned at src_stream to either filesystem, stdout or
  78  * buffer depending on the value of 'function' which is defined in libbb.h
  79  *
  80  * prefix doesnt have to be just a directory, it may prefix the filename as well.
  81  *
  82  * e.g. '/var/lib/dpkg/info/dpkg.' will extract all files to the base bath
  83  * '/var/lib/dpkg/info/' and all files/dirs created in that dir will have
  84  * 'dpkg.' as their prefix
  85  *
  86  * For this reason if prefix does point to a dir then it must end with a
  87  * trailing '/' or else the last dir will be assumed to be the file prefix
  88  */
  89 static char *
  90 extract_archive(FILE *src_stream, FILE *out_stream,
  91                 const file_header_t *file_entry, const int function,
  92                 const char *prefix,
  93                 int *err)
  94 {
  95         FILE *dst_stream = NULL;
  96         char *full_name = NULL;
  97         char *full_link_name = NULL;
  98         char *buffer = NULL;
  99         struct utimbuf t;
 100
 101         *err = 0;
 102
 103         /* prefix doesnt have to be a proper path it may prepend
 104          * the filename as well */
 105         if (prefix != NULL) {
 106                 /* strip leading '/' in filename to extract as prefix may not be dir */
 107                 /* Cant use concat_path_file here as prefix might not be a directory */
 108                 char *path = file_entry->name;
 109                 if (strncmp("./", path, 2) == 0) {
 110                         path += 2;
 111                         if (strlen(path) == 0)
 112                                 /* Do nothing, current dir already exists. */
 113                                 return NULL;
 114                 }
 115                 full_name = xmalloc(strlen(prefix) + strlen(path) + 1);
 116                 strcpy(full_name, prefix);
 117                 strcat(full_name, path);
 118                 if ( file_entry->link_name ){
 119                    full_link_name = xmalloc(strlen(prefix) + strlen(file_entry->link_name) + 1);
 120                    strcpy(full_link_name, prefix);
 121                    strcat(full_link_name, file_entry->link_name);
 122                 }
 123         } else {
 124                 full_name = xstrdup(file_entry->name);
 125                 if ( file_entry->link_name )
 126                    full_link_name = xstrdup(file_entry->link_name);
 127         }
 128
 129
 130         if (function & extract_to_stream) {
 131                 if (S_ISREG(file_entry->mode)) {
 132                         *err = copy_file_chunk(src_stream, out_stream, file_entry->size);
 133                         archive_offset += file_entry->size;
 134                 }
 135         }
 136         else if (function & extract_one_to_buffer) {
 137                 if (S_ISREG(file_entry->mode)) {
 138                         buffer = (char *) xmalloc(file_entry->size + 1);
 139                         fread(buffer, 1, file_entry->size, src_stream);
 140                         buffer[file_entry->size] = '\0';
 141                         archive_offset += file_entry->size;
 142                         goto cleanup;
 143                 }
 144         }
 145         else if (function & extract_all_to_fs) {
 146                 struct stat oldfile;
 147                 int stat_res;
 148                 stat_res = lstat (full_name, &oldfile);
 149                 if (stat_res == 0) { /* The file already exists */
 150                         if ((function & extract_unconditional) || (oldfile.st_mtime < file_entry->mtime)) {
 151                                 if (!S_ISDIR(oldfile.st_mode)) {
 152                                         unlink(full_name); /* Directories might not be empty etc */
 153                                 }
 154                         } else {
 155                                 if ((function & extract_quiet) != extract_quiet) {
 156                                         *err = -1;
 157                                         error_msg("%s not created: newer or same age file exists", file_entry->name);
 158                                 }
 159                                 seek_sub_file(src_stream, file_entry->size);
 160                                 goto cleanup;
 161                         }
 162                 }
 163                 if (function & extract_create_leading_dirs) { /* Create leading directories with default umask */
 164                         char *buf, *parent;
 165                         buf = xstrdup(full_name);
 166                         parent = dirname(buf);
 167                         if (make_directory (parent, -1, FILEUTILS_RECUR) != 0) {
 168                                 if ((function & extract_quiet) != extract_quiet) {
 169                                         *err = -1;
 170                                         error_msg("couldn't create leading directories");
 171                                 }
 172                         }
 173                         free (buf);
 174                 }
 175                 switch(file_entry->mode & S_IFMT) {
 176                         case S_IFREG:
 177                                 if (file_entry->link_name) { /* Found a cpio hard link */
 178                                         if (link(full_link_name, full_name) != 0) {
 179                                                 if ((function & extract_quiet) != extract_quiet) {
 180                                                         *err = -1;
 181                                                         perror_msg("Cannot link from %s to '%s'",
 182                                                                 file_entry->name, file_entry->link_name);
 183                                                 }
 184                                         }
 185                                 } else {
 186                                         if ((dst_stream = wfopen(full_name, "w")) == NULL) {
 187                                                 *err = -1;
 188                                                 seek_sub_file(src_stream, file_entry->size);
 189                                                 goto cleanup;
 190                                         }
 191                                         archive_offset += file_entry->size;
 192                                         *err = copy_file_chunk(src_stream, dst_stream, file_entry->size);
 193                                         fclose(dst_stream);
 194                                 }
 195                                 break;
 196                         case S_IFDIR:
 197                                 if (stat_res != 0) {
 198                                         if (mkdir(full_name, file_entry->mode) < 0) {
 199                                                 if ((function & extract_quiet) != extract_quiet) {
 200                                                         *err = -1;
 201                                                         perror_msg("Cannot make dir %s", full_name);
 202                                                 }
 203                                         }
 204                                 }
 205                                 break;
 206                         case S_IFLNK:
 207                                 if (symlink(file_entry->link_name, full_name) < 0) {
 208                                         if ((function & extract_quiet) != extract_quiet) {
 209                                                 *err = -1;
 210                                                 perror_msg("Cannot create symlink from %s to '%s'", file_entry->name, file_entry->link_name);
 211                                         }
 212                                         goto cleanup;
 213                                 }
 214                                 break;
 215                         case S_IFSOCK:
 216                         case S_IFBLK:
 217                         case S_IFCHR:
 218                         case S_IFIFO:
 219                                 if (mknod(full_name, file_entry->mode, file_entry->device) == -1) {
 220                                         if ((function & extract_quiet) != extract_quiet) {
 221                                                 *err = -1;
 222                                                 perror_msg("Cannot create node %s", file_entry->name);
 223                                         }
 224                                         goto cleanup;
 225                                 }
 226                                 break;
 227                          default:
 228                                 *err = -1;
 229                                 perror_msg("Don't know how to handle %s", full_name);
 230
 231                 }
 232
 233                 /* Changing a symlink's properties normally changes the properties of the
 234                  * file pointed to, so dont try and change the date or mode, lchown does
 235                  * does the right thing, but isnt available in older versions of libc */
 236                 if (S_ISLNK(file_entry->mode)) {
 237 #if (__GLIBC__ > 2) && (__GLIBC_MINOR__ > 1)
 238                         lchown(full_name, file_entry->uid, file_entry->gid);
 239 #endif
 240                 } else {
 241                         if (function & extract_preserve_date) {
 242                                 t.actime = file_entry->mtime;
 243                                 t.modtime = file_entry->mtime;
 244                                 utime(full_name, &t);
 245                         }
 246                         chown(full_name, file_entry->uid, file_entry->gid);
 247                         chmod(full_name, file_entry->mode);
 248                 }
 249         } else {
 250                 /* If we arent extracting data we have to skip it,
 251                  * if data size is 0 then then just do it anyway
 252                  * (saves testing for it) */
 253                 seek_sub_file(src_stream, file_entry->size);
 254         }
 255
 256         /* extract_list and extract_verbose_list can be used in conjunction
 257          * with one of the above four extraction functions, so do this seperately */
 258         if (function & extract_verbose_list) {
 259                 fprintf(out_stream, "%s %d/%d %8d %s ", mode_string(file_entry->mode),
 260                         file_entry->uid, file_entry->gid,
 261                         (int) file_entry->size, time_string(file_entry->mtime));
 262         }
 263         if ((function & extract_list) || (function & extract_verbose_list)){
 264                 /* fputs doesnt add a trailing \n, so use fprintf */
 265                 fprintf(out_stream, "%s\n", file_entry->name);
 266         }
 267
 268 cleanup:
 269         free(full_name);
 270         if ( full_link_name )
 271             free(full_link_name);
 272
 273         return buffer;
 274 }
 275
 276 static char *
 277 unarchive(FILE *src_stream, FILE *out_stream,
 278                 file_header_t *(*get_headers)(FILE *),
 279                 void (*free_headers)(file_header_t *),
 280                 const int extract_function,
 281                 const char *prefix,
 282                 const char **extract_names,
 283                 int *err)
 284 {
 285         file_header_t *file_entry;
 286         int extract_flag;
 287         int i;
 288         char *buffer = NULL;
 289
 290         *err = 0;
 291
 292         archive_offset = 0;
 293         while ((file_entry = get_headers(src_stream)) != NULL) {
 294                 extract_flag = TRUE;
 295
 296                 if (extract_names != NULL) {
 297                         int found_flag = FALSE;
 298                         for(i = 0; extract_names[i] != 0; i++) {
 299                                 if (strcmp(extract_names[i], file_entry->name) == 0) {
 300                                         found_flag = TRUE;
 301                                         break;
 302                                 }
 303                         }
 304                         if (extract_function & extract_exclude_list) {
 305                                 if (found_flag == TRUE) {
 306                                         extract_flag = FALSE;
 307                                 }
 308                         } else {
 309                                 /* If its not found in the include list dont extract it */
 310                                 if (found_flag == FALSE) {
 311                                         extract_flag = FALSE;
 312                                 }
 313                         }
 314                 }
 315
 316                 if (extract_flag == TRUE) {
 317                         buffer = extract_archive(src_stream, out_stream,
 318                                         file_entry, extract_function,
 319                                         prefix, err);
 320                         *err = 0; /* XXX: ignore extraction errors */
 321                         if (*err) {
 322                                 free_headers(file_entry);
 323                                 break;
 324                         }
 325                 } else {
 326                         /* seek past the data entry */
 327                         seek_sub_file(src_stream, file_entry->size);
 328                 }
 329                 free_headers(file_entry);
 330         }
 331
 332         return buffer;
 333 }
 334
 335 static file_header_t *
 336 get_header_ar(FILE *src_stream)
 337 {
 338         file_header_t *typed;
 339         union {
 340                 char raw[60];
 341                 struct {
 342                         char name[16];
 343                         char date[12];
 344                         char uid[6];
 345                         char gid[6];
 346                         char mode[8];
 347                         char size[10];
 348                         char magic[2];
 349                 } formated;
 350         } ar;
 351         static char *ar_long_names;
 352
 353         if (fread(ar.raw, 1, 60, src_stream) != 60) {
 354                 return(NULL);
 355         }
 356         archive_offset += 60;
 357         /* align the headers based on the header magic */
 358         if ((ar.formated.magic[0] != '`') || (ar.formated.magic[1] != '\n')) {
 359                 /* some version of ar, have an extra '\n' after each data entry,
 360                  * this puts the next header out by 1 */
 361                 if (ar.formated.magic[1] != '`') {
 362                         error_msg("Invalid magic");
 363                         return(NULL);
 364                 }
 365                 /* read the next char out of what would be the data section,
 366                  * if its a '\n' then it is a valid header offset by 1*/
 367                 archive_offset++;
 368                 if (fgetc(src_stream) != '\n') {
 369                         error_msg("Invalid magic");
 370                         return(NULL);
 371                 }
 372                 /* fix up the header, we started reading 1 byte too early */
 373                 /* raw_header[60] wont be '\n' as it should, but it doesnt matter */
 374                 memmove(ar.raw, &ar.raw[1], 59);
 375         }
 376
 377         typed = (file_header_t *) xcalloc(1, sizeof(file_header_t));
 378
 379         typed->size = (size_t) atoi(ar.formated.size);
 380         /* long filenames have '/' as the first character */
 381         if (ar.formated.name[0] == '/') {
 382                 if (ar.formated.name[1] == '/') {
 383                         /* If the second char is a '/' then this entries data section
 384                          * stores long filename for multiple entries, they are stored
 385                          * in static variable long_names for use in future entries */
 386                         ar_long_names = (char *) xrealloc(ar_long_names, typed->size);
 387                         fread(ar_long_names, 1, typed->size, src_stream);
 388                         archive_offset += typed->size;
 389                         /* This ar entries data section only contained filenames for other records
 390                          * they are stored in the static ar_long_names for future reference */
 391                         return (get_header_ar(src_stream)); /* Return next header */
 392                 } else if (ar.formated.name[1] == ' ') {
 393                         /* This is the index of symbols in the file for compilers */
 394                         seek_sub_file(src_stream, typed->size);
 395                         return (get_header_ar(src_stream)); /* Return next header */
 396                 } else {
 397                         /* The number after the '/' indicates the offset in the ar data section
 398                         (saved in variable long_name) that conatains the real filename */
 399                         if (!ar_long_names) {
 400                                 error_msg("Cannot resolve long file name");
 401                                 return (NULL);
 402                         }
 403                         typed->name = xstrdup(ar_long_names + atoi(&ar.formated.name[1]));
 404                 }
 405         } else {
 406                 /* short filenames */
 407                 typed->name = xcalloc(1, 16);
 408                 strncpy(typed->name, ar.formated.name, 16);
 409         }
 410         typed->name[strcspn(typed->name, " /")]='\0';
 411
 412         /* convert the rest of the now valid char header to its typed struct */
 413         parse_mode(ar.formated.mode, &typed->mode);
 414         typed->mtime = atoi(ar.formated.date);
 415         typed->uid = atoi(ar.formated.uid);
 416         typed->gid = atoi(ar.formated.gid);
 417
 418         return(typed);
 419 }
 420
 421 static void
 422 free_header_ar(file_header_t *ar_entry)
 423 {
 424         if (ar_entry == NULL)
 425                 return;
 426
 427         free(ar_entry->name);
 428         if (ar_entry->link_name)
 429                 free(ar_entry->link_name);
 430
 431         free(ar_entry);
 432 }
 433
 434
 435 static file_header_t *
 436 get_header_tar(FILE *tar_stream)
 437 {
 438         union {
 439                 unsigned char raw[512];
 440                 struct {
 441                         char name[100];         /*   0-99 */
 442                         char mode[8];           /* 100-107 */
 443                         char uid[8];            /* 108-115 */
 444                         char gid[8];            /* 116-123 */
 445                         char size[12];          /* 124-135 */
 446                         char mtime[12];         /* 136-147 */
 447                         char chksum[8];         /* 148-155 */
 448                         char typeflag;          /* 156-156 */
 449                         char linkname[100];     /* 157-256 */
 450                         char magic[6];          /* 257-262 */
 451                         char version[2];        /* 263-264 */
 452                         char uname[32];         /* 265-296 */
 453                         char gname[32];         /* 297-328 */
 454                         char devmajor[8];       /* 329-336 */
 455                         char devminor[8];       /* 337-344 */
 456                         char prefix[155];       /* 345-499 */
 457                         char padding[12];       /* 500-512 */
 458                 } formated;
 459         } tar;
 460         file_header_t *tar_entry = NULL;
 461         long i;
 462         long sum = 0;
 463
 464         if (archive_offset % 512 != 0) {
 465                 seek_sub_file(tar_stream, 512 - (archive_offset % 512));
 466         }
 467
 468         if (fread(tar.raw, 1, 512, tar_stream) != 512) {
 469                 /* Unfortunatly its common for tar files to have all sorts of
 470                  * trailing garbage, fail silently */
 471 //              error_msg("Couldnt read header");
 472                 return(NULL);
 473         }
 474         archive_offset += 512;
 475
 476         /* Check header has valid magic, unfortunately some tar files
 477          * have empty (0'ed) tar entries at the end, which will
 478          * cause this to fail, so fail silently for now
 479          */
 480         if (strncmp(tar.formated.magic, "ustar", 5) != 0) {
 481 #ifdef CONFIG_FEATURE_TAR_OLDGNU_COMPATABILITY
 482                 if (strncmp(tar.formated.magic, "\0\0\0\0\0", 5) != 0)
 483 #endif
 484                 return(NULL);
 485         }
 486
 487         /* Do checksum on headers */
 488         for (i =  0; i < 148 ; i++) {
 489                 sum += tar.raw[i];
 490         }
 491         sum += ' ' * 8;
 492         for (i =  156; i < 512 ; i++) {
 493                 sum += tar.raw[i];
 494         }
 495         if (sum != strtol(tar.formated.chksum, NULL, 8)) {
 496                 if ( strtol(tar.formated.chksum,NULL,8) != 0 )
 497                         error_msg("Invalid tar header checksum");
 498                 return(NULL);
 499         }
 500
 501         /* convert to type'ed variables */
 502         tar_entry = xcalloc(1, sizeof(file_header_t));
 503
 504 #ifdef CONFIG_FEATURE_TAR_GNU_EXTENSIONS
 505         if (longname) {
 506                 tar_entry->name = longname;
 507                 longname = NULL;
 508         }
 509         else if (linkname) {
 510                 tar_entry->name = linkname;
 511                 linkname = NULL;
 512         } else
 513 #endif
 514         {
 515                 tar_entry->name = xstrndup(tar.formated.name, 100);
 516
 517                 if (tar.formated.prefix[0]) {
 518                         char *temp = tar_entry->name;
 519                         char *prefixTemp = xstrndup(tar.formated.prefix, 155);
 520                         tar_entry->name = concat_path_file(prefixTemp, temp);
 521                         free(temp);
 522                         free(prefixTemp);
 523                 }
 524         }
 525
 526         // tar_entry->name = xstrdup(tar.formated.name);
 527
 528 /*
 529         parse_mode(tar.formated.mode, &tar_entry->mode);
 530 */
 531         tar_entry->mode = 07777 & strtol(tar.formated.mode, NULL, 8);
 532
 533         tar_entry->uid   = strtol(tar.formated.uid, NULL, 8);
 534         tar_entry->gid   = strtol(tar.formated.gid, NULL, 8);
 535         tar_entry->size  = strtol(tar.formated.size, NULL, 8);
 536         tar_entry->mtime = strtol(tar.formated.mtime, NULL, 8);
 537         tar_entry->link_name  = *tar.formated.linkname != '\0' ? xstrndup(tar.formated.linkname, 100) : NULL;
 538         tar_entry->device = (strtol(tar.formated.devmajor, NULL, 8) << 8) +
 539                 strtol(tar.formated.devminor, NULL, 8);
 540
 541         /* Fix mode, used by the old format */
 542         switch (tar.formated.typeflag) {
 543         /* hard links are detected as regular files with 0 size and a link name */
 544         case '1':
 545                 tar_entry->mode |= S_IFREG ;
 546                 break;
 547         case 0:
 548         case '0':
 549
 550 # ifdef CONFIG_FEATURE_TAR_OLDGNU_COMPATABILITY
 551                 if (last_char_is(tar_entry->name, '/')) {
 552                         tar_entry->mode |= S_IFDIR;
 553                 } else
 554 # endif
 555                         tar_entry->mode |= S_IFREG;
 556                 break;
 557         case '2':
 558                 tar_entry->mode |= S_IFLNK;
 559                 break;
 560         case '3':
 561                 tar_entry->mode |= S_IFCHR;
 562                 break;
 563         case '4':
 564                 tar_entry->mode |= S_IFBLK;
 565                 break;
 566         case '5':
 567                 tar_entry->mode |= S_IFDIR;
 568                 break;
 569         case '6':
 570                 tar_entry->mode |= S_IFIFO;
 571                 break;
 572 # ifdef CONFIG_FEATURE_TAR_GNU_EXTENSIONS
 573         case 'L': {
 574                         longname = xmalloc(tar_entry->size + 1);
 575                         if(fread(longname, tar_entry->size, 1, tar_stream) != 1)
 576                                 return NULL;
 577                         longname[tar_entry->size] = '\0';
 578                         archive_offset += tar_entry->size;
 579
 580                         return(get_header_tar(tar_stream));
 581                 }
 582         case 'K': {
 583                         linkname = xmalloc(tar_entry->size + 1);
 584                         if(fread(linkname, tar_entry->size, 1, tar_stream) != 1)
 585                                 return NULL;
 586                         linkname[tar_entry->size] = '\0';
 587                         archive_offset += tar_entry->size;
 588
 589                         tar_entry->name = linkname;
 590                         return(get_header_tar(tar_stream));
 591                 }
 592         case 'D':
 593         case 'M':
 594         case 'N':
 595         case 'S':
 596         case 'V':
 597                 perror_msg("Ignoring GNU extension type %c", tar.formated.typeflag);
 598 # endif
 599         default:
 600                 perror_msg("Unknown typeflag: 0x%x", tar.formated.typeflag);
 601                 break;
 602
 603         }
 604
 605         return(tar_entry);
 606 }
 607
 608 static void
 609 free_header_tar(file_header_t *tar_entry)
 610 {
 611         if (tar_entry == NULL)
 612                 return;
 613
 614         free(tar_entry->name);
 615         if (tar_entry->link_name);
 616                 free(tar_entry->link_name);
 617
 618         free(tar_entry);
 619 }
 620
 621 char *
 622 deb_extract(const char *package_filename, FILE *out_stream,
 623         const int extract_function, const char *prefix,
 624         const char *filename, int *err)
 625 {
 626         FILE *deb_stream = NULL;
 627         file_header_t *ar_header = NULL;
 628         const char **file_list = NULL;
 629         char *output_buffer = NULL;
 630         char *ared_file = NULL;
 631         char ar_magic[8];
 632         int gz_err;
 633
 634         *err = 0;
 635
 636         if (filename != NULL) {
 637                 file_list = xmalloc(sizeof(char *) * 2);
 638                 file_list[0] = filename;
 639                 file_list[1] = NULL;
 640         }
 641
 642         if (extract_function & extract_control_tar_gz) {
 643                 ared_file = "control.tar.gz";
 644         }
 645         else if (extract_function & extract_data_tar_gz) {
 646                 ared_file = "data.tar.gz";
 647         } else {
 648                 opkg_msg(ERROR, "Internal error: extract_function=%x\n",
 649                                 extract_function);
 650                 *err = -1;
 651                 goto cleanup;
 652         }
 653
 654         /* open the debian package to be worked on */
 655         deb_stream = wfopen(package_filename, "r");
 656         if (deb_stream == NULL) {
 657                 *err = -1;
 658                 goto cleanup;
 659         }
 660         /* set the buffer size */
 661         setvbuf(deb_stream, NULL, _IOFBF, 0x8000);
 662
 663         /* check ar magic */
 664         fread(ar_magic, 1, 8, deb_stream);
 665
 666         if (strncmp(ar_magic,"!<arch>",7) == 0) {
 667                 archive_offset = 8;
 668
 669                 while ((ar_header = get_header_ar(deb_stream)) != NULL) {
 670                         if (strcmp(ared_file, ar_header->name) == 0) {
 671                                 int gunzip_pid = 0;
 672                                 FILE *uncompressed_stream;
 673                                 /* open a stream of decompressed data */
 674                                 uncompressed_stream = gz_open(deb_stream, &gunzip_pid);
 675                                 if (uncompressed_stream == NULL) {
 676                                         *err = -1;
 677                                         goto cleanup;
 678                                 }
 679
 680                                 archive_offset = 0;
 681                                 output_buffer = unarchive(uncompressed_stream,
 682                                                 out_stream, get_header_tar,
 683                                                 free_header_tar,
 684                                                 extract_function, prefix,
 685                                                 file_list, err);
 686                                 fclose(uncompressed_stream);
 687                                 gz_err = gz_close(gunzip_pid);
 688                                 if (gz_err)
 689                                         *err = -1;
 690                                 free_header_ar(ar_header);
 691                                 break;
 692                         }
 693                         if (fseek(deb_stream, ar_header->size, SEEK_CUR) == -1) {
 694                                 opkg_perror(ERROR, "Couldn't fseek into %s", package_filename);
 695                                 *err = -1;
 696                                 free_header_ar(ar_header);
 697                                 goto cleanup;
 698                         }
 699                         free_header_ar(ar_header);
 700                 }
 701                 goto cleanup;
 702         } else if (strncmp(ar_magic, "\037\213", 2) == 0) {
 703                 /* it's a gz file, let's assume it's an opkg */
 704                 int unzipped_opkg_pid;
 705                 FILE *unzipped_opkg_stream;
 706                 file_header_t *tar_header;
 707                 archive_offset = 0;
 708                 if (fseek(deb_stream, 0, SEEK_SET) == -1) {
 709                         opkg_perror(ERROR, "Couldn't fseek into %s", package_filename);
 710                         *err = -1;
 711                         goto cleanup;
 712                 }
 713                 unzipped_opkg_stream = gz_open(deb_stream, &unzipped_opkg_pid);
 714                 if (unzipped_opkg_stream == NULL) {
 715                         *err = -1;
 716                         goto cleanup;
 717                 }
 718
 719                 /* walk through outer tar file to find ared_file */
 720                 while ((tar_header = get_header_tar(unzipped_opkg_stream)) != NULL) {
 721                         int name_offset = 0;
 722                         if (strncmp(tar_header->name, "./", 2) == 0)
 723                                 name_offset = 2;
 724                         if (strcmp(ared_file, tar_header->name+name_offset) == 0) {
 725                                 int gunzip_pid = 0;
 726                                 FILE *uncompressed_stream;
 727                                 /* open a stream of decompressed data */
 728                                 uncompressed_stream = gz_open(unzipped_opkg_stream, &gunzip_pid);
 729                                 if (uncompressed_stream == NULL) {
 730                                         *err = -1;
 731                                         goto cleanup;
 732                                 }
 733                                 archive_offset = 0;
 734
 735                                 output_buffer = unarchive(uncompressed_stream,
 736                                                           out_stream,
 737                                                           get_header_tar,
 738                                                           free_header_tar,
 739                                                           extract_function,
 740                                                           prefix,
 741                                                           file_list,
 742                                                           err);
 743
 744                                 free_header_tar(tar_header);
 745                                 fclose(uncompressed_stream);
 746                                 gz_err = gz_close(gunzip_pid);
 747                                 if (gz_err)
 748                                         *err = -1;
 749                                 free_header_tar(tar_header);
 750                                 break;
 751                         }
 752                         seek_sub_file(unzipped_opkg_stream, tar_header->size);
 753                         free_header_tar(tar_header);
 754                 }
 755                 fclose(unzipped_opkg_stream);
 756                 gz_err = gz_close(unzipped_opkg_pid);
 757                 if (gz_err)
 758                         *err = -1;
 759
 760                 goto cleanup;
 761         } else {
 762                 *err = -1;
 763                 error_msg("%s: invalid magic", package_filename);
 764         }
 765
 766 cleanup:
 767         if (deb_stream)
 768                 fclose(deb_stream);
 769         if (file_list)
 770                 free(file_list);
 771
 772         return output_buffer;
 773 }