search for: pollrdnorm

...= 0 lstat64("toolbox/vnet", 0xFFBEFAE0) = 0 lstat64("toolbox/vnet", 0xFFBEF1D8) = 0 lstat64("toolbox/vnet.VNet.attr", 0xFFBEFAE0) = 0 lstat64("toolbox/vnet/vnet.qual", 0xFFBEFAE0) = 0 poll(0xFFBEE7E0, 2, 60000) = 1 fd=1 ev=POLLOUT rev=POLLOUT fd=8 ev=POLLRDNORM rev=0 write(1, "04\0\007FFFFFFFF", 8) = 8 poll(0xFFBEF4D0, 2, 60000) = 1 fd=6 ev=POLLRDNORM rev=POLLRDNORM fd=8 ev=POLLRDNORM rev=0 read(6, "FFFFFFFF", 4) = 4 poll(0xFFBEE850, 2, 60000) = 1 fd=1 ev=POLLOUT rev=POLLOUT fd=8 ev=POLLRDNORM rev=0 write(1, "04\0...

According to poll(2), POLLRDNORM is only available ifdef _XOPEN_SOURCE. Signed-off-by: Erik van Konijnenburg <ekonijn@xs4all.nl> Index: exec/ipconfig/main.c =================================================================== --- exec.orig/ipconfig/main.c 2005-05-21 13:09:54.000000000 +0200 +++ exec/ipconfig/main.c 2005-05-...

https://bugzilla.mindrot.org/show_bug.cgi?id=2565 Bug ID: 2565 Summary: High baud rate gets sent, solaris closes pty Product: Portable OpenSSH Version: 7.1p2 Hardware: Sparc OS: Solaris Status: NEW Severity: minor Priority: P5 Component: sshd Assignee: unassigned-bugs at

..._t now) +static int do_pkt_recv(int nr, struct pollfd *fds, time_t now) { - int ret = 0; + int i, ret = 0; struct state *s; - for (s = slist; s; s = s->next) - ret |= process_receive_event(s, now); + for (i = 0, s = slist; s && nr; s = s->next, i++) { + if (fds[i].revents & POLLRDNORM) { + ret |= process_receive_event(s, now); + nr--; + } + } return ret; } static int loop(void) { -#define NR_FDS 1 - struct pollfd fds[NR_FDS]; + struct pollfd *fds; struct state *s; - int pkt_fd; - int nr = 0, rc = 0; + int i, nr = 0, rc = 0; struct timeval now, prev; time_t star...

..._t now) +static int do_pkt_recv(int nr, struct pollfd *fds, time_t now) { - int ret = 0; + int i, ret = 0; struct state *s; - for (s = slist; s; s = s->next) - ret |= process_receive_event(s, now); + for (i = 0, s = slist; s && nr; s = s->next, i++) { + if (fds[i].revents & POLLRDNORM) { + ret |= process_receive_event(s, now); + nr--; + } + } return ret; } static int loop(void) { -#define NR_FDS 1 - struct pollfd fds[NR_FDS]; + struct pollfd *fds; struct state *s; - int pkt_fd; - int nr = 0, rc = 0; + int i, nr = 0, rc = 0; struct timeval now, prev; time_t star...

...t(s, now); break; } + + bail: + return ret; } static int loop(void) @@ -254,7 +269,7 @@ struct state *s; int pkt_fd; int nr = 0; - time_t now; + struct timeval now, prev; pkt_fd = packet_open(); if (pkt_fd == -1) { @@ -265,10 +280,12 @@ fds[0].fd = pkt_fd; fds[0].events = POLLRDNORM; - now = time(NULL); + gettimeofday(&now, NULL); while (1) { int timeout = 60; int pending = 0; + int timeout_ms; + int x; for (s = slist; s; s = s->next) { if (s->state == DEVST_COMPLETE) @@ -276,24 +293,41 @@ pending++; - if (s->expire - now <= 0) -...

...},110)=0 >> writev(26,[{"\2\0...\0\22\0...",12},{"GeorgeDubbyaBusch\0",18}],2)=30 >> read(26,"\2\0\0\...\0\377\377\377\377\377\377"...,36)=36 >> close(26)=0 >> >> and the nscds spin like this >> >> poll({fd=3,events=POLLRDNORM,revents=POLLRDNORM}],1,-1)=1 >> accept(3,,NULL)=9 >> read(9,"\2\0\0\0\0\0\0\0\22\0\0\0",12)=12 >> read(9,"GeorgeDubbyaBusch\0",18)=18 >> write(9,"\2\0\...\0\377\377\377\377\377\377"...,36=36 >> close(9)=0 >> >> S...

...efore adding into waitqueue. It may block forever? No, we enqueue then check: port = filp->private_data; poll_wait(filp, &port->waitqueue, wait); if (!port->guest_connected) { /* Port got unplugged */ return POLLHUP; } ret = 0; if (!will_read_block(port)) ret |= POLLIN | POLLRDNORM; if (!will_write_block(port)) ret |= POLLOUT; if (!port->host_connected) ret |= POLLHUP; return ret; Which is the correct way to do this. Cheers, Rusty.

...efore adding into waitqueue. It may block forever? No, we enqueue then check: port = filp->private_data; poll_wait(filp, &port->waitqueue, wait); if (!port->guest_connected) { /* Port got unplugged */ return POLLHUP; } ret = 0; if (!will_read_block(port)) ret |= POLLIN | POLLRDNORM; if (!will_write_block(port)) ret |= POLLOUT; if (!port->host_connected) ret |= POLLHUP; return ret; Which is the correct way to do this. Cheers, Rusty.

..._INET, sin_port=htons(958), sin_addr=inet_addr("0.0.0.0")}, 16) = 0 connect(3, {sa_family=AF_INET, sin_port=htons(32916), sin_addr=inet_addr("192.168.1.2")}, 16) = 0 write(3, "\377\235&\256\0\0\0\0\0\0\0\2\0\1\206\245\0\0\0\1\0\0\0"..., 58) = 58 poll([{fd=3, events=POLLRDNORM, revents=POLLRDNORM}], 1, 2077) = 1 read(3, "\377\235&\256\0\0\0\1\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0"..., 96) = 60 socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP) = 4 bind(4, {sa_family=AF_INET, sin_port=htons(958), sin_addr=inet_addr("0.0.0.0")}, 16) = -1 EADDRINUSE (Address alrea...

The following patches come from Debian and/or Ubuntu packages of klibc. Ben. Ben Hutchings (1): [klibc] run-init: Add dry-run mode Jay Vosburgh (1): [klibc] ipconfig: Use separate sockets for DHCP from multiple interfaces Mathieu Trudel-Lapierre (1): [klibc] ipconfig: Set broadcast when sending DHCPREQUEST and DHCPDISCOVER YunQiang Su (1): [klibc] mips: setjmp.S: don't

...(26,{sa_family=AF_UNIX,path="/var/run/.nscd_socket"},110)=0 writev(26,[{"\2\0...\0\22\0...",12},{"GeorgeDubbyaBusch\0",18}],2)=30 read(26,"\2\0\0\...\0\377\377\377\377\377\377"...,36)=36 close(26)=0 and the nscds spin like this poll({fd=3,events=POLLRDNORM,revents=POLLRDNORM}],1,-1)=1 accept(3,,NULL)=9 read(9,"\2\0\0\0\0\0\0\0\22\0\0\0",12)=12 read(9,"GeorgeDubbyaBusch\0",18)=18 write(9,"\2\0\...\0\377\377\377\377\377\377"...,36=36 close(9)=0 Since both mis-spelled names are among the earliest user names...

...t stro.at> diff --git a/usr/kinit/ipconfig/main.c b/usr/kinit/ipconfig/main.c index 8782ae7..37ca573 100644 --- a/usr/kinit/ipconfig/main.c +++ b/usr/kinit/ipconfig/main.c @@ -408,7 +408,7 @@ static int loop(void) prev = now; gettimeofday(&now, NULL); - if ((fds[0].revents & POLLRDNORM)) { + if ((nr > 0) && (fds[0].revents & POLLRDNORM)) { if (do_pkt_recv(pkt_fd, now.tv_sec) == 1) break; } commit 7f47891c1678874cccca66cd25e6a13486c86d78 Author: Maciej ?enczykowski <zenczykowski at gmail.com> Date: Sun Nov 6 14:33:40 2011 -0800 [klibc]...

...p 28 23:29:31 2006 +0100 @@ -680,7 +680,6 @@ static unsigned int blktap_poll(struct f poll_wait(file, &info->wait, wait); if (info->ufe_ring.req_prod_pvt != info->ufe_ring.sring->req_prod) { - flush_tlb_all(); RING_PUSH_REQUESTS(&info->ufe_ring); return POLLIN | POLLRDNORM; } _______________________________________________ Xen-devel mailing list Xen-devel@lists.xensource.com http://lists.xensource.com/xen-devel

Hi All, I found this while working on a Linux agent for spice, the symptom I was seeing was select blocking on the spice vdagent virtio serial port even though there were messages queued up there. I found this while working on a Linux agent for spice, the symptom I was seeing was select blocking on the spice vdagent virtio serial port even though there were messages queued up there.

Hi All, I found this while working on a Linux agent for spice, the symptom I was seeing was select blocking on the spice vdagent virtio serial port even though there were messages queued up there. I found this while working on a Linux agent for spice, the symptom I was seeing was select blocking on the spice vdagent virtio serial port even though there were messages queued up there.

...include <stdlib.h> Index: exec/nfsmount/sunrpc.c =================================================================== --- exec.orig/nfsmount/sunrpc.c 2005-05-21 13:17:24.000000000 +0200 +++ exec/nfsmount/sunrpc.c 2005-05-21 13:34:29.000000000 +0200 @@ -1,5 +1,6 @@ #define _XOPEN_SOURCE /* for POLLRDNORM */ #include <sys/types.h> +#include <asm/byteorder.h> #include <sys/socket.h> #include <netinet/in.h> #include <errno.h> --

...static const char *progname; static char do_not_config; +static int loop_timeout = -1; struct state { int state; @@ -270,6 +271,7 @@ int pkt_fd; int nr = 0; struct timeval now, prev; + time_t start; pkt_fd = packet_open(); if (pkt_fd == -1) { @@ -281,6 +283,7 @@ fds[0].events = POLLRDNORM; gettimeofday(&now, NULL); + start = now.tv_sec; while (1) { int timeout = 60; int pending = 0; @@ -308,8 +311,8 @@ for (x = 0; x < 2; x++) { int delta_ms; - if (timeout_ms <= 0) - timeout_ms = 1; + if (timeout_ms <= 0 || loop_timeout == 0) + timeout_m...

...is + * is best done close to the caller, ie. here. */ + if (vr->ops && vr->ops->pull) { + err = vr->ops->pull(vr->ops_data); + if (unlikely(err < 0)) + return err; + + if (err > 0) { + /* Buffers have been used, no need to check indices */ + mask = POLLIN | POLLRDNORM; + goto poll_wait; + } + } + + err = get_user(used, &vr->ring.used->idx); + if (unlikely(err)) + return err; + + err = get_user(last_used, vr->last_used); + if (unlikely(err)) + return err; + + /* More buffers have been used? It's 'readable'. */ + if (used != last_use...

...is + * is best done close to the caller, ie. here. */ + if (vr->ops && vr->ops->pull) { + err = vr->ops->pull(vr->ops_data); + if (unlikely(err < 0)) + return err; + + if (err > 0) { + /* Buffers have been used, no need to check indices */ + mask = POLLIN | POLLRDNORM; + goto poll_wait; + } + } + + err = get_user(used, &vr->ring.used->idx); + if (unlikely(err)) + return err; + + err = get_user(last_used, vr->last_used); + if (unlikely(err)) + return err; + + /* More buffers have been used? It's 'readable'. */ + if (used != last_use...