Detection of subsequent data by poll()

[Rupert Scammell]

Donn Cave <donn at u.washington.edu> wrote in message news:<9um3qr$d20$1 at nntp6.u.washington.edu>...
> Quoth rupe at metro.yak.net (Rupert Scammell):
> | I recently wrote a program that uses the select.poll() method in order
> | to
> | check for incoming data on multiple listening sockets.  When I open a
> | connection to one of the listening sockets (e.g. via telnet), the
> | program accepts the first item of data sent (a character string with a
> | trailing CRLF).  However, subsequent calls to poll() never appear to
> | detect more strings sent in the same connection to this socket.  The
> | file descriptors for the sockets are all correctly registered with the
> | poll object.
> |
> | Is there a way to make poll() detect this incoming data without having
> | to close and re-open a connection to the socket in question each time?
> |
> | Any suggestions would be appreciated!
> 
> Suggestion:  post a program that shows the problem.  Also suggest
> you mention your platform.
> 
> 	Donn Cave, donn at u.washington.edu

Per Donn Cave's request, the source of the program that's producing
the problem is provided below.  The system in use is a RH Linux 6.2
machine (x86 architecture), running kernel version 2.4.13.  Again, any
assistance or insight into why the poll() call made against the poll
object is failing to return more than the first sent line of data
would be greatly appreciated.

Sincerely,

--- Rupert

Rupert Scammell
rupe at arrow.yak.net
http://arrow.yak.net/

Polling code source:

import sys, socket, select

# Create polling object.
poll_obj = select.poll()

# List of ports to open
port_list = [8555, 8556, 8557, 8558]

# List of associated file descriptor numbers.  These match up
# by subscript with the values in port_list, above.
fileno_list = []

# List of socket objects.
sock_obj_list = []

# Number of sockets to create:
num_sockets = len(port_list)

# Create socket objects for each port in port_list, append to
sock_obj_list,
# then bind and listen on each.
for i in range(num_sockets):
    print 'entering socket addition FOR, port: ', port_list[i]
    sock_obj_list.append(socket.socket(socket.AF_INET,
socket.SOCK_STREAM))
    sock_obj_list[i].setsockopt(socket.SOL_SOCKET,
socket.SO_REUSEADDR, 1)
    sock_obj_list[i].bind(('',port_list[i]))
    sock_obj_list[i].listen(1)
    

    # Add the file descriptor to fileno_list:
    fileno_list.append(sock_obj_list[i].fileno())

    # Register the fd with poll_obj.
    poll_obj.register(sock_obj_list[i])

# Poll for data on each of the registered socket objects.

print 'fileno_list: ', fileno_list
print 'sock_obj_list: ', sock_obj_list


while 1:
    # Start with an empty list that'll contain data from
    # our sockets that have events.
    data_list = []

    # Poll for data on each of the sockets.
    print 'Polling...'
    event_list = poll_obj.poll()
    print 'event_list', event_list

    # Number of socket objects returned.
    event_count = len(event_list)
    print 'event count: ', event_count

    """
    Match the file descriptor values returned by .poll() into
event_list with
    the socket that has that file descriptor value in sock_obj_list.
    Once we know the socket, call .accept() on it, then read 1024
bytes of data      from it.  Then print the list of retrieved data. 
Each item in the list is a     two item tuple in the form
(port_number, retrieved_data).
    """

    for i in range(event_count):
        current_fd = event_list[i][0]
        for b in range(num_sockets):
            if (current_fd == fileno_list[b]):
                (cur_conn_obj, cur_addr) = sock_obj_list[b].accept()
                data_list.append([port_list[b],
cur_conn_obj.recv(1024)])
    print data_list