gen_init_cpio: fix short read file handling
[linux-block.git] / usr / gen_init_cpio.c
index 0e2c8a5838b142ae14c7ed25fde5613b4a06f89c..9a0f8c37273a8223e465ef1f026bb3a61ad8f04e 100644 (file)
@@ -20,6 +20,7 @@
 
 #define xstr(s) #s
 #define str(s) xstr(s)
+#define MIN(a, b) ((a) < (b) ? (a) : (b))
 
 static unsigned int offset;
 static unsigned int ino = 721;
@@ -297,9 +298,8 @@ static int cpio_mkfile(const char *name, const char *location,
                        unsigned int nlinks)
 {
        char s[256];
-       char *filebuf = NULL;
        struct stat buf;
-       long size;
+       unsigned long size;
        int file = -1;
        int retval;
        int rc = -1;
@@ -326,22 +326,17 @@ static int cpio_mkfile(const char *name, const char *location,
                buf.st_mtime = 0xffffffff;
        }
 
-       filebuf = malloc(buf.st_size);
-       if (!filebuf) {
-               fprintf (stderr, "out of memory\n");
-               goto error;
-       }
-
-       retval = read (file, filebuf, buf.st_size);
-       if (retval < 0) {
-               fprintf (stderr, "Can not read %s file\n", location);
+       if (buf.st_size > 0xffffffff) {
+               fprintf(stderr, "%s: Size exceeds maximum cpio file size\n",
+                       location);
                goto error;
        }
 
        size = 0;
        for (i = 1; i <= nlinks; i++) {
                /* data goes on last link */
-               if (i == nlinks) size = buf.st_size;
+               if (i == nlinks)
+                       size = buf.st_size;
 
                if (name[0] == '/')
                        name++;
@@ -366,23 +361,34 @@ static int cpio_mkfile(const char *name, const char *location,
                push_string(name);
                push_pad();
 
-               if (size) {
-                       if (fwrite(filebuf, size, 1, stdout) != 1) {
+               while (size) {
+                       unsigned char filebuf[65536];
+                       ssize_t this_read;
+                       size_t this_size = MIN(size, sizeof(filebuf));
+
+                       this_read = read(file, filebuf, this_size);
+                       if (this_read <= 0 || this_read > this_size) {
+                               fprintf(stderr, "Can not read %s file\n", location);
+                               goto error;
+                       }
+
+                       if (fwrite(filebuf, this_read, 1, stdout) != 1) {
                                fprintf(stderr, "writing filebuf failed\n");
                                goto error;
                        }
-                       offset += size;
-                       push_pad();
+                       offset += this_read;
+                       size -= this_read;
                }
+               push_pad();
 
                name += namesize;
        }
        ino++;
        rc = 0;
-       
+
 error:
-       if (filebuf) free(filebuf);
-       if (file >= 0) close(file);
+       if (file >= 0)
+               close(file);
        return rc;
 }