fread(buffer, 1, file_entry->size, src_stream);
buffer[file_entry->size] = '\0';
archive_offset += file_entry->size;
- return(buffer);
+ goto cleanup;
}
}
else if (function & extract_all_to_fs) {
error_msg("%s not created: newer or same age file exists", file_entry->name);
}
seek_sub_file(src_stream, file_entry->size);
- return (NULL);
+ goto cleanup;
}
}
if (function & extract_create_leading_dirs) { /* Create leading directories with default umask */
} else {
if ((dst_stream = wfopen(full_name, "w")) == NULL) {
seek_sub_file(src_stream, file_entry->size);
- return NULL;
+ goto cleanup;
}
archive_offset += file_entry->size;
copy_file_chunk(src_stream, dst_stream, file_entry->size);
if ((function & extract_quiet) != extract_quiet) {
perror_msg("Cannot create symlink from %s to '%s'", file_entry->name, file_entry->link_name);
}
- return NULL;
+ goto cleanup;
}
break;
case S_IFSOCK:
if ((function & extract_quiet) != extract_quiet) {
perror_msg("Cannot create node %s", file_entry->name);
}
- return NULL;
+ goto cleanup;
}
break;
default:
fprintf(out_stream, "%s\n", file_entry->name);
}
+cleanup:
free(full_name);
if ( full_link_name )
free(full_link_name);
- return(NULL); /* Maybe we should say if failed */
+ return(buffer); /* Maybe we should say if failed */
}
#endif
char *deb_extract(const char *package_filename, FILE *out_stream,
const int extract_function, const char *prefix, const char *filename)
{
- FILE *deb_stream;
+ FILE *deb_stream = NULL;
FILE *uncompressed_stream = NULL;
file_header_t *ar_header = NULL;
char **file_list = NULL;
if (filename != NULL) {
file_list = xmalloc(sizeof(char *) * 2);
- file_list[0] = xstrdup(filename);
+ file_list[0] = filename;
file_list[1] = NULL;
}
if (extract_function & extract_control_tar_gz) {
- ared_file = xstrdup("control.tar.gz");
+ ared_file = "control.tar.gz";
}
else if (extract_function & extract_data_tar_gz) {
- ared_file = xstrdup("data.tar.gz");
+ ared_file = "data.tar.gz";
} else {
fprintf(stderr, "no file specified to extract -- extract_function=%x\n", extract_function);
- return NULL;
+ goto cleanup;
}
/* open the debian package to be worked on */
deb_stream = wfopen(package_filename, "r");
if (deb_stream == NULL) {
- return(NULL);
+ goto cleanup;
}
/* set the buffer size */
setvbuf(deb_stream, NULL, _IOFBF, 0x8000);
/* open a stream of decompressed data */
uncompressed_stream = gz_open(deb_stream, &gunzip_pid);
if (uncompressed_stream == NULL) {
- return(NULL);
+ goto cleanup;
}
archive_offset = 0;
free (ar_header);
}
gz_close(gunzip_pid);
- fclose(deb_stream);
fclose(uncompressed_stream);
- free(ared_file);
- return(output_buffer);
+ goto cleanup;
} else if (strncmp(ar_magic, "\037\213", 2) == 0) {
/* it's a gz file, let's assume it's an opkg */
int unzipped_opkg_pid;
fseek(deb_stream, 0, SEEK_SET);
unzipped_opkg_stream = gz_open(deb_stream, &unzipped_opkg_pid);
if (unzipped_opkg_stream == NULL) {
- return(NULL);
+ goto cleanup;
}
/*fprintf(stderr, __FUNCTION__ ": processing opkg %s -- ared_file=%s\n", package_filename, ared_file);*/
/* open a stream of decompressed data */
uncompressed_stream = gz_open(unzipped_opkg_stream, &gunzip_pid);
if (uncompressed_stream == NULL) {
- return(NULL);
+ goto cleanup;
}
archive_offset = 0;
/*fprintf(stderr, __FUNCTION__ ":%d: here -- found file\n", __LINE__);*/
}
gz_close(unzipped_opkg_pid);
fclose(unzipped_opkg_stream);
- fclose(deb_stream);
- free(ared_file);
/*fprintf(stderr, __FUNCTION__ ":%d: done\n", __LINE__);*/
- return output_buffer;
+ goto cleanup;
} else {
error_msg_and_die("invalid magic");
}
+cleanup:
+ if (deb_stream)
+ fclose(deb_stream);
+ if (file_list)
+ free(file_list);
+
+ return output_buffer;
}
#endif