From 4674ec0e4b833ab0d0365225ba99228df14abe87 Mon Sep 17 00:00:00 2001 From: Mattias Andrée Date: Fri, 13 Jan 2017 09:05:08 +0100 Subject: Rename to blind MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Mattias Andrée --- src/blind-split.c | 72 +++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 72 insertions(+) create mode 100644 src/blind-split.c (limited to 'src/blind-split.c') diff --git a/src/blind-split.c b/src/blind-split.c new file mode 100644 index 0000000..ff6ce38 --- /dev/null +++ b/src/blind-split.c @@ -0,0 +1,72 @@ +/* See LICENSE file for copyright and license details. */ +#include "stream.h" +#include "util.h" + +#include +#include +#include +#include +#include +#include + +USAGE("(file (end-point | 'end')) ...") + +int +main(int argc, char *argv[]) +{ + struct stream stream; + size_t *ends, i, parts, ptr, end, frame_size, n; + FILE *fp; + int fd; + + ENOFLAGS(argc < 2 || argc % 2); + + stream.file = ""; + stream.fd = STDIN_FILENO; + einit_stream(&stream); + echeck_frame_size(stream.width, stream.height, stream.pixel_size, 0, stream.file); + frame_size = stream.width * stream.height * stream.pixel_size; + if (stream.frames > SSIZE_MAX / frame_size) + eprintf("%s: video is too large\n", stream.file); + + parts = (size_t)argc / 2; + ends = alloca(parts * sizeof(*ends)); + + for (i = 0; i < parts; i++) { + if (!strcmp(argv[i * 2 + 1], "end")) + ends[i] = stream.frames; + else if (tozu(argv[i * 2 + 1], 0, SIZE_MAX, ends + i)) + eprintf("the end point must be an integer in [0, %zu]\n", SIZE_MAX); + if (i && ends[i] <= ends[i - 1]) + eprintf("the end points must be in strictly ascending order\n"); + if (ends[i] > stream.frames) + eprintf("frame %zu is beyond the end of the video\n", ends[i]); + } + + ptr = 0; + for (i = 0; i < parts; i++) { + fd = eopen(argv[i * 2], O_WRONLY | O_CREAT | O_TRUNC, 0666); + fp = fdopen(fd, "wb"); + if (!fp) + eprintf("fdopen %s:", argv[i * 2]); + + stream.frames = ends[i] - (i ? ends[i - 1] : 0); + fprint_stream_head(fp, &stream); + efflush(fp, argv[i * 2]); + + for (end = ends[i] * frame_size; ptr < end; ptr += n) { + if (stream.ptr == sizeof(stream.buf)) + n = stream.ptr < end - ptr ? stream.ptr : end - ptr; + else if (!(n = eread_stream(&stream, end - ptr))) + eprintf("%s: file is shorter than expected\n", stream.file); + ewriteall(STDOUT_FILENO, stream.buf, n, ""); + memmove(stream.buf, stream.buf + n, stream.ptr -= n); + } + + if (fclose(fp)) + eprintf("%s:", argv[i * 2]); + close(fd); + } + + return 0; +} -- cgit v1.2.3-70-g09d2