- add spoolpipe utility from Carl Sopchak
see [ 558422 ] Spool parallel output http://sourceforge.net/tracker/index.php?func=detail&aid=558422&group_id=12580&atid=312580
This commit is contained in:
Bryce Denney
parent
d9ac09ea26
commit
91402bb98a
181
bochs/misc/spoolpipe.c
Normal file
181
bochs/misc/spoolpipe.c
Normal file
@ -0,0 +1,181 @@
|
||||
/* $Id: spoolpipe.c,v 1.1 2002-09-23 19:25:06 bdenney Exp $
|
||||
*
|
||||
* spoolpipe.c
|
||||
* by Carl Sopchak
|
||||
*
|
||||
* Read a pipe that stays open, send the data to a temp file. Print
|
||||
* the temp file if no new input data is seen within a period of time. This
|
||||
* is useful, e.g., to create separate spool files without exiting a program
|
||||
* that doesn't close it's printer output file.
|
||||
*
|
||||
* ---------------------------------------------------------------------------
|
||||
*
|
||||
* Copyright (c) 2002 Cegis Enterprises, Inc. Syracuse, NY 13215
|
||||
*
|
||||
* ---------------------------------------------------------------------------
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU General Public License
|
||||
* as published by the Free Software Foundation; either version 2
|
||||
* of the License, or (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, write to the Free Software
|
||||
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
|
||||
*
|
||||
* --------------------------------------------------------------------------
|
||||
* Modification log:
|
||||
*
|
||||
* 2002/05/20 - Initial programming
|
||||
*
|
||||
* --------------------------------------------------------------------------
|
||||
*/
|
||||
|
||||
#define BUF_SIZE 4*1024
|
||||
#define DEBUG 0
|
||||
|
||||
#include <errno.h>
|
||||
#include <fcntl.h>
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
#include <sys/stat.h>
|
||||
#include <sys/types.h>
|
||||
#include <sys/wait.h>
|
||||
#include <unistd.h>
|
||||
|
||||
int infd, outfd;
|
||||
|
||||
unsigned int delay = 60; // default delay, in seconds
|
||||
unsigned int count_down = 0;
|
||||
|
||||
char buffer[BUF_SIZE];
|
||||
ssize_t readcnt, writecnt;
|
||||
|
||||
int didwait = 0; // have we already waited?
|
||||
int havedata = 0; // have we read anything in?
|
||||
|
||||
int q;
|
||||
|
||||
pid_t pid, wait_pid;
|
||||
int wait_status;
|
||||
|
||||
int main (int argc, char *argv[]) {
|
||||
|
||||
#if DEBUG
|
||||
printf("Command line arguments (%d):\n", argc);
|
||||
for (q = 0; q < argc ; q++) {
|
||||
printf(" %d = %s\n", q, argv[q]);
|
||||
}
|
||||
#endif
|
||||
|
||||
if ((argc < 3) || (argc > 4)) {
|
||||
printf("usage: %s <inpipe> <tempfilename> [<maxdelay>]\n", argv[0]);
|
||||
exit(1);
|
||||
}
|
||||
|
||||
if (argc == 4) { // get delay
|
||||
delay = strtol(argv[3], (char **) NULL, 10);
|
||||
if (delay < 0) {
|
||||
printf("Unable to convert maximum delay value: %s\n", argv[3]);
|
||||
exit(2);
|
||||
}
|
||||
} // get delay
|
||||
|
||||
#if DEBUG
|
||||
printf("Delay is set to %d seconds.\n", delay);
|
||||
#endif
|
||||
|
||||
infd = open(argv[1], O_RDONLY | O_NONBLOCK);
|
||||
if (infd == -1) {
|
||||
printf("Error opening input pipe %s: %d - %s\n", argv[1], errno, strerror(errno));
|
||||
exit(3);
|
||||
}
|
||||
|
||||
outfd = open(argv[2], O_RDWR | O_CREAT | O_TRUNC, S_IRWXU);
|
||||
if (outfd == -1) {
|
||||
printf("Error opening output file %s: %d - %s\n", argv[2], errno, strerror(errno));
|
||||
exit(4);
|
||||
}
|
||||
|
||||
count_down = delay;
|
||||
while (1) { // must kill with a signal....
|
||||
readcnt = read(infd, buffer, (size_t) BUF_SIZE);
|
||||
#if DEBUG
|
||||
printf("read() returned with readcnt = %d, errno = %d\n", readcnt, errno);
|
||||
#endif
|
||||
if ((readcnt == -1) && (errno != EAGAIN)) { // EAGAIN - no data waiting, can ignore
|
||||
printf("Error reading input pipe: %d - %s\n", errno, strerror(errno));
|
||||
exit(5);
|
||||
} else { // no errors reading input pipe
|
||||
if (readcnt > 0) {
|
||||
writecnt = write(outfd, buffer, readcnt);
|
||||
if (writecnt == -1) {
|
||||
printf("Error writing output file: %d - %s\n", errno, strerror(errno));
|
||||
exit(6);
|
||||
}
|
||||
didwait = 0; // reset wait flag (wait again)
|
||||
count_down = delay;
|
||||
havedata = 1; // set flag that we got some data
|
||||
} else { //readcnt must = 0
|
||||
if (!didwait) { //have not waited yet...
|
||||
if (count_down > 0) { // sleep a bit
|
||||
sleep(1);
|
||||
count_down -= 1;
|
||||
} else {
|
||||
didwait = 1; // set wait flag (don't wait again)
|
||||
}
|
||||
} else { // already waited
|
||||
if (havedata) { // have data to print, close & reopen output file
|
||||
if (close(outfd) != 0) {
|
||||
printf("Error closing output file: %d - %s\n", errno, strerror(errno));
|
||||
exit(7);
|
||||
}
|
||||
|
||||
#if DEBUG
|
||||
printf("Spooling temp file...\n");
|
||||
#endif
|
||||
|
||||
pid = fork();
|
||||
if (pid == -1) {
|
||||
printf("Error forking new process: %d - %s\n", errno, strerror(errno));
|
||||
exit(9);
|
||||
}
|
||||
if (pid == 0) { // we're now running in the child process...
|
||||
execlp("lpr", "lpr", argv[2], NULL);
|
||||
exit(99); // should never get here...
|
||||
} // we're now running in the child process...
|
||||
if (pid > 0) { // we're running in the parent process...
|
||||
wait_pid = waitpid(pid, (int *)&wait_status, 0);
|
||||
if (wait_pid != pid) { // some sort of error
|
||||
printf("Wait for 'lpr' command returned abnormally!\n");
|
||||
if (WIFEXITED(wait_status)) {
|
||||
printf(" 'lpr' exited normally.\n");
|
||||
} else {
|
||||
printf(" 'lpr' exited abnormally, return code = %d.\n", WEXITSTATUS(wait_status));
|
||||
}
|
||||
if (WIFSIGNALED(wait_status)) {
|
||||
printf(" 'lpr' received uncaught signal %d\n", WTERMSIG(wait_status));
|
||||
}
|
||||
} // some sort of error
|
||||
} // we're running in the parent process...
|
||||
outfd = open(argv[2], O_RDWR | O_TRUNC);
|
||||
if (outfd == -1) {
|
||||
printf("Error re-opening output file: %d - %s\n", errno, strerror(errno));
|
||||
exit(8);
|
||||
}
|
||||
} // have data to print, close & repoen output file.
|
||||
havedata = 0; // no more data waiting
|
||||
count_down = delay;
|
||||
didwait = 0; // reset wait flag (wait again)
|
||||
} // already waited
|
||||
} // readcnt must = 0
|
||||
} // no errors reading input pipe
|
||||
} // must kill with a signal...
|
||||
|
||||
exit(0);
|
||||
} // eof(spoolpipe.c)
|
||||
Loading…
Reference in New Issue
Block a user