From: Florian Fainelli Date: Mon, 7 Jul 2008 14:26:57 +0000 (+0000) Subject: Update p910nd to 0.92 (#3729) X-Git-Url: http://git.lede-project.org./?a=commitdiff_plain;h=6002cbccf17b44e84d2a8439cbfc4e8fd28fe281;p=openwrt%2Fsvn-archive%2Fpackages.git Update p910nd to 0.92 (#3729) SVN-Revision: 11741 --- diff --git a/net/p910nd/Makefile b/net/p910nd/Makefile index 682fd8826..a541d31e7 100644 --- a/net/p910nd/Makefile +++ b/net/p910nd/Makefile @@ -1,5 +1,5 @@ # -# Copyright (C) 2007 OpenWrt.org +# Copyright (C) 2008 OpenWrt.org # # This is free software, licensed under the GNU General Public License v2. # See /LICENSE for more information. @@ -9,12 +9,12 @@ include $(TOPDIR)/rules.mk PKG_NAME:=p910nd -PKG_VERSION:=0.7 -PKG_RELEASE:=4 +PKG_VERSION:=0.92 +PKG_RELEASE:=1 PKG_SOURCE:=$(PKG_NAME)-$(PKG_VERSION).tar.bz2 -PKG_SOURCE_URL:=http://www.etherboot.org/p910nd -PKG_MD5SUM:=7bf752532d26c9106f8039db95df3a6b +PKG_SOURCE_URL:=http://etherboot.sourceforge.net/p910nd +PKG_MD5SUM:=d0d0d0500d151c1a49dcb69dd94b8357 include $(INCLUDE_DIR)/package.mk @@ -22,7 +22,7 @@ define Package/p910nd SECTION:=net CATEGORY:=Network TITLE:=A small non-spooling printer server - URL:=http://www.etherboot.org/p910nd/ + URL:=http://etherboot.sourceforge.net/p910nd/ SUBMENU:=printing endef diff --git a/net/p910nd/patches/100-Makefile.patch b/net/p910nd/patches/100-Makefile.patch deleted file mode 100644 index e37bb51f1..000000000 --- a/net/p910nd/patches/100-Makefile.patch +++ /dev/null @@ -1,17 +0,0 @@ -Index: p910nd-0.7/Makefile -=================================================================== ---- p910nd-0.7.orig/Makefile 2007-09-02 15:17:23.000000000 +0200 -+++ p910nd-0.7/Makefile 2007-09-02 15:17:23.000000000 +0200 -@@ -2,9 +2,9 @@ - # below if you don't want to use libwrap (hosts.{allow,deny} access control) - - # If you don't have it in /var/log/subsys, uncomment and define --#CFLAGS+=-DLOCKFILE_DIR=\"/var/log\" -+CFLAGS+=-DLOCKFILE_DIR=\"/tmp\" - LIBWRAP=-lwrap - - p910nd: p910nd.c --# $(CC) -Wall $(CFLAGS) -o $@ p910nd.c -- $(CC) -Wall $(CFLAGS) -DUSE_LIBWRAP -o $@ p910nd.c $(LIBWRAP) -+ $(CC) -Wall $(CFLAGS) -o $@ p910nd.c -+# $(CC) -Wall $(CFLAGS) -DUSE_LIBWRAP -o $@ p910nd.c $(LIBWRAP) diff --git a/net/p910nd/patches/200-p910nd.patch b/net/p910nd/patches/200-p910nd.patch deleted file mode 100644 index ec66e47c3..000000000 --- a/net/p910nd/patches/200-p910nd.patch +++ /dev/null @@ -1,311 +0,0 @@ -Index: p910nd-0.7/p910nd.c -=================================================================== ---- p910nd-0.7.orig/p910nd.c 2007-09-02 15:17:23.000000000 +0200 -+++ p910nd-0.7/p910nd.c 2007-09-02 15:17:23.000000000 +0200 -@@ -73,8 +73,7 @@ - #else - #define LOCKFILE "/var/lock/subsys/p910%cd" - #endif --#define PRINTERFILE "/dev/lp%c" --#define LOGOPTS LOG_ERR -+#define PRINTERFILE "/dev/printers/%c" - - static char *progname; - static char version[] = "p910nd Version 0.7"; -@@ -93,9 +92,9 @@ - fprintf(stdout, "%s \n", version); - } - --FILE *open_printer(int lpnumber) -+int open_printer(int lpnumber) - { -- FILE *f; -+ int lp; - char lpname[sizeof(PRINTERFILE)]; - - #ifdef TESTING -@@ -105,12 +104,16 @@ - #endif - if (device == 0) - device = lpname; -- if ((f = fopen(device, bidir ? "w+" : "w")) == NULL) -+ if ((lp = open(device, bidir ? O_RDWR : O_WRONLY)) == -1) - { -- syslog(LOGOPTS, "%s: %m\n", device); -- exit(1); -+ syslog(LOG_ERR, "%s: %m\n", device); -+ -+ /* fallback to /dev/null if device is not available -+ * otherwise windows spooler will screw up -+ */ -+ lp = open("/dev/null", bidir ? O_RDWR : O_WRONLY); - } -- return (f); -+ return (lp); - } - - int get_lock(int lpnumber) -@@ -121,7 +124,7 @@ - (void)snprintf(lockname, sizeof(lockname), LOCKFILE, lpnumber); - if ((lockfd = open(lockname, O_CREAT|O_RDWR)) < 0) - { -- syslog(LOGOPTS, "%s: %m\n", lockname); -+ syslog(LOG_ERR, "%s: %m\n", lockname); - return (0); - } - memset(&lplock, 0, sizeof(lplock)); -@@ -129,7 +132,7 @@ - lplock.l_pid = getpid(); - if (fcntl(lockfd, F_SETLKW, &lplock) < 0) - { -- syslog(LOGOPTS, "%s: %m\n", lockname); -+ syslog(LOG_ERR, "%s: %m\n", lockname); - return (0); - } - return (1); -@@ -141,24 +144,36 @@ - (void)close(lockfd); - } - -+ssize_t safe_write(int fd, char *buf, size_t count) -+{ -+ size_t offset = 0; -+ -+ while (offset < count) { -+ ssize_t n = write(fd, buf + offset, count - offset); -+ -+ if (n < 0 && errno != EINTR) -+ return n; -+ -+ if (n > 0) -+ offset += n; -+ } -+ -+ return offset; -+} -+ - /* Copy network socket to FILE f until EOS */ --int copy_stream(int fd, FILE *f) -+int copy_stream(int fd, int lp) - { -- int nread; -+ int nread, rcvd = 0, sent = 0; - char buffer[8192]; - - if (bidir) { -- FILE *nf; -- -- if ((nf = fdopen(fd, "w")) == NULL) { -- syslog(LOGOPTS, "fdopen: %m\n"); -- } - for (;;) { - fd_set readfds; - int result; -- int maxfd = fileno(f) > fd ? fileno(f) : fd; -+ int maxfd = lp > fd ? lp : fd; - FD_ZERO(&readfds); -- FD_SET(fileno(f), &readfds); -+ FD_SET(lp, &readfds); - FD_SET(fd, &readfds); - result = select(maxfd + 1, &readfds, 0, 0, 0); - if (result < 0) -@@ -169,43 +184,54 @@ - nread = read(fd, buffer, sizeof(buffer)); - if (nread <= 0) - break; -- (void)fwrite(buffer, sizeof(char), nread, f); -+ if (safe_write(lp, buffer, nread) < 0) { -+ syslog(LOG_ERR, "write: %m\n"); -+ break; -+ } -+ rcvd += nread; - } -- if (FD_ISSET(fileno(f), &readfds)) { -- nread = read(fileno(f), buffer, sizeof(buffer)); -- if (nread > 0 && nf != NULL) { -- (void)fwrite(buffer, sizeof(char), nread, nf); -- (void)fflush(nf); -+ if (FD_ISSET(lp, &readfds)) { -+ nread = read(lp, buffer, sizeof(buffer)); -+ if (nread > 0) { -+ safe_write(fd, buffer, nread); -+ sent += nread; - } - } - } -- (void)fflush(f); -- (void)fclose(nf); -+ syslog(LOG_NOTICE, "Finished job: %d bytes received, %d bytes sent\n", -+ rcvd, sent); - return (0); - } else { -- while ((nread = read(fd, buffer, sizeof(buffer))) > 0) -- (void)fwrite(buffer, sizeof(char), nread, f); -- (void)fflush(f); -+ while ((nread = read(fd, buffer, sizeof(buffer))) > 0) { -+ if (safe_write(lp, buffer, nread) < 0) { -+ syslog(LOG_ERR, "write: %m\n"); -+ break; -+ } -+ rcvd += nread; -+ } -+ syslog(LOG_NOTICE, "Finished job: %d bytes received\n", rcvd); - return (nread); - } - } - - void one_job(int lpnumber) - { -- FILE *f; -+ int lp; - struct sockaddr_in client; - socklen_t clientlen = sizeof(client); - - if (getpeername(0, (struct sockaddr*) &client, &clientlen) >= 0) -- syslog(LOGOPTS, "Connection from %s port %hu\n", -+ syslog(LOG_NOTICE, "Connection from %s port %hu\n", - inet_ntoa(client.sin_addr), - ntohs(client.sin_port)); - if (get_lock(lpnumber) == 0) - return; -- f = open_printer(lpnumber); -- if (copy_stream(0, f) < 0) -- syslog(LOGOPTS, "copy_stream: %m\n"); -- fclose(f); -+ if ((lp = open_printer(lpnumber)) != -1) -+ { -+ if (copy_stream(0, lp) < 0) -+ syslog(LOG_ERR, "copy_stream: %m\n"); -+ close(lp); -+ } - free_lock(); - } - -@@ -215,7 +241,7 @@ - #ifdef USE_GETPROTOBYNAME - struct protoent *proto; - #endif -- int netfd, fd, one = 1; -+ int netfd, fd, lp, one = 1; - socklen_t clientlen; - struct sockaddr_in netaddr, client; - char pidfilename[sizeof(PIDFILE)]; -@@ -225,7 +251,7 @@ - switch (fork()) - { - case -1: -- syslog(LOGOPTS, "fork: %m\n"); -+ syslog(LOG_ERR, "fork: %m\n"); - exit (1); - case 0: /* child */ - break; -@@ -236,14 +262,14 @@ - resourcelimit.rlim_max = 0; - if (getrlimit(RLIMIT_NOFILE, &resourcelimit) < 0) - { -- syslog(LOGOPTS, "getrlimit: %m\n"); -+ syslog(LOG_ERR, "getrlimit: %m\n"); - exit(1); - } - for (fd = 0; fd < resourcelimit.rlim_max; ++fd) - (void)close(fd); - if (setsid() < 0) - { -- syslog(LOGOPTS, "setsid: %m\n"); -+ syslog(LOG_ERR, "setsid: %m\n"); - exit(1); - } - (void)chdir("/"); -@@ -254,7 +280,7 @@ - (void)snprintf(pidfilename, sizeof(pidfilename), PIDFILE, lpnumber); - if ((f = fopen(pidfilename, "w")) == NULL) - { -- syslog(LOGOPTS, "%s: %m\n", pidfilename); -+ syslog(LOG_ERR, "%s: %m\n", pidfilename); - exit(1); - } - (void)fprintf(f, "%d\n", getpid()); -@@ -262,11 +288,10 @@ - if (get_lock(lpnumber) == 0) - exit(1); - #endif -- f = open_printer(lpnumber); - #ifdef USE_GETPROTOBYNAME - if ((proto = getprotobyname("tcp")) == NULL) - { -- syslog(LOGOPTS, "Cannot find protocol for TCP!\n"); -+ syslog(LOG_ERR, "Cannot find protocol for TCP!\n"); - exit(1); - } - if ((netfd = socket(AF_INET, SOCK_STREAM, proto->p_proto)) < 0) -@@ -274,12 +299,12 @@ - if ((netfd = socket(AF_INET, SOCK_STREAM, IPPROTO_IP)) < 0) - #endif - { -- syslog(LOGOPTS, "socket: %m\n"); -+ syslog(LOG_ERR, "socket: %m\n"); - exit(1); - } - if (setsockopt(netfd, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one)) < 0) - { -- syslog(LOGOPTS, "setsocketopt: %m\n"); -+ syslog(LOG_ERR, "setsocketopt: %m\n"); - exit(1); - } - netaddr.sin_port = htons(BASEPORT + lpnumber - '0'); -@@ -287,12 +312,12 @@ - memset(netaddr.sin_zero, 0, sizeof(netaddr.sin_zero)); - if (bind(netfd, (struct sockaddr*) &netaddr, sizeof(netaddr)) < 0) - { -- syslog(LOGOPTS, "bind: %m\n"); -+ syslog(LOG_ERR, "bind: %m\n"); - exit(1); - } - if (listen(netfd, 5) < 0) - { -- syslog(LOGOPTS, "listen: %m\n"); -+ syslog(LOG_ERR, "listen: %m\n"); - exit(1); - } - clientlen = sizeof(client); -@@ -302,22 +327,26 @@ - #ifdef USE_LIBWRAP - if (hosts_ctl("p910nd", STRING_UNKNOWN, - inet_ntoa(client.sin_addr), STRING_UNKNOWN) == 0) { -- syslog(LOGOPTS, "Connection from %s port %hd rejected\n", -+ syslog(LOG_ERR, "Connection from %s port %hu rejected\n", - inet_ntoa(client.sin_addr), - ntohs(client.sin_port)); - close(fd); - continue; - } - #endif -- syslog(LOGOPTS, "Connection from %s port %hd accepted\n", -+ syslog(LOG_NOTICE, "Connection from %s port %hu accepted\n", - inet_ntoa(client.sin_addr), - ntohs(client.sin_port)); - /*write(fd, "Printing", 8);*/ -- if (copy_stream(fd, f) < 0) -- syslog(LOGOPTS, "copy_stream: %m\n"); -+ if ((lp = open_printer(lpnumber)) != -1) -+ { -+ if (copy_stream(fd, lp) < 0) -+ syslog(LOG_ERR, "copy_stream: %m\n"); -+ close(lp); -+ } - (void)close(fd); - } -- syslog(LOGOPTS, "accept: %m\n"); -+ syslog(LOG_ERR, "accept: %m\n"); - free_lock(); - exit(1); - } -@@ -338,7 +367,7 @@ - if (getsockname(0, (struct sockaddr*) &bind_addr, &ba_len) == 0) - return (0); /* under inetd */ - if (errno != ENOTSOCK) /* strange... */ -- syslog(LOGOPTS, "getsockname: %m\n"); -+ syslog(LOG_ERR, "getsockname: %m\n"); - return (1); - } - diff --git a/net/p910nd/patches/300-performance.patch b/net/p910nd/patches/300-performance.patch deleted file mode 100644 index 10cab3811..000000000 --- a/net/p910nd/patches/300-performance.patch +++ /dev/null @@ -1,232 +0,0 @@ ---- p910nd-0.7/p910nd.c.orig 2007-09-29 17:03:03.000000000 -0700 -+++ p910nd-0.7.new/p910nd.c 2007-09-29 17:06:53.000000000 -0700 -@@ -144,73 +144,185 @@ - (void)close(lockfd); - } - --ssize_t safe_write(int fd, char *buf, size_t count) -+typedef struct { -+ int detectEof; -+ int infd; -+ int outfd; -+ int startidx; -+ int endidx; -+ int bytes; -+ int totalin; -+ int totalout; -+ int eof; -+ int err; -+ char buffer[8192]; -+} Buffer_t; -+ -+void initBuffer( Buffer_t *b, int infd, int outfd, int detectEof ) -+{ -+ b->detectEof = detectEof; -+ b->infd = infd; -+ b->outfd = outfd; -+ b->startidx = 0; -+ b->endidx = 0; -+ b->bytes = 0; -+ b->totalin = 0; -+ b->totalout = 0; -+ b->eof = 0; -+ b->err = 0; -+} -+ -+void prepBuffer( Buffer_t *b, fd_set *readfds, fd_set *writefds ) - { -- size_t offset = 0; -- -- while (offset < count) { -- ssize_t n = write(fd, buf + offset, count - offset); -- -- if (n < 0 && errno != EINTR) -- return n; -- -- if (n > 0) -- offset += n; -+ if (!b->err && b->bytes != 0) { -+ FD_SET(b->outfd, writefds); - } -+ if (!b->eof && b->bytes < sizeof(b->buffer)) { -+ FD_SET(b->infd, readfds); -+ } -+} - -- return offset; -+ssize_t readBuffer( Buffer_t *b ) -+{ -+ int avail; -+ ssize_t result = 1; -+ if (b->bytes == 0 || b->err) { -+ b->startidx = b->endidx = 0; -+ avail = sizeof(b->buffer); -+ } else if (b->bytes == sizeof(b->buffer)) { -+ avail = 0; -+ } else if (b->endidx > b->startidx) { -+ avail = sizeof(b->buffer) - b->endidx; -+ } else { -+ avail = b->startidx - b->endidx; -+ } -+ if (avail) { -+ result = read(b->infd, b->buffer+b->endidx, avail); -+ if (result > 0) { -+ b->endidx += result; -+ b->totalin += result; -+ b->bytes += result; -+ if (b->endidx == sizeof(b->buffer)) -+ b->endidx = 0; -+ } else if (result < 0 || b->detectEof) { -+ b->eof = 1; -+ } -+ } -+ return result; -+} -+ -+ssize_t writeBuffer( Buffer_t *b ) -+{ -+ int avail; -+ ssize_t result = 1; -+ if (b->bytes == 0 || b->err) { -+ avail = 0; -+ } else if (b->endidx > b->startidx) { -+ avail = b->endidx - b->startidx; -+ } else { -+ avail = sizeof(b->buffer) - b->startidx; -+ } -+ if (avail) { -+ result = write(b->outfd, b->buffer + b->startidx, avail); -+ if (result < 0) { -+ syslog(LOG_ERR, "write: %m\n"); -+ b->err = 1; -+ } else { -+ b->startidx += result; -+ b->totalout += result; -+ b->bytes -= result; -+ if (b->startidx == sizeof(b->buffer)) -+ b->startidx = 0; -+ } -+ } -+ return result; - } - - /* Copy network socket to FILE f until EOS */ - int copy_stream(int fd, int lp) - { -- int nread, rcvd = 0, sent = 0; -- char buffer[8192]; -+ int result; -+ Buffer_t inbuffer; -+ initBuffer( &inbuffer, fd, lp, 1 ); - - if (bidir) { -- for (;;) { -- fd_set readfds; -- int result; -+ struct timeval now; -+ struct timeval then; -+ struct timeval timeout; -+ int timer = 0; -+ Buffer_t outbuffer; -+ initBuffer ( &outbuffer, lp, fd, 0 ); -+ fd_set readfds; -+ fd_set writefds; -+ FD_ZERO(&readfds); -+ FD_ZERO(&writefds); -+ FD_SET(lp, &readfds); -+ FD_SET(fd, &readfds); -+ while ( (FD_ISSET(fd, &readfds)) || -+ (FD_ISSET(lp, &writefds))) { - int maxfd = lp > fd ? lp : fd; -- FD_ZERO(&readfds); -- FD_SET(lp, &readfds); -- FD_SET(fd, &readfds); -- result = select(maxfd + 1, &readfds, 0, 0, 0); -+ if (timer) { -+ gettimeofday(&now,0); -+ // If timer expired, clear timer -+ // else don't try reading from printer -+ if ((now.tv_sec > then.tv_sec) || -+ (now.tv_sec == then.tv_sec && -+ now.tv_usec > then.tv_usec)) { -+ timer = 0; -+ } else { -+ timeout.tv_sec = then.tv_sec; -+ timeout.tv_usec = then.tv_usec; -+ FD_CLR(lp, &readfds); -+ } -+ } -+ if (timer) { -+ result = select(maxfd + 1, &readfds, &writefds, 0, &timeout); -+ } else { -+ result = select(maxfd + 1, &readfds, &writefds, 0, 0); -+ } - if (result < 0) - return (result); -- if (result == 0) -- continue; - if (FD_ISSET(fd, &readfds)) { -- nread = read(fd, buffer, sizeof(buffer)); -- if (nread <= 0) -- break; -- if (safe_write(lp, buffer, nread) < 0) { -- syslog(LOG_ERR, "write: %m\n"); -- break; -- } -- rcvd += nread; -+ result = readBuffer(&inbuffer); - } - if (FD_ISSET(lp, &readfds)) { -- nread = read(lp, buffer, sizeof(buffer)); -- if (nread > 0) { -- safe_write(fd, buffer, nread); -- sent += nread; -+ result = readBuffer(&outbuffer); -+ // Pace the printer data more slowly -+ if (result >= 0) { -+ gettimeofday(&then,0); -+ // wait 100 msec -+ then.tv_usec += 100000; -+ if (then.tv_usec > 1000000) { -+ then.tv_usec -= 1000000; -+ then.tv_sec ++; -+ } -+ timer = 1; - } - } -+ if (FD_ISSET(lp, &writefds)) { -+ result = writeBuffer(&inbuffer); -+ } -+ if (FD_ISSET(fd, &writefds)) { -+ result = writeBuffer(&outbuffer); -+ /* If socket write error, stop reading from it */ -+ if (result < 0) -+ inbuffer.eof = 1; -+ } -+ FD_ZERO(&readfds); -+ FD_ZERO(&writefds); -+ prepBuffer( &inbuffer, &readfds, &writefds ); -+ prepBuffer( &outbuffer, &readfds, &writefds ); - } - syslog(LOG_NOTICE, "Finished job: %d bytes received, %d bytes sent\n", -- rcvd, sent); -+ inbuffer.totalout, -+ outbuffer.totalout); - return (0); - } else { -- while ((nread = read(fd, buffer, sizeof(buffer))) > 0) { -- if (safe_write(lp, buffer, nread) < 0) { -- syslog(LOG_ERR, "write: %m\n"); -- break; -- } -- rcvd += nread; -+ while ((result = readBuffer( &inbuffer)) > 0) { -+ (void)writeBuffer( &inbuffer); - } -- syslog(LOG_NOTICE, "Finished job: %d bytes received\n", rcvd); -- return (nread); -+ syslog(LOG_NOTICE, "Finished job: %d bytes received\n", inbuffer.totalout); -+ return (result); - } - } -