lpd: now with "svn add"...

1 files changed, 79 insertions, 0 deletions

diff --git a/printutils/lpd.c b/printutils/lpd.c
new file mode 100644
index 000000000..ed3d9d100
--- /dev/null
+++ b/printutils/lpd.c
@@ -0,0 +1,79 @@
+/* vi: set sw=4 ts=4: */
+/*
+ * micro lpd - a small non-queueing lpd
+ *
+ * Copyright (C) 2008 by Vladimir Dronnikov <dronnikov@gmail.com>
+ *
+ * Licensed under GPLv2, see file LICENSE in this tarball for details.
+ */
+#include "libbb.h"
+
+int lpd_main(int argc, char *argv[]) MAIN_EXTERNALLY_VISIBLE;
+int lpd_main(int argc, char *argv[])
+{
+        char *s;
+
+        // goto spool directory
+        // spool directory contains either links to real printer devices or just simple files
+        // these links or files are called "queues"
+        if (!argv[1])
+                bb_show_usage();
+
+        xchdir(argv[1]);
+
+        xdup2(1, 2);
+
+        // read command
+        s = xmalloc_reads(STDIN_FILENO, NULL);
+
+        // N.B. we keep things simple
+        // only "receive job" command is meaningful here...
+        if (2 == *s) {
+                char *queue;
+
+                // parse command: "\x2QUEUE_NAME\n"
+                queue = s + 1;
+                *strchrnul(s, '\n') = '\0';
+
+                while (1) {
+                        // signal OK
+                        write(STDOUT_FILENO, "", 1);
+                        // get subcommand
+                        s = xmalloc_reads(STDIN_FILENO, NULL);
+                        if (!s)
+                                return EXIT_SUCCESS; // EOF (probably)
+                        // valid s must be of form: SUBCMD | LEN | SP | FNAME
+                        // N.B. we bail out on any error
+                        // control or data file follows
+                        if (2 == s[0] || 3 == s[0]) {
+                                int fd;
+                                size_t len;
+                                // 2: control file (ignoring), 3: data file
+                                fd = -1;
+                                if (3 == s[0])
+                                        fd = xopen(queue, O_RDWR | O_APPEND);
+                                // get data length
+                                *strchrnul(s, ' ') = '\0';
+                                len = xatou(s + 1);
+                                // dump exactly len bytes to file, or die
+                                bb_copyfd_exact_size(STDIN_FILENO, fd, len);
+                                close(fd); // NB: can do close(-1). Who cares?
+                                free(s);
+                                // got no ACK? -> bail out
+                                if (safe_read(STDIN_FILENO, s, 1) <= 0 || s[0]) {
+                                        // don't talk to peer - it obviously
+                                        // don't follow the protocol
+                                        return EXIT_FAILURE;
+                                }
+                        } else {
+                                // any other subcommand aborts receiving job
+                                // N.B. abort subcommand itself doesn't contain
+                                // fname so it failed earlier...
+                                break;
+                        }
+                }
+        }
+
+        printf("Command %02x not supported\n", (unsigned char)*s);
+        return EXIT_FAILURE;
+}